workflow

Documentation

Index

• Constants
• func GetActivityName(v1Name string, isV2 bool) string
• func IntegratedServiceJobWorkflow(ctx workflow.Context, input IntegratedServiceJobWorkflowInput) error
• func IntegratedServiceJobWorkflowV2(ctx workflow.Context, input IntegratedServiceJobWorkflowInput) error
• type IntegratedServiceApplyActivity
  • func MakeIntegratedServicesApplyActivity(integratedServices integratedservices.IntegratedServiceOperatorRegistry) IntegratedServiceApplyActivity
  • func (a IntegratedServiceApplyActivity) Execute(ctx context.Context, input IntegratedServiceApplyActivityInput) error
• type IntegratedServiceApplyActivityInput
• type IntegratedServiceCleanActivity
  • func MakeIntegratedServiceCleanActivity(integratedCleaner integratedservices.IntegratedServiceCleaner, ...) IntegratedServiceCleanActivity
  • func (a IntegratedServiceCleanActivity) Execute(ctx context.Context, input IntegratedServiceCleanActivityInput) error
• type IntegratedServiceCleanActivityInput
• type IntegratedServiceDeactivateActivity
  • func MakeIntegratedServiceDeactivateActivity(integratedServices integratedservices.IntegratedServiceOperatorRegistry) IntegratedServiceDeactivateActivity
  • func (a IntegratedServiceDeactivateActivity) Execute(ctx context.Context, input IntegratedServiceDeactivateActivityInput) error
• type IntegratedServiceDeactivateActivityInput
• type IntegratedServiceDeleteActivity
  • func MakeIntegratedServiceDeleteActivity(integratedServices integratedservices.IntegratedServiceRepository) IntegratedServiceDeleteActivity
  • func (a IntegratedServiceDeleteActivity) Execute(ctx context.Context, input IntegratedServiceDeleteActivityInput) error
• type IntegratedServiceDeleteActivityInput
• type IntegratedServiceJobSignalInput
• type IntegratedServiceJobWorkflowInput
• type IntegratedServiceSetSpecActivity
  • func MakeIntegratedServiceSetSpecActivity(integratedServices integratedservices.IntegratedServiceRepository) IntegratedServiceSetSpecActivity
  • func (a IntegratedServiceSetSpecActivity) Execute(ctx context.Context, input IntegratedServiceSetSpecActivityInput) error
• type IntegratedServiceSetSpecActivityInput
• type IntegratedServiceSetStatusActivity
  • func MakeIntegratedServiceSetStatusActivity(integratedServices integratedservices.IntegratedServiceRepository) IntegratedServiceSetStatusActivity
  • func (a IntegratedServiceSetStatusActivity) Execute(ctx context.Context, input IntegratedServiceSetStatusActivityInput) error
• type IntegratedServiceSetStatusActivityInput

Constants

const (
	// OperationApply identifies the integrated service apply operation
	OperationApply = "apply"
	// OperationDeactivate identifies the integrated service deactivation operation
	OperationDeactivate = "deactivate"
)

const IntegratedServiceApplyActivityName = "integrated-service-apply"

const IntegratedServiceCleanActivityName = "integrated-service-clean"

const IntegratedServiceDeactivateActivityName = "integrated-service-deactivate"

const IntegratedServiceDeleteActivityName = "integrated-service-delete"

const IntegratedServiceJobSignalName = "job"

IntegratedServiceJobSignalName is the name of signal with which jobs can be sent to the workflow

const IntegratedServiceJobWorkflowName = "integrated-service-job"

IntegratedServiceJobWorkflowName is the name the IntegratedServiceJobWorkflow is registered under

const IntegratedServiceJobWorkflowV2Name = "integrated-service-job-v2"

IntegratedServiceJobWorkflowV2Name name of the v2 integrated service workflow

const IntegratedServiceSetSpecActivityName = "integrated-service-set-spec"

const IntegratedServiceSetStatusActivityName = "integrated-service-set-status"

Functions

func GetActivityName

func GetActivityName(v1Name string, isV2 bool) string

func IntegratedServiceJobWorkflow

func IntegratedServiceJobWorkflow(ctx workflow.Context, input IntegratedServiceJobWorkflowInput) error

IntegratedServiceJobWorkflow executes integrated service jobs

func IntegratedServiceJobWorkflowV2

func IntegratedServiceJobWorkflowV2(ctx workflow.Context, input IntegratedServiceJobWorkflowInput) error

IntegratedServiceJobWorkflowV2 workflow that skips status updates (and all database operations related to integrated services)

Types

type IntegratedServiceApplyActivity

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

func MakeIntegratedServicesApplyActivity

func MakeIntegratedServicesApplyActivity(integratedServices integratedservices.IntegratedServiceOperatorRegistry) IntegratedServiceApplyActivity

func (IntegratedServiceApplyActivity) Execute

func (a IntegratedServiceApplyActivity) Execute(ctx context.Context, input IntegratedServiceApplyActivityInput) error

type IntegratedServiceApplyActivityInput

type IntegratedServiceApplyActivityInput struct {
	ClusterID             uint
	IntegratedServiceName string
	IntegratedServiceSpec integratedservices.IntegratedServiceSpec
	RetryInterval         time.Duration
}

type IntegratedServiceCleanActivity

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

func MakeIntegratedServiceCleanActivity

func MakeIntegratedServiceCleanActivity(integratedCleaner integratedservices.IntegratedServiceCleaner, logger logrus.FieldLogger) IntegratedServiceCleanActivity

func (IntegratedServiceCleanActivity) Execute

func (a IntegratedServiceCleanActivity) Execute(ctx context.Context, input IntegratedServiceCleanActivityInput) error

type IntegratedServiceCleanActivityInput

type IntegratedServiceCleanActivityInput struct {
	ClusterID uint
	Force     bool
}

type IntegratedServiceDeactivateActivity

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

func MakeIntegratedServiceDeactivateActivity

func MakeIntegratedServiceDeactivateActivity(integratedServices integratedservices.IntegratedServiceOperatorRegistry) IntegratedServiceDeactivateActivity

func (IntegratedServiceDeactivateActivity) Execute

func (a IntegratedServiceDeactivateActivity) Execute(ctx context.Context, input IntegratedServiceDeactivateActivityInput) error

type IntegratedServiceDeactivateActivityInput

type IntegratedServiceDeactivateActivityInput struct {
	ClusterID             uint
	IntegratedServiceName string
	IntegratedServiceSpec integratedservices.IntegratedServiceSpec
	RetryInterval         time.Duration
}

type IntegratedServiceDeleteActivity

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

func MakeIntegratedServiceDeleteActivity

func MakeIntegratedServiceDeleteActivity(integratedServices integratedservices.IntegratedServiceRepository) IntegratedServiceDeleteActivity

func (IntegratedServiceDeleteActivity) Execute

func (a IntegratedServiceDeleteActivity) Execute(ctx context.Context, input IntegratedServiceDeleteActivityInput) error

type IntegratedServiceDeleteActivityInput

type IntegratedServiceDeleteActivityInput struct {
	ClusterID             uint
	IntegratedServiceName string
}

type IntegratedServiceJobSignalInput

type IntegratedServiceJobSignalInput struct {
	Operation              string
	IntegratedServiceSpecs integratedservices.IntegratedServiceSpec
	RetryInterval          time.Duration
}

IntegratedServiceJobSignalInput defines the dynamic inputs of the IntegratedServiceJobWorkflow

type IntegratedServiceJobWorkflowInput

type IntegratedServiceJobWorkflowInput struct {
	ClusterID             uint
	IntegratedServiceName string
}

IntegratedServiceJobWorkflowInput defines the fixed inputs of the IntegratedServiceJobWorkflow

type IntegratedServiceSetSpecActivity

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

func MakeIntegratedServiceSetSpecActivity

func MakeIntegratedServiceSetSpecActivity(integratedServices integratedservices.IntegratedServiceRepository) IntegratedServiceSetSpecActivity

func (IntegratedServiceSetSpecActivity) Execute

func (a IntegratedServiceSetSpecActivity) Execute(ctx context.Context, input IntegratedServiceSetSpecActivityInput) error

type IntegratedServiceSetSpecActivityInput

type IntegratedServiceSetSpecActivityInput struct {
	ClusterID             uint
	IntegratedServiceName string
	Spec                  map[string]interface{}
}

type IntegratedServiceSetStatusActivity

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

func MakeIntegratedServiceSetStatusActivity

func MakeIntegratedServiceSetStatusActivity(integratedServices integratedservices.IntegratedServiceRepository) IntegratedServiceSetStatusActivity

func (IntegratedServiceSetStatusActivity) Execute

func (a IntegratedServiceSetStatusActivity) Execute(ctx context.Context, input IntegratedServiceSetStatusActivityInput) error

type IntegratedServiceSetStatusActivityInput

type IntegratedServiceSetStatusActivityInput struct {
	ClusterID             uint
	IntegratedServiceName string
	Status                string
}