uclient

Nov 1, 2024

Changes in this version

type UnifiedClient

+ GetApiService func() interface{}

Oct 18, 2024

Changes in this version

type DescribeWorkflowExecutionResponse

+ FirstRunId string

type UnifiedClient

+ GetBackendType func() (backendType service.BackendType)

Sep 30, 2024

Changes in this version

type StartWorkflowOptions

+ DataAttributes map[string]interface{}

May 15, 2024

Changes in this version

type StartWorkflowOptions

+ WorkflowStartDelay *time.Duration

Sep 18, 2023

Changes in this version

+ type DescribeWorkflowExecutionResponse struct

+ Memos map[string]iwfidl.EncodedObject

+ RunId string

+ SearchAttributes map[string]iwfidl.SearchAttribute

+ Status iwfidl.WorkflowStatus

+ WorkflowStartedTimestamp int64

+ type ListWorkflowExecutionsRequest struct

+ NextPageToken []byte

+ PageSize int32

+ Query string

+ type ListWorkflowExecutionsResponse struct

+ Executions []iwfidl.WorkflowSearchResponseEntry

+ NextPageToken []byte

+ type StartWorkflowOptions struct

+ CronSchedule *string

+ ID string

+ Memo map[string]interface{}

+ RetryPolicy *iwfidl.WorkflowRetryPolicy

+ SearchAttributes map[string]interface{}

+ TaskQueue string

+ WorkflowExecutionTimeout time.Duration

+ WorkflowIDReusePolicy *iwfidl.WorkflowIDReusePolicy

+ type UnifiedClient interface

+ CancelWorkflow func(ctx context.Context, workflowID string, runID string) error

+ Close func()

+ DescribeWorkflowExecution func(ctx context.Context, workflowID, runID string, ...) (*DescribeWorkflowExecutionResponse, error)

+ GetWorkflowResult func(ctx context.Context, valuePtr interface{}, workflowID string, runID string) error

+ ListWorkflow func(ctx context.Context, request *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

+ QueryWorkflow func(ctx context.Context, valuePtr interface{}, workflowID string, runID string, ...) error

+ ResetWorkflow func(ctx context.Context, request iwfidl.WorkflowResetRequest) (runId string, err error)

+ SignalWithStartWaitForStateCompletionWorkflow func(ctx context.Context, options StartWorkflowOptions, ...) error

+ SignalWorkflow func(ctx context.Context, workflowID string, runID string, signalName string, ...) error

+ StartInterpreterWorkflow func(ctx context.Context, options StartWorkflowOptions, args ...interface{}) (runId string, err error)

+ StartWaitForStateCompletionWorkflow func(ctx context.Context, options StartWorkflowOptions) (runId string, err error)

+ SynchronousUpdateWorkflow func(ctx context.Context, valuePtr interface{}, ...) error

+ TerminateWorkflow func(ctx context.Context, workflowID string, runID string, reason string) error