workers

Documentation

Index

• Constants
• type Climon
  • func NewClimon(client *temporalclient.Client, log logging.Logger) *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
  • func NewConfig(client *temporalclient.Client, log logging.Logger) *Config
  • func (d *Config) GetWorkflowName() string
  • func (d *Config) SendEvent(ctx context.Context, confParams *model.ConfigureParameters, ...) (client.WorkflowRun, error)
• type Deployment
  • func NewDeployment(client *temporalclient.Client, log logging.Logger) *Deployment
  • func (d *Deployment) GetWorkflowName() string
  • func (d *Deployment) SendDeleteEvent(ctx context.Context, action string, ...) (client.WorkflowRun, error)
  • func (d *Deployment) SendEvent(ctx context.Context, action string, ...) (client.WorkflowRun, error)
• type Worker

Constants

const (
	ConfigWorkerWorkflowName = "Workflow"
	ConfigWorkerTaskQueue    = "Configure"
)

const (
	DeploymentWorkerWorkflowName = "Workflow"
	DeploymentWorkerTaskQueue    = "Deployment"
)

const (
	ClimonHelmTaskQueue = "CLIMON_HELM_TASK_QUEUE"
	DeployWorkflowName  = "Workflow"
)

Types

type Climon

type Climon struct {
	// contains filtered or unexported fields
}

func NewClimon

func NewClimon(client *temporalclient.Client, log logging.Logger) *Climon

func (*Climon) GetWorkflowName

func (c *Climon) GetWorkflowName() string

func (*Climon) SendDeleteEvent

func (c *Climon) SendDeleteEvent(ctx context.Context, action string, payload *agentpb.ClimonDeleteRequest) (client.WorkflowRun, error)

func (*Climon) SendEvent

func (c *Climon) SendEvent(ctx context.Context, action string, payload *agentpb.ClimonInstallRequest) (client.WorkflowRun, error)

type Config

type Config struct {
	// contains filtered or unexported fields
}

func NewConfig

func NewConfig(client *temporalclient.Client, log logging.Logger) *Config

func (*Config) GetWorkflowName

func (d *Config) GetWorkflowName() string

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
}