workers

Documentation

Index

• Constants
• type Config
  • func NewConfig(client *temporalclient.Client, log logging.Logger) *Config
  • func (d *Config) GetWorkflowInformation(ctx context.Context, workFlowId string) (model.ResponsePayload, error)
  • func (d *Config) GetWorkflowName() string
  • func (d *Config) SendAsyncEvent(ctx context.Context, confParams *model.ConfigureParameters, ...) (string, error)
  • 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) GetPluginWorkflowName() string
  • func (d *Deployment) GetWorkflowName() string
  • func (d *Deployment) SendDeleteEvent(ctx context.Context, workflowName string, action string, deployPayload any) (client.WorkflowRun, error)
  • func (d *Deployment) SendEvent(ctx context.Context, workflowName string, action string, ...) (client.WorkflowRun, error)
  • func (d *Deployment) SendEventV2(ctx context.Context, workflowName string, action string, ...) (client.WorkflowRun, error)
• type Worker

Constants

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

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

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

Types

type Config

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

func NewConfig

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

func (*Config) GetWorkflowInformation

func (d *Config) GetWorkflowInformation(ctx context.Context, workFlowId string) (model.ResponsePayload, error)

func (*Config) GetWorkflowName

func (d *Config) GetWorkflowName() string

func (*Config) SendAsyncEvent

func (d *Config) SendAsyncEvent(ctx context.Context, confParams *model.ConfigureParameters, deployPayload interface{}) (string, error)

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) GetPluginWorkflowName

func (d *Deployment) GetPluginWorkflowName() string

func (*Deployment) GetWorkflowName

func (d *Deployment) GetWorkflowName() string

func (*Deployment) SendDeleteEvent

func (d *Deployment) SendDeleteEvent(
	ctx context.Context,
	workflowName string,
	action string,
	deployPayload any,
) (client.WorkflowRun, error)

func (*Deployment) SendEvent

func (d *Deployment) SendEvent(
	ctx context.Context,
	workflowName string,
	action string,
	deployPayload *model.ApplicationInstallRequest,
) (client.WorkflowRun, error)

func (*Deployment) SendEventV2

func (d *Deployment) SendEventV2(
	ctx context.Context,
	workflowName string,
	action string,
	deployPayload model.DeployRequest,
) (client.WorkflowRun, error)

type Worker

type Worker interface {
	SendEvent(ctx context.Context, payload json.RawMessage) (client.WorkflowRun, error)
	GetWorkflowName() string
}