actors

type ActivityAction[S any] struct {
	// contains filtered or unexported fields
}

type ActivityCallOption func(*ActivityCallOptions)

type ActivityCallOptions struct {
	ScheduleToClose time.Duration
	ScheduleToStart time.Duration
	StartToClose    time.Duration
	Heartbeat       time.Duration
	Retry           RetryPolicy
	TaskQueue       string
}

type ActivityFunc func(context.Context, any) (any, error)

type ActivityFuture interface {
	Get() (any, error)
}

type ActivityMetadata struct {
	Name            string
	RequestType     string
	ResponseType    string
	ScheduleToClose time.Duration
	ScheduleToStart time.Duration
	StartToClose    time.Duration
	Heartbeat       time.Duration
	TaskQueue       string
	Retry           RetryPolicy
}

type ActivityMsg[Resp any] struct{}

type ActivityOption[S any] func(*ActivityAction[S])

type ActivitySpec struct {
	Handler ActivityFunc
	Options ActivityCallOptions
}

type Actor interface {
	Kind() string
	Spec() *Description
}

type ActorMetadata struct {
	Kind           string
	VersionTag     string
	WorkflowQueue  string
	ActivityQueue  string
	DefaultTimeout time.Duration
	DefaultRetry   RetryPolicy
	SnapshotEvery  int
	Start          StartMetadata
	Commands       []CommandMetadata
	Queries        []QueryMetadata
	Activities     []ActivityMetadata
	Patches        []PatchMetadata
	CommandTypes   map[string]string
	QueryTypes     map[string]string
	ActivityTypes  map[string]string
}

type AskOption func(*AskOptions)

type AskOptions struct {
	CorrelationID string
}

type ClientInvoker interface {
	InvokeCommand(ctx context.Context, ref Ref, method string, payload any) error
	InvokeAsk(ctx context.Context, ref Ref, method string, payload any, resp any, opts AskOptions) error
	InvokeQuery(ctx context.Context, ref Ref, method string, payload any, resp any) error
}

type CommandAction[S any] struct {
	// contains filtered or unexported fields
}

type CommandHandler struct {
	Name  string
	Input string
	// contains filtered or unexported fields
}

type CommandMetadata struct {
	Name          string
	RequestType   string
	ResponseType  string
	Timeout       time.Duration
	SignalTimeout time.Duration
	Retry         RetryPolicy
	HasValidator  bool
}

type CommandMsg[Resp any] struct{}

type CommandOption func(*commandOptions)

type CommandSpec struct {
	Handler        CommandHandler
	Timeout        time.Duration
	Retry          RetryPolicy
	ResponseType   string
	PayloadFactory func() any
	DecodePayload  func(any) (any, error)
	Validator      func(any) error
}

type ContinueAsNewOption func(*ContinueAsNewOptions)

type ContinueAsNewOptions struct {
	Init any
}

type CorrelationData struct {
	SagaID     string
	TraceID    string
	ParentID   string
	Attributes map[string]string
}

type Ctx interface {
	ActorID() string
	Now() time.Time
	Sleep(delay time.Duration) error
	Version(changeID string, defaultVersion, newVersion int) int
	Activity(name string, payload any) ActivityFuture
	ActivityWithOptions(name string, payload any, opts ActivityCallOptions) ActivityFuture
	BackgroundActivity(name string, payload any)
	Logger() Logger
	Self() Ref
	UpsertSearchAttributes(attrs map[string]any) error
	SearchAttributes() map[string]any
	MessageMetadata() MessageMetadata
	Effect(key string, fn EffectFunc, opts ...EffectOption) (any, error)
	Correlation() CorrelationData
	SetCorrelation(CorrelationData)
	SnapshotInfo() SnapshotInfo
}

type Description struct {
	Kind           string
	VersionTag     string
	Timeout        time.Duration
	Retry          RetryPolicy
	SignalTimeouts map[string]time.Duration
	WorkflowQueue  string
	ActivityQueue  string
	StateFactory   func() any
	Start          StartHandler
	Commands       map[string]CommandSpec
	Queries        map[string]QuerySpec
	Activities     map[string]ActivitySpec

	ActivityTypes     map[string]string
	ActivityResults   map[string]string
	ActivityNames     map[string]string
	ActivityObservers []func(string, ActivityCallOptions)
	CommandTypes      map[string]string
	QueryTypes        map[string]string
	Patches           map[string]PatchSpec
	SnapshotEvery     int
	SnapshotArgs      func(any) (any, error)
	// contains filtered or unexported fields
}

type DescriptionManifest struct {
	Version int             `json:"version"`
	Hash    string          `json:"hash"`
	Actor   serializedActor `json:"actor"`
}

type DescriptionRegistry interface {
	RegisterActor(actor Actor)
	RegisterDescription(desc *Description)
	Unregister(kind string)
	Lookup(kind string) *Description
	List() []RegisteredActor
}

type EffectFunc func(Ctx) (any, error)

type EffectOption func(*EffectOptions)

type EffectOptions struct {
	TTL time.Duration
}

type Logger interface {
	Debug(msg string, kv ...any)
	Info(msg string, kv ...any)
	Warn(msg string, kv ...any)
	Error(msg string, kv ...any)
}

type MessageMetadata struct {
	// ID uniquely identifies the delivery attempt within the receiving workflow.
	ID string
	// CorrelationID links the delivery back to the caller; defaults to ID when unset.
	CorrelationID string
	// Correlation carries saga IDs or tracing spans that should propagate downstream.
	Correlation CorrelationData
	// Deadline is optional and represents the point after which the call is considered expired.
	Deadline time.Time
	// RetryBudget expresses how many retries remain from the caller's perspective.
	RetryBudget int
	// RetryBudgetSet reports whether RetryBudget should be enforced. When false, the
	// budget is treated as unlimited.
	RetryBudgetSet bool
	// Caller identifies who initiated the delivery if known.
	Caller Ref
}

type PatchMetadata struct {
	ID        string
	DefaultOn bool
	Note      string
}

type PatchReport struct {
	Kind    string
	Patches []PatchStatus
}

type PatchSpec struct {
	ID        string
	DefaultOn bool
	Note      string
}

type PatchStatus struct {
	ID        string
	DefaultOn bool
	Note      string
}

type QueryAction[S any] struct {
	// contains filtered or unexported fields
}

type QueryHandler struct {
	Name  string
	Input string
	// contains filtered or unexported fields
}

type QueryMetadata struct {
	Name         string
	RequestType  string
	ResponseType string
	CacheTTL     time.Duration
}

type QueryMsg[Resp any] struct{}

type QueryOption func(*queryOptions)

type QuerySpec struct {
	Handler        QueryHandler
	CacheTTL       time.Duration
	ResponseType   string
	PayloadFactory func() any
	DecodePayload  func(any) (any, error)
}

type Ref struct {
	Workflow     string
	Kind         string
	ID           string
	Tenant       string
	WorkflowType string
	TaskQueue    string
	RunID        string
	StartArgs    []any
}

type RefOption func(*Ref)

type RegisteredActor struct {
	Kind        string
	Description *Description
	Metadata    ActorMetadata
}

type RetryPolicy struct {
	MaxAttempts        int
	InitialInterval    time.Duration
	BackoffCoefficient float64
}

type Session struct {
	// contains filtered or unexported fields
}

type SessionOptions struct {
	CreationTimeout  time.Duration
	ExecutionTimeout time.Duration
	HeartbeatTimeout time.Duration
}

type SessionRuntime interface {
	InvokeSessionActivity(handle any, name string, payload any, opts ActivityCallOptions) (ActivityFuture, error)
	CompleteSessionHandle(handle any) error
}

type SnapshotConfig[S any] struct {
	Every        int
	ContinueArgs func(state S) (any, error)
}

type SnapshotInfo struct {
	Enabled               bool
	SnapshotEvery         int
	SnapshotsTaken        int
	ContinueAsNewCount    int
	CommandsSinceSnapshot int
	LastSnapshotTime      time.Time
}

type SnapshotReport struct {
	Kind     string
	Snapshot SnapshotInfo
}

type SpawnConfig struct {
	Kind      string
	Name      string
	Timeout   time.Duration
	TaskQueue string
}

type SpawnOption func(*SpawnConfig)

type StartAction[S any] struct {
	// contains filtered or unexported fields
}

type StartHandler struct {
	Input string
	// contains filtered or unexported fields
}

type StartMetadata struct {
	InputType string
}

type StatefulBuilder[S any] struct {
	// contains filtered or unexported fields
}

type StatelessBuilder struct {
	// contains filtered or unexported fields
}

type StopCommand struct {
	CommandMsg[struct{}]
}

type TypedActivityMessage[Resp any] interface {
	ActivityResponsePrototype() Resp
}

type TypedCommandMessage[Resp any] interface {
	CommandResponsePrototype() Resp
}

type TypedQueryMessage[Resp any] interface {
	QueryResponsePrototype() Resp
}