commands

package
v8.5.10 Latest Latest
Warning

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

 Go to latest Published: Dec 3, 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 (cmd *ActivateJobsCommand) Timeout(timeout time.Duration) ActivateJobsCommandStep3

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 ActivateJobsCommandStep3 

type ActivateJobsCommandStep3 interface {
	DispatchActivateJobsCommand

	TenantIds(...string) ActivateJobsCommandStep3
	Timeout(time.Duration) ActivateJobsCommandStep3
	WorkerName(string) ActivateJobsCommandStep3
	FetchVariables(...string) 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 (cmd *BroadcastSignalCommand) Send(ctx context.Context) (*pb.BroadcastSignalResponse, error)

func (*BroadcastSignalCommand) SignalName added in v8.2.0 

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

func (*BroadcastSignalCommand) TenantId added in v8.4.0 

func (cmd *BroadcastSignalCommand) TenantId(tenantId string) BroadcastSignalCommandStep2

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 (cmd *CancelProcessInstanceCommand) ProcessInstanceKey(key int64) DispatchCancelProcessInstanceCommand

func (*CancelProcessInstanceCommand) Send 

func (cmd *CancelProcessInstanceCommand) Send(ctx context.Context) (*pb.CancelProcessInstanceResponse, error)

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 (cmd *CompleteJobCommand) Send(ctx context.Context) (*pb.CompleteJobResponse, error)

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 (cmd *CreateInstanceCommand) BPMNProcessId(id string) CreateInstanceCommandStep2

func (*CreateInstanceCommand) LatestVersion 

func (cmd *CreateInstanceCommand) LatestVersion() CreateInstanceCommandStep3

func (*CreateInstanceCommand) ProcessDefinitionKey 

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

func (*CreateInstanceCommand) Send 

func (cmd *CreateInstanceCommand) Send(ctx context.Context) (*pb.CreateProcessInstanceResponse, error)

func (*CreateInstanceCommand) StartBeforeElement added in v8.0.15 

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

func (*CreateInstanceCommand) TenantId added in v8.4.0 

func (cmd *CreateInstanceCommand) TenantId(tenantId string) CreateInstanceCommandStep3

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 (cmd *CreateInstanceCommand) Version(version int32) CreateInstanceCommandStep3

func (*CreateInstanceCommand) WithResult 

func (cmd *CreateInstanceCommand) WithResult() CreateInstanceWithResultCommandStep1

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 

func (cmd *CreateInstanceWithResultCommand) Send(ctx context.Context) (*pb.CreateProcessInstanceWithResultResponse, error)

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 (cmd *DeleteResourceCommand) ResourceKey(key int64) DispatchDeleteResourceCommand

func (*DeleteResourceCommand) Send added in v8.3.0 

func (cmd *DeleteResourceCommand) Send(ctx context.Context) (*pb.DeleteResourceResponse, error)

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 

func (cmd *DeployCommand) Send(ctx context.Context) (*pb.DeployProcessResponse, error)

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 (cmd *DeployResourceCommand) Send(ctx context.Context) (*pb.DeployResourceResponse, error)

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 (cmd *EvaluateDecisionCommand) DecisionId(id string) EvaluateDecisionCommandStep2

func (*EvaluateDecisionCommand) DecisionKey added in v8.2.0 

func (cmd *EvaluateDecisionCommand) DecisionKey(key int64) EvaluateDecisionCommandStep2

func (*EvaluateDecisionCommand) Send added in v8.2.0 

func (cmd *EvaluateDecisionCommand) Send(ctx context.Context) (*pb.EvaluateDecisionResponse, error)

func (*EvaluateDecisionCommand) TenantId added in v8.4.0 

func (cmd *EvaluateDecisionCommand) TenantId(tenantId string) EvaluateDecisionCommandStep2

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 (cmd *FailJobCommand) Send(ctx context.Context) (*pb.FailJobResponse, error)

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 (cmd *PublishMessageCommand) MessageName(name string) PublishMessageCommandStep2

func (*PublishMessageCommand) Send 

func (cmd *PublishMessageCommand) Send(ctx context.Context) (*pb.PublishMessageResponse, error)

func (*PublishMessageCommand) TenantId added in v8.4.0 

func (cmd *PublishMessageCommand) TenantId(tenantId string) PublishMessageCommandStep3

func (*PublishMessageCommand) TimeToLive 

func (cmd *PublishMessageCommand) TimeToLive(duration time.Duration) PublishMessageCommandStep3

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 

func (cmd *ResolveIncidentCommand) Send(ctx context.Context) (*pb.ResolveIncidentResponse, error)

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 (cmd *SetVariablesCommand) Local(local bool) DispatchSetVariablesCommand

func (*SetVariablesCommand) Send 

func (cmd *SetVariablesCommand) Send(ctx context.Context) (*pb.SetVariablesResponse, error)

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 (cmd *StreamJobsCommand) Consumer(consumer StreamJobsConsumer) StreamJobsCommandStep3

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 (c *ThrowErrorCommand) JobKey(jobKey int64) ThrowErrorCommandStep2

func (*ThrowErrorCommand) Send 

func (c *ThrowErrorCommand) Send(ctx context.Context) (*pb.ThrowErrorResponse, error)

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 

func (cmd *TopologyCommand) Send(ctx context.Context) (*pb.TopologyResponse, error)

type UpdateJobRetriesCommand 

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

func (*UpdateJobRetriesCommand) JobKey 

func (cmd *UpdateJobRetriesCommand) JobKey(jobKey int64) UpdateJobRetriesCommandStep2

func (*UpdateJobRetriesCommand) Retries 

func (cmd *UpdateJobRetriesCommand) Retries(retries int32) DispatchUpdateJobRetriesCommand

func (*UpdateJobRetriesCommand) Send 

func (cmd *UpdateJobRetriesCommand) Send(ctx context.Context) (*pb.UpdateJobRetriesResponse, error)

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 (cmd *UpdateJobTimeoutCommand) JobKey(jobKey int64) UpdateJobTimeoutCommandStep2

func (*UpdateJobTimeoutCommand) Send added in v8.4.0 

func (cmd *UpdateJobTimeoutCommand) Send(ctx context.Context) (*pb.UpdateJobTimeoutResponse, error)

func (*UpdateJobTimeoutCommand) Timeout added in v8.4.0 

func (cmd *UpdateJobTimeoutCommand) Timeout(timeout int64) DispatchUpdateJobTimeoutCommand

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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.