internal

package

Go to main page

Versions in this module

v1

v1.31.0

Dec 10, 2024

Changes in this version

type Client

+ NewWithStartWorkflowOperation func(options StartWorkflowOptions, workflow interface{}, args ...interface{}) WithStartWorkflowOperation

+ UpdateWithStartWorkflow func(ctx context.Context, options UpdateWithStartWorkflowOptions) (WorkflowUpdateHandle, error)

type ClientOutboundInterceptor

+ UpdateWithStartWorkflow func(context.Context, *ClientUpdateWithStartWorkflowInput) (WorkflowUpdateHandle, error)

type ClientOutboundInterceptorBase

+ func (c *ClientOutboundInterceptorBase) UpdateWithStartWorkflow(ctx context.Context, in *ClientUpdateWithStartWorkflowInput) (WorkflowUpdateHandle, error)

+ type ClientUpdateWithStartWorkflowInput struct

+ StartWorkflowOperation WithStartWorkflowOperation

+ UpdateOptions *UpdateWorkflowOptions

type CompositeTuner

+ func (c *CompositeTuner) GetSessionActivitySlotSupplier() SlotSupplier

type CompositeTunerOptions

+ SessionActivitySlotSupplier SlotSupplier

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) InOrderMockCalls(calls ...*MockCallWrapper)

+ type UpdateWithStartWorkflowOptions struct

+ StartWorkflowOperation WithStartWorkflowOperation

+ UpdateOptions UpdateWorkflowOptions

type WithStartWorkflowOperation

+ Get func(ctx context.Context) (WorkflowRun, error)

type WorkerTuner

+ GetSessionActivitySlotSupplier func() SlotSupplier

type WorkflowClient

+ func (wc *WorkflowClient) NewWithStartWorkflowOperation(options StartWorkflowOptions, workflow interface{}, args ...interface{}) WithStartWorkflowOperation

+ func (wc *WorkflowClient) UpdateWithStartWorkflow(ctx context.Context, options UpdateWithStartWorkflowOptions) (WorkflowUpdateHandle, error)

v1.30.1

Nov 27, 2024

Changes in this version

+ const SDKFlagBlockedSelectorSignalReceive

+ var ErrMissingWorkflowID = errors.New("workflow ID is unset for Nexus operation")

+ func SetUnblockSelectorSignal(unblockSignal bool)

type ActivityOptions

+ Summary string

type ChildWorkflowExecutionError

+ func (e *ChildWorkflowExecutionError) InitiatedEventID() int64

+ func (e *ChildWorkflowExecutionError) Namespace() string

+ func (e *ChildWorkflowExecutionError) RetryState() enumspb.RetryState

+ func (e *ChildWorkflowExecutionError) RunID() string

+ func (e *ChildWorkflowExecutionError) StartedEventID() int64

+ func (e *ChildWorkflowExecutionError) WorkflowID() string

+ func (e *ChildWorkflowExecutionError) WorkflowType() string

type ChildWorkflowOptions

+ StaticDetails string

+ StaticSummary string

type ExecuteActivityOptions

+ Summary string

+ type TestUpdateCallback struct

+ OnAccept func()

+ OnComplete func(interface{}, error)

+ OnReject func(error)

+ func (uc *TestUpdateCallback) Accept()

+ func (uc *TestUpdateCallback) Complete(success interface{}, err error)

+ func (uc *TestUpdateCallback) Reject(err error)

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) UpdateWorkflowNoRejection(updateName string, updateID string, t mock.TestingT, args ...interface{})

type WorkflowEnvironment

+ GetFlag func(flag sdkFlag) bool

type WorkflowOptions

+ StaticDetails string

+ StaticSummary string

v1.30.0

Oct 29, 2024

Changes in this version

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) AssertNexusOperationCalled(t mock.TestingT, service string, operation string, input any, options any) bool

+ func (e *TestWorkflowEnvironment) AssertNexusOperationNotCalled(t mock.TestingT, service string, operation string, input any, options any) bool

+ func (e *TestWorkflowEnvironment) AssertNexusOperationNumberOfCalls(t mock.TestingT, service string, expectedCalls int) bool

+ func (e *TestWorkflowEnvironment) OnNexusOperation(service any, operation any, input any, options any) *MockCallWrapper

+ func (e *TestWorkflowEnvironment) RegisterNexusAsyncOperationCompletion(service string, operation string, operationID string, result any, err error, ...) error

+ func (e *TestWorkflowEnvironment) SetOnNexusOperationCanceledListener(listener func(service string, operation string)) *TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) SetOnNexusOperationCompletedListener(...) *TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) SetOnNexusOperationStartedListener(listener func(service string, operation string, input converter.EncodedValue)) *TestWorkflowEnvironment

v1.29.1

Sep 11, 2024

Changes in this version

+ func AwaitWithOptions(ctx Context, options AwaitOptions, condition func() bool) (ok bool, err error)

+ type AwaitOptions struct

+ Timeout time.Duration

+ TimerOptions TimerOptions

type WorkflowOutboundInterceptor

+ AwaitWithOptions func(ctx Context, options AwaitOptions, condition func() bool) (bool, error)

type WorkflowOutboundInterceptorBase

+ func (w *WorkflowOutboundInterceptorBase) AwaitWithOptions(ctx Context, options AwaitOptions, condition func() bool) (bool, error)

v1.29.0

Sep 5, 2024

Changes in this version

+ const QueryTypeWorkflowMetadata

+ func GetCurrentDetails(ctx Context) string

+ func SetCurrentDetails(ctx Context, details string)

+ func SetLinksOnStartWorkflowOptions(opts *StartWorkflowOptions, links []*commonpb.Link)

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

+ type CompositeTuner struct

+ func (c *CompositeTuner) GetActivityTaskSlotSupplier() SlotSupplier

+ func (c *CompositeTuner) GetLocalActivitySlotSupplier() SlotSupplier

+ func (c *CompositeTuner) GetNexusSlotSupplier() SlotSupplier

+ func (c *CompositeTuner) GetWorkflowTaskSlotSupplier() SlotSupplier

+ type CompositeTunerOptions struct

+ ActivitySlotSupplier SlotSupplier

+ LocalActivitySlotSupplier SlotSupplier

+ NexusSlotSupplier SlotSupplier

+ WorkflowSlotSupplier SlotSupplier

type DescribeTaskQueueEnhancedOptions

+ ReportStats bool

+ type ExecuteNexusOperationInput struct

+ Client NexusClient

+ Input any

+ NexusHeader nexus.Header

+ Operation any

+ Options NexusOperationOptions

+ type FixedSizeSlotSupplier struct

+ func NewFixedSizeSlotSupplier(numSlots int) (*FixedSizeSlotSupplier, error)

+ func (f *FixedSizeSlotSupplier) MarkSlotUsed(SlotMarkUsedInfo)

+ func (f *FixedSizeSlotSupplier) MaxSlots() int

+ func (f *FixedSizeSlotSupplier) ReleaseSlot(SlotReleaseInfo)

+ func (f *FixedSizeSlotSupplier) ReserveSlot(ctx context.Context, _ SlotReservationInfo) (*SlotPermit, error)

+ func (f *FixedSizeSlotSupplier) TryReserveSlot(SlotReservationInfo) *SlotPermit

+ type FixedSizeTunerOptions struct

+ NumActivitySlots int

+ NumLocalActivitySlots int

+ NumNexusSlots int

+ NumWorkflowSlots int

type Future

+ func NewTimerWithOptions(ctx Context, d time.Duration, options TimerOptions) Future

type NexusOperationContext

+ MetricsHandler metrics.Handler

+ Namespace string

+ type QueryHandlerOptions struct

+ Description string

+ type QueryRejectedError struct

+ func (q *QueryRejectedError) Error() string

+ func (q *QueryRejectedError) QueryRejected() *querypb.QueryRejected

type ReceiveChannel

+ func GetSignalChannelWithOptions(ctx Context, signalName string, options SignalChannelOptions) ReceiveChannel

type ScheduleDescription

+ TypedSearchAttributes SearchAttributes

type ScheduleUpdate

+ TypedSearchAttributes *SearchAttributes

+ type SignalChannelOptions struct

+ Description string

+ type SlotMarkUsedInfo interface

+ Logger func() log.Logger

+ MetricsHandler func() metrics.Handler

+ Permit func() *SlotPermit

+ type SlotPermit struct

+ UserData any

+ type SlotReleaseInfo interface

+ Logger func() log.Logger

+ MetricsHandler func() metrics.Handler

+ Permit func() *SlotPermit

+ Reason func() SlotReleaseReason

+ type SlotReleaseReason int

+ const SlotReleaseReasonTaskProcessed

+ const SlotReleaseReasonUnused

+ type SlotReservationInfo interface

+ Logger func() log.Logger

+ MetricsHandler func() metrics.Handler

+ NumIssuedSlots func() int

+ TaskQueue func() string

+ WorkerBuildId func() string

+ WorkerIdentity func() string

+ type SlotSupplier interface

+ MarkSlotUsed func(info SlotMarkUsedInfo)

+ MaxSlots func() int

+ ReleaseSlot func(info SlotReleaseInfo)

+ ReserveSlot func(ctx context.Context, info SlotReservationInfo) (*SlotPermit, error)

+ TryReserveSlot func(info SlotReservationInfo) *SlotPermit

type StartWorkflowOptions

+ StaticDetails string

+ StaticSummary string

+ WithStartOperation WithStartWorkflowOperation

+ WorkflowIDConflictPolicy enumspb.WorkflowIdConflictPolicy

+ type TaskQueueStats struct

+ ApproximateBacklogAge time.Duration

+ ApproximateBacklogCount int64

+ BacklogIncreaseRate float32

+ TasksAddRate float32

+ TasksDispatchRate float32

type TaskQueueTypeInfo

+ Stats *TaskQueueStats

+ type TimerOptions struct

+ Summary string

type UpdateHandlerOptions

+ Description string

+ type UpdateWithStartWorkflowOperation struct

+ func NewUpdateWithStartWorkflowOperation(options UpdateWorkflowOptions) *UpdateWithStartWorkflowOperation

+ func (op *UpdateWithStartWorkflowOperation) Get(ctx context.Context) (WorkflowUpdateHandle, error)

+ type WithStartWorkflowOperation interface

type WorkerOptions

+ Tuner WorkerTuner

+ type WorkerTuner interface

+ GetActivityTaskSlotSupplier func() SlotSupplier

+ GetLocalActivitySlotSupplier func() SlotSupplier

+ GetNexusSlotSupplier func() SlotSupplier

+ GetWorkflowTaskSlotSupplier func() SlotSupplier

+ func NewCompositeTuner(options CompositeTunerOptions) (WorkerTuner, error)

+ func NewFixedSizeTuner(options FixedSizeTunerOptions) (WorkerTuner, error)

type WorkflowOptions

+ WorkflowIDConflictPolicy enumspb.WorkflowIdConflictPolicy

type WorkflowOutboundInterceptor

+ GetSignalChannelWithOptions func(ctx Context, signalName string, options SignalChannelOptions) ReceiveChannel

+ NewTimerWithOptions func(ctx Context, d time.Duration, options TimerOptions) Future

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

type WorkflowOutboundInterceptorBase

+ func (w *WorkflowOutboundInterceptorBase) GetSignalChannelWithOptions(ctx Context, signalName string, options SignalChannelOptions) ReceiveChannel

+ func (w *WorkflowOutboundInterceptorBase) NewTimerWithOptions(ctx Context, d time.Duration, options TimerOptions) Future

+ func (w *WorkflowOutboundInterceptorBase) SetQueryHandlerWithOptions(ctx Context, queryType string, handler interface{}, ...) error

v1.28.1

Jul 22, 2024

v1.28.0

Jul 22, 2024

Changes in this version

+ var IsWorkflowRunOpContextKey = isWorkflowRunOpContextKeyType

+ func AllHandlersFinished(ctx Context) bool

+ func SetCallbacksOnStartWorkflowOptions(opts *StartWorkflowOptions, callbacks []*commonpb.Callback)

+ func SetRequestIDOnStartWorkflowOptions(opts *StartWorkflowOptions, requestID string)

type AggregatedWorker

+ func (aw *AggregatedWorker) RegisterNexusService(service *nexus.Service)

+ type CloudOperationsClient interface

+ Close func()

+ CloudService func() cloudservice.CloudServiceClient

+ func DialCloudOperationsClient(ctx context.Context, options CloudOperationsClientOptions) (CloudOperationsClient, error)

+ type CloudOperationsClientOptions struct

+ ConnectionOptions ConnectionOptions

+ Credentials Credentials

+ DisableTLS bool

+ HostPort string

+ Logger log.Logger

+ MetricsHandler metrics.Handler

+ Version string

+ type HandlerUnfinishedPolicy int

+ const HandlerUnfinishedPolicyAbandon

+ const HandlerUnfinishedPolicyWarnAndAbandon

+ type Mutex interface

+ IsLocked func() bool

+ Lock func(ctx Context) error

+ TryLock func(ctx Context) bool

+ Unlock func()

+ func NewMutex(ctx Context) Mutex

+ type NexusClient interface

+ Endpoint func() string

+ ExecuteOperation func(ctx Context, operation any, input any, options NexusOperationOptions) NexusOperationFuture

+ Service func() string

+ func NewNexusClient(endpoint, service string) NexusClient

+ type NexusOperationContext struct

+ Client Client

+ Log log.Logger

+ TaskQueue string

+ func NexusOperationContextFromGoContext(ctx context.Context) (nctx *NexusOperationContext, ok bool)

+ type NexusOperationError struct

+ Cause error

+ Endpoint string

+ Failure *failurepb.Failure

+ Message string

+ Operation string

+ OperationID string

+ ScheduledEventID int64

+ Service string

+ func (e *NexusOperationError) Error() string

+ func (e *NexusOperationError) Unwrap() error

+ type NexusOperationExecution struct

+ OperationID string

+ type NexusOperationFuture interface

+ GetNexusOperationExecution func() Future

+ type NexusOperationOptions struct

+ ScheduleToCloseTimeout time.Duration

type ReceiveChannel

+ Name func() string

+ type RequestCancelNexusOperationInput struct

+ Client NexusClient

+ ID string

+ Operation any

type ScheduleListOptions

+ Query string

+ type Semaphore interface

+ Acquire func(ctx Context, n int64) error

+ Release func(n int64)

+ TryAcquire func(ctx Context, n int64) bool

+ func NewSemaphore(ctx Context, n int64) Semaphore

type SendChannel

+ Name func() string

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) RegisterNexusService(s *nexus.Service)

type UpdateHandlerOptions

+ UnfinishedPolicy HandlerUnfinishedPolicy

type WorkerOptions

+ MaxConcurrentNexusTaskExecutionSize int

+ MaxConcurrentNexusTaskPollers int

type WorkflowEnvironment

+ ExecuteNexusOperation func(params executeNexusOperationParams, callback func(*commonpb.Payload, error), ...) int64

+ RequestCancelNexusOperation func(seq int64)

type WorkflowOutboundInterceptor

+ ExecuteNexusOperation func(ctx Context, client NexusClient, operation any, input any, ...) NexusOperationFuture

+ RequestCancelNexusOperation func(ctx Context, input RequestCancelNexusOperationInput)

type WorkflowOutboundInterceptorBase

+ func (w *WorkflowOutboundInterceptorBase) ExecuteNexusOperation(ctx Context, client NexusClient, operation any, input any, ...) NexusOperationFuture

+ func (w *WorkflowOutboundInterceptorBase) RequestCancelNexusOperation(ctx Context, input RequestCancelNexusOperationInput)

+ type WorkflowUpdateServiceTimeoutOrCanceledError struct

+ func NewWorkflowUpdateServiceTimeoutOrCanceledError(err error) *WorkflowUpdateServiceTimeoutOrCanceledError

+ func (e *WorkflowUpdateServiceTimeoutOrCanceledError) Error() string

+ func (e *WorkflowUpdateServiceTimeoutOrCanceledError) Unwrap() error

v1.27.0

Jun 13, 2024

Changes in this version

+ const BuildIDTaskReachabilityClosedWorkflowsOnly

+ const BuildIDTaskReachabilityReachable

+ const BuildIDTaskReachabilityUnreachable

+ const BuildIDTaskReachabilityUnspecified

+ const TaskQueueTypeActivity

+ const TaskQueueTypeNexus

+ const TaskQueueTypeUnspecified

+ const TaskQueueTypeWorkflow

+ type BuildIDTaskReachability int

type Client

+ DescribeTaskQueueEnhanced func(ctx context.Context, options DescribeTaskQueueEnhancedOptions) (TaskQueueDescription, error)

+ GetWorkerVersioningRules func(ctx context.Context, options GetWorkerVersioningOptions) (*WorkerVersioningRules, error)

+ UpdateWorkerVersioningRules func(ctx context.Context, options UpdateWorkerVersioningRulesOptions) (*WorkerVersioningRules, error)

type ClientOptions

+ DisableErrorCodeMetricTags bool

+ type ClientPollWorkflowUpdateOutput struct

+ Error error

+ Result converter.EncodedValue

type ClientUpdateWorkflowInput

+ WaitForStage WorkflowUpdateStage

+ type DescribeTaskQueueEnhancedOptions struct

+ ReportPollers bool

+ ReportTaskReachability bool

+ TaskQueue string

+ TaskQueueTypes []TaskQueueType

+ Versions *TaskQueueVersionSelection

+ type GetWorkerVersioningOptions struct

+ TaskQueue string

+ type TaskQueueDescription struct

+ VersionsInfo map[string]TaskQueueVersionInfo

+ type TaskQueuePollerInfo struct

+ Identity string

+ LastAccessTime time.Time

+ RatePerSecond float64

+ WorkerVersionCapabilities *WorkerVersionCapabilities

+ type TaskQueueType int

+ type TaskQueueTypeInfo struct

+ Pollers []TaskQueuePollerInfo

+ type TaskQueueVersionInfo struct

+ TaskReachability BuildIDTaskReachability

+ TypesInfo map[TaskQueueType]TaskQueueTypeInfo

+ type TaskQueueVersionSelection struct

+ AllActive bool

+ BuildIDs []string

+ Unversioned bool

type TestActivityEnvironment

+ func (t *TestActivityEnvironment) SetFailureConverter(failureConverter converter.FailureConverter) *TestActivityEnvironment

type TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetFailureConverter(failureConverter converter.FailureConverter) *TestWorkflowEnvironment

type UpdateInfo

+ Name string

+ func GetCurrentUpdateInfo(ctx Context) *UpdateInfo

+ type UpdateWorkerVersioningRulesOptions struct

+ ConflictToken VersioningConflictToken

+ Operation VersioningOperation

+ TaskQueue string

+ type UpdateWorkflowOptions struct

+ Args []interface{}

+ FirstExecutionRunID string

+ RunID string

+ UpdateID string

+ UpdateName string

+ WaitForStage WorkflowUpdateStage

+ WorkflowID string

+ type VersioningAssignmentRule struct

+ Ramp VersioningRamp

+ TargetBuildID string

+ type VersioningAssignmentRuleWithTimestamp struct

+ CreateTime time.Time

+ Rule VersioningAssignmentRule

+ type VersioningConflictToken struct

+ func (c *VersioningConflictToken) Token() []byte

type VersioningIntent

+ const VersioningIntentInheritBuildID

+ const VersioningIntentUseAssignmentRules

+ type VersioningOperation interface

+ type VersioningOperationAddRedirectRule struct

+ Rule VersioningRedirectRule

+ type VersioningOperationCommitBuildID struct

+ Force bool

+ TargetBuildID string

+ type VersioningOperationDeleteAssignmentRule struct

+ Force bool

+ RuleIndex int32

+ type VersioningOperationDeleteRedirectRule struct

+ SourceBuildID string

+ type VersioningOperationInsertAssignmentRule struct

+ Rule VersioningAssignmentRule

+ RuleIndex int32

+ type VersioningOperationReplaceAssignmentRule struct

+ Force bool

+ Rule VersioningAssignmentRule

+ RuleIndex int32

+ type VersioningOperationReplaceRedirectRule struct

+ Rule VersioningRedirectRule

+ type VersioningRamp interface

+ type VersioningRampByPercentage struct

+ Percentage float32

+ type VersioningRedirectRule struct

+ SourceBuildID string

+ TargetBuildID string

+ type VersioningRedirectRuleWithTimestamp struct

+ CreateTime time.Time

+ Rule VersioningRedirectRule

+ type WorkerVersionCapabilities struct

+ BuildID string

+ UseVersioning bool

+ type WorkerVersioningRules struct

+ AssignmentRules []*VersioningAssignmentRuleWithTimestamp

+ ConflictToken VersioningConflictToken

+ RedirectRules []*VersioningRedirectRuleWithTimestamp

type WorkflowClient

+ func (wc *WorkflowClient) DescribeTaskQueueEnhanced(ctx context.Context, options DescribeTaskQueueEnhancedOptions) (TaskQueueDescription, error)

+ func (wc *WorkflowClient) GetWorkerVersioningRules(ctx context.Context, options GetWorkerVersioningOptions) (*WorkerVersioningRules, error)

+ func (wc *WorkflowClient) UpdateWorkerVersioningRules(ctx context.Context, options UpdateWorkerVersioningRulesOptions) (*WorkerVersioningRules, error)

type WorkflowOutboundInterceptor

+ GetCurrentUpdateInfo func(ctx Context) *UpdateInfo

type WorkflowOutboundInterceptorBase

+ func (w *WorkflowOutboundInterceptorBase) GetCurrentUpdateInfo(ctx Context) *UpdateInfo

+ type WorkflowUpdateStage int

+ const WorkflowUpdateStageAccepted

+ const WorkflowUpdateStageAdmitted

+ const WorkflowUpdateStageCompleted

+ const WorkflowUpdateStageUnspecified

v1.26.1

Apr 10, 2024

Changes in this version

type ConnectionOptions

+ GetSystemInfoTimeout time.Duration

v1.26.0

Mar 11, 2024

Changes in this version

+ const SDKPriorityUpdateHandling

+ var ErrUnknownHistoryEvent = errors.New("unknown history event")

+ func DeterministicKeysFunc[K comparable, V any](m map[K]V, cmp func(a K, b K) int) []K

+ func DeterministicKeys[K constraints.Ordered, V any](m map[K]V) []K

+ func NewApplicationErrorWithOptions(msg string, errType string, options ApplicationErrorOptions) error

+ func NewContinueAsNewErrorWithOptions(ctx Context, options ContinueAsNewErrorOptions, wfn interface{}, ...) error

+ func UpsertTypedSearchAttributes(ctx Context, attributes ...SearchAttributeUpdate) error

type ApplicationError

+ func (e *ApplicationError) NextRetryDelay() time.Duration

+ type ApplicationErrorOptions struct

+ Cause error

+ Details []interface{}

+ NextRetryDelay time.Duration

+ NonRetryable bool

type ChildWorkflowOptions

+ TypedSearchAttributes SearchAttributes

type ClientOptions

+ Credentials Credentials

type ConnectionOptions

+ DisableKeepAliveCheck bool

+ DisableKeepAlivePermitWithoutStream bool

type Context

+ func WithTypedSearchAttributes(ctx Context, searchAttributes SearchAttributes) Context

type ContinueAsNewError

+ RetryPolicy *RetryPolicy

+ type ContinueAsNewErrorOptions struct

+ RetryPolicy *RetryPolicy

+ type Credentials interface

+ func NewAPIKeyDynamicCredentials(apiKeyCallback func(context.Context) (string, error)) Credentials

+ func NewAPIKeyStaticCredentials(apiKey string) Credentials

+ func NewMTLSCredentials(certificate tls.Certificate) Credentials

+ type HistoryJSONOptions struct

+ LastEventID int64

type MockCallWrapper

+ func (c *MockCallWrapper) NotBefore(calls ...*MockCallWrapper) *MockCallWrapper

type ScheduleOptions

+ TypedSearchAttributes SearchAttributes

type ScheduleWorkflowAction

+ TypedSearchAttributes SearchAttributes

+ UntypedSearchAttributes map[string]*commonpb.Payload

+ type SearchAttributeKey interface

+ GetName func() string

+ GetReflectType func() reflect.Type

+ GetValueType func() enumspb.IndexedValueType

+ type SearchAttributeKeyBool struct

+ func NewSearchAttributeKeyBool(name string) SearchAttributeKeyBool

+ func (bk SearchAttributeKeyBool) GetName() string

+ func (bk SearchAttributeKeyBool) GetReflectType() reflect.Type

+ func (bk SearchAttributeKeyBool) GetValueType() enumspb.IndexedValueType

+ func (k SearchAttributeKeyBool) ValueSet(value bool) SearchAttributeUpdate

+ func (k SearchAttributeKeyBool) ValueUnset() SearchAttributeUpdate

+ type SearchAttributeKeyFloat64 struct

+ func NewSearchAttributeKeyFloat64(name string) SearchAttributeKeyFloat64

+ func (bk SearchAttributeKeyFloat64) GetName() string

+ func (bk SearchAttributeKeyFloat64) GetReflectType() reflect.Type

+ func (bk SearchAttributeKeyFloat64) GetValueType() enumspb.IndexedValueType

+ func (k SearchAttributeKeyFloat64) ValueSet(value float64) SearchAttributeUpdate

+ func (k SearchAttributeKeyFloat64) ValueUnset() SearchAttributeUpdate

+ type SearchAttributeKeyInt64 struct

+ func NewSearchAttributeKeyInt64(name string) SearchAttributeKeyInt64

+ func (bk SearchAttributeKeyInt64) GetName() string

+ func (bk SearchAttributeKeyInt64) GetReflectType() reflect.Type

+ func (bk SearchAttributeKeyInt64) GetValueType() enumspb.IndexedValueType

+ func (k SearchAttributeKeyInt64) ValueSet(value int64) SearchAttributeUpdate

+ func (k SearchAttributeKeyInt64) ValueUnset() SearchAttributeUpdate

+ type SearchAttributeKeyKeyword struct

+ func NewSearchAttributeKeyKeyword(name string) SearchAttributeKeyKeyword

+ func (bk SearchAttributeKeyKeyword) GetName() string

+ func (bk SearchAttributeKeyKeyword) GetReflectType() reflect.Type

+ func (bk SearchAttributeKeyKeyword) GetValueType() enumspb.IndexedValueType

+ func (k SearchAttributeKeyKeyword) ValueSet(value string) SearchAttributeUpdate

+ func (k SearchAttributeKeyKeyword) ValueUnset() SearchAttributeUpdate

+ type SearchAttributeKeyKeywordList struct

+ func NewSearchAttributeKeyKeywordList(name string) SearchAttributeKeyKeywordList

+ func (bk SearchAttributeKeyKeywordList) GetName() string

+ func (bk SearchAttributeKeyKeywordList) GetReflectType() reflect.Type

+ func (bk SearchAttributeKeyKeywordList) GetValueType() enumspb.IndexedValueType

+ func (k SearchAttributeKeyKeywordList) ValueSet(values []string) SearchAttributeUpdate

+ func (k SearchAttributeKeyKeywordList) ValueUnset() SearchAttributeUpdate

+ type SearchAttributeKeyString struct

+ func NewSearchAttributeKeyString(name string) SearchAttributeKeyString

+ func (bk SearchAttributeKeyString) GetName() string

+ func (bk SearchAttributeKeyString) GetReflectType() reflect.Type

+ func (bk SearchAttributeKeyString) GetValueType() enumspb.IndexedValueType

+ func (k SearchAttributeKeyString) ValueSet(value string) SearchAttributeUpdate

+ func (k SearchAttributeKeyString) ValueUnset() SearchAttributeUpdate

+ type SearchAttributeKeyTime struct

+ func NewSearchAttributeKeyTime(name string) SearchAttributeKeyTime

+ func (bk SearchAttributeKeyTime) GetName() string

+ func (bk SearchAttributeKeyTime) GetReflectType() reflect.Type

+ func (bk SearchAttributeKeyTime) GetValueType() enumspb.IndexedValueType

+ func (k SearchAttributeKeyTime) ValueSet(value time.Time) SearchAttributeUpdate

+ func (k SearchAttributeKeyTime) ValueUnset() SearchAttributeUpdate

+ type SearchAttributeUpdate func(*SearchAttributes)

+ type SearchAttributes struct

+ func GetTypedSearchAttributes(ctx Context) SearchAttributes

+ func NewSearchAttributes(attributes ...SearchAttributeUpdate) SearchAttributes

+ func (sa SearchAttributes) ContainsKey(key SearchAttributeKey) bool

+ func (sa SearchAttributes) Copy() SearchAttributeUpdate

+ func (sa SearchAttributes) GetBool(key SearchAttributeKeyBool) (bool, bool)

+ func (sa SearchAttributes) GetFloat64(key SearchAttributeKeyFloat64) (float64, bool)

+ func (sa SearchAttributes) GetInt64(key SearchAttributeKeyInt64) (int64, bool)

+ func (sa SearchAttributes) GetKeyword(key SearchAttributeKeyKeyword) (string, bool)

+ func (sa SearchAttributes) GetKeywordList(key SearchAttributeKeyKeywordList) ([]string, bool)

+ func (sa SearchAttributes) GetString(key SearchAttributeKeyString) (string, bool)

+ func (sa SearchAttributes) GetTime(key SearchAttributeKeyTime) (time.Time, bool)

+ func (sa SearchAttributes) GetUntypedValues() map[SearchAttributeKey]interface{}

+ func (sa SearchAttributes) Size() int

type StartWorkflowOptions

+ TypedSearchAttributes SearchAttributes

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) AssertActivityCalled(t mock.TestingT, methodName string, arguments ...interface{}) bool

+ func (e *TestWorkflowEnvironment) AssertActivityNotCalled(t mock.TestingT, methodName string, arguments ...interface{}) bool

+ func (e *TestWorkflowEnvironment) AssertActivityNumberOfCalls(t mock.TestingT, methodName string, expectedCalls int) bool

+ func (e *TestWorkflowEnvironment) AssertWorkflowCalled(t mock.TestingT, methodName string, arguments ...interface{}) bool

+ func (e *TestWorkflowEnvironment) AssertWorkflowNotCalled(t mock.TestingT, methodName string, arguments ...interface{}) bool

+ func (e *TestWorkflowEnvironment) AssertWorkflowNumberOfCalls(t mock.TestingT, methodName string, expectedCalls int) bool

+ func (e *TestWorkflowEnvironment) CancelWorkflowByID(workflowID string, runID string)

+ func (e *TestWorkflowEnvironment) OnUpsertTypedSearchAttributes(attributes interface{}) *MockCallWrapper

+ func (e *TestWorkflowEnvironment) SetTypedSearchAttributesOnStart(searchAttributes SearchAttributes) error

type WorkflowEnvironment

+ DrainUnhandledUpdates func() bool

+ HandleQueuedUpdates func(name string)

+ QueueUpdate func(name string, f func())

+ TryUse func(flag sdkFlag) bool

+ TypedSearchAttributes func() SearchAttributes

+ UpsertTypedSearchAttributes func(attributes SearchAttributes) error

type WorkflowInfo

+ func (wInfo *WorkflowInfo) GetCurrentBuildID() string

type WorkflowOptions

+ TypedSearchAttributes SearchAttributes

type WorkflowOutboundInterceptor

+ GetTypedSearchAttributes func(ctx Context) SearchAttributes

+ UpsertTypedSearchAttributes func(ctx Context, attributes ...SearchAttributeUpdate) error

type WorkflowOutboundInterceptorBase

+ func (w *WorkflowOutboundInterceptorBase) GetTypedSearchAttributes(ctx Context) SearchAttributes

+ func (w *WorkflowOutboundInterceptorBase) UpsertTypedSearchAttributes(ctx Context, attributes ...SearchAttributeUpdate) error

v1.26.0-rc.4

Mar 1, 2024

v1.26.0-rc.3

Feb 27, 2024

v1.26.0-rc.2

Feb 2, 2024

v1.26.0-rc.1

Feb 1, 2024

v1.25.1

Oct 13, 2023

Changes in this version

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) UpdateWorkflowByID(workflowID, updateName, updateID string, uc UpdateCallbacks, args interface{}) error

v1.25.0

Oct 6, 2023

Changes in this version

+ const SDKName

+ const TaskReachabilityClosedWorkflows

+ const TaskReachabilityExistingWorkflows

+ const TaskReachabilityNewWorkflows

+ const TaskReachabilityOpenWorkflows

+ const TaskReachabilityUnspecified

+ const UnversionedBuildID

+ type BuildIDReachability struct

+ TaskQueueReachable map[string]*TaskQueueReachability

+ UnretrievedTaskQueues []string

type Client

+ GetWorkerTaskReachability func(ctx context.Context, options *GetWorkerTaskReachabilityOptions) (*WorkerTaskReachability, error)

+ type GetWorkerTaskReachabilityOptions struct

+ BuildIDs []string

+ Reachability TaskReachability

+ TaskQueues []string

type StartWorkflowOptions

+ StartDelay time.Duration

+ type TaskQueueReachability struct

+ TaskQueueReachability []TaskReachability

+ type TaskReachability int

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) SetContinueAsNewSuggested(suggest bool)

+ func (e *TestWorkflowEnvironment) SetContinuedExecutionRunID(rid string)

+ func (e *TestWorkflowEnvironment) SetCurrentHistorySize(length int)

+ type WorkerTaskReachability struct

+ BuildIDReachability map[string]*BuildIDReachability

type WorkflowClient

+ func (wc *WorkflowClient) GetWorkerTaskReachability(ctx context.Context, options *GetWorkerTaskReachabilityOptions) (*WorkerTaskReachability, error)

type WorkflowInfo

+ func (wInfo *WorkflowInfo) GetContinueAsNewSuggested() bool

+ func (wInfo *WorkflowInfo) GetCurrentHistorySize() int

type WorkflowReplayerOptions

+ DisableDeadlockDetection bool

v1.24.0

Aug 1, 2023

Changes in this version

+ func IsActivity(ctx context.Context) bool

type ActivityInfo

+ IsLocalActivity bool

type ClientQueryWorkflowInput

+ QueryRejectCondition enumspb.QueryRejectCondition

type StartWorkflowOptions

+ EnableEagerStart bool

+ type UpdateInfo struct

+ ID string

+ func GetUpdateInfo(ctx Context) *UpdateInfo

+ type WorkflowContextManager interface

+ GetOrCreateWorkflowContext func(task *workflowservice.PollWorkflowTaskQueueResponse, ...) (*workflowExecutionContextImpl, error)

type WorkflowOutboundInterceptor

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

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

+ GetUpdateInfo func(ctx Context) *UpdateInfo

type WorkflowOutboundInterceptorBase

+ func (w *WorkflowOutboundInterceptorBase) Await(ctx Context, condition func() bool) error

+ func (w *WorkflowOutboundInterceptorBase) AwaitWithTimeout(ctx Context, timeout time.Duration, condition func() bool) (bool, error)

+ func (w *WorkflowOutboundInterceptorBase) GetUpdateInfo(ctx Context) *UpdateInfo

v1.23.1

Jun 16, 2023

Changes in this version

type BuildIDOpAddNewCompatibleVersion

+ ExistingCompatibleBuildID string

v1.23.0

May 26, 2023

Changes in this version

+ const SDKFlagProtocolMessageCommand

type ActivityOptions

+ VersioningIntent VersioningIntent

+ type BuildIDOpAddNewCompatibleVersion struct

+ BuildID string

+ ExistingCompatibleBuildId string

+ MakeSetDefault bool

+ type BuildIDOpAddNewIDInNewDefaultSet struct

+ BuildID string

+ type BuildIDOpPromoteIDWithinSet struct

+ BuildID string

+ type BuildIDOpPromoteSet struct

+ BuildID string

type ChildWorkflowOptions

+ VersioningIntent VersioningIntent

type Context

+ func WithWorkflowVersioningIntent(ctx Context, intent VersioningIntent) Context

type ContinueAsNewError

+ VersioningIntent VersioningIntent

type ExecuteActivityOptions

+ VersioningIntent VersioningIntent

+ type UpdateBuildIDOp interface

type UpdateWorkerBuildIdCompatibilityOptions

+ Operation UpdateBuildIDOp

+ type VersioningIntent int

+ const VersioningIntentCompatible

+ const VersioningIntentDefault

+ const VersioningIntentUnspecified

type WorkerOptions

+ BuildID string

+ UseBuildIDForVersioning bool

type WorkflowOptions

+ VersioningIntent VersioningIntent

v1.22.2

May 12, 2023

Changes in this version

type Client

+ GetWorkflowUpdateHandle func(GetWorkflowUpdateHandleOptions) WorkflowUpdateHandle

type ClientOutboundInterceptor

+ PollWorkflowUpdate func(context.Context, *ClientPollWorkflowUpdateInput) (converter.EncodedValue, error)

type ClientOutboundInterceptorBase

+ func (c *ClientOutboundInterceptorBase) PollWorkflowUpdate(ctx context.Context, in *ClientPollWorkflowUpdateInput) (converter.EncodedValue, error)

+ type ClientPollWorkflowUpdateInput struct

+ UpdateRef *updatepb.UpdateRef

type ClientUpdateWorkflowInput

+ WaitPolicy *updatepb.WaitPolicy

+ type GetWorkflowUpdateHandleOptions struct

+ RunID string

+ UpdateID string

+ WorkflowID string

type UpdateWorkflowWithOptionsRequest

+ WaitPolicy *updatepb.WaitPolicy

type WorkflowClient

+ func (wc *WorkflowClient) GetWorkflowUpdateHandle(ref GetWorkflowUpdateHandleOptions) WorkflowUpdateHandle

+ func (wc *WorkflowClient) PollWorkflowUpdate(ctx context.Context, ref *updatepb.UpdateRef) (converter.EncodedValue, error)

type WorkflowInfo

+ FirstRunID string

+ OriginalRunID string

v1.22.1

Apr 13, 2023

v1.22.0

Apr 12, 2023

Changes in this version

+ const SDKFlagChildWorkflowErrorExecution

+ const SDKFlagLimitChangeVersionSASize

+ const SDKFlagUnknown

+ const SDKFlagUnset

type Client

+ GetWorkerBuildIdCompatibility func(ctx context.Context, options *GetWorkerBuildIdCompatibilityOptions) (*WorkerBuildIDVersionSets, error)

+ UpdateWorkerBuildIdCompatibility func(ctx context.Context, options *UpdateWorkerBuildIdCompatibilityOptions) error

+ type CompatibleVersionSet struct

+ BuildIDs []string

+ type GetWorkerBuildIdCompatibilityOptions struct

+ MaxSets int

+ TaskQueue string

+ type UpdateWorkerBuildIdCompatibilityOptions struct

+ BecomeDefault bool

+ CompatibleBuildID string

+ TaskQueue string

+ WorkerBuildID string

+ type WorkerBuildIDVersionSets struct

+ Sets []*CompatibleVersionSet

+ func (s *WorkerBuildIDVersionSets) Default() string

type WorkerOptions

+ BuildIDForVersioning string

type WorkflowClient

+ func (wc *WorkflowClient) GetWorkerBuildIdCompatibility(ctx context.Context, options *GetWorkerBuildIdCompatibilityOptions) (*WorkerBuildIDVersionSets, error)

+ func (wc *WorkflowClient) UpdateWorkerBuildIdCompatibility(ctx context.Context, options *UpdateWorkerBuildIdCompatibilityOptions) error

type WorkflowReplayer

+ func (aw *WorkflowReplayer) GetWorkflowResult(workflowID string, valuePtr interface{}) error

v1.21.2

Apr 17, 2023

v1.21.1

Feb 10, 2023

Changes in this version

+ func SetRetryLongPollGracePeriod(period time.Duration)

v1.21.0

Feb 3, 2023

Changes in this version

type SessionInfo

+ SessionState SessionState

+ type SessionState int

+ const SessionStateClosed

+ const SessionStateFailed

+ const SessionStateOpen

+ type UpdateScheduler interface

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

+ Yield func(ctx Context, status string)

type WorkflowReplayerOptions

+ ContextPropagators []ContextPropagator

type WorkflowUpdateHandle

+ RunID func() string

+ UpdateID func() string

+ WorkflowID func() string

v1.20.0

Jan 16, 2023

Changes in this version

+ func GetUnhandledSignalNames(ctx Context) []string

type Client

+ UpdateWorkflow func(ctx context.Context, workflowID string, workflowRunID string, ...) (WorkflowUpdateHandle, error)

+ UpdateWorkflowWithOptions func(ctx context.Context, request *UpdateWorkflowWithOptionsRequest) (WorkflowUpdateHandle, error)

type ClientOutboundInterceptor

+ UpdateWorkflow func(context.Context, *ClientUpdateWorkflowInput) (WorkflowUpdateHandle, error)

type ClientOutboundInterceptorBase

+ func (c *ClientOutboundInterceptorBase) UpdateWorkflow(ctx context.Context, in *ClientUpdateWorkflowInput) (WorkflowUpdateHandle, error)

+ type ClientUpdateWorkflowInput struct

+ Args []interface{}

+ FirstExecutionRunID string

+ RunID string

+ UpdateID string

+ UpdateName string

+ WorkflowID string

+ type ReplayWorkflowHistoryOptions struct

+ OriginalExecution WorkflowExecution

+ type UpdateHandlerOptions struct

+ Validator interface{}

+ type UpdateWorkflowWithOptionsRequest struct

+ Args []interface{}

+ FirstExecutionRunID string

+ RunID string

+ UpdateID string

+ UpdateName string

+ WorkflowID string

type WorkflowClient

+ func (wc *WorkflowClient) UpdateWorkflow(ctx context.Context, workflowID string, workflowRunID string, ...) (WorkflowUpdateHandle, error)

+ func (wc *WorkflowClient) UpdateWorkflowWithOptions(ctx context.Context, req *UpdateWorkflowWithOptionsRequest) (WorkflowUpdateHandle, error)

type WorkflowReplayer

+ func (aw *WorkflowReplayer) ReplayWorkflowHistoryWithOptions(logger log.Logger, history *historypb.History, ...) error

type WorkflowReplayerOptions

+ EnableLoggingInReplay bool

+ type WorkflowUpdateHandle interface

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

v1.19.0

Dec 7, 2022

v1.18.1

Nov 10, 2022

v1.18.0

Nov 9, 2022

Changes in this version

+ var ErrScheduleAlreadyRunning = errors.New("schedule with this ID is already registered")

+ var ErrSkipScheduleUpdate = errors.New("skip schedule update")

+ func GetDefaultFailureConverter() converter.FailureConverter

type Client

+ ScheduleClient func() ScheduleClient

type ClientOptions

+ FailureConverter converter.FailureConverter

type ClientOutboundInterceptor

+ CreateSchedule func(ctx context.Context, options *ScheduleClientCreateInput) (ScheduleHandle, error)

type ClientOutboundInterceptorBase

+ func (c *ClientOutboundInterceptorBase) CreateSchedule(ctx context.Context, in *ScheduleClientCreateInput) (ScheduleHandle, error)

+ type DefaultFailureConverter struct

+ func NewDefaultFailureConverter(opt DefaultFailureConverterOptions) *DefaultFailureConverter

+ func (dfc *DefaultFailureConverter) ErrorToFailure(err error) *failurepb.Failure

+ func (dfc *DefaultFailureConverter) FailureToError(failure *failurepb.Failure) error

+ type DefaultFailureConverterOptions struct

+ DataConverter converter.DataConverter

+ EncodeCommonAttributes bool

+ type EventLevelResetter func(int64)

+ type Schedule struct

+ Action ScheduleAction

+ Policy *SchedulePolicies

+ Spec *ScheduleSpec

+ State *ScheduleState

+ type ScheduleAction interface

+ type ScheduleActionResult struct

+ ActualTime time.Time

+ ScheduleTime time.Time

+ StartWorkflowResult *ScheduleWorkflowExecution

+ type ScheduleBackfill struct

+ End time.Time

+ Overlap enumspb.ScheduleOverlapPolicy

+ Start time.Time

+ type ScheduleBackfillOptions struct

+ Backfill []ScheduleBackfill

+ type ScheduleCalendarSpec struct

+ Comment string

+ DayOfMonth []ScheduleRange

+ DayOfWeek []ScheduleRange

+ Hour []ScheduleRange

+ Minute []ScheduleRange

+ Month []ScheduleRange

+ Second []ScheduleRange

+ Year []ScheduleRange

+ type ScheduleClient interface

+ Create func(ctx context.Context, options ScheduleOptions) (ScheduleHandle, error)

+ GetHandle func(ctx context.Context, scheduleID string) ScheduleHandle

+ List func(ctx context.Context, options ScheduleListOptions) (ScheduleListIterator, error)

+ type ScheduleClientCreateInput struct

+ Options *ScheduleOptions

+ type ScheduleDescription struct

+ Info ScheduleInfo

+ Memo *commonpb.Memo

+ Schedule Schedule

+ SearchAttributes *commonpb.SearchAttributes

+ type ScheduleHandle interface

+ Backfill func(ctx context.Context, options ScheduleBackfillOptions) error

+ Delete func(ctx context.Context) error

+ Describe func(ctx context.Context) (*ScheduleDescription, error)

+ GetID func() string

+ Pause func(ctx context.Context, options SchedulePauseOptions) error

+ Trigger func(ctx context.Context, options ScheduleTriggerOptions) error

+ Unpause func(ctx context.Context, options ScheduleUnpauseOptions) error

+ Update func(ctx context.Context, options ScheduleUpdateOptions) error

+ type ScheduleInfo struct

+ CreatedAt time.Time

+ LastUpdateAt time.Time

+ NextActionTimes []time.Time

+ NumActions int

+ NumActionsMissedCatchupWindow int

+ NumActionsSkippedOverlap int

+ RecentActions []ScheduleActionResult

+ RunningWorkflows []ScheduleWorkflowExecution

+ type ScheduleIntervalSpec struct

+ Every time.Duration

+ Offset time.Duration

+ type ScheduleListEntry struct

+ ID string

+ Memo *commonpb.Memo

+ NextActionTimes []time.Time

+ Note string

+ Paused bool

+ RecentActions []ScheduleActionResult

+ SearchAttributes *commonpb.SearchAttributes

+ Spec *ScheduleSpec

+ WorkflowType WorkflowType

+ type ScheduleListIterator interface

+ HasNext func() bool

+ Next func() (*ScheduleListEntry, error)

+ type ScheduleListOptions struct

+ PageSize int

+ type ScheduleOptions struct

+ Action ScheduleAction

+ CatchupWindow time.Duration

+ ID string

+ Memo map[string]interface{}

+ Note string

+ Overlap enumspb.ScheduleOverlapPolicy

+ PauseOnFailure bool

+ Paused bool

+ RemainingActions int64

+ ScheduleBackfill []ScheduleBackfill

+ SearchAttributes map[string]interface{}

+ Spec ScheduleSpec

+ TriggerImmediately bool

+ type SchedulePauseOptions struct

+ Note string

+ type SchedulePolicies struct

+ CatchupWindow time.Duration

+ Overlap enumspb.ScheduleOverlapPolicy

+ PauseOnFailure bool

+ type ScheduleRange struct

+ End int

+ Start int

+ Step int

+ type ScheduleSpec struct

+ Calendars []ScheduleCalendarSpec

+ CronExpressions []string

+ EndAt time.Time

+ Intervals []ScheduleIntervalSpec

+ Jitter time.Duration

+ Skip []ScheduleCalendarSpec

+ StartAt time.Time

+ TimeZoneName string

+ type ScheduleState struct

+ LimitedActions bool

+ Note string

+ Paused bool

+ RemainingActions int

+ type ScheduleTriggerOptions struct

+ Overlap enumspb.ScheduleOverlapPolicy

+ type ScheduleUnpauseOptions struct

+ Note string

+ type ScheduleUpdate struct

+ Schedule *Schedule

+ type ScheduleUpdateInput struct

+ Description ScheduleDescription

+ type ScheduleUpdateOptions struct

+ DoUpdate func(ScheduleUpdateInput) (*ScheduleUpdate, error)

+ type ScheduleWorkflowAction struct

+ Args []interface{}

+ ID string

+ Memo map[string]interface{}

+ RetryPolicy *RetryPolicy

+ SearchAttributes map[string]interface{}

+ TaskQueue string

+ Workflow interface{}

+ WorkflowExecutionTimeout time.Duration

+ WorkflowIDReusePolicy enumspb.WorkflowIdReusePolicy

+ WorkflowRunTimeout time.Duration

+ WorkflowTaskTimeout time.Duration

+ type ScheduleWorkflowExecution struct

+ FirstExecutionRunID string

+ WorkflowID string

type WorkflowClient

+ func (wc *WorkflowClient) ScheduleClient() ScheduleClient

type WorkflowEnvironment

+ GetFailureConverter func() converter.FailureConverter

type WorkflowReplayerOptions

+ FailureConverter converter.FailureConverter

v1.17.0

Sep 9, 2022

Changes in this version

+ func UpsertMemo(ctx Context, memo map[string]interface{}) error

type Client

+ func NewClientFromExisting(existingClient Client, options ClientOptions) (Client, error)

+ OperatorService func() operatorservice.OperatorServiceClient

type ReceiveChannel

+ Len func() int

+ ReceiveWithTimeout func(ctx Context, timeout time.Duration, valuePtr interface{}) (ok, more bool)

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) OnUpsertMemo(attributes interface{}) *MockCallWrapper

type WorkflowClient

+ func (wc *WorkflowClient) OperatorService() operatorservice.OperatorServiceClient

type WorkflowEnvironment

+ UpsertMemo func(memoMap map[string]interface{}) error

type WorkflowOutboundInterceptor

+ UpsertMemo func(ctx Context, memo map[string]interface{}) error

type WorkflowOutboundInterceptorBase

+ func (w *WorkflowOutboundInterceptorBase) UpsertMemo(ctx Context, memo map[string]interface{}) error

v1.16.0

Aug 8, 2022

Changes in this version

+ func HistoryFromJSON(r io.Reader, lastEventID int64) (*historypb.History, error)

+ func SetUpdateHandler(ctx Context, updateName string, handler interface{}, opts UpdateOptions) error

type ActivityOptions

+ DisableEagerExecution bool

type ExecuteActivityOptions

+ DisableEagerExecution bool

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) SetCurrentHistoryLength(length int)

+ func (e *TestWorkflowEnvironment) UpdateWorkflow(name string, uc UpdateCallbacks, args ...interface{})

+ type UpdateCallbacks interface

+ Accept func()

+ Complete func(success interface{}, err error)

+ Reject func(err error)

+ type UpdateInput struct

+ Args []interface{}

+ Name string

+ type UpdateOptions struct

+ Validator interface{}

type WorkerOptions

+ DisableEagerActivities bool

+ DisableRegistrationAliasing bool

+ MaxConcurrentEagerActivityExecutionSize int

type WorkflowEnvironment

+ RegisterUpdateHandler func(handler func(string, *commonpb.Payloads, *commonpb.Header, UpdateCallbacks))

type WorkflowInboundInterceptor

+ ExecuteUpdate func(ctx Context, in *UpdateInput) (interface{}, error)

+ ValidateUpdate func(ctx Context, in *UpdateInput) error

type WorkflowInboundInterceptorBase

+ func (w *WorkflowInboundInterceptorBase) ExecuteUpdate(ctx Context, in *UpdateInput) (interface{}, error)

+ func (w *WorkflowInboundInterceptorBase) ValidateUpdate(ctx Context, in *UpdateInput) error

type WorkflowInfo

+ func (wInfo *WorkflowInfo) GetCurrentHistoryLength() int

type WorkflowOutboundInterceptor

+ SetUpdateHandler func(ctx Context, updateName string, handler interface{}, opts UpdateOptions) error

type WorkflowOutboundInterceptorBase

+ func (w *WorkflowOutboundInterceptorBase) SetUpdateHandler(ctx Context, updateName string, handler interface{}, opts UpdateOptions) error

type WorkflowReplayerOptions

+ DisableRegistrationAliasing bool

+ Interceptors []WorkerInterceptor

type WorkflowTestSuite

+ func (s *WorkflowTestSuite) SetDisableRegistrationAliasing(disableRegistrationAliasing bool)

v1.15.0

Jun 7, 2022

Changes in this version

+ func DataConverterWithoutDeadlockDetection(c converter.DataConverter) converter.DataConverter

+ func PauseDeadlockDetector(ctx Context)

+ func ResumeDeadlockDetector(ctx Context)

type ApplicationError

+ func (e *ApplicationError) Message() string

+ type CheckHealthRequest struct

+ type CheckHealthResponse struct

type Client

+ func DialClient(options ClientOptions) (Client, error)

+ func NewLazyClient(options ClientOptions) (Client, error)

+ CheckHealth func(ctx context.Context, request *CheckHealthRequest) (*CheckHealthResponse, error)

+ type NamespaceNotFoundError struct

+ func (*NamespaceNotFoundError) Error() string

type ServerError

+ func (e *ServerError) Message() string

type TestActivityEnvironment

+ func (t *TestActivityEnvironment) SetOnActivityHeartbeatListener(listener func(activityInfo *ActivityInfo, details converter.EncodedValues)) *TestActivityEnvironment

type TimeoutError

+ func (e *TimeoutError) Message() string

type WorkerOptions

+ OnFatalError func(error)

type WorkflowClient

+ func (wc *WorkflowClient) CheckHealth(ctx context.Context, request *CheckHealthRequest) (*CheckHealthResponse, error)

type WorkflowRun

+ GetWithOptions func(ctx context.Context, valuePtr interface{}, options WorkflowRunGetOptions) error

+ type WorkflowRunGetOptions struct

+ DisableFollowingRuns bool

v1.14.0

Mar 10, 2022

Changes in this version

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) AssertCalled(t mock.TestingT, methodName string, arguments ...interface{}) bool

+ func (e *TestWorkflowEnvironment) AssertNotCalled(t mock.TestingT, methodName string, arguments ...interface{}) bool

+ func (e *TestWorkflowEnvironment) AssertNumberOfCalls(t mock.TestingT, methodName string, expectedCalls int) bool

v1.13.1

Feb 18, 2022

v1.13.0

Feb 1, 2022

Changes in this version

type QueryWorkflowWithOptionsRequest

+ Header *commonpb.Header

type WorkerOptions

+ DefaultHeartbeatThrottleInterval time.Duration

+ MaxHeartbeatThrottleInterval time.Duration

type WorkflowInfo

+ RetryPolicy *RetryPolicy

type WorkflowOutboundInterceptor

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

type WorkflowOutboundInterceptorBase

+ func (w *WorkflowOutboundInterceptorBase) SignalChildWorkflow(ctx Context, workflowID string, signalName string, arg interface{}) Future

v1.12.0

Dec 8, 2021

Changes in this version

+ func GetActivityMetricsHandler(ctx context.Context) metrics.Handler

+ func GetMetricsHandler(ctx Context) metrics.Handler

+ func Header(ctx context.Context) map[string]*commonpb.Payload

+ func WorkflowHeader(ctx Context) map[string]*commonpb.Payload

+ type ActivityInboundInterceptor interface

+ ExecuteActivity func(ctx context.Context, in *ExecuteActivityInput) (interface{}, error)

+ Init func(outbound ActivityOutboundInterceptor) error

+ type ActivityInboundInterceptorBase struct

+ Next ActivityInboundInterceptor

+ func (a *ActivityInboundInterceptorBase) ExecuteActivity(ctx context.Context, in *ExecuteActivityInput) (interface{}, error)

+ func (a *ActivityInboundInterceptorBase) Init(outbound ActivityOutboundInterceptor) error

+ type ActivityOutboundInterceptor interface

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

+ GetInfo func(ctx context.Context) ActivityInfo

+ GetLogger func(ctx context.Context) log.Logger

+ GetMetricsHandler func(ctx context.Context) metrics.Handler

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

+ HasHeartbeatDetails func(ctx context.Context) bool

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

+ type ActivityOutboundInterceptorBase struct

+ Next ActivityOutboundInterceptor

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

+ func (a *ActivityOutboundInterceptorBase) GetInfo(ctx context.Context) ActivityInfo

+ func (a *ActivityOutboundInterceptorBase) GetLogger(ctx context.Context) log.Logger

+ func (a *ActivityOutboundInterceptorBase) GetMetricsHandler(ctx context.Context) metrics.Handler

+ func (a *ActivityOutboundInterceptorBase) GetWorkerStopChannel(ctx context.Context) <-chan struct{}

+ func (a *ActivityOutboundInterceptorBase) HasHeartbeatDetails(ctx context.Context) bool

+ func (a *ActivityOutboundInterceptorBase) RecordHeartbeat(ctx context.Context, details ...interface{})

type Client

+ WorkflowService func() workflowservice.WorkflowServiceClient

+ type ClientCancelWorkflowInput struct

+ RunID string

+ WorkflowID string

+ type ClientExecuteWorkflowInput struct

+ Args []interface{}

+ Options *StartWorkflowOptions

+ WorkflowType string

+ type ClientInterceptor interface

+ InterceptClient func(next ClientOutboundInterceptor) ClientOutboundInterceptor

+ type ClientInterceptorBase struct

+ func (*ClientInterceptorBase) InterceptClient(next ClientOutboundInterceptor) ClientOutboundInterceptor

type ClientOptions

+ Interceptors []ClientInterceptor

+ MetricsHandler metrics.Handler

+ type ClientOutboundInterceptor interface

+ CancelWorkflow func(context.Context, *ClientCancelWorkflowInput) error

+ ExecuteWorkflow func(context.Context, *ClientExecuteWorkflowInput) (WorkflowRun, error)

+ QueryWorkflow func(context.Context, *ClientQueryWorkflowInput) (converter.EncodedValue, error)

+ SignalWithStartWorkflow func(context.Context, *ClientSignalWithStartWorkflowInput) (WorkflowRun, error)

+ SignalWorkflow func(context.Context, *ClientSignalWorkflowInput) error

+ TerminateWorkflow func(context.Context, *ClientTerminateWorkflowInput) error

+ type ClientOutboundInterceptorBase struct

+ Next ClientOutboundInterceptor

+ func (c *ClientOutboundInterceptorBase) CancelWorkflow(ctx context.Context, in *ClientCancelWorkflowInput) error

+ func (c *ClientOutboundInterceptorBase) ExecuteWorkflow(ctx context.Context, in *ClientExecuteWorkflowInput) (WorkflowRun, error)

+ func (c *ClientOutboundInterceptorBase) QueryWorkflow(ctx context.Context, in *ClientQueryWorkflowInput) (converter.EncodedValue, error)

+ func (c *ClientOutboundInterceptorBase) SignalWithStartWorkflow(ctx context.Context, in *ClientSignalWithStartWorkflowInput) (WorkflowRun, error)

+ func (c *ClientOutboundInterceptorBase) SignalWorkflow(ctx context.Context, in *ClientSignalWorkflowInput) error

+ func (c *ClientOutboundInterceptorBase) TerminateWorkflow(ctx context.Context, in *ClientTerminateWorkflowInput) error

+ type ClientQueryWorkflowInput struct

+ Args []interface{}

+ QueryType string

+ RunID string

+ WorkflowID string

+ type ClientSignalWithStartWorkflowInput struct

+ Args []interface{}

+ Options *StartWorkflowOptions

+ SignalArg interface{}

+ SignalName string

+ WorkflowType string

+ type ClientSignalWorkflowInput struct

+ Arg interface{}

+ RunID string

+ SignalName string

+ WorkflowID string

+ type ClientTerminateWorkflowInput struct

+ Details []interface{}

+ Reason string

+ RunID string

+ WorkflowID string

type ConnectionOptions

+ DialOptions []grpc.DialOption

+ type ExecuteActivityInput struct

+ Args []interface{}

+ type ExecuteWorkflowInput struct

+ Args []interface{}

+ type HandleQueryInput struct

+ Args []interface{}

+ QueryType string

+ type HandleSignalInput struct

+ Arg *commonpb.Payloads

+ SignalName string

+ type Interceptor interface

+ type InterceptorBase struct

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) SetDetachedChildWait(detachedChildWait bool) *TestWorkflowEnvironment

+ type WorkerInterceptor interface

+ InterceptActivity func(ctx context.Context, next ActivityInboundInterceptor) ActivityInboundInterceptor

+ InterceptWorkflow func(ctx Context, next WorkflowInboundInterceptor) WorkflowInboundInterceptor

+ type WorkerInterceptorBase struct

+ func (*WorkerInterceptorBase) InterceptActivity(ctx context.Context, next ActivityInboundInterceptor) ActivityInboundInterceptor

+ func (*WorkerInterceptorBase) InterceptWorkflow(ctx Context, next WorkflowInboundInterceptor) WorkflowInboundInterceptor

type WorkerOptions

+ Interceptors []WorkerInterceptor

type WorkflowClient

+ func (wc *WorkflowClient) WorkflowService() workflowservice.WorkflowServiceClient

type WorkflowEnvironment

+ GetMetricsHandler func() metrics.Handler

+ type WorkflowInboundInterceptor interface

+ ExecuteWorkflow func(ctx Context, in *ExecuteWorkflowInput) (interface{}, error)

+ HandleQuery func(ctx Context, in *HandleQueryInput) (interface{}, error)

+ HandleSignal func(ctx Context, in *HandleSignalInput) error

+ Init func(outbound WorkflowOutboundInterceptor) error

+ type WorkflowInboundInterceptorBase struct

+ Next WorkflowInboundInterceptor

+ func (w *WorkflowInboundInterceptorBase) ExecuteWorkflow(ctx Context, in *ExecuteWorkflowInput) (interface{}, error)

+ func (w *WorkflowInboundInterceptorBase) HandleQuery(ctx Context, in *HandleQueryInput) (interface{}, error)

+ func (w *WorkflowInboundInterceptorBase) HandleSignal(ctx Context, in *HandleSignalInput) error

+ func (w *WorkflowInboundInterceptorBase) Init(outbound WorkflowOutboundInterceptor) error

+ type WorkflowOutboundInterceptor 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

+ GetInfo func(ctx Context) *WorkflowInfo

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

+ GetLastError func(ctx Context) error

+ GetLogger func(ctx Context) log.Logger

+ GetMetricsHandler func(ctx Context) metrics.Handler

+ GetSignalChannel func(ctx Context, signalName string) ReceiveChannel

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

+ 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

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

+ 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 WorkflowOutboundInterceptorBase struct

+ Next WorkflowOutboundInterceptor

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

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

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

+ func (w *WorkflowOutboundInterceptorBase) GetInfo(ctx Context) *WorkflowInfo

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

+ func (w *WorkflowOutboundInterceptorBase) GetLastError(ctx Context) error

+ func (w *WorkflowOutboundInterceptorBase) GetLogger(ctx Context) log.Logger

+ func (w *WorkflowOutboundInterceptorBase) GetMetricsHandler(ctx Context) metrics.Handler

+ func (w *WorkflowOutboundInterceptorBase) GetSignalChannel(ctx Context, signalName string) ReceiveChannel

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

+ func (w *WorkflowOutboundInterceptorBase) Go(ctx Context, name string, f func(ctx Context)) Context

+ func (w *WorkflowOutboundInterceptorBase) HasLastCompletionResult(ctx Context) bool

+ func (w *WorkflowOutboundInterceptorBase) IsReplaying(ctx Context) bool

+ func (w *WorkflowOutboundInterceptorBase) MutableSideEffect(ctx Context, id string, f func(ctx Context) interface{}, ...) converter.EncodedValue

+ func (w *WorkflowOutboundInterceptorBase) NewContinueAsNewError(ctx Context, wfn interface{}, args ...interface{}) error

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

+ func (w *WorkflowOutboundInterceptorBase) Now(ctx Context) time.Time

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

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

+ func (w *WorkflowOutboundInterceptorBase) SideEffect(ctx Context, f func(ctx Context) interface{}) converter.EncodedValue

+ func (w *WorkflowOutboundInterceptorBase) SignalExternalWorkflow(ctx Context, workflowID string, runID string, signalName string, ...) Future

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

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

type WorkflowTestSuite

+ func (s *WorkflowTestSuite) SetMetricsHandler(metricsHandler metrics.Handler)

v1.11.1

Nov 12, 2021

v1.11.0

Oct 27, 2021

Changes in this version

+ type ChildWorkflowExecutionAlreadyStartedError struct

+ func (*ChildWorkflowExecutionAlreadyStartedError) Error() string

+ type WorkflowReplayerOptions struct

+ DataConverter converter.DataConverter

v1.10.0

Sep 15, 2021

Changes in this version

type WorkflowInboundCallsInterceptor

+ HandleQuery func(ctx Context, queryType string, args *commonpb.Payloads, ...) (*commonpb.Payloads, error)

+ ProcessSignal func(ctx Context, signalName string, arg interface{})

type WorkflowInboundCallsInterceptorBase

+ func (w WorkflowInboundCallsInterceptorBase) HandleQuery(ctx Context, queryType string, args *commonpb.Payloads, ...) (*commonpb.Payloads, error)

+ func (w WorkflowInboundCallsInterceptorBase) ProcessSignal(ctx Context, signalName string, arg interface{})

v1.9.0

Aug 5, 2021

Changes in this version

+ func WithLocalActivityTask(ctx context.Context, task *localActivityTask, logger log.Logger, ...) context.Context

type ActivityError

+ func (e *ActivityError) ActivityID() string

+ func (e *ActivityError) ActivityType() *commonpb.ActivityType

+ func (e *ActivityError) Identity() string

+ func (e *ActivityError) RetryState() enumspb.RetryState

+ func (e *ActivityError) ScheduledEventID() int64

+ func (e *ActivityError) StartedEventID() int64

type MockCallWrapper

+ func (c *MockCallWrapper) Maybe() *MockCallWrapper

v1.8.0

Jul 2, 2021

Changes in this version

+ func NewActivityNotRegisteredError(activityType string, supportedTypes []string) error

+ type ActivityNotRegisteredError struct

+ func (e *ActivityNotRegisteredError) Error() string

type ConnectionOptions

+ MaxPayloadSize int

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) GetWorkflowErrorByID(workflowID string) error

+ func (e *TestWorkflowEnvironment) GetWorkflowResultByID(workflowID string, valuePtr interface{}) error

type WorkerOptions

+ DeadlockDetectionTimeout time.Duration

v1.7.0

Jun 10, 2021

Changes in this version

type ClientOptions

+ TrafficController TrafficController

type ConnectionOptions

+ Authority string

+ HealthCheckAttemptTimeout time.Duration

type MockCallWrapper

+ func (c *MockCallWrapper) Never() *MockCallWrapper

+ type TrafficController interface

+ CheckCallAllowed func(ctx context.Context, method string, req, reply interface{}) error

type WorkflowInfo

+ WorkflowStartTime time.Time

v1.6.0

Apr 6, 2021

Changes in this version

+ func WithContext(ctx context.Context, dc converter.DataConverter) converter.DataConverter

+ func WithWorkflowContext(ctx Context, dc converter.DataConverter) converter.DataConverter

type ActivityOptions

+ func GetActivityOptions(ctx Context) ActivityOptions

type ChildWorkflowOptions

+ func GetChildWorkflowOptions(ctx Context) ChildWorkflowOptions

type Client

+ ResetWorkflowExecution func(ctx context.Context, request *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)

+ type ContextAware interface

+ WithContext func(ctx context.Context) converter.DataConverter

+ WithWorkflowContext func(ctx Context) converter.DataConverter

type LocalActivityOptions

+ func GetLocalActivityOptions(ctx Context) LocalActivityOptions

type RegisterActivityOptions

+ SkipInvalidStructFunctions bool

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) QueryWorkflowByID(workflowID, queryType string, args ...interface{}) (converter.EncodedValue, error)

type WorkflowClient

+ func (wc *WorkflowClient) ResetWorkflowExecution(ctx context.Context, request *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)

v1.5.0

Feb 26, 2021

Changes in this version

type ClientOptions

+ HeadersProvider HeadersProvider

type ConnectionOptions

+ EnableKeepAliveCheck bool

+ KeepAlivePermitWithoutStream bool

+ KeepAliveTime time.Duration

+ KeepAliveTimeout time.Duration

+ type HeadersProvider interface

+ GetHeaders func(ctx context.Context) (map[string]string, error)

v1.4.1

Jan 25, 2021

v1.4.0

Jan 21, 2021

Changes in this version

+ func ConvertErrorToFailure(err error, dc converter.DataConverter) *failurepb.Failure

+ func ConvertFailureToError(failure *failurepb.Failure, dc converter.DataConverter) error

+ func GetLastCompletionResultFromWorkflowInfo(info *WorkflowInfo) *commonpb.Payloads

v1.3.0

Jan 7, 2021

Changes in this version

+ func GetLastError(ctx Context) error

+ func PurgeStickyWorkflowCache()

type ActivityID

+ func ParseActivityID(id string) (ActivityID, error)

+ func (i ActivityID) String() string

type ContinueAsNewError

+ Header *commonpb.Header

+ Input *commonpb.Payloads

+ TaskQueueName string

+ WorkflowExecutionTimeout time.Duration

+ WorkflowRunTimeout time.Duration

+ WorkflowTaskTimeout time.Duration

type LocalActivityID

+ func ParseLocalActivityID(v string) (LocalActivityID, error)

+ func (i LocalActivityID) String() string

type Selector

+ HasPending func() bool

type StartWorkflowOptions

+ WorkflowExecutionErrorWhenAlreadyStarted bool

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) SetLastError(err error)

+ type TimerID struct

+ func ParseTimerID(id string) (TimerID, error)

+ func (i TimerID) String() string

+ type WorkerCache struct

+ func NewWorkerCache() *WorkerCache

+ func (wc *WorkerCache) MaxWorkflowCacheSize() int

type WorkerOptions

+ Identity string

+ LocalActivityWorkerOnly bool

+ WorkflowPanicPolicy WorkflowPanicPolicy

type WorkflowOutboundCallsInterceptor

+ GetLastError func(ctx Context) error

type WorkflowOutboundCallsInterceptorBase

+ func (t *WorkflowOutboundCallsInterceptorBase) GetLastError(ctx Context) error

v1.2.0

Nov 11, 2020

Changes in this version

type MockCallWrapper

+ func (c *MockCallWrapper) Panic(msg string) *MockCallWrapper

v1.1.0

Oct 9, 2020

Changes in this version

type HeaderReader

+ Get func(string) (*commonpb.Payload, bool)

type TestActivityEnvironment

+ func (t *TestActivityEnvironment) SetHeader(header *commonpb.Header)

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) SetContextPropagators(contextPropagators []ContextPropagator) *TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) SetHeader(header *commonpb.Header)

v1.0.0

Sep 29, 2020

Changes in this version

+ const SupportedServerVersions

v1.0.0-rc1

Sep 28, 2020

v0

v0.31.0

Sep 22, 2020

v0.30.0

Sep 17, 2020

v0.29.0

Aug 24, 2020

v0.28.2

Aug 14, 2020

Changes in this version

type TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) SetOnTimerCanceledListener(listener func(timerID string)) *TestWorkflowEnvironment

v0.28.1

Aug 10, 2020

v0.28.0

Jul 31, 2020

Changes in this version

+ func InterruptCh() <-chan interface

type ActivityInfo

+ ScheduledTime time.Time

+ StartedTime time.Time

type ConnectionOptions

+ DisableHealthCheck bool

+ HealthCheckTimeout time.Duration

type ExecuteActivityOptions

+ HeartbeatTimeout time.Duration

+ ScheduleToCloseTimeout time.Duration

+ ScheduleToStartTimeout time.Duration

+ StartToCloseTimeout time.Duration

type ExecuteLocalActivityOptions

+ ScheduleToCloseTimeout time.Duration

+ StartToCloseTimeout time.Duration

type WorkflowInfo

+ WorkflowExecutionTimeout time.Duration

+ WorkflowRunTimeout time.Duration

+ WorkflowTaskTimeout time.Duration

type WorkflowOptions

+ WorkflowExecutionTimeout time.Duration

+ WorkflowRunTimeout time.Duration

+ WorkflowTaskTimeout time.Duration

v0.27.0

Jul 15, 2020

Changes in this version

+ const DefaultNamespace

+ const LocalHostPort

+ const QueryTypeOpenSessions

+ const QueryTypeStackTrace

+ const ReplayNamespace

+ const SDKFeatureVersion

+ const SDKVersion

+ const TemporalChangeVersion

+ var DefaultDataConverter = &defaultDataConverter

+ 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 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 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 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")

+ 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) *zap.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) *zap.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 IsCanceledError(err error) bool

+ func IsReplayNamespace(dn string) bool

+ func IsReplaying(ctx Context) bool

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

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

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

+ 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 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

+ ScheduledTimestamp time.Time

+ StartedTimestamp 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() 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, ...) (Value, 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 DataConverter

+ HostPort string

+ Identity string

+ Logger *zap.Logger

+ MetricsScope tally.Scope

+ Namespace string

+ Tracer opentracing.Tracer

+ type ConnectionOptions struct

+ 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 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 *zap.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 DataConverter interface

+ 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)

+ ToStrings func(input *commonpb.Payloads) ([]string, error)

+ 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

+ HeartbeatTimeoutSeconds int32

+ OriginalTaskQueueName string

+ RetryPolicy *commonpb.RetryPolicy

+ ScheduleToCloseTimeoutSeconds int32

+ ScheduleToStartTimeoutSeconds int32

+ StartToCloseTimeoutSeconds int32

+ TaskQueueName 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

+ 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 Value

+ 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{}) (Value, error)

+ func (t *TestActivityEnvironment) ExecuteLocalActivity(activityFn interface{}, args ...interface{}) (val Value, 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 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{}) (Value, 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 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(listener func(activityInfo *ActivityInfo, result Value, err error)) *TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) SetOnActivityHeartbeatListener(listener func(activityInfo *ActivityInfo, details Values)) *TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) SetOnActivityStartedListener(listener func(activityInfo *ActivityInfo, ctx context.Context, args Values)) *TestWorkflowEnvironment

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

+ func (e *TestWorkflowEnvironment) SetOnChildWorkflowCompletedListener(listener func(workflowInfo *WorkflowInfo, result Value, err error)) *TestWorkflowEnvironment

+ func (e *TestWorkflowEnvironment) SetOnChildWorkflowStartedListener(listener func(workflowInfo *WorkflowInfo, ctx Context, args Values)) *TestWorkflowEnvironment

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

+ func (e *TestWorkflowEnvironment) SetOnLocalActivityCompletedListener(listener func(activityInfo *ActivityInfo, result Value, err error)) *TestWorkflowEnvironment

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

+ func (e *TestWorkflowEnvironment) SetOnTimerCancelledListener(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 Value interface

+ Get func(valuePtr interface{}) error

+ HasValue func() bool

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

+ func NewValue(data *commonpb.Payloads) Value

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

+ type Values interface

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

+ HasValues func() bool

+ func NewValues(data *commonpb.Payloads) Values

+ 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

+ DisableActivityWorker bool

+ DisableStickyExecution bool

+ DisableWorkflowWorker 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, ...) (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, 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() 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 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

+ WorkflowExecutionTimeoutSeconds int32

+ WorkflowRunTimeoutSeconds int32

+ WorkflowTaskTimeoutSeconds int32

+ 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 DataConverter

+ Memo map[string]interface{}

+ Namespace string

+ ParentClosePolicy enumspb.ParentClosePolicy

+ RetryPolicy *commonpb.RetryPolicy

+ SearchAttributes map[string]interface{}

+ TaskQueueName string

+ WaitForCancellation bool

+ WorkflowExecutionTimeoutSeconds int32

+ WorkflowID string

+ WorkflowIDReusePolicy enumspb.WorkflowIdReusePolicy

+ WorkflowRunTimeoutSeconds int32

+ WorkflowTaskTimeoutSeconds int32

+ 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

+ 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(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 *historypb.History) error

+ func (aw *WorkflowReplayer) ReplayWorkflowHistoryFromJSONFile(logger *zap.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() *zap.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 *zap.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

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