internal

Mar 1, 2024

Changes in this version

+ type OAuthAuthorizerConfig struct

+ ClientID string

+ ClientSecret string

+ EndpointParams map[string]string

+ Scopes []string

+ TokenURL string

+ type OAuthProvider struct

+ func NewOAuthAuthorizationProvider(config OAuthAuthorizerConfig) *OAuthProvider

+ func (o *OAuthProvider) GetAuthToken() ([]byte, error)

type QueryBuilder

+ CloseTime func(time.Time, time.Time) QueryBuilder

type ShadowOptions

+ WorkflowCloseTimeFilter TimeFilter

type WorkerOptions

+ func AugmentWorkerOptions(options WorkerOptions) WorkerOptions

Nov 24, 2023

Changes in this version

+ const QueryTypeQueryTypes

+ func BuiltinQueryTypes() []string

+ func GetHistoryCount(ctx Context) int64

+ func GetTotalEstimatedHistoryBytes(ctx Context) int64

type WorkflowInfo

+ HistoryBytesServer int64

+ HistoryCount int64

+ TotalHistoryBytes int64

Nov 9, 2023

Changes in this version

+ func GetActivityTaskList(ctx Context) *string

+ func GetWorkflowTaskList(ctx Context) *string

+ type WorkerBugPorts struct

+ DisableStrictNonDeterminismCheck bool

type WorkerOptions

+ WorkerBugPorts WorkerBugPorts

Sep 25, 2023

Changes in this version

+ func NewNonDeterminsticError(reason string, info *WorkflowInfo, history *shared.HistoryEvent, ...) error

+ type NonDeterministicError struct

+ DecisionText string

+ DomainName string

+ HistoryEventText string

+ Reason string

+ RunID string

+ TaskList string

+ WorkflowID string

+ WorkflowType string

+ func (e *NonDeterministicError) Error() string

Aug 14, 2023

Changes in this version

type WorkerOptions

+ Host string

Jul 12, 2023

Changes in this version

+ var StopMetrics = make(chan struct{})

+ func GetRegisteredWorkflowTypes() []string

+ func GetUnhandledSignalNames(ctx Context) []string

+ func StartVersionMetrics(metricsScope tally.Scope)

+ type CancelReason string

type Client

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

type ClientOptions

+ IsolationGroup string

type ContinueAsNewError

+ func (e *ContinueAsNewError) Header() *shared.Header

+ func (e *ContinueAsNewError) Input() []byte

+ func (e *ContinueAsNewError) WorkflowIDReusePolicy() WorkflowIDReusePolicy

type FeatureFlags

+ PollerAutoScalerEnabled bool

+ type Option interface

+ func WithCancelReason(reason string) Option

type StartWorkflowOptions

+ JitterStart time.Duration

type WorkerOptions

+ IsolationGroup string

+ MinConcurrentActivityTaskPollers int

+ MinConcurrentDecisionTaskPollers int

+ PollerAutoScalerCooldown time.Duration

+ PollerAutoScalerDryRun bool

+ PollerAutoScalerTargetUtilization float64

type WorkflowReplayer

+ func (r *WorkflowReplayer) RegisterActivity(a interface{})

+ func (r *WorkflowReplayer) RegisterActivityWithOptions(a interface{}, options RegisterActivityOptions)

+ func (r *WorkflowReplayer) ReplayPartialWorkflowHistoryFromJSON(logger *zap.Logger, reader io.Reader, lastEventID int64) error

+ func (r *WorkflowReplayer) ReplayWorkflowHistoryFromJSON(logger *zap.Logger, reader io.Reader) error

Jan 5, 2022

Changes in this version

+ func NewAdminJwtAuthorizationProvider(privateKey []byte) auth.AuthorizationProvider

type ClientOptions

+ Authorization auth.AuthorizationProvider

+ type JWTAuthProvider struct

+ PrivateKey []byte

+ func (j *JWTAuthProvider) GetAuthToken() ([]byte, error)

type WorkerOptions

+ Authorization auth.AuthorizationProvider

Nov 8, 2021

Changes in this version

+ type Bugports struct

+ StartChildWorkflowsOnCanceledContext bool

type ChildWorkflowOptions

+ Bugports Bugports

type WorkflowInfo

+ OriginalRunId string

Oct 6, 2021

Changes in this version

type WorkflowInfo

+ DecisionStartedEventID int64

+ func (wInfo *WorkflowInfo) GetDecisionStartedEventID() int64

Aug 18, 2021

Changes in this version

type ClientOptions

+ FeatureFlags FeatureFlags

+ type FeatureFlags struct

+ WorkflowExecutionAlreadyCompletedErrorEnabled bool

type ReplayOptions

+ FeatureFlags FeatureFlags

type ServiceInvoker

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

type WorkerOptions

+ FeatureFlags FeatureFlags

Apr 20, 2021

Changes in this version

+ var WorkflowStatusCanceled = WorkflowStatus(shared.WorkflowExecutionCloseStatusCanceled.String())

+ var WorkflowStatusCompleted = WorkflowStatus(shared.WorkflowExecutionCloseStatusCompleted.String())

+ var WorkflowStatusContinuedAsNew = WorkflowStatus(shared.WorkflowExecutionCloseStatusContinuedAsNew.String())

+ var WorkflowStatusFailed = WorkflowStatus(shared.WorkflowExecutionCloseStatusFailed.String())

+ var WorkflowStatusTerminated = WorkflowStatus(shared.WorkflowExecutionCloseStatusTerminated.String())

+ var WorkflowStatusTimedOut = WorkflowStatus(shared.WorkflowExecutionCloseStatusTimedOut.String())

+ type QueryBuilder interface

+ Build func() string

+ StartTime func(time.Time, time.Time) QueryBuilder

+ WorkflowStatus func([]WorkflowStatus) QueryBuilder

+ WorkflowTypes func([]string) QueryBuilder

+ func NewQueryBuilder() QueryBuilder

type RegisterActivityOptions

+ EnableAutoHeartbeat bool

+ type ReplayOptions struct

+ ContextPropagators []ContextPropagator

+ DataConverter DataConverter

+ Tracer opentracing.Tracer

+ WorkflowInterceptorChainFactories []WorkflowInterceptorFactory

type ServiceInvoker

+ BackgroundHeartbeat func() error

+ BatchHeartbeat func(details []byte) error

+ type ShadowExitCondition struct

+ ExpirationInterval time.Duration

+ ShadowCount int

+ type ShadowMode int

+ const ShadowModeContinuous

+ const ShadowModeNormal

+ type ShadowOptions struct

+ Concurrency int

+ ExitCondition ShadowExitCondition

+ Mode ShadowMode

+ SamplingRate float64

+ WorkflowQuery string

+ WorkflowStartTimeFilter TimeFilter

+ WorkflowStatus []string

+ WorkflowTypes []string

type StartWorkflowOptions

+ DelayStart time.Duration

+ type TimeFilter struct

+ MaxTimestamp time.Time

+ MinTimestamp time.Time

type WorkerOptions

+ EnableShadowWorker bool

+ ShadowOptions ShadowOptions

type WorkflowReplayer

+ func NewWorkflowReplayerWithOptions(options ReplayOptions) *WorkflowReplayer

+ type WorkflowShadower struct

+ func NewWorkflowShadower(service workflowserviceclient.Interface, domain string, ...) (*WorkflowShadower, error)

+ func (s *WorkflowShadower) RegisterWorkflow(w interface{})

+ func (s *WorkflowShadower) RegisterWorkflowWithOptions(w interface{}, options RegisterWorkflowOptions)

+ func (s *WorkflowShadower) Run() error

+ func (s *WorkflowShadower) Stop()

+ type WorkflowStatus string

+ const WorkflowStatusALL

+ const WorkflowStatusClosed

+ const WorkflowStatusOpen

+ func ToWorkflowStatus(statusString string) (WorkflowStatus, error)

Feb 10, 2021

Changes in this version

type Client

+ ResetWorkflow func(ctx context.Context, request *s.ResetWorkflowExecutionRequest) (*s.ResetWorkflowExecutionResponse, error)

Dec 3, 2020

Changes in this version

type TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetWorkflowCronMaxIterations(maxIterations int) *TestWorkflowEnvironment

+ func (t *TestWorkflowEnvironment) SetWorkflowCronSchedule(cron string) *TestWorkflowEnvironment

Jul 13, 2020

Changes in this version

type RegisterActivityOptions

+ EnableShortName bool

type RegisterWorkflowOptions

+ EnableShortName bool

type WorkflowInfo

+ RetryPolicy *s.RetryPolicy

Jun 23, 2020

Changes in this version

type TestActivityEnvironment

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

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

type WorkerOptions

+ WorkflowInterceptorChainFactories []WorkflowInterceptorFactory

type WorkflowInfo

+ func (wInfo *WorkflowInfo) GetBinaryChecksum() string

+ type WorkflowInterceptor interface

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

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

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

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

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

+ GetLogger func(ctx Context) *zap.Logger

+ GetMetricsScope func(ctx Context) tally.Scope

+ GetSignalChannel func(ctx Context, signalName string) Channel

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

+ GetWorkflowInfo func(ctx Context) *WorkflowInfo

+ HasLastCompletionResult func(ctx Context) bool

+ IsReplaying func(ctx Context) bool

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

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

+ Now func(ctx Context) time.Time

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

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

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

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

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

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

+ type WorkflowInterceptorBase struct

+ Next WorkflowInterceptor

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type WorkflowInterceptorFactory interface

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

+ type WorkflowReplayer struct

+ func NewWorkflowReplayer() *WorkflowReplayer

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

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

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

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

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

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

May 15, 2020

Changes in this version

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

type RegisterActivityOptions

+ DisableAlreadyRegisteredCheck bool

type RegisterWorkflowOptions

+ DisableAlreadyRegisteredCheck bool

type TestWorkflowEnvironment

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

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

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

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

type WorkflowIDReusePolicy

+ const WorkflowIDReusePolicyTerminateIfRunning

Mar 5, 2020

Changes in this version

type WorkerOptions

+ MaxConcurrentActivityTaskPollers int

+ MaxConcurrentDecisionTaskPollers int

Feb 18, 2020

Changes in this version

type QueryWorkflowWithOptionsRequest

+ QueryConsistencyLevel *s.QueryConsistencyLevel

type SessionOptions

+ HeartbeatTimeout time.Duration

Dec 2, 2019

Changes in this version

+ func IsCanceledError(err error) bool

Nov 21, 2019

Changes in this version

+ const CadenceChangeVersion

+ func SetBinaryChecksum(checksum string)

type ChildWorkflowOptions

+ ParentClosePolicy ParentClosePolicy

type Client

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

+ type ParentClosePolicy int

+ const ParentClosePolicyAbandon

+ const ParentClosePolicyRequestCancel

+ const ParentClosePolicyTerminate

type WorkflowInfo

+ BinaryChecksum *string

Oct 8, 2019

Changes in this version

type Client

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

+ type QueryWorkflowWithOptionsRequest struct

+ Args []interface{}

+ QueryRejectCondition *s.QueryRejectCondition

+ QueryType string

+ RunID string

+ WorkflowID string

+ type QueryWorkflowWithOptionsResponse struct

+ QueryRejected *s.QueryRejected

+ QueryResult Value

Aug 29, 2019

Changes in this version

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

Aug 6, 2019

Changes in this version

+ var DefaultDataConverter = getDefaultDataConverter()

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

type ChildWorkflowOptions

+ Memo map[string]interface{}

+ SearchAttributes map[string]interface{}

+ type DataConverter interface

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

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

type TestWorkflowEnvironment

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

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

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

+ type Value interface

+ Get func(valuePtr interface{}) error

+ HasValue func() bool

+ type Values interface

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

+ HasValues func() bool

+ type WaitGroup interface

+ Add func(delta int)

+ Done func()

+ Wait func(ctx Context)

+ func NewWaitGroup(ctx Context) WaitGroup

type WorkflowInfo

+ Memo *s.Memo

+ SearchAttributes *s.SearchAttributes

Jun 26, 2019

Changes in this version

type WorkerOptions

+ MaxConcurrentSessionExecutionSize int

Jun 19, 2019

Changes in this version

+ func IsReplayDomain(dn string) bool

type NonDeterministicWorkflowPolicy

+ const ReplayDomainName

Jun 14, 2019

Changes in this version

+ const QueryTypeOpenSessions

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

+ func CompleteSession(ctx Context)

type Client

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

type ClientOptions

+ ContextPropagators []ContextPropagator

+ Tracer opentracing.Tracer

type Context

+ func Background() Context

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

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

+ type ContextPropagator interface

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

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

+ Inject func(context.Context, HeaderWriter) error

+ InjectFromWorkflow func(Context, HeaderWriter) error

+ func NewTracingContextPropagator(tracer opentracing.Tracer) ContextPropagator

type ContinueAsNewError

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

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

+ type HeaderReader interface

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

+ func NewHeaderReader(header *shared.Header) HeaderReader

+ type HeaderWriter interface

+ Set func(string, []byte)

+ func NewHeaderWriter(header *shared.Header) HeaderWriter

type ServiceInvoker

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

+ type SessionInfo struct

+ HostName string

+ SessionID string

+ func GetSessionInfo(ctx Context) *SessionInfo

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

+ type SessionOptions struct

+ CreationTimeout time.Duration

+ ExecutionTimeout time.Duration

type StartWorkflowOptions

+ SearchAttributes map[string]interface{}

type TestWorkflowEnvironment

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

type WorkerOptions

+ ContextPropagators []ContextPropagator

+ EnableSessionWorker bool

+ MaxConCurrentSessionExecutionSize int

+ Tracer opentracing.Tracer

type WorkflowTestSuite

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

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

May 18, 2019

Changes in this version

type Client

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

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

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

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

May 8, 2019

Changes in this version

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

type StartWorkflowOptions

+ Memo map[string]interface{}

type TestActivityEnvironment

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

type TestWorkflowEnvironment

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

type WorkerOptions

+ WorkerStopTimeout time.Duration

Mar 19, 2019

Changes in this version

type TestActivityEnvironment

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

type TestWorkflowEnvironment

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

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

+ type UnknownExternalWorkflowExecutionError struct

+ func (e *UnknownExternalWorkflowExecutionError) Error() string

type WorkflowInfo

+ ContinuedExecutionRunID *string

+ CronSchedule *string

+ ParentWorkflowDomain *string

+ ParentWorkflowExecution *WorkflowExecution

Jan 9, 2019

Changes in this version

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

+ func HasLastCompletionResult(ctx Context) bool

type ChildWorkflowOptions

+ CronSchedule string

type StartWorkflowOptions

+ CronSchedule string

Oct 25, 2018

Changes in this version

type ActivityInfo

+ WorkflowDomain string

+ WorkflowType *WorkflowType

Oct 4, 2018

Changes in this version

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

+ func HasHeartbeatDetails(ctx context.Context) bool

type ActivityInfo

+ Attempt int32

type ActivityOptions

+ RetryPolicy *RetryPolicy

type ChildWorkflowOptions

+ RetryPolicy *RetryPolicy

type Context

+ func WithRetryPolicy(ctx Context, retryPolicy RetryPolicy) Context

type LocalActivityOptions

+ RetryPolicy *RetryPolicy

+ type RetryPolicy struct

+ BackoffCoefficient float64

+ ExpirationInterval time.Duration

+ InitialInterval time.Duration

+ MaximumAttempts int32

+ MaximumInterval time.Duration

+ NonRetriableErrorReasons []string

type StartWorkflowOptions

+ RetryPolicy *RetryPolicy

type TestWorkflowEnvironment

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

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

type WorkflowExecutionContext

+ IsDestroyed func() bool

type WorkflowInfo

+ Attempt int32

Aug 13, 2018

Changes in this version

type WorkerOptions

+ MaxConcurrentDecisionTaskExecutionSize int

+ WorkerDecisionTasksPerSecond float64

Jul 27, 2018

Changes in this version

type MockCallWrapper

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

type WorkflowExecutionContext

+ Lock func()

+ Unlock func(err error)

Jul 3, 2018

Changes in this version

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

+ type WorkflowExecutionContext interface

+ CompleteDecisionTask func(waitLocalActivity bool) interface{}

+ GetCurrentDecisionTask func() *s.PollForDecisionTaskResponse

+ GetDecisionTimeout func() time.Duration

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

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

+ StackTrace func() string

type WorkflowRun

+ GetID func() string

May 25, 2018

Changes in this version

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

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

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

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

+ func SetStickyWorkflowCacheSize(cacheSize int)

type ClientOptions

+ DataConverter encoded.DataConverter

type Context

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

+ type ErrorDetailsValues []interface

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

+ func (b ErrorDetailsValues) HasValues() bool

+ type NonDeterministicWorkflowPolicy int

+ const NonDeterministicWorkflowPolicyBlockWorkflow

+ const NonDeterministicWorkflowPolicyFailWorkflow

type TestActivityEnvironment

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

type WorkerOptions

+ DataConverter encoded.DataConverter

+ NonDeterministicWorkflowPolicy NonDeterministicWorkflowPolicy

Apr 17, 2018

Changes in this version

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

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

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

type Client

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

+ type SignalChannel interface

+ ReceiveEncodedValue func(ctx Context) (value encoded.Value, more bool)

+ ReceiveEncodedValueAsync func() (value encoded.Value, ok bool)

+ ReceiveEncodedValueAsyncWithMoreFlag func() (value encoded.Value, ok bool, more bool)

type TestWorkflowEnvironment

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

Mar 9, 2018

Changes in this version

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

+ func IsReplaying(ctx Context) bool

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

type ActivityInfo

+ Deadline time.Time

+ HeartbeatTimeout time.Duration

+ ScheduledTimestamp time.Time

+ StartedTimestamp time.Time

+ TaskList string

type CanceledError

+ func (e *CanceledError) HasDetails() bool

type ChildWorkflowFuture

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

type Client

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

type Context

+ func WithLocalActivityOptions(ctx Context, options LocalActivityOptions) Context

type CustomError

+ func (e *CustomError) HasDetails() bool

type EncodedValue

+ func (b EncodedValue) HasValue() bool

type EncodedValues

+ func (b EncodedValues) HasValues() bool

type Future

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

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

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

+ type LocalActivityOptions struct

+ ScheduleToCloseTimeout time.Duration

type TestActivityEnvironment

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

type TestWorkflowEnvironment

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

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

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

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

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

type TimeoutError

+ func (e *TimeoutError) HasDetails() bool

type WorkerOptions

+ MaxConcurrentLocalActivityExecutionSize int

+ WorkerLocalActivitiesPerSecond float64

Jan 17, 2018

Changes in this version

+ const FeatureVersion

+ const LibraryVersion

+ const QueryTypeStackTrace

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

+ var ErrCanceled = NewCanceledError()

+ var ErrDeadlineExceeded = NewTimeoutError(shared.TimeoutTypeScheduleToClose)

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

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

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

+ func EnableVerboseLogging(enable bool)

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

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

+ func GetLogger(ctx Context) *zap.Logger

+ func GetMetricsScope(ctx Context) tally.Scope

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

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

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

+ func Now(ctx Context) time.Time

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

+ func RegisterActivity(activityFunc interface{})

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

+ func RegisterWorkflow(workflowFunc interface{})

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

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

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

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

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

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

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

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

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

+ type ActivityInfo struct

+ ActivityID string

+ ActivityType ActivityType

+ TaskToken []byte

+ WorkflowExecution WorkflowExecution

+ func GetActivityInfo(ctx context.Context) ActivityInfo

+ type ActivityOptions struct

+ ActivityID string

+ HeartbeatTimeout time.Duration

+ ScheduleToCloseTimeout time.Duration

+ ScheduleToStartTimeout time.Duration

+ StartToCloseTimeout time.Duration

+ TaskList string

+ WaitForCancellation bool

+ type ActivityTaskHandler interface

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

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

+ type ActivityType struct

+ Name string

+ type CancelFunc func()

+ type CanceledError struct

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

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

+ func (e *CanceledError) Error() string

+ type Channel interface

+ Close func()

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

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

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

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

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

+ func GetSignalChannel(ctx Context, signalName string) Channel

+ func NewBufferedChannel(ctx Context, size int) Channel

+ func NewChannel(ctx Context) Channel

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

+ func NewNamedChannel(ctx Context, name string) Channel

+ type ChildWorkflowFuture interface

+ GetChildWorkflowExecution func() Future

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

+ type ChildWorkflowOptions struct

+ ChildPolicy ChildWorkflowPolicy

+ Domain string

+ ExecutionStartToCloseTimeout time.Duration

+ TaskList string

+ TaskStartToCloseTimeout time.Duration

+ WaitForCancellation bool

+ WorkflowID string

+ WorkflowIDReusePolicy WorkflowIDReusePolicy

+ type ChildWorkflowPolicy int32

+ const ChildWorkflowPolicyAbandon

+ const ChildWorkflowPolicyRequestCancel

+ const ChildWorkflowPolicyTerminate

+ type Client interface

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type ClientOptions struct

+ Identity string

+ MetricsScope tally.Scope

+ type Context interface

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

+ Done func() Channel

+ Err func() error

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

+ func WithActivityOptions(ctx Context, options ActivityOptions) Context

+ func WithChildPolicy(ctx Context, childPolicy ChildWorkflowPolicy) Context

+ func WithChildWorkflowOptions(ctx Context, cwo ChildWorkflowOptions) Context

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

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

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

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

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

+ func WithTaskList(ctx Context, name string) Context

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

+ func WithWaitForCancellation(ctx Context, wait bool) Context

+ func WithWorkflowDomain(ctx Context, name string) Context

+ func WithWorkflowID(ctx Context, workflowID string) Context

+ func WithWorkflowTaskList(ctx Context, name string) Context

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

+ type ContinueAsNewError struct

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

+ func (e *ContinueAsNewError) Error() string

+ type CustomError struct

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

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

+ func (e *CustomError) Error() string

+ func (e *CustomError) Reason() string

+ type DomainClient interface

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

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

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

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

+ type EncodedValue []byte

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

+ type EncodedValues []byte

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

+ type Future interface

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

+ IsReady func() bool

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

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

+ type GenericError struct

+ func (e *GenericError) Error() string

+ type HistoryEventIterator interface

+ HasNext func() bool

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

+ type HistoryIterator interface

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

+ HasNextPage func() bool

+ Reset func()

+ type MockCallWrapper struct

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

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

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

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

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

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

+ type PanicError struct

+ func (e *PanicError) Error() string

+ func (e *PanicError) StackTrace() string

+ type RegisterActivityOptions struct

+ Name string

+ type RegisterWorkflowOptions struct

+ Name string

+ type Selector interface

+ AddDefault func(f func())

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

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

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

+ Select func(ctx Context)

+ func NewNamedSelector(ctx Context, name string) Selector

+ func NewSelector(ctx Context) Selector

+ type ServiceInvoker interface

+ Close func()

+ Heartbeat func(details []byte) error

+ type Settable interface

+ Chain func(future Future)

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

+ SetError func(err error)

+ SetValue func(value interface{})

+ type StartWorkflowOptions struct

+ DecisionTaskStartToCloseTimeout time.Duration

+ ExecutionStartToCloseTimeout time.Duration

+ ID string

+ TaskList string

+ WorkflowIDReusePolicy WorkflowIDReusePolicy

+ type TerminatedError struct

+ func (e *TerminatedError) Error() string

+ type TestActivityEnvironment struct

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

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

+ type TestWorkflowEnvironment struct

+ func (t *TestWorkflowEnvironment) CancelWorkflow()

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

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

+ func (t *TestWorkflowEnvironment) GetWorkflowError() error

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

+ func (t *TestWorkflowEnvironment) IsWorkflowCompleted() bool

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type TimeoutError struct

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

+ func NewTimeoutError(timeoutType shared.TimeoutType) *TimeoutError

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

+ func (e *TimeoutError) Error() string

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

+ type Version int

+ const DefaultVersion

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

+ type Worker interface

+ Run func() error

+ Start func() error

+ Stop func()

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

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

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

+ type WorkerOptions struct

+ AutoHeartBeat bool

+ BackgroundActivityContext context.Context

+ DisableActivityWorker bool

+ DisableStickyExecution bool

+ DisableWorkflowWorker bool

+ EnableLoggingInReplay bool

+ Identity string

+ Logger *zap.Logger

+ MaxConcurrentActivityExecutionSize int

+ MetricsScope tally.Scope

+ StickyScheduleToStartTimeout time.Duration

+ TaskListActivitiesPerSecond float64

+ WorkerActivitiesPerSecond float64

+ type WorkflowExecution struct

+ ID string

+ RunID string

+ type WorkflowIDReusePolicy int

+ const WorkflowIDReusePolicyAllowDuplicate

+ const WorkflowIDReusePolicyAllowDuplicateFailedOnly

+ const WorkflowIDReusePolicyRejectDuplicate

+ type WorkflowInfo struct

+ Domain string

+ ExecutionStartToCloseTimeoutSeconds int32

+ TaskListName string

+ TaskStartToCloseTimeoutSeconds int32

+ WorkflowExecution WorkflowExecution

+ WorkflowType WorkflowType

+ func GetWorkflowInfo(ctx Context) *WorkflowInfo

+ type WorkflowRun interface

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

+ GetRunID func() string

+ type WorkflowTaskHandler interface

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

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

+ type WorkflowTestSuite struct

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

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

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

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

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

+ type WorkflowType struct

+ Name string