commands

package
v8.5.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 4, 2024 License: Apache-2.0 Imports: 9 Imported by: 5

Documentation

Index

Constants

View Source
const (
	DefaultJobTimeout     = 5 * time.Minute
	DefaultJobTimeoutInMs = int64(DefaultJobTimeout / time.Millisecond)
	DefaultJobWorkerName  = "default"
)
View Source
const (
	DefaultJobRetries = 3
)
View Source
const LatestVersion = -1

Variables

This section is empty.

Functions

This section is empty.

Types

type ActivateJobsCommand

type ActivateJobsCommand struct {
	Command
	// contains filtered or unexported fields
}

func (*ActivateJobsCommand) FetchVariables

func (cmd *ActivateJobsCommand) FetchVariables(fetchVariables ...string) ActivateJobsCommandStep3

func (*ActivateJobsCommand) JobType

func (cmd *ActivateJobsCommand) JobType(jobType string) ActivateJobsCommandStep2

func (*ActivateJobsCommand) MaxJobsToActivate

func (cmd *ActivateJobsCommand) MaxJobsToActivate(maxJobsToActivate int32) ActivateJobsCommandStep3

func (*ActivateJobsCommand) Send

func (cmd *ActivateJobsCommand) Send(ctx context.Context) ([]entities.Job, error)

func (*ActivateJobsCommand) TenantIds added in v8.4.0

func (cmd *ActivateJobsCommand) TenantIds(tenantIds ...string) ActivateJobsCommandStep3

func (*ActivateJobsCommand) Timeout

func (*ActivateJobsCommand) WorkerName

func (cmd *ActivateJobsCommand) WorkerName(workerName string) ActivateJobsCommandStep3

type ActivateJobsCommandStep1

type ActivateJobsCommandStep1 interface {
	JobType(string) ActivateJobsCommandStep2
}

func NewActivateJobsCommand

func NewActivateJobsCommand(gateway pb.GatewayClient, pred retryPredicate) ActivateJobsCommandStep1

type ActivateJobsCommandStep2

type ActivateJobsCommandStep2 interface {
	MaxJobsToActivate(int32) ActivateJobsCommandStep3
}

type BroadcastSignalCommand added in v8.2.0

type BroadcastSignalCommand struct {
	Command
	// contains filtered or unexported fields
}

func (*BroadcastSignalCommand) Send added in v8.2.0

func (*BroadcastSignalCommand) SignalName added in v8.2.0

func (cmd *BroadcastSignalCommand) SignalName(signalName string) BroadcastSignalCommandStep2

func (*BroadcastSignalCommand) TenantId added in v8.4.0

func (*BroadcastSignalCommand) VariablesFromMap added in v8.2.0

func (cmd *BroadcastSignalCommand) VariablesFromMap(variables map[string]interface{}) (BroadcastSignalCommandStep2, error)

func (*BroadcastSignalCommand) VariablesFromObject added in v8.2.0

func (cmd *BroadcastSignalCommand) VariablesFromObject(variables interface{}) (BroadcastSignalCommandStep2, error)

func (*BroadcastSignalCommand) VariablesFromObjectIgnoreOmitempty added in v8.2.0

func (cmd *BroadcastSignalCommand) VariablesFromObjectIgnoreOmitempty(variables interface{}) (BroadcastSignalCommandStep2, error)

func (*BroadcastSignalCommand) VariablesFromString added in v8.2.0

func (cmd *BroadcastSignalCommand) VariablesFromString(variables string) (BroadcastSignalCommandStep2, error)

func (*BroadcastSignalCommand) VariablesFromStringer added in v8.2.0

func (cmd *BroadcastSignalCommand) VariablesFromStringer(variables fmt.Stringer) (BroadcastSignalCommandStep2, error)

type BroadcastSignalCommandStep1 added in v8.2.0

type BroadcastSignalCommandStep1 interface {
	SignalName(string) BroadcastSignalCommandStep2
}

func NewBroadcastSignalCommand added in v8.2.0

func NewBroadcastSignalCommand(gateway pb.GatewayClient, pred retryPredicate) BroadcastSignalCommandStep1

type BroadcastSignalCommandStep2 added in v8.2.0

type BroadcastSignalCommandStep2 interface {
	DispatchBroadcastSignalCommand

	TenantId(string) BroadcastSignalCommandStep2
	// Expected to be valid JSON string
	VariablesFromString(string) (BroadcastSignalCommandStep2, error)

	// Expected to construct a valid JSON string
	VariablesFromStringer(fmt.Stringer) (BroadcastSignalCommandStep2, error)

	// Expected that object is JSON serializable
	VariablesFromObject(interface{}) (BroadcastSignalCommandStep2, error)
	VariablesFromObjectIgnoreOmitempty(interface{}) (BroadcastSignalCommandStep2, error)
	VariablesFromMap(map[string]interface{}) (BroadcastSignalCommandStep2, error)
}

type CancelInstanceStep1

type CancelInstanceStep1 interface {
	ProcessInstanceKey(int64) DispatchCancelProcessInstanceCommand
}

func NewCancelInstanceCommand

func NewCancelInstanceCommand(gateway pb.GatewayClient, pred retryPredicate) CancelInstanceStep1

type CancelProcessInstanceCommand

type CancelProcessInstanceCommand struct {
	Command
	// contains filtered or unexported fields
}

func (*CancelProcessInstanceCommand) ProcessInstanceKey

func (*CancelProcessInstanceCommand) Send

type Command

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

type CompleteJobCommand

type CompleteJobCommand struct {
	Command
	// contains filtered or unexported fields
}

func (*CompleteJobCommand) JobKey

func (cmd *CompleteJobCommand) JobKey(jobKey int64) CompleteJobCommandStep2

func (*CompleteJobCommand) Send

func (*CompleteJobCommand) VariablesFromMap

func (cmd *CompleteJobCommand) VariablesFromMap(variables map[string]interface{}) (DispatchCompleteJobCommand, error)

func (*CompleteJobCommand) VariablesFromObject

func (cmd *CompleteJobCommand) VariablesFromObject(variables interface{}) (DispatchCompleteJobCommand, error)

func (*CompleteJobCommand) VariablesFromObjectIgnoreOmitempty

func (cmd *CompleteJobCommand) VariablesFromObjectIgnoreOmitempty(variables interface{}) (DispatchCompleteJobCommand, error)

func (*CompleteJobCommand) VariablesFromString

func (cmd *CompleteJobCommand) VariablesFromString(variables string) (DispatchCompleteJobCommand, error)

func (*CompleteJobCommand) VariablesFromStringer

func (cmd *CompleteJobCommand) VariablesFromStringer(variables fmt.Stringer) (DispatchCompleteJobCommand, error)

type CompleteJobCommandStep1

type CompleteJobCommandStep1 interface {
	JobKey(int64) CompleteJobCommandStep2
}

func NewCompleteJobCommand

func NewCompleteJobCommand(gateway pb.GatewayClient, pred retryPredicate) CompleteJobCommandStep1

type CompleteJobCommandStep2

type CompleteJobCommandStep2 interface {
	DispatchCompleteJobCommand

	VariablesFromString(string) (DispatchCompleteJobCommand, error)
	VariablesFromStringer(fmt.Stringer) (DispatchCompleteJobCommand, error)
	VariablesFromMap(map[string]interface{}) (DispatchCompleteJobCommand, error)
	VariablesFromObject(interface{}) (DispatchCompleteJobCommand, error)
	VariablesFromObjectIgnoreOmitempty(interface{}) (DispatchCompleteJobCommand, error)
}

type CreateInstanceCommand

type CreateInstanceCommand struct {
	Command
	// contains filtered or unexported fields
}

func (*CreateInstanceCommand) BPMNProcessId

func (*CreateInstanceCommand) LatestVersion

func (*CreateInstanceCommand) ProcessDefinitionKey

func (cmd *CreateInstanceCommand) ProcessDefinitionKey(key int64) CreateInstanceCommandStep3

func (*CreateInstanceCommand) Send

func (*CreateInstanceCommand) StartBeforeElement added in v8.0.15

func (cmd *CreateInstanceCommand) StartBeforeElement(elementID string) CreateInstanceCommandStep3

func (*CreateInstanceCommand) TenantId added in v8.4.0

func (*CreateInstanceCommand) VariablesFromMap

func (cmd *CreateInstanceCommand) VariablesFromMap(variables map[string]interface{}) (CreateInstanceCommandStep3, error)

func (*CreateInstanceCommand) VariablesFromObject

func (cmd *CreateInstanceCommand) VariablesFromObject(variables interface{}) (CreateInstanceCommandStep3, error)

func (*CreateInstanceCommand) VariablesFromObjectIgnoreOmitempty

func (cmd *CreateInstanceCommand) VariablesFromObjectIgnoreOmitempty(variables interface{}) (CreateInstanceCommandStep3, error)

func (*CreateInstanceCommand) VariablesFromString

func (cmd *CreateInstanceCommand) VariablesFromString(variables string) (CreateInstanceCommandStep3, error)

func (*CreateInstanceCommand) VariablesFromStringer

func (cmd *CreateInstanceCommand) VariablesFromStringer(variables fmt.Stringer) (CreateInstanceCommandStep3, error)

func (*CreateInstanceCommand) Version

func (*CreateInstanceCommand) WithResult

type CreateInstanceCommandStep1

type CreateInstanceCommandStep1 interface {
	BPMNProcessId(string) CreateInstanceCommandStep2
	ProcessDefinitionKey(int64) CreateInstanceCommandStep3
}

func NewCreateInstanceCommand

func NewCreateInstanceCommand(gateway pb.GatewayClient, pred retryPredicate) CreateInstanceCommandStep1

type CreateInstanceCommandStep2

type CreateInstanceCommandStep2 interface {
	Version(int32) CreateInstanceCommandStep3
	LatestVersion() CreateInstanceCommandStep3
}

type CreateInstanceCommandStep3

type CreateInstanceCommandStep3 interface {
	DispatchCreateInstanceCommand

	TenantId(string) CreateInstanceCommandStep3
	// Expected to be valid JSON string
	VariablesFromString(string) (CreateInstanceCommandStep3, error)

	// Expected to construct a valid JSON string
	VariablesFromStringer(fmt.Stringer) (CreateInstanceCommandStep3, error)

	// Expected that object is JSON serializable
	VariablesFromObject(interface{}) (CreateInstanceCommandStep3, error)
	VariablesFromObjectIgnoreOmitempty(interface{}) (CreateInstanceCommandStep3, error)
	VariablesFromMap(map[string]interface{}) (CreateInstanceCommandStep3, error)

	StartBeforeElement(string) CreateInstanceCommandStep3

	WithResult() CreateInstanceWithResultCommandStep1
}

type CreateInstanceWithResultCommand

type CreateInstanceWithResultCommand struct {
	Command
	// contains filtered or unexported fields
}

func (*CreateInstanceWithResultCommand) FetchVariables

func (cmd *CreateInstanceWithResultCommand) FetchVariables(variableNames ...string) CreateInstanceWithResultCommandStep1

func (*CreateInstanceWithResultCommand) Send

type CreateInstanceWithResultCommandStep1

type CreateInstanceWithResultCommandStep1 interface {
	DispatchCreateInstanceWithResultCommand

	FetchVariables(variableNames ...string) CreateInstanceWithResultCommandStep1
}

type DeleteResourceCommand added in v8.3.0

type DeleteResourceCommand struct {
	Command
	// contains filtered or unexported fields
}

func (*DeleteResourceCommand) ResourceKey added in v8.3.0

func (*DeleteResourceCommand) Send added in v8.3.0

type DeleteResourceCommandStep1 added in v8.3.0

type DeleteResourceCommandStep1 interface {
	ResourceKey(int64) DispatchDeleteResourceCommand
}

func NewDeleteResourceCommand added in v8.3.0

func NewDeleteResourceCommand(gateway pb.GatewayClient, pred retryPredicate) DeleteResourceCommandStep1

type DeployCommand

type DeployCommand struct {
	Command
	// contains filtered or unexported fields
}

func NewDeployCommand deprecated

func NewDeployCommand(gateway pb.GatewayClient, pred retryPredicate) *DeployCommand

Deprecated: Use NewDeployResourceCommand instead. To be removed in 8.1.0.

func (*DeployCommand) AddResource

func (cmd *DeployCommand) AddResource(definition []byte, name string) *DeployCommand

func (*DeployCommand) AddResourceFile

func (cmd *DeployCommand) AddResourceFile(path string) *DeployCommand

func (*DeployCommand) Send

type DeployResourceCommand

type DeployResourceCommand struct {
	Command
	// contains filtered or unexported fields
}

func NewDeployResourceCommand

func NewDeployResourceCommand(gateway pb.GatewayClient, pred retryPredicate) *DeployResourceCommand

func (*DeployResourceCommand) AddResource

func (cmd *DeployResourceCommand) AddResource(definition []byte, name string) *DeployResourceCommand

func (*DeployResourceCommand) AddResourceFile

func (cmd *DeployResourceCommand) AddResourceFile(path string) *DeployResourceCommand

func (*DeployResourceCommand) Send

func (*DeployResourceCommand) TenantId added in v8.4.0

func (cmd *DeployResourceCommand) TenantId(tenantId string) *DeployResourceCommand

type DispatchActivateJobsCommand

type DispatchActivateJobsCommand interface {
	Send(ctx context.Context) ([]entities.Job, error)
}

type DispatchBroadcastSignalCommand added in v8.2.0

type DispatchBroadcastSignalCommand interface {
	Send(context.Context) (*pb.BroadcastSignalResponse, error)
}

type DispatchCancelProcessInstanceCommand

type DispatchCancelProcessInstanceCommand interface {
	Send(context.Context) (*pb.CancelProcessInstanceResponse, error)
}

type DispatchCompleteJobCommand

type DispatchCompleteJobCommand interface {
	Send(context.Context) (*pb.CompleteJobResponse, error)
}

type DispatchCreateInstanceCommand

type DispatchCreateInstanceCommand interface {
	Send(context.Context) (*pb.CreateProcessInstanceResponse, error)
}

type DispatchCreateInstanceWithResultCommand

type DispatchCreateInstanceWithResultCommand interface {
	Send(context.Context) (*pb.CreateProcessInstanceWithResultResponse, error)
}

type DispatchDeleteResourceCommand added in v8.3.0

type DispatchDeleteResourceCommand interface {
	Send(context.Context) (*pb.DeleteResourceResponse, error)
}

type DispatchEvaluateDecisionCommand added in v8.2.0

type DispatchEvaluateDecisionCommand interface {
	Send(context.Context) (*pb.EvaluateDecisionResponse, error)
}

type DispatchFailJobCommand

type DispatchFailJobCommand interface {
	Send(context.Context) (*pb.FailJobResponse, error)
}

type DispatchPublishMessageCommand

type DispatchPublishMessageCommand interface {
	Send(context.Context) (*pb.PublishMessageResponse, error)
}

type DispatchResolveIncidentCommand

type DispatchResolveIncidentCommand interface {
	Send(context.Context) (*pb.ResolveIncidentResponse, error)
}

type DispatchSetVariablesCommand

type DispatchSetVariablesCommand interface {
	Local(bool) DispatchSetVariablesCommand
	Send(context.Context) (*pb.SetVariablesResponse, error)
}

type DispatchStreamJobsCommand added in v8.4.0

type DispatchStreamJobsCommand interface {
	RequestTimeout(time.Duration) DispatchStreamJobsCommand
	Send(ctx context.Context) error
}

type DispatchThrowErrorCommand

type DispatchThrowErrorCommand interface {
	ErrorMessage(string) DispatchThrowErrorCommand

	VariablesFromString(string) (DispatchThrowErrorCommand, error)
	VariablesFromStringer(fmt.Stringer) (DispatchThrowErrorCommand, error)
	VariablesFromMap(map[string]interface{}) (DispatchThrowErrorCommand, error)
	VariablesFromObject(interface{}) (DispatchThrowErrorCommand, error)
	VariablesFromObjectIgnoreOmitempty(interface{}) (DispatchThrowErrorCommand, error)

	Send(context.Context) (*pb.ThrowErrorResponse, error)
}

type DispatchUpdateJobRetriesCommand

type DispatchUpdateJobRetriesCommand interface {
	Send(context.Context) (*pb.UpdateJobRetriesResponse, error)
}

type DispatchUpdateJobTimeoutCommand added in v8.4.0

type DispatchUpdateJobTimeoutCommand interface {
	Send(context.Context) (*pb.UpdateJobTimeoutResponse, error)
}

type EvaluateDecisionCommand added in v8.2.0

type EvaluateDecisionCommand struct {
	Command
	// contains filtered or unexported fields
}

func (*EvaluateDecisionCommand) DecisionId added in v8.2.0

func (*EvaluateDecisionCommand) DecisionKey added in v8.2.0

func (*EvaluateDecisionCommand) Send added in v8.2.0

func (*EvaluateDecisionCommand) TenantId added in v8.4.0

func (*EvaluateDecisionCommand) VariablesFromMap added in v8.2.0

func (cmd *EvaluateDecisionCommand) VariablesFromMap(variables map[string]interface{}) (EvaluateDecisionCommandStep2, error)

func (*EvaluateDecisionCommand) VariablesFromObject added in v8.2.0

func (cmd *EvaluateDecisionCommand) VariablesFromObject(variables interface{}) (EvaluateDecisionCommandStep2, error)

func (*EvaluateDecisionCommand) VariablesFromObjectIgnoreOmitempty added in v8.2.0

func (cmd *EvaluateDecisionCommand) VariablesFromObjectIgnoreOmitempty(variables interface{}) (EvaluateDecisionCommandStep2, error)

func (*EvaluateDecisionCommand) VariablesFromString added in v8.2.0

func (cmd *EvaluateDecisionCommand) VariablesFromString(variables string) (EvaluateDecisionCommandStep2, error)

func (*EvaluateDecisionCommand) VariablesFromStringer added in v8.2.0

func (cmd *EvaluateDecisionCommand) VariablesFromStringer(variables fmt.Stringer) (EvaluateDecisionCommandStep2, error)

type EvaluateDecisionCommandStep1 added in v8.2.0

type EvaluateDecisionCommandStep1 interface {
	DecisionId(string) EvaluateDecisionCommandStep2
	DecisionKey(int64) EvaluateDecisionCommandStep2
}

func NewEvaluateDecisionCommand added in v8.2.0

func NewEvaluateDecisionCommand(gateway pb.GatewayClient, pred retryPredicate) EvaluateDecisionCommandStep1

type EvaluateDecisionCommandStep2 added in v8.2.0

type EvaluateDecisionCommandStep2 interface {
	DispatchEvaluateDecisionCommand

	TenantId(string) EvaluateDecisionCommandStep2
	// Expected to be valid JSON string
	VariablesFromString(string) (EvaluateDecisionCommandStep2, error)

	// Expected to construct a valid JSON string
	VariablesFromStringer(fmt.Stringer) (EvaluateDecisionCommandStep2, error)

	// Expected that object is JSON serializable
	VariablesFromObject(interface{}) (EvaluateDecisionCommandStep2, error)
	VariablesFromObjectIgnoreOmitempty(interface{}) (EvaluateDecisionCommandStep2, error)
	VariablesFromMap(map[string]interface{}) (EvaluateDecisionCommandStep2, error)
}

type FailJobCommand

type FailJobCommand struct {
	Command
	// contains filtered or unexported fields
}

func (*FailJobCommand) ErrorMessage

func (cmd *FailJobCommand) ErrorMessage(errorMessage string) FailJobCommandStep3

func (*FailJobCommand) JobKey

func (cmd *FailJobCommand) JobKey(jobKey int64) FailJobCommandStep2

func (*FailJobCommand) Retries

func (cmd *FailJobCommand) Retries(retries int32) FailJobCommandStep3

func (*FailJobCommand) RetryBackoff added in v8.0.15

func (cmd *FailJobCommand) RetryBackoff(retryBackoff time.Duration) FailJobCommandStep3

func (*FailJobCommand) Send

func (*FailJobCommand) VariablesFromMap added in v8.2.0

func (cmd *FailJobCommand) VariablesFromMap(variables map[string]interface{}) (DispatchFailJobCommand, error)

func (*FailJobCommand) VariablesFromObject added in v8.2.0

func (cmd *FailJobCommand) VariablesFromObject(variables interface{}) (DispatchFailJobCommand, error)

func (*FailJobCommand) VariablesFromObjectIgnoreOmitempty added in v8.2.0

func (cmd *FailJobCommand) VariablesFromObjectIgnoreOmitempty(variables interface{}) (DispatchFailJobCommand, error)

func (*FailJobCommand) VariablesFromString added in v8.2.0

func (cmd *FailJobCommand) VariablesFromString(variables string) (DispatchFailJobCommand, error)

func (*FailJobCommand) VariablesFromStringer added in v8.2.0

func (cmd *FailJobCommand) VariablesFromStringer(variables fmt.Stringer) (DispatchFailJobCommand, error)

type FailJobCommandStep1

type FailJobCommandStep1 interface {
	JobKey(int64) FailJobCommandStep2
}

func NewFailJobCommand

func NewFailJobCommand(gateway pb.GatewayClient, pred retryPredicate) FailJobCommandStep1

type FailJobCommandStep2

type FailJobCommandStep2 interface {
	Retries(int32) FailJobCommandStep3
}

type FailJobCommandStep3

type FailJobCommandStep3 interface {
	DispatchFailJobCommand
	RetryBackoff(retryBackoff time.Duration) FailJobCommandStep3
	ErrorMessage(string) FailJobCommandStep3

	VariablesFromString(string) (DispatchFailJobCommand, error)
	VariablesFromStringer(fmt.Stringer) (DispatchFailJobCommand, error)
	VariablesFromMap(map[string]interface{}) (DispatchFailJobCommand, error)
	VariablesFromObject(interface{}) (DispatchFailJobCommand, error)
	VariablesFromObjectIgnoreOmitempty(interface{}) (DispatchFailJobCommand, error)
}

type PublishMessageCommand

type PublishMessageCommand struct {
	Command
	// contains filtered or unexported fields
}

func (*PublishMessageCommand) CorrelationKey

func (cmd *PublishMessageCommand) CorrelationKey(key string) PublishMessageCommandStep3

func (*PublishMessageCommand) MessageId

func (cmd *PublishMessageCommand) MessageId(messageId string) PublishMessageCommandStep3

func (*PublishMessageCommand) MessageName

func (*PublishMessageCommand) Send

func (*PublishMessageCommand) TenantId added in v8.4.0

func (*PublishMessageCommand) TimeToLive

func (*PublishMessageCommand) VariablesFromMap

func (cmd *PublishMessageCommand) VariablesFromMap(variables map[string]interface{}) (PublishMessageCommandStep3, error)

func (*PublishMessageCommand) VariablesFromObject

func (cmd *PublishMessageCommand) VariablesFromObject(variables interface{}) (PublishMessageCommandStep3, error)

func (*PublishMessageCommand) VariablesFromObjectIgnoreOmitempty

func (cmd *PublishMessageCommand) VariablesFromObjectIgnoreOmitempty(variables interface{}) (PublishMessageCommandStep3, error)

func (*PublishMessageCommand) VariablesFromString

func (cmd *PublishMessageCommand) VariablesFromString(variables string) (PublishMessageCommandStep3, error)

func (*PublishMessageCommand) VariablesFromStringer

func (cmd *PublishMessageCommand) VariablesFromStringer(variables fmt.Stringer) (PublishMessageCommandStep3, error)

type PublishMessageCommandStep1

type PublishMessageCommandStep1 interface {
	MessageName(string) PublishMessageCommandStep2
}

func NewPublishMessageCommand

func NewPublishMessageCommand(gateway pb.GatewayClient, pred retryPredicate) PublishMessageCommandStep1

type PublishMessageCommandStep2

type PublishMessageCommandStep2 interface {
	CorrelationKey(string) PublishMessageCommandStep3
}

type PublishMessageCommandStep3

type PublishMessageCommandStep3 interface {
	DispatchPublishMessageCommand

	MessageId(string) PublishMessageCommandStep3
	TenantId(string) PublishMessageCommandStep3
	TimeToLive(duration time.Duration) PublishMessageCommandStep3

	// Expected to be valid JSON string
	VariablesFromString(string) (PublishMessageCommandStep3, error)

	// Expected to construct a valid JSON string
	VariablesFromStringer(fmt.Stringer) (PublishMessageCommandStep3, error)

	// Expected that object is JSON serializable
	VariablesFromObject(interface{}) (PublishMessageCommandStep3, error)
	VariablesFromObjectIgnoreOmitempty(interface{}) (PublishMessageCommandStep3, error)
	VariablesFromMap(map[string]interface{}) (PublishMessageCommandStep3, error)
}

type ResolveIncidentCommand

type ResolveIncidentCommand struct {
	Command
	// contains filtered or unexported fields
}

func (*ResolveIncidentCommand) IncidentKey

func (cmd *ResolveIncidentCommand) IncidentKey(incidentKey int64) ResolveIncidentCommandStep2

func (*ResolveIncidentCommand) Send

type ResolveIncidentCommandStep1

type ResolveIncidentCommandStep1 interface {
	IncidentKey(int64) ResolveIncidentCommandStep2
}

func NewResolveIncidentCommand

func NewResolveIncidentCommand(gateway pb.GatewayClient, pred retryPredicate) ResolveIncidentCommandStep1

type ResolveIncidentCommandStep2

type ResolveIncidentCommandStep2 interface {
	DispatchResolveIncidentCommand
}

type SetVariablesCommand

type SetVariablesCommand struct {
	Command
	// contains filtered or unexported fields
}

func (*SetVariablesCommand) ElementInstanceKey

func (cmd *SetVariablesCommand) ElementInstanceKey(elementInstanceKey int64) SetVariablesCommandStep2

func (*SetVariablesCommand) Local

func (*SetVariablesCommand) Send

func (*SetVariablesCommand) VariablesFromMap

func (cmd *SetVariablesCommand) VariablesFromMap(variables map[string]interface{}) (DispatchSetVariablesCommand, error)

func (*SetVariablesCommand) VariablesFromObject

func (cmd *SetVariablesCommand) VariablesFromObject(variables interface{}) (DispatchSetVariablesCommand, error)

func (*SetVariablesCommand) VariablesFromObjectIgnoreOmitempty

func (cmd *SetVariablesCommand) VariablesFromObjectIgnoreOmitempty(variables interface{}) (DispatchSetVariablesCommand, error)

func (*SetVariablesCommand) VariablesFromString

func (cmd *SetVariablesCommand) VariablesFromString(variables string) (DispatchSetVariablesCommand, error)

func (*SetVariablesCommand) VariablesFromStringer

func (cmd *SetVariablesCommand) VariablesFromStringer(variables fmt.Stringer) (DispatchSetVariablesCommand, error)

type SetVariablesCommandStep1

type SetVariablesCommandStep1 interface {
	ElementInstanceKey(int64) SetVariablesCommandStep2
}

func NewSetVariablesCommand

func NewSetVariablesCommand(gateway pb.GatewayClient, pred retryPredicate) SetVariablesCommandStep1

type SetVariablesCommandStep2

type SetVariablesCommandStep2 interface {
	VariablesFromString(string) (DispatchSetVariablesCommand, error)
	VariablesFromStringer(fmt.Stringer) (DispatchSetVariablesCommand, error)
	VariablesFromMap(map[string]interface{}) (DispatchSetVariablesCommand, error)
	VariablesFromObject(interface{}) (DispatchSetVariablesCommand, error)
	VariablesFromObjectIgnoreOmitempty(interface{}) (DispatchSetVariablesCommand, error)
}

type StreamJobsCommand added in v8.4.0

type StreamJobsCommand struct {
	Command
	// contains filtered or unexported fields
}

func (*StreamJobsCommand) Consumer added in v8.4.0

func (*StreamJobsCommand) FetchVariables added in v8.4.0

func (cmd *StreamJobsCommand) FetchVariables(fetchVariables ...string) StreamJobsCommandStep3

func (*StreamJobsCommand) JobType added in v8.4.0

func (cmd *StreamJobsCommand) JobType(jobType string) StreamJobsCommandStep2

func (*StreamJobsCommand) RequestTimeout added in v8.4.0

func (cmd *StreamJobsCommand) RequestTimeout(requestTimeout time.Duration) DispatchStreamJobsCommand

func (*StreamJobsCommand) Send added in v8.4.0

func (cmd *StreamJobsCommand) Send(ctx context.Context) error

func (*StreamJobsCommand) TenantIds added in v8.4.0

func (cmd *StreamJobsCommand) TenantIds(tenantIds ...string) StreamJobsCommandStep3

func (*StreamJobsCommand) Timeout added in v8.4.0

func (cmd *StreamJobsCommand) Timeout(timeout time.Duration) StreamJobsCommandStep3

func (*StreamJobsCommand) WorkerName added in v8.4.0

func (cmd *StreamJobsCommand) WorkerName(workerName string) StreamJobsCommandStep3

type StreamJobsCommandStep1 added in v8.4.0

type StreamJobsCommandStep1 interface {
	JobType(string) StreamJobsCommandStep2
}

func NewStreamJobsCommand added in v8.4.0

func NewStreamJobsCommand(gateway pb.GatewayClient, pred retryPredicate) StreamJobsCommandStep1

type StreamJobsCommandStep2 added in v8.4.0

type StreamJobsCommandStep2 interface {
	Consumer(StreamJobsConsumer) StreamJobsCommandStep3
}

type StreamJobsCommandStep3 added in v8.4.0

type StreamJobsCommandStep3 interface {
	DispatchStreamJobsCommand

	TenantIds(...string) StreamJobsCommandStep3
	Timeout(time.Duration) StreamJobsCommandStep3
	WorkerName(string) StreamJobsCommandStep3
	FetchVariables(...string) StreamJobsCommandStep3
}

type StreamJobsConsumer added in v8.4.0

type StreamJobsConsumer chan<- entities.Job

type ThrowErrorCommand

type ThrowErrorCommand struct {
	Command
	// contains filtered or unexported fields
}

func (*ThrowErrorCommand) ErrorCode

func (c *ThrowErrorCommand) ErrorCode(errorCode string) DispatchThrowErrorCommand

func (*ThrowErrorCommand) ErrorMessage

func (c *ThrowErrorCommand) ErrorMessage(errorMsg string) DispatchThrowErrorCommand

func (*ThrowErrorCommand) JobKey

func (*ThrowErrorCommand) Send

func (*ThrowErrorCommand) VariablesFromMap added in v8.2.0

func (c *ThrowErrorCommand) VariablesFromMap(variables map[string]interface{}) (DispatchThrowErrorCommand, error)

func (*ThrowErrorCommand) VariablesFromObject added in v8.2.0

func (c *ThrowErrorCommand) VariablesFromObject(variables interface{}) (DispatchThrowErrorCommand, error)

func (*ThrowErrorCommand) VariablesFromObjectIgnoreOmitempty added in v8.2.0

func (c *ThrowErrorCommand) VariablesFromObjectIgnoreOmitempty(variables interface{}) (DispatchThrowErrorCommand, error)

func (*ThrowErrorCommand) VariablesFromString added in v8.2.0

func (c *ThrowErrorCommand) VariablesFromString(variables string) (DispatchThrowErrorCommand, error)

func (*ThrowErrorCommand) VariablesFromStringer added in v8.2.0

func (c *ThrowErrorCommand) VariablesFromStringer(variables fmt.Stringer) (DispatchThrowErrorCommand, error)

type ThrowErrorCommandStep1

type ThrowErrorCommandStep1 interface {
	JobKey(int64) ThrowErrorCommandStep2
}

func NewThrowErrorCommand

func NewThrowErrorCommand(gateway pb.GatewayClient, pred retryPredicate) ThrowErrorCommandStep1

type ThrowErrorCommandStep2

type ThrowErrorCommandStep2 interface {
	ErrorCode(string) DispatchThrowErrorCommand
}

type TopologyCommand

type TopologyCommand struct {
	Command
}

func NewTopologyCommand

func NewTopologyCommand(gateway pb.GatewayClient, pred retryPredicate) *TopologyCommand

func (*TopologyCommand) Send

type UpdateJobRetriesCommand

type UpdateJobRetriesCommand struct {
	Command
	// contains filtered or unexported fields
}

func (*UpdateJobRetriesCommand) JobKey

func (*UpdateJobRetriesCommand) Retries

func (*UpdateJobRetriesCommand) Send

type UpdateJobRetriesCommandStep1

type UpdateJobRetriesCommandStep1 interface {
	JobKey(int64) UpdateJobRetriesCommandStep2
}

func NewUpdateJobRetriesCommand

func NewUpdateJobRetriesCommand(gateway pb.GatewayClient, pred retryPredicate) UpdateJobRetriesCommandStep1

type UpdateJobRetriesCommandStep2

type UpdateJobRetriesCommandStep2 interface {
	DispatchUpdateJobRetriesCommand

	Retries(int32) DispatchUpdateJobRetriesCommand
}

type UpdateJobTimeoutCommand added in v8.4.0

type UpdateJobTimeoutCommand struct {
	Command
	// contains filtered or unexported fields
}

func (*UpdateJobTimeoutCommand) JobKey added in v8.4.0

func (*UpdateJobTimeoutCommand) Send added in v8.4.0

func (*UpdateJobTimeoutCommand) Timeout added in v8.4.0

type UpdateJobTimeoutCommandStep1 added in v8.4.0

type UpdateJobTimeoutCommandStep1 interface {
	JobKey(int64) UpdateJobTimeoutCommandStep2
}

func NewUpdateJobTimeoutCommand added in v8.4.0

func NewUpdateJobTimeoutCommand(gateway pb.GatewayClient, pred retryPredicate) UpdateJobTimeoutCommandStep1

type UpdateJobTimeoutCommandStep2 added in v8.4.0

type UpdateJobTimeoutCommandStep2 interface {
	DispatchUpdateJobTimeoutCommand

	Timeout(int64) DispatchUpdateJobTimeoutCommand
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL