Documentation ¶
Index ¶
Constants ¶
View Source
const ( ConfigWorkerWorkflowName = "Workflow" ConfigWorkerTaskQueue = "Configure" )
View Source
const ( DeploymentWorkerWorkflowName = "Workflow" DeploymentWorkerTaskQueue = "Deployment" )
View Source
const ( ClimonHelmTaskQueue = "CLIMON_HELM_TASK_QUEUE" DeployWorkflowName = "DeployApp" )
Variables ¶
This section is empty.
Functions ¶
func NewClimon ¶
func NewClimon(client *temporalclient.Client) *climon
Types ¶
type Config ¶
type Config struct {
// contains filtered or unexported fields
}
func (*Config) GetWorkflowName ¶
func (*Config) SendEvent ¶
func (d *Config) SendEvent(ctx context.Context, deployPayload json.RawMessage) (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) SendEvent ¶
func (d *Deployment) SendEvent(ctx context.Context, deployPayload json.RawMessage) (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.