Versions in this module Expand all Collapse all v0 v0.29.0 Aug 18, 2020 Changes in this version + const DefaultNamespace + const LocalHostPort + const QueryTypeOpenSessions + const QueryTypeStackTrace + const ReplayNamespace + const SDKFeatureVersion + const SDKVersion + const TemporalChangeVersion + var ErrActivityResultPending = errors.New("not error: do not autocomplete, using Client.CompleteActivity() to complete") + var ErrCanceled = NewCanceledError() + var ErrDeadlineExceeded = NewTimeoutError(enumspb.TIMEOUT_TYPE_SCHEDULE_TO_CLOSE, nil) + var ErrMissingMarkerDataKey = errors.New("marker key is missing in details") + var ErrMissingMarkerDetails = errors.New("marker details are nil") + var ErrMockStartChildWorkflowFailed = fmt.Errorf("start child workflow failed: %v", ...) + var ErrNoData = errors.New("no data available") + var ErrSessionFailed = errors.New("session has failed") + var ErrTooManyArg = errors.New("too many arguments") + var ErrUnknownMarkerName = errors.New("unknown marker name") + func Await(ctx Context, condition func() bool) error + func AwaitWithTimeout(ctx Context, timeout time.Duration, condition func() bool) (ok bool, err error) + func CompleteSession(ctx Context) + func EnableVerboseLogging(enable bool) + func GetActivityLogger(ctx context.Context) log.Logger + func GetActivityMetricsScope(ctx context.Context) tally.Scope + func GetHeartbeatDetails(ctx context.Context, d ...interface{}) error + func GetLastCompletionResult(ctx Context, d ...interface{}) error + func GetLogger(ctx Context) log.Logger + func GetMetricsScope(ctx Context) tally.Scope + func GetWorkerStopChannel(ctx context.Context) <-chan struct + func Go(ctx Context, f func(ctx Context)) + func GoNamed(ctx Context, name string, f func(ctx Context)) + func HasHeartbeatDetails(ctx context.Context) bool + func HasLastCompletionResult(ctx Context) bool + func InterruptCh() <-chan interface + func IsCanceledError(err error) bool + func IsReplayNamespace(dn string) bool + func IsReplaying(ctx Context) bool + func IsRetryable(err error, nonRetryableTypes []string) bool + func MutableSideEffect(ctx Context, id string, f func(ctx Context) interface{}, ...) converter.EncodedValue + func NewDisconnectedContext(parent Context) (ctx Context, cancel CancelFunc) + func NewFuture(ctx Context) (Future, Settable) + func NewValue(data *commonpb.Payloads) converter.EncodedValue + func NewValues(data *commonpb.Payloads) converter.EncodedValues + func Now(ctx Context) time.Time + func RecordActivityHeartbeat(ctx context.Context, details ...interface{}) + func SetBinaryChecksum(checksum string) + func SetQueryHandler(ctx Context, queryType string, handler interface{}) error + func SetStickyWorkflowCacheSize(cacheSize int) + func SideEffect(ctx Context, f func(ctx Context) interface{}) converter.EncodedValue + func Sleep(ctx Context, d time.Duration) (err error) + func UpsertSearchAttributes(ctx Context, attributes map[string]interface{}) error + func WithActivityTask(ctx context.Context, task *workflowservice.PollActivityTaskQueueResponse, ...) context.Context + func WithCancel(parent Context) (ctx Context, cancel CancelFunc) + type ActivityError struct + func NewActivityError(scheduledEventID int64, startedEventID int64, identity string, ...) *ActivityError + func (e *ActivityError) Error() string + func (e *ActivityError) Unwrap() error + type ActivityID struct + type ActivityInfo struct + ActivityID string + ActivityType ActivityType + Attempt int32 + Deadline time.Time + HeartbeatTimeout time.Duration + ScheduledTime time.Time + StartedTime time.Time + TaskQueue string + TaskToken []byte + WorkflowExecution WorkflowExecution + WorkflowNamespace string + WorkflowType *WorkflowType + func GetActivityInfo(ctx context.Context) ActivityInfo + type ActivityOptions struct + ActivityID string + HeartbeatTimeout time.Duration + RetryPolicy *RetryPolicy + ScheduleToCloseTimeout time.Duration + ScheduleToStartTimeout time.Duration + StartToCloseTimeout time.Duration + TaskQueue string + WaitForCancellation bool + type ActivityTaskHandler interface + Execute func(taskQueue string, task *workflowservice.PollActivityTaskQueueResponse) (interface{}, error) + type ActivityType struct + Name string + type AggregatedWorker struct + func NewAggregatedWorker(client *WorkflowClient, taskQueue string, options WorkerOptions) *AggregatedWorker + func NewWorker(client Client, taskQueue string, options WorkerOptions) *AggregatedWorker + 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(interruptCh <-chan interface{}) error + func (aw *AggregatedWorker) Start() error + func (aw *AggregatedWorker) Stop() + type ApplicationError struct + func NewApplicationError(message, errType string, nonRetryable bool, cause error, ...) *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) Type() string + func (e *ApplicationError) Unwrap() error + type AsyncActivityClient interface + ExecuteActivity func(parameters ExecuteActivityParams, callback ResultHandler) *ActivityID + RequestCancelActivity func(activityID string) + type CancelFunc func() + type CanceledError struct + func NewCanceledError(details ...interface{}) *CanceledError + func (e *CanceledError) Details(d ...interface{}) error + func (e *CanceledError) Error() string + func (e *CanceledError) HasDetails() bool + type Channel interface + 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 ChildWorkflowExecutionError struct + func NewChildWorkflowExecutionError(namespace string, workflowID string, runID string, workflowType string, ...) *ChildWorkflowExecutionError + func (e *ChildWorkflowExecutionError) Error() string + func (e *ChildWorkflowExecutionError) Unwrap() error + type ChildWorkflowFuture interface + GetChildWorkflowExecution func() Future + SignalChildWorkflow func(ctx Context, signalName string, data interface{}) Future + func ExecuteChildWorkflow(ctx Context, childWorkflow interface{}, args ...interface{}) ChildWorkflowFuture + type ChildWorkflowOptions struct + CronSchedule string + Memo map[string]interface{} + Namespace string + ParentClosePolicy enumspb.ParentClosePolicy + RetryPolicy *RetryPolicy + SearchAttributes map[string]interface{} + TaskQueue string + WaitForCancellation bool + WorkflowExecutionTimeout time.Duration + WorkflowID string + WorkflowIDReusePolicy enumspb.WorkflowIdReusePolicy + WorkflowRunTimeout time.Duration + WorkflowTaskTimeout time.Duration + type Client interface + CancelWorkflow func(ctx context.Context, workflowID string, runID string) error + Close func() + CompleteActivity func(ctx context.Context, taskToken []byte, result interface{}, err error) error + CompleteActivityByID func(ctx context.Context, namespace, workflowID, runID, activityID string, ...) error + CountWorkflow func(ctx context.Context, request *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error) + DescribeTaskQueue func(ctx context.Context, taskqueue string, taskqueueType enumspb.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error) + DescribeWorkflowExecution func(ctx context.Context, workflowID, runID string) (*workflowservice.DescribeWorkflowExecutionResponse, error) + ExecuteWorkflow func(ctx context.Context, options StartWorkflowOptions, workflow interface{}, ...) (WorkflowRun, error) + GetSearchAttributes func(ctx context.Context) (*workflowservice.GetSearchAttributesResponse, error) + GetWorkflow func(ctx context.Context, workflowID string, runID string) WorkflowRun + GetWorkflowHistory func(ctx context.Context, workflowID string, runID string, isLongPoll bool, ...) HistoryEventIterator + ListArchivedWorkflow func(ctx context.Context, ...) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error) + ListClosedWorkflow func(ctx context.Context, ...) (*workflowservice.ListClosedWorkflowExecutionsResponse, error) + ListOpenWorkflow func(ctx context.Context, ...) (*workflowservice.ListOpenWorkflowExecutionsResponse, error) + ListWorkflow func(ctx context.Context, request *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error) + QueryWorkflow func(ctx context.Context, workflowID string, runID string, queryType string, ...) (converter.EncodedValue, error) + QueryWorkflowWithOptions func(ctx context.Context, request *QueryWorkflowWithOptionsRequest) (*QueryWorkflowWithOptionsResponse, error) + RecordActivityHeartbeat func(ctx context.Context, taskToken []byte, details ...interface{}) error + RecordActivityHeartbeatByID func(ctx context.Context, namespace, workflowID, runID, activityID string, ...) error + ScanWorkflow func(ctx context.Context, request *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error) + SignalWithStartWorkflow func(ctx context.Context, workflowID string, signalName string, ...) (WorkflowRun, error) + SignalWorkflow func(ctx context.Context, workflowID string, runID string, signalName string, ...) error + TerminateWorkflow func(ctx context.Context, workflowID string, runID string, reason string, ...) error + func NewClient(options ClientOptions) (Client, error) + type ClientOptions struct + ConnectionOptions ConnectionOptions + ContextPropagators []ContextPropagator + DataConverter converter.DataConverter + HostPort string + Identity string + Logger log.Logger + MetricsScope tally.Scope + Namespace string + Tracer opentracing.Tracer + type ConnectionOptions struct + DisableHealthCheck bool + HealthCheckTimeout time.Duration + TLS *tls.Config + type Context interface + Deadline func() (deadline time.Time, ok bool) + Done func() Channel + Err func() error + Value func(key interface{}) interface{} + func Background() Context + func CreateSession(ctx Context, sessionOptions *SessionOptions) (Context, error) + func RecreateSession(ctx Context, recreateToken []byte, sessionOptions *SessionOptions) (Context, error) + func WithActivityOptions(ctx Context, options ActivityOptions) Context + func WithChildWorkflowOptions(ctx Context, cwo ChildWorkflowOptions) Context + func WithDataConverter(ctx Context, dc converter.DataConverter) Context + func WithHeartbeatTimeout(ctx Context, d time.Duration) Context + func WithLocalActivityOptions(ctx Context, options LocalActivityOptions) Context + func WithRetryPolicy(ctx Context, retryPolicy RetryPolicy) 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 WithTaskQueue(ctx Context, name string) Context + func WithValue(parent Context, key interface{}, val interface{}) Context + func WithWaitForCancellation(ctx Context, wait bool) Context + func WithWorkflowID(ctx Context, workflowID string) Context + func WithWorkflowNamespace(ctx Context, name string) Context + func WithWorkflowRunTimeout(ctx Context, d time.Duration) Context + func WithWorkflowTaskQueue(ctx Context, name string) Context + func WithWorkflowTaskTimeout(ctx Context, d time.Duration) Context + 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(logger log.Logger, tracer opentracing.Tracer) ContextPropagator + type ContinueAsNewError struct + func NewContinueAsNewError(ctx Context, wfn interface{}, args ...interface{}) *ContinueAsNewError + func (e *ContinueAsNewError) Args() []interface{} + func (e *ContinueAsNewError) Error() string + func (e *ContinueAsNewError) WorkflowType() *WorkflowType + type EncodedValue struct + func (b EncodedValue) Get(valuePtr interface{}) error + func (b EncodedValue) HasValue() bool + type EncodedValues struct + func (b EncodedValues) Get(valuePtr ...interface{}) error + func (b EncodedValues) HasValues() bool + type ErrorDetailsValues []interface + func (b ErrorDetailsValues) Get(valuePtr ...interface{}) error + func (b ErrorDetailsValues) HasValues() bool + type ExecuteActivityOptions struct + ActivityID string + HeartbeatTimeout time.Duration + OriginalTaskQueueName string + RetryPolicy *commonpb.RetryPolicy + ScheduleToCloseTimeout time.Duration + ScheduleToStartTimeout time.Duration + StartToCloseTimeout time.Duration + TaskQueueName string + WaitForCancellation bool + type ExecuteActivityParams struct + ActivityType ActivityType + DataConverter converter.DataConverter + Header *commonpb.Header + Input *commonpb.Payloads + type ExecuteLocalActivityOptions struct + RetryPolicy *RetryPolicy + ScheduleToCloseTimeout time.Duration + StartToCloseTimeout time.Duration + type ExecuteLocalActivityParams struct + ActivityFn interface{} + ActivityType string + Attempt int32 + DataConverter converter.DataConverter + Header *commonpb.Header + InputArgs []interface{} + ScheduledTime time.Time + WorkflowInfo *WorkflowInfo + type ExecuteWorkflowParams struct + Header *commonpb.Header + Input *commonpb.Payloads + WorkflowType *WorkflowType + type Future interface + Get func(ctx Context, valuePtr interface{}) error + IsReady func() bool + func ExecuteActivity(ctx Context, activity interface{}, args ...interface{}) Future + func ExecuteLocalActivity(ctx Context, activity interface{}, args ...interface{}) Future + func NewTimer(ctx Context, d time.Duration) Future + func RequestCancelExternalWorkflow(ctx Context, workflowID, runID string) Future + func SignalExternalWorkflow(ctx Context, workflowID, runID, signalName string, arg interface{}) Future + type HeaderReader interface + ForEachKey func(handler func(string, *commonpb.Payload) error) error + func NewHeaderReader(header *commonpb.Header) HeaderReader + type HeaderWriter interface + Set func(string, *commonpb.Payload) + func NewHeaderWriter(header *commonpb.Header) HeaderWriter + type HistoryEventIterator interface + HasNext func() bool + Next func() (*historypb.HistoryEvent, error) + type HistoryIterator interface + GetNextPage func() (*historypb.History, error) + HasNextPage func() bool + Reset func() + type LocalActivityClient interface + ExecuteLocalActivity func(params ExecuteLocalActivityParams, callback LocalActivityResultHandler) *LocalActivityID + RequestCancelLocalActivity func(activityID string) + type LocalActivityID struct + type LocalActivityOptions struct + RetryPolicy *RetryPolicy + ScheduleToCloseTimeout time.Duration + StartToCloseTimeout time.Duration + type LocalActivityResultHandler func(lar *LocalActivityResultWrapper) + type LocalActivityResultWrapper struct + Attempt int32 + Backoff time.Duration + Err error + Result *commonpb.Payloads + type MockCallWrapper struct + func (c *MockCallWrapper) After(d time.Duration) *MockCallWrapper + func (c *MockCallWrapper) AfterFn(fn func() 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 NamespaceClient interface + Close func() + 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 PanicError struct + func (e *PanicError) Error() string + func (e *PanicError) StackTrace() string + type QueryWorkflowWithOptionsRequest struct + Args []interface{} + QueryRejectCondition enumspb.QueryRejectCondition + QueryType string + RunID string + WorkflowID string + type QueryWorkflowWithOptionsResponse struct + QueryRejected *querypb.QueryRejected + QueryResult converter.EncodedValue + 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) + func GetSignalChannel(ctx Context, signalName string) ReceiveChannel + type RegisterActivityOptions struct + DisableAlreadyRegisteredCheck bool + Name string + type RegisterWorkflowOptions struct + DisableAlreadyRegisteredCheck bool + Name string + type ResultHandler func(result *commonpb.Payloads, err error) + type RetryPolicy struct + BackoffCoefficient float64 + InitialInterval time.Duration + MaximumAttempts int32 + MaximumInterval time.Duration + NonRetryableErrorTypes []string + type Selector interface + AddDefault func(f func()) + AddFuture func(future Future, f func(f Future)) Selector + AddReceive func(c ReceiveChannel, f func(c ReceiveChannel, more bool)) Selector + AddSend func(c SendChannel, v interface{}, f func()) Selector + Select func(ctx Context) + func NewNamedSelector(_ Context, name string) Selector + func NewSelector(ctx Context) Selector + type SendChannel interface + Close func() + Send func(ctx Context, v interface{}) + SendAsync func(v interface{}) (ok bool) + type ServerError struct + func NewServerError(message string, nonRetryable bool, cause error) *ServerError + func (e *ServerError) Error() string + func (e *ServerError) Unwrap() error + type ServiceInvoker interface + Close func(flushBufferedHeartbeat bool) + GetClient func(options ClientOptions) Client + Heartbeat func(details *commonpb.Payloads, skipBatching bool) error + 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 + HeartbeatTimeout time.Duration + type Settable interface + Chain func(future Future) + Set func(value interface{}, err error) + SetError func(err error) + SetValue func(value interface{}) + type StartWorkflowOptions struct + CronSchedule string + ID string + Memo map[string]interface{} + RetryPolicy *RetryPolicy + SearchAttributes map[string]interface{} + TaskQueue string + WorkflowExecutionTimeout time.Duration + WorkflowIDReusePolicy enumspb.WorkflowIdReusePolicy + WorkflowRunTimeout time.Duration + WorkflowTaskTimeout time.Duration + type TerminatedError struct + func (e *TerminatedError) Error() string + type TestActivityEnvironment struct + func (t *TestActivityEnvironment) ExecuteActivity(activityFn interface{}, args ...interface{}) (converter.EncodedValue, error) + func (t *TestActivityEnvironment) ExecuteLocalActivity(activityFn interface{}, args ...interface{}) (val converter.EncodedValue, err error) + func (t *TestActivityEnvironment) RegisterActivity(a interface{}) + func (t *TestActivityEnvironment) RegisterActivityWithOptions(a interface{}, options RegisterActivityOptions) + func (t *TestActivityEnvironment) SetContextPropagators(contextPropagators []ContextPropagator) *TestActivityEnvironment + func (t *TestActivityEnvironment) SetDataConverter(dataConverter converter.DataConverter) *TestActivityEnvironment + func (t *TestActivityEnvironment) SetHeartbeatDetails(details interface{}) + func (t *TestActivityEnvironment) SetIdentity(identity string) *TestActivityEnvironment + func (t *TestActivityEnvironment) SetTestTimeout(idleTimeout time.Duration) *TestActivityEnvironment + func (t *TestActivityEnvironment) SetTracer(tracer opentracing.Tracer) *TestActivityEnvironment + func (t *TestActivityEnvironment) SetWorkerOptions(options WorkerOptions) *TestActivityEnvironment + func (t *TestActivityEnvironment) SetWorkerStopChannel(c chan struct{}) + type TestWorkflowEnvironment struct + func (e *TestWorkflowEnvironment) AssertExpectations(t *testing.T) bool + func (e *TestWorkflowEnvironment) CancelWorkflow() + func (e *TestWorkflowEnvironment) CompleteActivity(taskToken []byte, result interface{}, err error) error + func (e *TestWorkflowEnvironment) ExecuteWorkflow(workflowFn interface{}, args ...interface{}) + func (e *TestWorkflowEnvironment) GetWorkflowError() error + func (e *TestWorkflowEnvironment) GetWorkflowResult(valuePtr interface{}) error + func (e *TestWorkflowEnvironment) IsWorkflowCompleted() bool + func (e *TestWorkflowEnvironment) Now() time.Time + func (e *TestWorkflowEnvironment) OnActivity(activity interface{}, args ...interface{}) *MockCallWrapper + func (e *TestWorkflowEnvironment) OnGetVersion(changeID string, minSupported, maxSupported Version) *MockCallWrapper + func (e *TestWorkflowEnvironment) OnRequestCancelExternalWorkflow(namespace, workflowID, runID string) *MockCallWrapper + func (e *TestWorkflowEnvironment) OnSignalExternalWorkflow(namespace, workflowID, runID, signalName, arg interface{}) *MockCallWrapper + func (e *TestWorkflowEnvironment) OnUpsertSearchAttributes(attributes map[string]interface{}) *MockCallWrapper + func (e *TestWorkflowEnvironment) OnWorkflow(workflow interface{}, args ...interface{}) *MockCallWrapper + func (e *TestWorkflowEnvironment) QueryWorkflow(queryType string, args ...interface{}) (converter.EncodedValue, error) + func (e *TestWorkflowEnvironment) RegisterActivity(a interface{}) + func (e *TestWorkflowEnvironment) RegisterActivityWithOptions(a interface{}, options RegisterActivityOptions) + func (e *TestWorkflowEnvironment) RegisterDelayedCallback(callback func(), delayDuration time.Duration) + func (e *TestWorkflowEnvironment) RegisterWorkflow(w interface{}) + func (e *TestWorkflowEnvironment) RegisterWorkflowWithOptions(w interface{}, options RegisterWorkflowOptions) + func (e *TestWorkflowEnvironment) SetActivityTaskQueue(taskqueue string, activityFn ...interface{}) + func (e *TestWorkflowEnvironment) SetDataConverter(dataConverter converter.DataConverter) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetIdentity(identity string) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetLastCompletionResult(result interface{}) + func (e *TestWorkflowEnvironment) SetMemoOnStart(memo map[string]interface{}) error + func (e *TestWorkflowEnvironment) SetOnActivityCanceledListener(listener func(activityInfo *ActivityInfo)) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetOnActivityCompletedListener(...) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetOnActivityHeartbeatListener(listener func(activityInfo *ActivityInfo, details converter.EncodedValues)) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetOnActivityStartedListener(...) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetOnChildWorkflowCanceledListener(listener func(workflowInfo *WorkflowInfo)) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetOnChildWorkflowCompletedListener(...) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetOnChildWorkflowStartedListener(...) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetOnLocalActivityCanceledListener(listener func(activityInfo *ActivityInfo)) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetOnLocalActivityCompletedListener(...) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetOnLocalActivityStartedListener(...) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetOnTimerCanceledListener(listener func(timerID string)) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetOnTimerFiredListener(listener func(timerID string)) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetOnTimerScheduledListener(listener func(timerID string, duration time.Duration)) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetSearchAttributesOnStart(searchAttributes map[string]interface{}) error + func (e *TestWorkflowEnvironment) SetStartTime(startTime time.Time) + func (e *TestWorkflowEnvironment) SetStartWorkflowOptions(options StartWorkflowOptions) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetTestTimeout(idleTimeout time.Duration) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetTracer(tracer opentracing.Tracer) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetWorkerOptions(options WorkerOptions) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SetWorkerStopChannel(c chan struct{}) + func (e *TestWorkflowEnvironment) SetWorkflowRunTimeout(runTimeout time.Duration) *TestWorkflowEnvironment + func (e *TestWorkflowEnvironment) SignalWorkflow(name string, input interface{}) + func (e *TestWorkflowEnvironment) SignalWorkflowByID(workflowID, signalName string, input interface{}) error + func (e *TestWorkflowEnvironment) SignalWorkflowSkippingWorkflowTask(name string, input interface{}) + type TimeoutError struct + func NewHeartbeatTimeoutError(details ...interface{}) *TimeoutError + func NewTimeoutError(timeoutType enumspb.TimeoutType, cause error, ...) *TimeoutError + func (e *TimeoutError) Error() string + func (e *TimeoutError) HasLastHeartbeatDetails() bool + func (e *TimeoutError) LastHeartbeatDetails(d ...interface{}) error + func (e *TimeoutError) TimeoutType() enumspb.TimeoutType + func (e *TimeoutError) Unwrap() error + type TimerInfo struct + type UnknownExternalWorkflowExecutionError struct + func (e *UnknownExternalWorkflowExecutionError) Error() string + type Version int + const DefaultVersion + func GetVersion(ctx Context, changeID string, minSupported, maxSupported Version) Version + type WaitGroup interface + Add func(delta int) + Done func() + Wait func(ctx Context) + func NewWaitGroup(ctx Context) WaitGroup + type WorkerOptions struct + BackgroundActivityContext context.Context + DisableStickyExecution bool + EnableLoggingInReplay bool + EnableSessionWorker bool + MaxConcurrentActivityExecutionSize int + MaxConcurrentActivityTaskPollers int + MaxConcurrentLocalActivityExecutionSize int + MaxConcurrentSessionExecutionSize int + MaxConcurrentWorkflowTaskExecutionSize int + MaxConcurrentWorkflowTaskPollers int + NonDeterministicWorkflowPolicy WorkflowPanicPolicy + StickyScheduleToStartTimeout time.Duration + TaskQueueActivitiesPerSecond float64 + WorkerActivitiesPerSecond float64 + WorkerLocalActivitiesPerSecond float64 + WorkerStopTimeout time.Duration + WorkerWorkflowTasksPerSecond float64 + WorkflowInterceptorChainFactories []WorkflowInterceptor + type WorkflowClient struct + func NewServiceClient(workflowServiceClient workflowservice.WorkflowServiceClient, ...) *WorkflowClient + func (wc *WorkflowClient) CancelWorkflow(ctx context.Context, workflowID string, runID string) error + func (wc *WorkflowClient) Close() + func (wc *WorkflowClient) CompleteActivity(ctx context.Context, taskToken []byte, result interface{}, err error) error + func (wc *WorkflowClient) CompleteActivityByID(ctx context.Context, namespace, workflowID, runID, activityID string, ...) error + func (wc *WorkflowClient) CountWorkflow(ctx context.Context, request *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error) + func (wc *WorkflowClient) DescribeTaskQueue(ctx context.Context, taskQueue string, taskQueueType enumspb.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, 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, ...) (converter.EncodedValue, 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, namespace, 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, ...) (WorkflowRun, 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 + type WorkflowDefinition interface + Close func() + Execute func(env WorkflowEnvironment, header *commonpb.Header, input *commonpb.Payloads) + OnWorkflowTaskStarted 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() converter.DataConverter + GetLogger func() log.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) converter.EncodedValue + 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 WorkflowExecution struct + ID string + RunID string + type WorkflowExecutionContext interface + CompleteWorkflowTask func(workflowTask *workflowTask, waitLocalActivity bool) interface{} + GetCurrentWorkflowTask func() *workflowservice.PollWorkflowTaskQueueResponse + GetWorkflowTaskTimeout func() time.Duration + IsDestroyed func() bool + Lock func() + ProcessLocalActivityResult func(workflowTask *workflowTask, lar *localActivityResult) (interface{}, error) + ProcessWorkflowTask func(workflowTask *workflowTask) (completeRequest interface{}, err error) + StackTrace func() string + Unlock func(err 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 + 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 WorkflowInfo struct + Attempt int32 + BinaryChecksum string + ContinuedExecutionRunID string + CronSchedule string + Memo *commonpb.Memo + Namespace string + ParentWorkflowExecution *WorkflowExecution + ParentWorkflowNamespace string + SearchAttributes *commonpb.SearchAttributes + TaskQueueName string + WorkflowExecution WorkflowExecution + WorkflowExecutionTimeout time.Duration + WorkflowRunTimeout time.Duration + WorkflowTaskTimeout time.Duration + WorkflowType WorkflowType + func GetWorkflowInfo(ctx Context) *WorkflowInfo + func (wInfo *WorkflowInfo) GetBinaryChecksum() string + type WorkflowInterceptor interface + InterceptWorkflow func(info *WorkflowInfo, next WorkflowInboundCallsInterceptor) WorkflowInboundCallsInterceptor + type WorkflowOptions struct + ContextPropagators []ContextPropagator + CronSchedule string + DataConverter converter.DataConverter + Memo map[string]interface{} + Namespace string + ParentClosePolicy enumspb.ParentClosePolicy + RetryPolicy *commonpb.RetryPolicy + SearchAttributes map[string]interface{} + TaskQueueName string + WaitForCancellation bool + WorkflowExecutionTimeout time.Duration + WorkflowID string + WorkflowIDReusePolicy enumspb.WorkflowIdReusePolicy + WorkflowRunTimeout time.Duration + WorkflowTaskTimeout time.Duration + 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) log.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{}, ...) converter.EncodedValue + 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{}) converter.EncodedValue + 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) log.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{}, ...) converter.EncodedValue + 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{}) converter.EncodedValue + 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 + type WorkflowPanicPolicy int + const BlockWorkflow + const FailWorkflow + type WorkflowReplayer struct + func NewWorkflowReplayer() *WorkflowReplayer + func (aw *WorkflowReplayer) RegisterWorkflow(w interface{}) + func (aw *WorkflowReplayer) RegisterWorkflowWithOptions(w interface{}, options RegisterWorkflowOptions) + func (aw *WorkflowReplayer) ReplayPartialWorkflowHistoryFromJSONFile(loger log.Logger, jsonfileName string, lastEventID int64) error + func (aw *WorkflowReplayer) ReplayWorkflowExecution(ctx context.Context, service workflowservice.WorkflowServiceClient, ...) error + func (aw *WorkflowReplayer) ReplayWorkflowHistory(logger log.Logger, history *historypb.History) error + func (aw *WorkflowReplayer) ReplayWorkflowHistoryFromJSONFile(logger log.Logger, jsonfileName string) error + type WorkflowRun interface + Get func(ctx context.Context, valuePtr interface{}) error + GetID func() string + GetRunID func() string + type WorkflowTaskHandler interface + ProcessWorkflowTask func(task *workflowTask, f workflowTaskHeartbeatFunc) (response interface{}, err error) + type WorkflowTestSuite struct + func (s *WorkflowTestSuite) GetLogger() log.Logger + func (s *WorkflowTestSuite) NewTestActivityEnvironment() *TestActivityEnvironment + func (s *WorkflowTestSuite) NewTestWorkflowEnvironment() *TestWorkflowEnvironment + func (s *WorkflowTestSuite) SetContextPropagators(ctxProps []ContextPropagator) + func (s *WorkflowTestSuite) SetHeader(header *commonpb.Header) + func (s *WorkflowTestSuite) SetLogger(logger log.Logger) + func (s *WorkflowTestSuite) SetMetricsScope(scope tally.Scope) + type WorkflowTimerClient interface + NewTimer func(d time.Duration, callback ResultHandler) *TimerInfo + Now func() time.Time + RequestCancelTimer func(timerID string) + type WorkflowType struct + Name string