Documentation
¶
Index ¶
- Constants
- type Climon
- func (c *Climon) GetWorkflowName() string
- func (c *Climon) SendDeleteEvent(ctx context.Context, action string, payload *agentpb.ClimonDeleteRequest) (client.WorkflowRun, error)
- func (c *Climon) SendEvent(ctx context.Context, action string, payload *agentpb.ClimonInstallRequest) (client.WorkflowRun, error)
- type Config
- type Deployment
- type Worker
Constants ¶
View Source
const ( ConfigWorkerWorkflowName = "Workflow" ConfigWorkerTaskQueue = "Configure" )
View Source
const ( DeploymentWorkerWorkflowName = "Workflow" DeploymentWorkerTaskQueue = "Deployment" )
View Source
const ( ClimonHelmTaskQueue = "CLIMON_HELM_TASK_QUEUE" DeployWorkflowName = "Workflow" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Climon ¶
type Climon struct {
// contains filtered or unexported fields
}
func (*Climon) GetWorkflowName ¶
func (*Climon) SendDeleteEvent ¶
func (c *Climon) SendDeleteEvent(ctx context.Context, action string, payload *agentpb.ClimonDeleteRequest) (client.WorkflowRun, error)
type Config ¶
type Config struct {
// contains filtered or unexported fields
}
func (*Config) GetWorkflowName ¶
func (*Config) SendEvent ¶
func (d *Config) SendEvent(ctx context.Context, confParams *model.ConfigureParameters, deployPayload interface{}) (client.WorkflowRun, error)
type Deployment ¶
type Deployment struct {
// contains filtered or unexported fields
}
func NewDeployment ¶
func NewDeployment(client *temporalclient.Client, log logging.Logger) *Deployment
func (*Deployment) GetWorkflowName ¶
func (d *Deployment) GetWorkflowName() string
func (*Deployment) SendDeleteEvent ¶
func (d *Deployment) SendDeleteEvent(ctx context.Context, action string, deployPayload *agentpb.ApplicationDeleteRequest) (client.WorkflowRun, error)
func (*Deployment) SendEvent ¶
func (d *Deployment) SendEvent(ctx context.Context, action string, deployPayload *agentpb.ApplicationInstallRequest) (client.WorkflowRun, error)
type Worker ¶
type Worker interface { SendEvent(ctx context.Context, payload json.RawMessage) (client.WorkflowRun, error) GetWorkflowName() string }
Click to show internal directories.
Click to hide internal directories.