options

type AttachOption interface {
	BeforeAttach(*AttachOptions)
}

type AttachOptions struct {
	Codec encoding.Codec
}

type AwakeableOption interface {
	BeforeAwakeable(*AwakeableOptions)
}

type AwakeableOptions struct {
	Codec encoding.Codec
}

type ClientOption interface {
	BeforeClient(*ClientOptions)
}

type ClientOptions struct {
	InputCodec  encoding.Codec
	OutputCodec encoding.Codec
	Scope       string
}

type GetOption interface {
	BeforeGet(*GetOptions)
}

type GetOptions struct {
	Codec encoding.Codec
}

type HandlerOption interface {
	BeforeHandler(*HandlerOptions)
}

type HandlerOptions struct {
	InputCodec            encoding.Codec
	OutputCodec           encoding.Codec
	Metadata              map[string]string
	Documentation         string
	AbortTimeout          *time.Duration
	EnableLazyState       *bool
	IdempotencyRetention  *time.Duration
	InactivityTimeout     *time.Duration
	IngressPrivate        *bool
	JournalRetention      *time.Duration
	WorkflowRetention     *time.Duration
	InvocationRetryPolicy *InvocationRetryPolicy
}

type IngressClientOption interface {
	BeforeIngress(*IngressClientOptions)
}

type IngressClientOptions struct {
	HttpClient *http.Client
	AuthKey    string
	Codec      encoding.Codec
}

type IngressInvocationHandleOption interface {
	BeforeIngressInvocationHandle(*IngressInvocationHandleOptions)
}

type IngressInvocationHandleOptions struct {
	Codec encoding.Codec
}

type IngressRequestOption interface {
	BeforeIngressRequest(*IngressRequestOptions)
}

type IngressRequestOptions struct {
	RequestOptions
	InputCodec  encoding.Codec
	OutputCodec encoding.Codec
}

type IngressSendOption interface {
	BeforeIngressSend(*IngressSendOptions)
}

type IngressSendOptions struct {
	SendOptions
	Codec encoding.Codec
}

type InvocationRetryPolicy struct {
	InitialInterval      *time.Duration
	ExponentiationFactor *float64
	MaxInterval          *time.Duration
	MaxAttempts          *int
	OnMaxAttempts        *OnMaxAttempts
}

type InvocationRetryPolicyOption interface {
	BeforeRetryPolicy(*InvocationRetryPolicy)
}

type OnMaxAttempts string

type PromiseOption interface {
	BeforePromise(*PromiseOptions)
}

type PromiseOptions struct {
	Codec encoding.Codec
}

type RequestOption interface {
	BeforeRequest(*RequestOptions)
}

type RequestOptions struct {
	IdempotencyKey string
	Headers        map[string]string
	Scope          string
	LimitKey       string
}

type ResolveAwakeableOption interface {
	BeforeResolveAwakeable(*ResolveAwakeableOptions)
}

type ResolveAwakeableOptions struct {
	Codec encoding.Codec
}

type ResolveSignalOption interface {
	BeforeResolveSignal(*ResolveSignalOptions)
}

type ResolveSignalOptions struct {
	Codec encoding.Codec
}

type RunOption interface {
	BeforeRun(*RunOptions)
}

type RunOptions struct {
	// MaxRetryAttempts (including the initial attempt) before giving up.
	//
	// When giving up, Run will return a TerminalError wrapping the original error message.
	MaxRetryAttempts *uint

	// MaxRetryDuration before giving up.
	//
	// When giving up, Run will return a TerminalError wrapping the original error message.
	MaxRetryDuration *time.Duration

	// InitialRetryInterval for the first retry attempt.
	//
	// The retry interval will grow by a factor specified in RetryIntervalFactor.
	//
	// If any of the other retry options are set, this will be set by default to 50 milliseconds.
	InitialRetryInterval *time.Duration

	// RetryIntervalFactor to use when computing the next retry delay.
	//
	// If any of the other retry options are set, this will be set by default to 2, meaning retry interval will double at each attempt.
	RetryIntervalFactor *float32

	// MaxRetryInterval between retries.
	// Retry interval will grow by a factor specified in RetryIntervalFactor up to the interval specified in this value.
	//
	// If any of the other retry options are set, this will be set by default to 2 seconds.
	MaxRetryInterval *time.Duration

	// Name used for observability.
	Name string

	// Codec used to encode/decode the run result.
	Codec encoding.Codec
}

type SendOption interface {
	BeforeSend(*SendOptions)
}

type SendOptions struct {
	IdempotencyKey string
	Headers        map[string]string
	Delay          time.Duration
	Scope          string
	LimitKey       string
}

type ServiceDefinitionOption interface {
	BeforeServiceDefinition(*ServiceDefinitionOptions)
}

type ServiceDefinitionOptions struct {
	DefaultCodec          encoding.Codec
	Metadata              map[string]string
	Documentation         string
	AbortTimeout          *time.Duration
	EnableLazyState       *bool
	IdempotencyRetention  *time.Duration
	WorkflowRetention     *time.Duration
	InactivityTimeout     *time.Duration
	IngressPrivate        *bool
	JournalRetention      *time.Duration
	InvocationRetryPolicy *InvocationRetryPolicy
}

type SetOption interface {
	BeforeSet(*SetOptions)
}

type SetOptions struct {
	Codec encoding.Codec
}

type SignalOption interface {
	BeforeSignal(*SignalOptions)
}

type SignalOptions struct {
	Codec encoding.Codec
}

type SleepOption interface {
	BeforeSleep(*SleepOptions)
}

type SleepOptions struct {
	// Name used for observability.
	Name string
}