internal

Jun 28, 2020

Changes in this version

type ActivityInfo

+ TaskQueue string

type ActivityOptions

+ TaskQueue string

type ChildWorkflowOptions

+ TaskQueue string

type Client

+ DescribeTaskQueue func(ctx context.Context, taskqueue string, taskqueueType enumspb.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)

type Context

+ func WithTaskQueue(ctx Context, name string) Context

+ func WithWorkflowTaskQueue(ctx Context, name string) Context

type ExecuteActivityOptions

+ OriginalTaskQueueName string

+ TaskQueueName string

type StartWorkflowOptions

+ TaskQueue string

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) SetActivityTaskQueue(taskqueue string, activityFn ...interface{})

type WorkerOptions

+ TaskQueueActivitiesPerSecond float64

type WorkflowClient

+ func (wc *WorkflowClient) DescribeTaskQueue(ctx context.Context, taskQueue string, taskQueueType enumspb.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)

type WorkflowInfo

+ TaskQueueName string

type WorkflowOptions

+ TaskQueueName string

Jun 25, 2020

Changes in this version

+ type WorkflowInboundCallsInterceptor interface

+ ExecuteWorkflow func(ctx Context, workflowType string, args ...interface{}) []interface{}

+ Init func(outbound WorkflowOutboundCallsInterceptor) error

+ type WorkflowInboundCallsInterceptorBase struct

+ Next WorkflowInboundCallsInterceptor

+ func (w WorkflowInboundCallsInterceptorBase) ExecuteWorkflow(ctx Context, workflowType string, args ...interface{}) []interface{}

+ func (w WorkflowInboundCallsInterceptorBase) Init(outbound WorkflowOutboundCallsInterceptor) error

type WorkflowInterceptor

+ InterceptWorkflow func(info *WorkflowInfo, next WorkflowInboundCallsInterceptor) WorkflowInboundCallsInterceptor

+ type WorkflowOutboundCallsInterceptor interface

+ ExecuteActivity func(ctx Context, activityType string, args ...interface{}) Future

+ ExecuteChildWorkflow func(ctx Context, childWorkflowType string, args ...interface{}) ChildWorkflowFuture

+ ExecuteLocalActivity func(ctx Context, activityType string, args ...interface{}) Future

+ GetLastCompletionResult func(ctx Context, d ...interface{}) error

+ GetLogger func(ctx Context) *zap.Logger

+ GetMetricsScope func(ctx Context) tally.Scope

+ GetSignalChannel func(ctx Context, signalName string) ReceiveChannel

+ GetVersion func(ctx Context, changeID string, minSupported, maxSupported Version) Version

+ GetWorkflowInfo func(ctx Context) *WorkflowInfo

+ Go func(ctx Context, name string, f func(ctx Context)) Context

+ HasLastCompletionResult func(ctx Context) bool

+ IsReplaying func(ctx Context) bool

+ MutableSideEffect func(ctx Context, id string, f func(ctx Context) interface{}, ...) Value

+ NewTimer func(ctx Context, d time.Duration) Future

+ Now func(ctx Context) time.Time

+ RequestCancelExternalWorkflow func(ctx Context, workflowID, runID string) Future

+ SetQueryHandler func(ctx Context, queryType string, handler interface{}) error

+ SideEffect func(ctx Context, f func(ctx Context) interface{}) Value

+ SignalExternalWorkflow func(ctx Context, workflowID, runID, signalName string, arg interface{}) Future

+ Sleep func(ctx Context, d time.Duration) (err error)

+ UpsertSearchAttributes func(ctx Context, attributes map[string]interface{}) error

+ type WorkflowOutboundCallsInterceptorBase struct

+ Next WorkflowOutboundCallsInterceptor

+ func (t *WorkflowOutboundCallsInterceptorBase) ExecuteActivity(ctx Context, activityType string, args ...interface{}) Future

+ func (t *WorkflowOutboundCallsInterceptorBase) ExecuteChildWorkflow(ctx Context, childWorkflowType string, args ...interface{}) ChildWorkflowFuture

+ func (t *WorkflowOutboundCallsInterceptorBase) ExecuteLocalActivity(ctx Context, activityType string, args ...interface{}) Future

+ func (t *WorkflowOutboundCallsInterceptorBase) GetLastCompletionResult(ctx Context, d ...interface{}) error

+ func (t *WorkflowOutboundCallsInterceptorBase) GetLogger(ctx Context) *zap.Logger

+ func (t *WorkflowOutboundCallsInterceptorBase) GetMetricsScope(ctx Context) tally.Scope

+ func (t *WorkflowOutboundCallsInterceptorBase) GetSignalChannel(ctx Context, signalName string) ReceiveChannel

+ func (t *WorkflowOutboundCallsInterceptorBase) GetVersion(ctx Context, changeID string, minSupported, maxSupported Version) Version

+ func (t *WorkflowOutboundCallsInterceptorBase) GetWorkflowInfo(ctx Context) *WorkflowInfo

+ func (t *WorkflowOutboundCallsInterceptorBase) Go(ctx Context, name string, f func(ctx Context)) Context

+ func (t *WorkflowOutboundCallsInterceptorBase) HasLastCompletionResult(ctx Context) bool

+ func (t *WorkflowOutboundCallsInterceptorBase) IsReplaying(ctx Context) bool

+ func (t *WorkflowOutboundCallsInterceptorBase) MutableSideEffect(ctx Context, id string, f func(ctx Context) interface{}, ...) Value

+ func (t *WorkflowOutboundCallsInterceptorBase) NewTimer(ctx Context, d time.Duration) Future

+ func (t *WorkflowOutboundCallsInterceptorBase) Now(ctx Context) time.Time

+ func (t *WorkflowOutboundCallsInterceptorBase) RequestCancelExternalWorkflow(ctx Context, workflowID, runID string) Future

+ func (t *WorkflowOutboundCallsInterceptorBase) SetQueryHandler(ctx Context, queryType string, handler interface{}) error

+ func (t *WorkflowOutboundCallsInterceptorBase) SideEffect(ctx Context, f func(ctx Context) interface{}) Value

+ func (t *WorkflowOutboundCallsInterceptorBase) SignalExternalWorkflow(ctx Context, workflowID, runID, signalName string, arg interface{}) Future

+ func (t *WorkflowOutboundCallsInterceptorBase) Sleep(ctx Context, d time.Duration) (err error)

+ func (t *WorkflowOutboundCallsInterceptorBase) UpsertSearchAttributes(ctx Context, attributes map[string]interface{}) error

Jun 6, 2020

Changes in this version

type DataConverter

+ FromPayload func(input *commonpb.Payload, valuePtr interface{}) error

+ FromPayloads func(input *commonpb.Payloads, valuePtrs ...interface{}) error

+ ToPayload func(value interface{}) (*commonpb.Payload, error)

+ ToPayloads func(value ...interface{}) (*commonpb.Payloads, error)

Jun 5, 2020

Changes in this version

+ type ActivityError struct

+ func NewActivityError(scheduledEventID int64, startedEventID int64, identity string, ...) *ActivityError

+ func (e *ActivityError) Error() string

+ func (e *ActivityError) Unwrap() error

type ApplicationError

+ func (e *ApplicationError) Unwrap() error

Jun 4, 2020

Changes in this version

+ var ErrMissingMarkerDataKey = errors.New("marker key is missing in details")

+ var ErrMissingMarkerDetails = errors.New("marker details are nil")

+ var ErrUnknownMarkerName = errors.New("unknown marker name")

+ type ActivityID struct

+ type AsyncActivityClient interface

+ ExecuteActivity func(parameters ExecuteActivityParams, callback ResultHandler) *ActivityID

+ RequestCancelActivity func(activityID string)

+ type ExecuteActivityOptions struct

+ ActivityID string

+ HeartbeatTimeoutSeconds int32

+ OriginalTaskListName string

+ RetryPolicy *commonpb.RetryPolicy

+ ScheduleToCloseTimeoutSeconds int32

+ ScheduleToStartTimeoutSeconds int32

+ StartToCloseTimeoutSeconds int32

+ TaskListName string

+ WaitForCancellation bool

+ type ExecuteActivityParams struct

+ ActivityType ActivityType

+ DataConverter DataConverter

+ Header *commonpb.Header

+ Input *commonpb.Payloads

+ type ExecuteLocalActivityOptions struct

+ RetryPolicy *RetryPolicy

+ ScheduleToCloseTimeoutSeconds int32

+ StartToCloseTimeoutSeconds int32

+ type ExecuteLocalActivityParams struct

+ ActivityFn interface{}

+ ActivityType string

+ Attempt int32

+ DataConverter DataConverter

+ InputArgs []interface{}

+ ScheduledTime time.Time

+ WorkflowInfo *WorkflowInfo

+ type ExecuteWorkflowParams struct

+ Header *commonpb.Header

+ Input *commonpb.Payloads

+ WorkflowType *WorkflowType

+ type LocalActivityClient interface

+ ExecuteLocalActivity func(params ExecuteLocalActivityParams, callback LocalActivityResultHandler) *LocalActivityID

+ RequestCancelLocalActivity func(activityID string)

+ type LocalActivityID struct

+ type LocalActivityResultHandler func(lar *LocalActivityResultWrapper)

+ type LocalActivityResultWrapper struct

+ Attempt int32

+ Backoff time.Duration

+ Err error

+ Result *commonpb.Payloads

+ type ResultHandler func(result *commonpb.Payloads, err error)

+ type TimerInfo struct

+ type WorkflowDefinition interface

+ Close func()

+ Execute func(env WorkflowEnvironment, header *commonpb.Header, input *commonpb.Payloads)

+ OnDecisionTaskStarted func()

+ StackTrace func() string

+ type WorkflowDefinitionFactory interface

+ NewWorkflowDefinition func() WorkflowDefinition

+ type WorkflowEnvironment interface

+ AddSession func(sessionInfo *SessionInfo)

+ Complete func(result *commonpb.Payloads, err error)

+ ExecuteChildWorkflow func(params ExecuteWorkflowParams, callback ResultHandler, ...)

+ GetContextPropagators func() []ContextPropagator

+ GetDataConverter func() DataConverter

+ GetLogger func() *zap.Logger

+ GetMetricsScope func() tally.Scope

+ GetRegistry func() *registry

+ GetVersion func(changeID string, minSupported, maxSupported Version) Version

+ IsReplaying func() bool

+ MutableSideEffect func(id string, f func() interface{}, equals func(a, b interface{}) bool) Value

+ RegisterCancelHandler func(handler func())

+ RegisterQueryHandler func(...)

+ RegisterSignalHandler func(handler func(name string, input *commonpb.Payloads))

+ RemoveSession func(sessionID string)

+ RequestCancelChildWorkflow func(namespace, workflowID string)

+ RequestCancelExternalWorkflow func(namespace, workflowID, runID string, callback ResultHandler)

+ SideEffect func(f func() (*commonpb.Payloads, error), callback ResultHandler)

+ SignalExternalWorkflow func(namespace, workflowID, runID, signalName string, input *commonpb.Payloads, ...)

+ UpsertSearchAttributes func(attributes map[string]interface{}) error

+ WorkflowInfo func() *WorkflowInfo

+ type WorkflowOptions struct

+ ContextPropagators []ContextPropagator

+ CronSchedule string

+ DataConverter DataConverter

+ Memo map[string]interface{}

+ Namespace string

+ ParentClosePolicy ParentClosePolicy

+ RetryPolicy *commonpb.RetryPolicy

+ SearchAttributes map[string]interface{}

+ TaskListName string

+ WaitForCancellation bool

+ WorkflowExecutionTimeoutSeconds int32

+ WorkflowID string

+ WorkflowIDReusePolicy WorkflowIDReusePolicy

+ WorkflowRunTimeoutSeconds int32

+ WorkflowTaskTimeoutSeconds int32

+ type WorkflowTimerClient interface

+ NewTimer func(d time.Duration, callback ResultHandler) *TimerInfo

+ Now func() time.Time

+ RequestCancelTimer func(timerID string)

May 27, 2020

Changes in this version

type Client

+ Close func()

type NamespaceClient

+ Close func()

type WorkflowClient

+ func (wc *WorkflowClient) Close()

May 26, 2020

Changes in this version

+ func IsRetryable(err error, nonRetryableTypes []string) bool

+ type ActivityTaskError struct

+ func NewActivityTaskError(scheduledEventID int64, startedEventID int64, identity string, cause error) *ActivityTaskError

+ func (e *ActivityTaskError) Error() string

+ func (e *ActivityTaskError) Unwrap() error

+ type ApplicationError struct

+ func NewApplicationError(message string, nonRetryable bool, details ...interface{}) *ApplicationError

+ func (e *ApplicationError) Details(d ...interface{}) error

+ func (e *ApplicationError) Error() string

+ func (e *ApplicationError) HasDetails() bool

+ func (e *ApplicationError) NonRetryable() bool

+ func (e *ApplicationError) OriginalType() string

+ type ChildWorkflowExecutionError struct

+ func NewChildWorkflowExecutionError(namespace string, workflowID string, runID string, workflowType string, ...) *ChildWorkflowExecutionError

+ func (e *ChildWorkflowExecutionError) Error() string

+ func (e *ChildWorkflowExecutionError) Unwrap() error

type RetryPolicy

+ NonRetryableErrorTypes []string

+ type ServerError struct

+ func NewServerError(message string, nonRetryable bool, cause error) *ServerError

+ func (e *ServerError) Error() string

+ func (e *ServerError) Unwrap() error

type TimeoutError

+ func (e *TimeoutError) HasLastHeartbeatDetails() bool

+ func (e *TimeoutError) LastHeartbeatDetails(d ...interface{}) error

+ func (e *TimeoutError) Unwrap() error

+ type WorkflowExecutionError struct

+ func NewWorkflowExecutionError(workflowID string, runID string, workflowType string, cause error) *WorkflowExecutionError

+ func (e *WorkflowExecutionError) Error() string

+ func (e *WorkflowExecutionError) Unwrap() error

May 15, 2020

Changes in this version

type ClientOptions

+ ConnectionOptions ConnectionOptions

+ Logger *zap.Logger

+ type ConnectionOptions struct

+ TLS *tls.Config

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) AssertExpectations(t *testing.T) bool

May 1, 2020

Changes in this version

+ var DefaultPayloadConverter = &defaultPayloadConverter

+ type PayloadConverter interface

+ FromData func(input *commonpb.Payload, valuePtr interface{}) error

+ ToData func(value interface{}) (*commonpb.Payload, error)

Apr 29, 2020

Changes in this version

type ChildWorkflowOptions

+ WorkflowExecutionTimeout time.Duration

+ WorkflowRunTimeout time.Duration

+ WorkflowTaskTimeout time.Duration

type Context

+ func WithWorkflowRunTimeout(ctx Context, d time.Duration) Context

+ func WithWorkflowTaskTimeout(ctx Context, d time.Duration) Context

type LocalActivityOptions

+ StartToCloseTimeout time.Duration

type StartWorkflowOptions

+ WorkflowExecutionTimeout time.Duration

+ WorkflowRunTimeout time.Duration

+ WorkflowTaskTimeout time.Duration

type TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetWorkflowRunTimeout(runTimeout time.Duration) *TestWorkflowEnvironment

type WorkflowInfo

+ WorkflowExecutionTimeoutSeconds int32

+ WorkflowRunTimeoutSeconds int32

+ WorkflowTaskTimeoutSeconds int32

Apr 24, 2020

Changes in this version

+ var ErrEncodingIsNotSet = errors.New("payload encoding metadata is not set")

+ var ErrEncodingIsNotSupported = errors.New("payload encoding is not supported")

+ var ErrMetadataIsNotSet = errors.New("metadata is not set")

+ var ErrUnableToDecodeJSON = errors.New("unable to decode JSON")

+ var ErrUnableToEncodeJSON = errors.New("unable to encode to JSON")

+ var ErrUnableToSetBytes = errors.New("unable to set []byte value")

+ type NameValuePair struct

+ Name string

+ Value interface{}

Apr 14, 2020

Changes in this version

+ type ReceiveChannel interface

+ Receive func(ctx Context, valuePtr interface{}) (more bool)

+ ReceiveAsync func(valuePtr interface{}) (ok bool)

+ ReceiveAsyncWithMoreFlag func(valuePtr interface{}) (ok bool, more bool)

+ type SendChannel interface

+ Close func()

+ Send func(ctx Context, v interface{})

+ SendAsync func(v interface{}) (ok bool)

type TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetStartWorkflowOptions(options StartWorkflowOptions) *TestWorkflowEnvironment

+ type WorkflowPanicPolicy int

+ const BlockWorkflow

+ const FailWorkflow

Mar 28, 2020

Changes in this version

+ const DefaultNamespace

+ func IsReplayNamespace(dn string) bool

type ActivityInfo

+ WorkflowNamespace string

type ChildWorkflowOptions

+ Namespace string

type ClientOptions

+ Namespace string

type Context

+ func WithWorkflowNamespace(ctx Context, name string) Context

+ type NamespaceClient interface

+ CloseConnection func() error

+ Describe func(ctx context.Context, name string) (*workflowservice.DescribeNamespaceResponse, error)

+ Register func(ctx context.Context, request *workflowservice.RegisterNamespaceRequest) error

+ Update func(ctx context.Context, request *workflowservice.UpdateNamespaceRequest) error

+ func NewNamespaceClient(options ClientOptions) (NamespaceClient, error)

type NonDeterministicWorkflowPolicy

+ const ReplayNamespace

type WorkflowInfo

+ Namespace string

+ ParentWorkflowNamespace string

Mar 27, 2020

Changes in this version

+ const SDKFeatureVersion

+ const SDKVersion

type WorkerOptions

+ MaxConcurrentActivityTaskPollers int

+ MaxConcurrentDecisionTaskPollers int

Mar 18, 2020

Changes in this version

type TestActivityEnvironment

+ func (t *TestActivityEnvironment) SetContextPropagators(contextPropagators []ContextPropagator) *TestActivityEnvironment

+ func (t *TestActivityEnvironment) SetDataConverter(dataConverter DataConverter) *TestActivityEnvironment

+ func (t *TestActivityEnvironment) SetIdentity(identity string) *TestActivityEnvironment

+ func (t *TestActivityEnvironment) SetTracer(tracer opentracing.Tracer) *TestActivityEnvironment

type TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetDataConverter(dataConverter DataConverter) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetIdentity(identity string) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetTracer(tracer opentracing.Tracer) *TestWorkflowEnvironment

+ type WorkflowClient struct

+ func NewServiceClient(workflowServiceClient workflowservice.WorkflowServiceClient, ...) *WorkflowClient

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

+ func (wc *WorkflowClient) CloseConnection() error

+ func (wc *WorkflowClient) CompleteActivity(ctx context.Context, taskToken []byte, result interface{}, err error) error

+ func (wc *WorkflowClient) CompleteActivityByID(ctx context.Context, domain, workflowID, runID, activityID string, ...) error

+ func (wc *WorkflowClient) CountWorkflow(ctx context.Context, request *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error)

+ func (wc *WorkflowClient) DescribeTaskList(ctx context.Context, taskList string, taskListType enums.TaskListType) (*workflowservice.DescribeTaskListResponse, error)

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

+ func (wc *WorkflowClient) ExecuteWorkflow(ctx context.Context, options StartWorkflowOptions, workflow interface{}, ...) (WorkflowRun, error)

+ func (wc *WorkflowClient) GetSearchAttributes(ctx context.Context) (*workflowservice.GetSearchAttributesResponse, error)

+ func (wc *WorkflowClient) GetWorkflow(_ context.Context, workflowID string, runID string) WorkflowRun

+ func (wc *WorkflowClient) GetWorkflowHistory(ctx context.Context, workflowID string, runID string, isLongPoll bool, ...) HistoryEventIterator

+ func (wc *WorkflowClient) ListArchivedWorkflow(ctx context.Context, ...) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)

+ func (wc *WorkflowClient) ListClosedWorkflow(ctx context.Context, ...) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)

+ func (wc *WorkflowClient) ListOpenWorkflow(ctx context.Context, ...) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)

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

+ func (wc *WorkflowClient) QueryWorkflow(ctx context.Context, workflowID string, runID string, queryType string, ...) (Value, error)

+ func (wc *WorkflowClient) QueryWorkflowWithOptions(ctx context.Context, request *QueryWorkflowWithOptionsRequest) (*QueryWorkflowWithOptionsResponse, error)

+ func (wc *WorkflowClient) RecordActivityHeartbeat(ctx context.Context, taskToken []byte, details ...interface{}) error

+ func (wc *WorkflowClient) RecordActivityHeartbeatByID(ctx context.Context, domain, workflowID, runID, activityID string, ...) error

+ func (wc *WorkflowClient) ScanWorkflow(ctx context.Context, request *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error)

+ func (wc *WorkflowClient) SignalWithStartWorkflow(ctx context.Context, workflowID string, signalName string, ...) (*WorkflowExecution, error)

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

+ func (wc *WorkflowClient) StartWorkflow(ctx context.Context, options StartWorkflowOptions, workflowFunc interface{}, ...) (*WorkflowExecution, error)

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

Mar 17, 2020

Changes in this version

+ const DefaultDomainName

type ClientOptions

+ DomainName string

type WorkerOptions

+ DomainName string

Mar 16, 2020

Changes in this version

+ const DefaultServiceConfig

+ const LocalHostPort

type AggregatedWorker

+ func NewAggregatedWorker(service workflowservice.WorkflowServiceClient, clientConn *grpc.ClientConn, ...) (worker *AggregatedWorker)

type Client

+ CloseConnection func() error

type ClientOptions

+ GRPCDialer GRPCDialer

+ HostPort string

type DomainClient

+ CloseConnection func() error

+ type GRPCDialer func(params GRPCDialerParams) (*grpc.ClientConn, error)

+ type GRPCDialerParams struct

+ DefaultServiceConfig string

+ HostPort string

+ RequiredInterceptors []grpc.UnaryClientInterceptor

type WorkerOptions

+ GRPCDialer GRPCDialer

+ HostPort string

Mar 16, 2020

Changes in this version

+ const TemporalChangeVersion

Feb 27, 2020

Changes in this version

type TestActivityEnvironment

+ func (t *TestActivityEnvironment) RegisterActivity(a interface{})

+ func (t *TestActivityEnvironment) RegisterActivityWithOptions(a interface{}, options RegisterActivityOptions)

type WorkerOptions

+ WorkflowInterceptorChainFactories []WorkflowInterceptorFactory

+ type WorkflowInterceptor interface

+ ExecuteActivity func(ctx Context, activityType string, args ...interface{}) Future

+ ExecuteChildWorkflow func(ctx Context, childWorkflowType string, args ...interface{}) ChildWorkflowFuture

+ ExecuteLocalActivity func(ctx Context, activityType string, args ...interface{}) Future

+ ExecuteWorkflow func(ctx Context, workflowType string, args ...interface{}) []interface{}

+ GetLastCompletionResult func(ctx Context, d ...interface{}) error

+ GetLogger func(ctx Context) *zap.Logger

+ GetMetricsScope func(ctx Context) tally.Scope

+ GetSignalChannel func(ctx Context, signalName string) Channel

+ GetVersion func(ctx Context, changeID string, minSupported, maxSupported Version) Version

+ GetWorkflowInfo func(ctx Context) *WorkflowInfo

+ HasLastCompletionResult func(ctx Context) bool

+ IsReplaying func(ctx Context) bool

+ MutableSideEffect func(ctx Context, id string, f func(ctx Context) interface{}, ...) Value

+ NewTimer func(ctx Context, d time.Duration) Future

+ Now func(ctx Context) time.Time

+ RequestCancelExternalWorkflow func(ctx Context, workflowID, runID string) Future

+ SetQueryHandler func(ctx Context, queryType string, handler interface{}) error

+ SideEffect func(ctx Context, f func(ctx Context) interface{}) Value

+ SignalExternalWorkflow func(ctx Context, workflowID, runID, signalName string, arg interface{}) Future

+ Sleep func(ctx Context, d time.Duration) (err error)

+ UpsertSearchAttributes func(ctx Context, attributes map[string]interface{}) error

+ type WorkflowInterceptorBase struct

+ Next WorkflowInterceptor

+ func (t *WorkflowInterceptorBase) ExecuteActivity(ctx Context, activityType string, args ...interface{}) Future

+ func (t *WorkflowInterceptorBase) ExecuteChildWorkflow(ctx Context, childWorkflowType string, args ...interface{}) ChildWorkflowFuture

+ func (t *WorkflowInterceptorBase) ExecuteLocalActivity(ctx Context, activityType string, args ...interface{}) Future

+ func (t *WorkflowInterceptorBase) ExecuteWorkflow(ctx Context, workflowType string, args ...interface{}) []interface{}

+ func (t *WorkflowInterceptorBase) GetLastCompletionResult(ctx Context, d ...interface{}) error

+ func (t *WorkflowInterceptorBase) GetLogger(ctx Context) *zap.Logger

+ func (t *WorkflowInterceptorBase) GetMetricsScope(ctx Context) tally.Scope

+ func (t *WorkflowInterceptorBase) GetSignalChannel(ctx Context, signalName string) Channel

+ func (t *WorkflowInterceptorBase) GetVersion(ctx Context, changeID string, minSupported, maxSupported Version) Version

+ func (t *WorkflowInterceptorBase) GetWorkflowInfo(ctx Context) *WorkflowInfo

+ func (t *WorkflowInterceptorBase) HasLastCompletionResult(ctx Context) bool

+ func (t *WorkflowInterceptorBase) IsReplaying(ctx Context) bool

+ func (t *WorkflowInterceptorBase) MutableSideEffect(ctx Context, id string, f func(ctx Context) interface{}, ...) Value

+ func (t *WorkflowInterceptorBase) NewTimer(ctx Context, d time.Duration) Future

+ func (t *WorkflowInterceptorBase) Now(ctx Context) time.Time

+ func (t *WorkflowInterceptorBase) RequestCancelExternalWorkflow(ctx Context, workflowID, runID string) Future

+ func (t *WorkflowInterceptorBase) SetQueryHandler(ctx Context, queryType string, handler interface{}) error

+ func (t *WorkflowInterceptorBase) SideEffect(ctx Context, f func(ctx Context) interface{}) Value

+ func (t *WorkflowInterceptorBase) SignalExternalWorkflow(ctx Context, workflowID, runID, signalName string, arg interface{}) Future

+ func (t *WorkflowInterceptorBase) Sleep(ctx Context, d time.Duration) (err error)

+ func (t *WorkflowInterceptorBase) UpsertSearchAttributes(ctx Context, attributes map[string]interface{}) error

+ type WorkflowInterceptorFactory interface

+ NewInterceptor func(info *WorkflowInfo, next WorkflowInterceptor) WorkflowInterceptor

+ type WorkflowReplayer struct

+ func NewWorkflowReplayer() *WorkflowReplayer

+ func (aw *WorkflowReplayer) RegisterWorkflow(w interface{})

+ func (aw *WorkflowReplayer) RegisterWorkflowWithOptions(w interface{}, options RegisterWorkflowOptions)

+ func (aw *WorkflowReplayer) ReplayPartialWorkflowHistoryFromJSONFile(logger *zap.Logger, jsonfileName string, lastEventID int64) error

+ func (aw *WorkflowReplayer) ReplayWorkflowExecution(ctx context.Context, service workflowservice.WorkflowServiceClient, ...) error

+ func (aw *WorkflowReplayer) ReplayWorkflowHistory(logger *zap.Logger, history *commonproto.History) error

+ func (aw *WorkflowReplayer) ReplayWorkflowHistoryFromJSONFile(logger *zap.Logger, jsonfileName string) error

Feb 21, 2020

Changes in this version

+ func AwaitWithTimeout(ctx Context, timeout time.Duration, condition func() bool) (ok bool, err error)

Jan 28, 2020

Changes in this version

type SessionOptions

+ HeartbeatTimeout time.Duration

Dec 22, 2019

Changes in this version

+ func Await(ctx Context, condition func() bool) error

+ func IsCanceledError(err error) bool

+ func SetBinaryChecksum(checksum string)

+ type AggregatedWorker struct

+ func (aw *AggregatedWorker) RegisterActivity(a interface{})

+ func (aw *AggregatedWorker) RegisterActivityWithOptions(a interface{}, options RegisterActivityOptions)

+ func (aw *AggregatedWorker) RegisterWorkflow(w interface{})

+ func (aw *AggregatedWorker) RegisterWorkflowWithOptions(w interface{}, options RegisterWorkflowOptions)

+ func (aw *AggregatedWorker) Run() error

+ func (aw *AggregatedWorker) Start() error

+ func (aw *AggregatedWorker) Stop()

type QueryWorkflowWithOptionsRequest

+ QueryConsistencyLevel enums.QueryConsistencyLevel

type RegisterActivityOptions

+ DisableAlreadyRegisteredCheck bool

type RegisterWorkflowOptions

+ DisableAlreadyRegisteredCheck bool

type TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) RegisterActivity(a interface{})

+ func (t *TestWorkflowEnvironment) RegisterActivityWithOptions(a interface{}, options RegisterActivityOptions)

+ func (t *TestWorkflowEnvironment) RegisterWorkflow(w interface{})

+ func (t *TestWorkflowEnvironment) RegisterWorkflowWithOptions(w interface{}, options RegisterWorkflowOptions)

Oct 27, 2019

Changes in this version

+ const CadenceChangeVersion

type ChildWorkflowOptions

+ ParentClosePolicy ParentClosePolicy

type Client

+ ListArchivedWorkflow func(ctx context.Context, request *s.ListArchivedWorkflowExecutionsRequest) (*s.ListArchivedWorkflowExecutionsResponse, error)

+ QueryWorkflowWithOptions func(ctx context.Context, request *QueryWorkflowWithOptionsRequest) (*QueryWorkflowWithOptionsResponse, error)

+ type ParentClosePolicy int

+ const ParentClosePolicyAbandon

+ const ParentClosePolicyRequestCancel

+ const ParentClosePolicyTerminate

+ type QueryWorkflowWithOptionsRequest struct

+ Args []interface{}

+ QueryRejectCondition *s.QueryRejectCondition

+ QueryType string

+ RunID string

+ WorkflowID string

+ type QueryWorkflowWithOptionsResponse struct

+ QueryRejected *s.QueryRejected

+ QueryResult Value

type WorkflowInfo

+ BinaryChecksum *string

Aug 29, 2019

Changes in this version

+ var DefaultDataConverter = getDefaultDataConverter()

+ func ReplayPartialWorkflowHistoryFromJSONFile(logger *zap.Logger, jsonfileName string, lastEventID int64) error

+ func UpsertSearchAttributes(ctx Context, attributes map[string]interface{}) error

type ChildWorkflowOptions

+ Memo map[string]interface{}

+ SearchAttributes map[string]interface{}

+ type DataConverter interface

+ FromData func(input []byte, valuePtr ...interface{}) error

+ ToData func(value ...interface{}) ([]byte, error)

type TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) OnUpsertSearchAttributes(attributes map[string]interface{}) *MockCallWrapper

+ func (t *TestWorkflowEnvironment) SetMemoOnStart(memo map[string]interface{}) error

+ func (t *TestWorkflowEnvironment) SetSearchAttributesOnStart(searchAttributes map[string]interface{}) error

+ type Value interface

+ Get func(valuePtr interface{}) error

+ HasValue func() bool

+ type Values interface

+ Get func(valuePtr ...interface{}) error

+ HasValues func() bool

+ type WaitGroup interface

+ Add func(delta int)

+ Done func()

+ Wait func(ctx Context)

+ func NewWaitGroup(ctx Context) WaitGroup

type WorkflowInfo

+ Memo *s.Memo

+ SearchAttributes *s.SearchAttributes

Jul 29, 2019

Changes in this version

type WorkerOptions

+ MaxConcurrentSessionExecutionSize int

Jun 19, 2019

Changes in this version

+ func IsReplayDomain(dn string) bool

type NonDeterministicWorkflowPolicy

+ const ReplayDomainName

Jun 14, 2019

Changes in this version

+ const QueryTypeOpenSessions

+ var ErrSessionFailed = errors.New("session has failed")

+ func CompleteSession(ctx Context)

type Client

+ GetSearchAttributes func(ctx context.Context) (*s.GetSearchAttributesResponse, error)

type ClientOptions

+ ContextPropagators []ContextPropagator

+ Tracer opentracing.Tracer

type Context

+ func Background() Context

+ func CreateSession(ctx Context, sessionOptions *SessionOptions) (Context, error)

+ func RecreateSession(ctx Context, recreateToken []byte, sessionOptions *SessionOptions) (Context, error)

+ type ContextPropagator interface

+ Extract func(context.Context, HeaderReader) (context.Context, error)

+ ExtractToWorkflow func(Context, HeaderReader) (Context, error)

+ Inject func(context.Context, HeaderWriter) error

+ InjectFromWorkflow func(Context, HeaderWriter) error

+ func NewTracingContextPropagator(tracer opentracing.Tracer) ContextPropagator

type ContinueAsNewError

+ func (e *ContinueAsNewError) Args() []interface{}

+ func (e *ContinueAsNewError) WorkflowType() *WorkflowType

+ type HeaderReader interface

+ ForEachKey func(handler func(string, []byte) error) error

+ func NewHeaderReader(header *shared.Header) HeaderReader

+ type HeaderWriter interface

+ Set func(string, []byte)

+ func NewHeaderWriter(header *shared.Header) HeaderWriter

type ServiceInvoker

+ GetClient func(domain string, options *ClientOptions) Client

+ type SessionInfo struct

+ HostName string

+ SessionID string

+ func GetSessionInfo(ctx Context) *SessionInfo

+ func (s *SessionInfo) GetRecreateToken() []byte

+ type SessionOptions struct

+ CreationTimeout time.Duration

+ ExecutionTimeout time.Duration

type StartWorkflowOptions

+ SearchAttributes map[string]interface{}

type TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SignalWorkflowSkippingDecision(name string, input interface{})

type WorkerOptions

+ ContextPropagators []ContextPropagator

+ EnableSessionWorker bool

+ MaxConCurrentSessionExecutionSize int

+ Tracer opentracing.Tracer

type WorkflowTestSuite

+ func (s *WorkflowTestSuite) SetContextPropagators(ctxProps []ContextPropagator)

+ func (s *WorkflowTestSuite) SetHeader(header *shared.Header)

May 18, 2019

Changes in this version

type Client

+ CountWorkflow func(ctx context.Context, request *s.CountWorkflowExecutionsRequest) (*s.CountWorkflowExecutionsResponse, error)

+ GetWorkflow func(ctx context.Context, workflowID string, runID string) WorkflowRun

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

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

May 8, 2019

Changes in this version

+ func GetLastCompletionResult(ctx Context, d ...interface{}) error

+ func GetWorkerStopChannel(ctx context.Context) <-chan struct

+ func HasLastCompletionResult(ctx Context) bool

type ChildWorkflowOptions

+ CronSchedule string

type StartWorkflowOptions

+ CronSchedule string

+ Memo map[string]interface{}

type TestActivityEnvironment

+ func (t *TestActivityEnvironment) SetHeartbeatDetails(details interface{})

+ func (t *TestActivityEnvironment) SetWorkerStopChannel(c chan struct{})

type TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) OnGetVersion(changeID string, minSupported, maxSupported Version) *MockCallWrapper

+ func (t *TestWorkflowEnvironment) SetLastCompletionResult(result interface{})

+ func (t *TestWorkflowEnvironment) SetWorkerStopChannel(c chan struct{})

+ type UnknownExternalWorkflowExecutionError struct

+ func (e *UnknownExternalWorkflowExecutionError) Error() string

type WorkerOptions

+ WorkerStopTimeout time.Duration

type WorkflowInfo

+ ContinuedExecutionRunID *string

+ CronSchedule *string

+ ParentWorkflowDomain *string

+ ParentWorkflowExecution *WorkflowExecution

Oct 25, 2018

Changes in this version

+ func GetHeartbeatDetails(ctx context.Context, d ...interface{}) error

+ func HasHeartbeatDetails(ctx context.Context) bool

type ActivityInfo

+ Attempt int32

+ WorkflowDomain string

+ WorkflowType *WorkflowType

type ActivityOptions

+ RetryPolicy *RetryPolicy

type ChildWorkflowOptions

+ RetryPolicy *RetryPolicy

type Context

+ func WithRetryPolicy(ctx Context, retryPolicy RetryPolicy) Context

type LocalActivityOptions

+ RetryPolicy *RetryPolicy

+ type RetryPolicy struct

+ BackoffCoefficient float64

+ ExpirationInterval time.Duration

+ InitialInterval time.Duration

+ MaximumAttempts int32

+ MaximumInterval time.Duration

+ NonRetriableErrorReasons []string

type StartWorkflowOptions

+ RetryPolicy *RetryPolicy

type TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetWorkflowTimeout(executionTimeout time.Duration) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SignalWorkflowByID(workflowID, signalName string, input interface{}) error

type WorkflowExecutionContext

+ IsDestroyed func() bool

type WorkflowInfo

+ Attempt int32

Aug 13, 2018

Changes in this version

type MockCallWrapper

+ func (c *MockCallWrapper) AfterFn(fn func() time.Duration) *MockCallWrapper

type WorkerOptions

+ MaxConcurrentDecisionTaskExecutionSize int

+ WorkerDecisionTasksPerSecond float64

type WorkflowExecutionContext

+ Lock func()

+ Unlock func(err error)

Jul 3, 2018

Changes in this version

+ var ErrMockStartChildWorkflowFailed = fmt.Errorf("start child workflow failed: %v", ...)

+ var ErrTooManyArg = errors.New("too many arguments")

+ func MutableSideEffect(ctx Context, id string, f func(ctx Context) interface{}, ...) encoded.Value

+ func NewValue(data []byte) encoded.Value

+ func NewValues(data []byte) encoded.Values

+ func ReplayWorkflowExecution(ctx context.Context, service workflowserviceclient.Interface, ...) error

+ func ReplayWorkflowHistory(logger *zap.Logger, history *shared.History) error

+ func ReplayWorkflowHistoryFromJSONFile(logger *zap.Logger, jsonfileName string) error

+ func SetStickyWorkflowCacheSize(cacheSize int)

type Client

+ SignalWithStartWorkflow func(ctx context.Context, workflowID string, signalName string, ...) (*WorkflowExecution, error)

type ClientOptions

+ DataConverter encoded.DataConverter

type Context

+ func WithDataConverter(ctx Context, dc encoded.DataConverter) Context

+ type ErrorDetailsValues []interface

+ func (b ErrorDetailsValues) Get(valuePtr ...interface{}) error

+ func (b ErrorDetailsValues) HasValues() bool

+ type NonDeterministicWorkflowPolicy int

+ const NonDeterministicWorkflowPolicyBlockWorkflow

+ const NonDeterministicWorkflowPolicyFailWorkflow

type TestActivityEnvironment

+ func (t *TestActivityEnvironment) SetTestTimeout(idleTimeout time.Duration) *TestActivityEnvironment

type TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetStartTime(startTime time.Time)

type WorkerOptions

+ DataConverter encoded.DataConverter

+ NonDeterministicWorkflowPolicy NonDeterministicWorkflowPolicy

+ type WorkflowExecutionContext interface

+ CompleteDecisionTask func(waitLocalActivity bool) interface{}

+ GetCurrentDecisionTask func() *s.PollForDecisionTaskResponse

+ GetDecisionTimeout func() time.Duration

+ ProcessLocalActivityResult func(lar *localActivityResult) (interface{}, error)

+ ProcessWorkflowTask func(task *s.PollForDecisionTaskResponse, historyIterator HistoryIterator) (completeRequest interface{}, err error)

+ StackTrace func() string

type WorkflowRun

+ GetID func() string

Mar 9, 2018

Changes in this version

+ var ErrNoData = errors.New("no data available")

+ func IsReplaying(ctx Context) bool

+ func NewDisconnectedContext(parent Context) (ctx Context, cancel CancelFunc)

type ActivityInfo

+ Deadline time.Time

+ HeartbeatTimeout time.Duration

+ ScheduledTimestamp time.Time

+ StartedTimestamp time.Time

+ TaskList string

type CanceledError

+ func (e *CanceledError) HasDetails() bool

type ChildWorkflowFuture

+ SignalChildWorkflow func(ctx Context, signalName string, data interface{}) Future

type Client

+ RecordActivityHeartbeatByID func(ctx context.Context, domain, workflowID, runID, activityID string, ...) error

type Context

+ func WithLocalActivityOptions(ctx Context, options LocalActivityOptions) Context

type CustomError

+ func (e *CustomError) HasDetails() bool

type EncodedValue

+ func (b EncodedValue) HasValue() bool

type EncodedValues

+ func (b EncodedValues) HasValues() bool

type Future

+ func ExecuteLocalActivity(ctx Context, activity interface{}, args ...interface{}) Future

+ func RequestCancelExternalWorkflow(ctx Context, workflowID, runID string) Future

+ func SignalExternalWorkflow(ctx Context, workflowID, runID, signalName string, arg interface{}) Future

+ type LocalActivityOptions struct

+ ScheduleToCloseTimeout time.Duration

type TestActivityEnvironment

+ func (t *TestActivityEnvironment) ExecuteLocalActivity(activityFn interface{}, args ...interface{}) (encoded.Value, error)

type TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) OnRequestCancelExternalWorkflow(domainName, workflowID, runID string) *MockCallWrapper

+ func (t *TestWorkflowEnvironment) OnSignalExternalWorkflow(domainName, workflowID, runID, signalName, arg interface{}) *MockCallWrapper

+ func (t *TestWorkflowEnvironment) SetOnLocalActivityCanceledListener(listener func(activityInfo *ActivityInfo)) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetOnLocalActivityCompletedListener(listener func(activityInfo *ActivityInfo, result encoded.Value, err error)) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetOnLocalActivityStartedListener(...) *TestWorkflowEnvironment

type TimeoutError

+ func (e *TimeoutError) HasDetails() bool

type WorkerOptions

+ MaxConcurrentLocalActivityExecutionSize int

+ WorkerLocalActivitiesPerSecond float64

Jan 17, 2018

Changes in this version

+ const FeatureVersion

+ const LibraryVersion

+ const QueryTypeStackTrace

+ var ErrActivityResultPending = errors.New("not error: do not autocomplete, using Client.CompleteActivity() to complete")

+ var ErrCanceled = NewCanceledError()

+ var ErrDeadlineExceeded = NewTimeoutError(shared.TimeoutTypeScheduleToClose)

+ func AddActivityRegistrationInterceptor(i func(name string, activity interface{}) (string, interface{}))

+ func AddWorkflowRegistrationInterceptor(i func(name string, workflow interface{}) (string, interface{}))

+ func DeserializeFnResults(result []byte, to interface{}) error

+ func EnableVerboseLogging(enable bool)

+ func GetActivityLogger(ctx context.Context) *zap.Logger

+ func GetActivityMetricsScope(ctx context.Context) tally.Scope

+ func GetLogger(ctx Context) *zap.Logger

+ func GetMetricsScope(ctx Context) tally.Scope

+ func Go(ctx Context, f func(ctx Context))

+ func GoNamed(ctx Context, name string, f func(ctx Context))

+ func NewFuture(ctx Context) (Future, Settable)

+ func Now(ctx Context) time.Time

+ func RecordActivityHeartbeat(ctx context.Context, details ...interface{})

+ func RegisterActivity(activityFunc interface{})

+ func RegisterActivityWithOptions(activityFunc interface{}, opts RegisterActivityOptions)

+ func RegisterWorkflow(workflowFunc interface{})

+ func RegisterWorkflowWithOptions(workflowFunc interface{}, opts RegisterWorkflowOptions)

+ func RequestCancelWorkflow(ctx Context, workflowID, runID string) error

+ func SerializeFnArgs(args ...interface{}) ([]byte, error)

+ func SetQueryHandler(ctx Context, queryType string, handler interface{}) error

+ func SideEffect(ctx Context, f func(ctx Context) interface{}) encoded.Value

+ func Sleep(ctx Context, d time.Duration) (err error)

+ func WithActivityTask(ctx context.Context, task *shared.PollForActivityTaskResponse, ...) context.Context

+ func WithCancel(parent Context) (ctx Context, cancel CancelFunc)

+ func WithTestTags(ctx context.Context, testTags map[string]map[string]string) context.Context

+ type ActivityInfo struct

+ ActivityID string

+ ActivityType ActivityType

+ TaskToken []byte

+ WorkflowExecution WorkflowExecution

+ func GetActivityInfo(ctx context.Context) ActivityInfo

+ type ActivityOptions struct

+ ActivityID string

+ HeartbeatTimeout time.Duration

+ ScheduleToCloseTimeout time.Duration

+ ScheduleToStartTimeout time.Duration

+ StartToCloseTimeout time.Duration

+ TaskList string

+ WaitForCancellation bool

+ type ActivityTaskHandler interface

+ Execute func(task *s.PollForActivityTaskResponse) (interface{}, error)

+ func NewActivityTaskHandler(service workflowserviceclient.Interface, identity string, logger *zap.Logger) ActivityTaskHandler

+ type ActivityType struct

+ Name string

+ type CancelFunc func()

+ type CanceledError struct

+ func NewCanceledError(details ...interface{}) *CanceledError

+ func (e *CanceledError) Details(d ...interface{})

+ func (e *CanceledError) Error() string

+ type Channel interface

+ Close func()

+ Receive func(ctx Context, valuePtr interface{}) (more bool)

+ ReceiveAsync func(valuePtr interface{}) (ok bool)

+ ReceiveAsyncWithMoreFlag func(valuePtr interface{}) (ok bool, more bool)

+ Send func(ctx Context, v interface{})

+ SendAsync func(v interface{}) (ok bool)

+ func GetSignalChannel(ctx Context, signalName string) Channel

+ func NewBufferedChannel(ctx Context, size int) Channel

+ func NewChannel(ctx Context) Channel

+ func NewNamedBufferedChannel(ctx Context, name string, size int) Channel

+ func NewNamedChannel(ctx Context, name string) Channel

+ type ChildWorkflowFuture interface

+ GetChildWorkflowExecution func() Future

+ func ExecuteChildWorkflow(ctx Context, childWorkflow interface{}, args ...interface{}) ChildWorkflowFuture

+ type ChildWorkflowOptions struct

+ ChildPolicy ChildWorkflowPolicy

+ Domain string

+ ExecutionStartToCloseTimeout time.Duration

+ TaskList string

+ TaskStartToCloseTimeout time.Duration

+ WaitForCancellation bool

+ WorkflowID string

+ WorkflowIDReusePolicy WorkflowIDReusePolicy

+ type ChildWorkflowPolicy int32

+ const ChildWorkflowPolicyAbandon

+ const ChildWorkflowPolicyRequestCancel

+ const ChildWorkflowPolicyTerminate

+ type Client interface

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

+ CompleteActivity func(ctx context.Context, taskToken []byte, result interface{}, err error) error

+ CompleteActivityByID func(ctx context.Context, domainID, workflowID, runID, activityID string, ...) error

+ DescribeTaskList func(ctx context.Context, tasklist string, tasklistType s.TaskListType) (*s.DescribeTaskListResponse, error)

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

+ ExecuteWorkflow func(ctx context.Context, options StartWorkflowOptions, workflow interface{}, ...) (WorkflowRun, error)

+ GetWorkflowHistory func(ctx context.Context, workflowID string, runID string, isLongPoll bool, ...) HistoryEventIterator

+ ListClosedWorkflow func(ctx context.Context, request *s.ListClosedWorkflowExecutionsRequest) (*s.ListClosedWorkflowExecutionsResponse, error)

+ ListOpenWorkflow func(ctx context.Context, request *s.ListOpenWorkflowExecutionsRequest) (*s.ListOpenWorkflowExecutionsResponse, error)

+ QueryWorkflow func(ctx context.Context, workflowID string, runID string, queryType string, ...) (encoded.Value, error)

+ RecordActivityHeartbeat func(ctx context.Context, taskToken []byte, details ...interface{}) error

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

+ StartWorkflow func(ctx context.Context, options StartWorkflowOptions, workflow interface{}, ...) (*WorkflowExecution, error)

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

+ func NewClient(service workflowserviceclient.Interface, domain string, options *ClientOptions) Client

+ type ClientOptions struct

+ Identity string

+ MetricsScope tally.Scope

+ type Context interface

+ Deadline func() (deadline time.Time, ok bool)

+ Done func() Channel

+ Err func() error

+ Value func(key interface{}) interface{}

+ func WithActivityOptions(ctx Context, options ActivityOptions) Context

+ func WithChildPolicy(ctx Context, childPolicy ChildWorkflowPolicy) Context

+ func WithChildWorkflowOptions(ctx Context, cwo ChildWorkflowOptions) Context

+ func WithExecutionStartToCloseTimeout(ctx Context, d time.Duration) Context

+ func WithHeartbeatTimeout(ctx Context, d time.Duration) Context

+ func WithScheduleToCloseTimeout(ctx Context, d time.Duration) Context

+ func WithScheduleToStartTimeout(ctx Context, d time.Duration) Context

+ func WithStartToCloseTimeout(ctx Context, d time.Duration) Context

+ func WithTaskList(ctx Context, name string) Context

+ func WithValue(parent Context, key interface{}, val interface{}) Context

+ func WithWaitForCancellation(ctx Context, wait bool) Context

+ func WithWorkflowDomain(ctx Context, name string) Context

+ func WithWorkflowID(ctx Context, workflowID string) Context

+ func WithWorkflowTaskList(ctx Context, name string) Context

+ func WithWorkflowTaskStartToCloseTimeout(ctx Context, d time.Duration) Context

+ type ContinueAsNewError struct

+ func NewContinueAsNewError(ctx Context, wfn interface{}, args ...interface{}) *ContinueAsNewError

+ func (e *ContinueAsNewError) Error() string

+ type CustomError struct

+ func NewCustomError(reason string, details ...interface{}) *CustomError

+ func (e *CustomError) Details(d ...interface{})

+ func (e *CustomError) Error() string

+ func (e *CustomError) Reason() string

+ type DomainClient interface

+ Describe func(ctx context.Context, name string) (*s.DomainInfo, *s.DomainConfiguration, error)

+ Register func(ctx context.Context, request *s.RegisterDomainRequest) error

+ Update func(ctx context.Context, name string, domainInfo *s.UpdateDomainInfo, ...) error

+ func NewDomainClient(service workflowserviceclient.Interface, options *ClientOptions) DomainClient

+ type EncodedValue []byte

+ func (b EncodedValue) Get(valuePtr interface{}) error

+ type EncodedValues []byte

+ func (b EncodedValues) Get(valuePtr ...interface{}) error

+ type Future interface

+ Get func(ctx Context, valuePtr interface{}) error

+ IsReady func() bool

+ func ExecuteActivity(ctx Context, activity interface{}, args ...interface{}) Future

+ func NewTimer(ctx Context, d time.Duration) Future

+ type GenericError struct

+ func (e *GenericError) Error() string

+ type HistoryEventIterator interface

+ HasNext func() bool

+ Next func() (*s.HistoryEvent, error)

+ type HistoryIterator interface

+ GetNextPage func() (*s.History, error)

+ HasNextPage func() bool

+ Reset func()

+ type MockCallWrapper struct

+ func (c *MockCallWrapper) After(d time.Duration) *MockCallWrapper

+ func (c *MockCallWrapper) Once() *MockCallWrapper

+ func (c *MockCallWrapper) Return(returnArguments ...interface{}) *MockCallWrapper

+ func (c *MockCallWrapper) Run(fn func(args mock.Arguments)) *MockCallWrapper

+ func (c *MockCallWrapper) Times(i int) *MockCallWrapper

+ func (c *MockCallWrapper) Twice() *MockCallWrapper

+ type PanicError struct

+ func (e *PanicError) Error() string

+ func (e *PanicError) StackTrace() string

+ type RegisterActivityOptions struct

+ Name string

+ type RegisterWorkflowOptions struct

+ Name string

+ type Selector interface

+ AddDefault func(f func())

+ AddFuture func(future Future, f func(f Future)) Selector

+ AddReceive func(c Channel, f func(c Channel, more bool)) Selector

+ AddSend func(c Channel, v interface{}, f func()) Selector

+ Select func(ctx Context)

+ func NewNamedSelector(ctx Context, name string) Selector

+ func NewSelector(ctx Context) Selector

+ type ServiceInvoker interface

+ Close func()

+ Heartbeat func(details []byte) error

+ type Settable interface

+ Chain func(future Future)

+ Set func(value interface{}, err error)

+ SetError func(err error)

+ SetValue func(value interface{})

+ type StartWorkflowOptions struct

+ DecisionTaskStartToCloseTimeout time.Duration

+ ExecutionStartToCloseTimeout time.Duration

+ ID string

+ TaskList string

+ WorkflowIDReusePolicy WorkflowIDReusePolicy

+ type TerminatedError struct

+ func (e *TerminatedError) Error() string

+ type TestActivityEnvironment struct

+ func (t *TestActivityEnvironment) ExecuteActivity(activityFn interface{}, args ...interface{}) (encoded.Value, error)

+ func (t *TestActivityEnvironment) SetWorkerOptions(options WorkerOptions) *TestActivityEnvironment

+ type TestWorkflowEnvironment struct

+ func (t *TestWorkflowEnvironment) CancelWorkflow()

+ func (t *TestWorkflowEnvironment) CompleteActivity(taskToken []byte, result interface{}, err error) error

+ func (t *TestWorkflowEnvironment) ExecuteWorkflow(workflowFn interface{}, args ...interface{})

+ func (t *TestWorkflowEnvironment) GetWorkflowError() error

+ func (t *TestWorkflowEnvironment) GetWorkflowResult(valuePtr interface{}) error

+ func (t *TestWorkflowEnvironment) IsWorkflowCompleted() bool

+ func (t *TestWorkflowEnvironment) Now() time.Time

+ func (t *TestWorkflowEnvironment) OnActivity(activity interface{}, args ...interface{}) *MockCallWrapper

+ func (t *TestWorkflowEnvironment) OnWorkflow(workflow interface{}, args ...interface{}) *MockCallWrapper

+ func (t *TestWorkflowEnvironment) QueryWorkflow(queryType string, args ...interface{}) (encoded.Value, error)

+ func (t *TestWorkflowEnvironment) RegisterDelayedCallback(callback func(), delayDuration time.Duration)

+ func (t *TestWorkflowEnvironment) SetActivityTaskList(tasklist string, activityFn ...interface{})

+ func (t *TestWorkflowEnvironment) SetOnActivityCanceledListener(listener func(activityInfo *ActivityInfo)) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetOnActivityCompletedListener(listener func(activityInfo *ActivityInfo, result encoded.Value, err error)) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetOnActivityHeartbeatListener(listener func(activityInfo *ActivityInfo, details encoded.Values)) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetOnActivityStartedListener(...) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetOnChildWorkflowCanceledListener(listener func(workflowInfo *WorkflowInfo)) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetOnChildWorkflowCompletedListener(listener func(workflowInfo *WorkflowInfo, result encoded.Value, err error)) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetOnChildWorkflowStartedListener(listener func(workflowInfo *WorkflowInfo, ctx Context, args encoded.Values)) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetOnTimerCancelledListener(listener func(timerID string)) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetOnTimerFiredListener(listener func(timerID string)) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetOnTimerScheduledListener(listener func(timerID string, duration time.Duration)) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetTestTimeout(idleTimeout time.Duration) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetWorkerOptions(options WorkerOptions) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SignalWorkflow(name string, input interface{})

+ type TimeoutError struct

+ func NewHeartbeatTimeoutError(details ...interface{}) *TimeoutError

+ func NewTimeoutError(timeoutType shared.TimeoutType) *TimeoutError

+ func (e *TimeoutError) Details(d ...interface{})

+ func (e *TimeoutError) Error() string

+ func (e *TimeoutError) TimeoutType() shared.TimeoutType

+ type Version int

+ const DefaultVersion

+ func GetVersion(ctx Context, changeID string, minSupported, maxSupported Version) Version

+ type Worker interface

+ Run func() error

+ Start func() error

+ Stop func()

+ func NewActivityTaskWorker(taskHandler ActivityTaskHandler, service workflowserviceclient.Interface, ...) Worker

+ func NewWorker(service workflowserviceclient.Interface, domain string, taskList string, ...) Worker

+ func NewWorkflowTaskWorker(taskHandler WorkflowTaskHandler, service workflowserviceclient.Interface, ...) (worker Worker)

+ type WorkerOptions struct

+ AutoHeartBeat bool

+ BackgroundActivityContext context.Context

+ DisableActivityWorker bool

+ DisableStickyExecution bool

+ DisableWorkflowWorker bool

+ EnableLoggingInReplay bool

+ Identity string

+ Logger *zap.Logger

+ MaxConcurrentActivityExecutionSize int

+ MetricsScope tally.Scope

+ StickyScheduleToStartTimeout time.Duration

+ TaskListActivitiesPerSecond float64

+ WorkerActivitiesPerSecond float64

+ type WorkflowExecution struct

+ ID string

+ RunID string

+ type WorkflowIDReusePolicy int

+ const WorkflowIDReusePolicyAllowDuplicate

+ const WorkflowIDReusePolicyAllowDuplicateFailedOnly

+ const WorkflowIDReusePolicyRejectDuplicate

+ type WorkflowInfo struct

+ Domain string

+ ExecutionStartToCloseTimeoutSeconds int32

+ TaskListName string

+ TaskStartToCloseTimeoutSeconds int32

+ WorkflowExecution WorkflowExecution

+ WorkflowType WorkflowType

+ func GetWorkflowInfo(ctx Context) *WorkflowInfo

+ type WorkflowRun interface

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

+ GetRunID func() string

+ type WorkflowTaskHandler interface

+ ProcessWorkflowTask func(task *s.PollForDecisionTaskResponse, historyIterator HistoryIterator, ...) (response interface{}, stackTrace string, err error)

+ func NewWorkflowTaskHandler(domain string, identity string, logger *zap.Logger) WorkflowTaskHandler

+ type WorkflowTestSuite struct

+ func (s *WorkflowTestSuite) GetLogger() *zap.Logger

+ func (s *WorkflowTestSuite) NewTestActivityEnvironment() *TestActivityEnvironment

+ func (s *WorkflowTestSuite) NewTestWorkflowEnvironment() *TestWorkflowEnvironment

+ func (s *WorkflowTestSuite) SetLogger(logger *zap.Logger)

+ func (s *WorkflowTestSuite) SetMetricsScope(scope tally.Scope)

+ type WorkflowType struct

+ Name string