/
agent_deployer.go
38 lines (30 loc) · 1.12 KB
/
agent_deployer.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
package agent
import (
"context"
"github.com/kube-tarian/kad/integrator/agent/pkg/agentpb"
"github.com/kube-tarian/kad/integrator/agent/pkg/workers"
)
func (a *Agent) DeployerAppInstall(ctx context.Context, request *agentpb.ApplicationInstallRequest) (*agentpb.JobResponse, error) {
a.log.Infof("Recieved Deployer Install event %+v", request)
worker := workers.NewDeployment(a.client, a.log)
if request.ClusterName == "" {
request.ClusterName = "inbuilt"
}
run, err := worker.SendEvent(ctx, "install", request)
if err != nil {
return &agentpb.JobResponse{}, err
}
return prepareJobResponse(run, worker.GetWorkflowName()), err
}
func (a *Agent) DeployerAppDelete(ctx context.Context, request *agentpb.ApplicationDeleteRequest) (*agentpb.JobResponse, error) {
a.log.Infof("Recieved Deployer delete event %+v", request)
worker := workers.NewDeployment(a.client, a.log)
if request.ClusterName == "" {
request.ClusterName = "inbuilt"
}
run, err := worker.SendDeleteEvent(ctx, "delete", request)
if err != nil {
return &agentpb.JobResponse{}, err
}
return prepareJobResponse(run, worker.GetWorkflowName()), err
}