core/oc-datacenter
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

monitord is able to create an admiralty Source on remote peer

Browse Source
This commit is contained in:
pb 2025-03-10 17:57:14 +01:00
parent 0a15357445
commit 3c692d2026
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
controllers/admiralty.go
View File

@ -95,7 +95,7 @@ func (c *AdmiraltyController) GetAllTargets() {
// @Success 200 // @Success 200
// @router /targets/:execution [get] // @router /targets/:execution [get]
func (c *AdmiraltyController) GetOneTarget() { func (c *AdmiraltyController) GetOneTarget() {
id := c.Ctx.Input.Param(":id") id := c.Ctx.Input.Param(":execution")
serv, err := infrastructure.NewService() serv, err := infrastructure.NewService()
if err != nil { if err != nil {
// change code to 500 // change code to 500
@ -125,6 +125,8 @@ func (c *AdmiraltyController) GetOneTarget() {
func (c *AdmiraltyController) CreateSource() { func (c *AdmiraltyController) CreateSource() {
execution := c.Ctx.Input.Param(":execution") execution := c.Ctx.Input.Param(":execution")
fmt.Println("execution :: ", execution)
fmt.Println("input :: ", c.Ctx.Input)
serv, err := infrastructure.NewKubernetesService() serv, err := infrastructure.NewKubernetesService()
if err != nil { if err != nil {
// change code to 500 // change code to 500

3
infrastructure/kubernetes.go
View File

@ -450,6 +450,9 @@ func postCDRapiKube(client kubernetes.Clientset, ctx context.Context, path strin
return resp, nil return resp, nil
} }
// Returns the Kubernetes' Node object corresponding to the executionID if it exists on this host
//
// The node is created when an admiralty Target (on host) can connect to an admiralty Source (on remote)
func (k *KubernetesService) GetOneNode(context context.Context,executionID string) (*v1.Node, error) { func (k *KubernetesService) GetOneNode(context context.Context,executionID string) (*v1.Node, error) {
res, err := k.Set.CoreV1(). res, err := k.Set.CoreV1().
Nodes(). Nodes().