callbacks

Sep 6, 2024

Changes in this version

+ var AllowedAddresses = dynamicconfig.NewNamespaceTypedSettingWithConverter("component.callbacks.allowedAddresses", allowedAddressConverter, ...)

+ var RequestCounter = metrics.NewCounterDef("callback_outbound_requests", ...)

+ var RequestLatencyHistogram = metrics.NewTimerDef("callback_outbound_latency", ...)

+ var RetryPolicyInitialInterval = dynamicconfig.NewGlobalDurationSetting("component.callbacks.retryPolicy.initialInterval", time.Second, ...)

+ var RetryPolicyMaximumInterval = dynamicconfig.NewGlobalDurationSetting("component.callbacks.retryPolicy.maxInterval", time.Hour, ...)

+ type AddressMatchRule struct

+ AllowInsecure bool

+ Regexp *regexp.Regexp

+ type CanGetHSMCompletionCallbackArg interface

+ GetHSMCompletionCallbackArg func(ctx context.Context) (*persistencespb.HSMCompletionCallbackArg, error)

type Config

+ RetryPolicy func() backoff.RetryPolicy

type EventAttemptFailed

+ RetryPolicy backoff.RetryPolicy

+ type HTTPCallerProvider func(queues.NamespaceIDAndDestination) HTTPCaller

+ func HTTPCallerProviderProvider(clusterMetadata cluster.Metadata, rpcFactory common.RPCFactory, ...) (HTTPCallerProvider, error)

+ type TaskExecutorOptions struct

+ Config *Config

+ HTTPCallerProvider HTTPCallerProvider

+ HistoryClient resource.HistoryClient

+ Logger log.Logger

+ MetricsHandler metrics.Handler

+ NamespaceRegistry namespace.Registry

May 31, 2024

Changes in this version

+ const RequestTimeout

+ var Module = fx.Module("component.callbacks", fx.Provide(ConfigProvider), ...)

+ var StateMachineType = hsm.MachineType

+ var TaskTypeBackoff = hsm.TaskType

+ var TaskTypeInvocation = hsm.TaskType

+ var TransitionAttemptFailed = hsm.NewTransition([]enumspb.CallbackState{ ... }, enumspb.CALLBACK_STATE_BACKING_OFF, ...)

+ var TransitionFailed = hsm.NewTransition([]enumspb.CallbackState{ ... }, enumspb.CALLBACK_STATE_FAILED, ...)

+ var TransitionRescheduled = hsm.NewTransition([]enumspb.CallbackState{ ... }, enumspb.CALLBACK_STATE_SCHEDULED, ...)

+ var TransitionScheduled = hsm.NewTransition([]enumspb.CallbackState{ ... }, enumspb.CALLBACK_STATE_SCHEDULED, ...)

+ var TransitionSucceeded = hsm.NewTransition([]enumspb.CallbackState{ ... }, enumspb.CALLBACK_STATE_SUCCEEDED, ...)

+ func MachineCollection(tree *hsm.Node) hsm.Collection[Callback]

+ func NewWorkflowClosedTrigger() *workflowpb.CallbackInfo_Trigger

+ func RegisterExecutor(registry *hsm.Registry, options ActiveExecutorOptions, config *Config) error

+ func RegisterStateMachine(r *hsm.Registry) error

+ func RegisterTaskSerializers(reg *hsm.Registry) error

+ type ActiveExecutorOptions struct

+ CallerProvider func(queues.NamespaceIDAndDestination) HTTPCaller

+ func CallbackExecutorOptionsProvider() ActiveExecutorOptions

+ type BackoffTask struct

+ Deadline time.Time

+ func (BackoffTask) Concurrent() bool

+ func (BackoffTask) Type() hsm.TaskType

+ func (t BackoffTask) Kind() hsm.TaskKind

+ type BackoffTaskSerializer struct

+ func (BackoffTaskSerializer) Deserialize(data []byte, kind hsm.TaskKind) (hsm.Task, error)

+ func (BackoffTaskSerializer) Serialize(hsm.Task) ([]byte, error)

+ type Callback struct

+ func NewCallback(registrationTime *timestamppb.Timestamp, ...) Callback

+ func (c Callback) RegenerateTasks(*hsm.Node) ([]hsm.Task, error)

+ func (c Callback) SetState(state enumspb.CallbackState)

+ func (c Callback) State() enumspb.CallbackState

+ type CanGetNexusCompletion interface

+ GetNexusCompletion func(ctx context.Context) (nexus.OperationCompletion, error)

+ type Config struct

+ RequestTimeout dynamicconfig.DurationPropertyFn

+ func ConfigProvider(dc *dynamicconfig.Collection) *Config

+ type EventAttemptFailed struct

+ Err error

+ Time time.Time

+ type EventFailed struct

+ Err error

+ Time time.Time

+ type EventRescheduled struct

+ type EventScheduled struct

+ type EventSucceeded struct

+ Time time.Time

+ type HTTPCaller func(*http.Request) (*http.Response, error)

+ type InvocationTask struct

+ Destination string

+ func (InvocationTask) Concurrent() bool

+ func (InvocationTask) Type() hsm.TaskType

+ func (t InvocationTask) Kind() hsm.TaskKind

+ type InvocationTaskSerializer struct

+ func (InvocationTaskSerializer) Deserialize(data []byte, kind hsm.TaskKind) (hsm.Task, error)

+ func (InvocationTaskSerializer) Serialize(hsm.Task) ([]byte, error)