Versions in this module Expand all Collapse all v1 v1.11.0 Apr 7, 2025 v1.10.1 Apr 7, 2025 Changes in this version + const HandlerUnfinishedPolicyAbandon + const HandlerUnfinishedPolicyWarnAndAbandon + const VersioningBehaviorAutoUpgrade + const VersioningBehaviorPinned + const VersioningBehaviorUnspecified + var ErrCanceled = internal.ErrCanceled + var ErrDeadlineExceeded = internal.ErrDeadlineExceeded + var ErrSessionFailed = internal.ErrSessionFailed + var SessionStateClosed = internal.SessionStateClosed + var SessionStateFailed = internal.SessionStateFailed + var SessionStateOpen = internal.SessionStateOpen + func AllHandlersFinished(ctx Context) bool + func Await(ctx Context, condition func() bool) error + func AwaitWithOptions(ctx Context, options AwaitOptions, condition func() bool) (ok bool, err error) + func AwaitWithTimeout(ctx Context, timeout time.Duration, condition func() bool) (ok bool, err error) + func CompleteSession(ctx Context) + func DataConverterWithoutDeadlockDetection(c converter.DataConverter) converter.DataConverter + func DeterministicKeysFunc[K comparable, V any](m map[K]V, cmp func(K, K) int) []K + func DeterministicKeys[K cmp.Ordered, V any](m map[K]V) []K + func GetCurrentDetails(ctx Context) string + func GetLastCompletionResult(ctx Context, d ...interface{}) error + func GetLastError(ctx Context) error + func GetLogger(ctx Context) log.Logger + func GetMetricsHandler(ctx Context) metrics.Handler + func GetTypedSearchAttributes(ctx Context) temporal.SearchAttributes + func GetUnhandledSignalNames(ctx Context) []string + func Go(ctx Context, f func(ctx Context)) + func GoNamed(ctx Context, name string, f func(ctx Context)) + func HasLastCompletionResult(ctx Context) bool + func IsContinueAsNewError(err error) bool + func IsReplaying(ctx Context) bool + func MutableSideEffect(ctx Context, id string, f func(ctx Context) interface{}, ...) converter.EncodedValue + func NewContinueAsNewError(ctx Context, wfn interface{}, args ...interface{}) error + func NewContinueAsNewErrorWithOptions(ctx Context, options ContinueAsNewErrorOptions, wfn interface{}, ...) error + func NewDisconnectedContext(parent Context) (ctx Context, cancel CancelFunc) + func NewFuture(ctx Context) (Future, Settable) + func Now(ctx Context) time.Time + func SetCurrentDetails(ctx Context, details string) + func SetQueryHandler(ctx Context, queryType string, handler interface{}) error + func SetQueryHandlerWithOptions(ctx Context, queryType string, handler interface{}, ...) error + func SetUpdateHandler(ctx Context, updateName string, handler interface{}) error + func SetUpdateHandlerWithOptions(ctx Context, updateName string, handler interface{}, opts UpdateHandlerOptions) error + func SideEffect(ctx Context, f func(ctx Context) interface{}) converter.EncodedValue + func Sleep(ctx Context, d time.Duration) (err error) + func UpsertMemo(ctx Context, memo map[string]interface{}) error + func UpsertSearchAttributes(ctx Context, attributes map[string]interface{}) error + func UpsertTypedSearchAttributes(ctx Context, searchAttributeUpdate ...temporal.SearchAttributeUpdate) error + func WithCancel(parent Context) (ctx Context, cancel CancelFunc) + type ActivityOptions = internal.ActivityOptions + func GetActivityOptions(ctx Context) ActivityOptions + type AwaitOptions = internal.AwaitOptions + type CancelFunc = internal.CancelFunc + type Channel = internal.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 = internal.ChildWorkflowFuture + func ExecuteChildWorkflow(ctx Context, childWorkflow interface{}, args ...interface{}) ChildWorkflowFuture + type ChildWorkflowOptions = internal.ChildWorkflowOptions + func GetChildWorkflowOptions(ctx Context) ChildWorkflowOptions + type Context = internal.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 WithChildOptions(ctx Context, cwo ChildWorkflowOptions) Context + func WithDataConverter(ctx Context, dc converter.DataConverter) Context + func WithHeartbeatTimeout(ctx Context, d time.Duration) Context + func WithLocalActivityOptions(ctx Context, options LocalActivityOptions) Context + func WithPriority(ctx Context, priority temporal.Priority) Context + func WithRetryPolicy(ctx Context, retryPolicy temporal.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 WithWorkflowPriority(ctx Context, priority internal.Priority) Context + func WithWorkflowRunTimeout(ctx Context, d time.Duration) Context + func WithWorkflowTaskQueue(ctx Context, name string) Context + func WithWorkflowTaskTimeout(ctx Context, d time.Duration) Context + func WithWorkflowVersioningIntent(ctx Context, intent temporal.VersioningIntent) Context + type ContextAware = internal.ContextAware + type ContextPropagator = internal.ContextPropagator + type ContinueAsNewError = internal.ContinueAsNewError + type ContinueAsNewErrorOptions = internal.ContinueAsNewErrorOptions + type Execution = internal.WorkflowExecution + type Future = internal.Future + 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 NewTimerWithOptions(ctx Context, d time.Duration, options TimerOptions) Future + func RequestCancelExternalWorkflow(ctx Context, workflowID, runID string) Future + func SignalExternalWorkflow(ctx Context, workflowID, runID, signalName string, arg interface{}) Future + type HandlerUnfinishedPolicy = internal.HandlerUnfinishedPolicy + type HeaderReader = internal.HeaderReader + type HeaderWriter = internal.HeaderWriter + type Info = internal.WorkflowInfo + func GetInfo(ctx Context) *Info + type LocalActivityOptions = internal.LocalActivityOptions + func GetLocalActivityOptions(ctx Context) LocalActivityOptions + type Mutex = internal.Mutex + 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 NexusOperationExecution = internal.NexusOperationExecution + type NexusOperationFuture = internal.NexusOperationFuture + type NexusOperationOptions = internal.NexusOperationOptions + type QueryHandlerOptions = internal.QueryHandlerOptions + type ReceiveChannel = internal.ReceiveChannel + func GetSignalChannel(ctx Context, signalName string) ReceiveChannel + func GetSignalChannelWithOptions(ctx Context, signalName string, options SignalChannelOptions) ReceiveChannel + type RegisterOptions = internal.RegisterWorkflowOptions + type Selector = internal.Selector + func NewNamedSelector(ctx Context, name string) Selector + func NewSelector(ctx Context) Selector + type Semaphore = internal.Semaphore + func NewSemaphore(ctx Context, n int64) Semaphore + type SendChannel = internal.SendChannel + type SessionInfo = internal.SessionInfo + func GetSessionInfo(ctx Context) *SessionInfo + type SessionOptions = internal.SessionOptions + type SessionState = internal.SessionState + type Settable = internal.Settable + type SignalChannelOptions = internal.SignalChannelOptions + type TimerOptions = internal.TimerOptions + type Type = internal.WorkflowType + type UpdateHandlerOptions = internal.UpdateHandlerOptions + type UpdateInfo = internal.UpdateInfo + func GetCurrentUpdateInfo(ctx Context) *UpdateInfo + type Version = internal.Version + const DefaultVersion + func GetVersion(ctx Context, changeID string, minSupported, maxSupported Version) Version + type VersioningBehavior = internal.VersioningBehavior + type WaitGroup = internal.WaitGroup + func NewWaitGroup(ctx Context) WaitGroup
Go to main page