temporal

type ArtifactStoreBackend string

type ArtifactStoreConfig struct {
	Backend ArtifactStoreBackend
	Local   LocalArtifactStoreConfig
	S3      S3ArtifactStoreConfig
}

type EvaluatePlanExpansionOutput struct {
	Expanded           bool
	Delta              agentosplan.PlanDelta
	Spec               agentos.RunPlanSpec
	Plan               agentosplan.ExecutablePlan
	ControlsByNode     map[string][]agentoscore.ControlOperation
	CapabilitiesByNode map[string]agentosplan.CapabilitySelectionTrace
}

type ExternalBackendConfig struct {
	Name         string
	TaskQueue    string
	WorkflowType string
	QueryType    string
	Signals      ExternalSignalNames
}

type ExternalSignalNames struct {
	Pause    string
	Resume   string
	Cancel   string
	Defaults map[agentoscore.SignalType]string
}

type GRPCBackendConfig struct {
	Name      string
	Target    string
	Authority string
	Insecure  bool
	Service   string
	Methods   GRPCMethodNames
}

type GRPCMethodNames struct {
	Start   string
	Signal  string
	Control string
	Status  string
}

type HTTPBackendConfig struct {
	Name     string
	Endpoint string
	Headers  map[string]string
}

type LocalArtifactStoreConfig struct {
	Root string
}

type PersistPlanStateOutput struct {
	Event agentos.PlanEvent
}

type PlanActivities struct {
	Runtime             agentos.Runtime
	PlanNodeStarter     PlanNodeStarter
	Validator           agentosplan.Validator
	PlanTransitionStore agentosplan.PlanTransitionStore
	PlanEventPublisher  agentosplan.PlanEventPublisher
	ArtifactStore       agentosplan.ArtifactStore
	ArtifactSchemas     agentosplan.ArtifactSchemaCatalog
	PlanDeltaProvider   agentosplan.PlanDeltaProvider
	Expressions         agentosplan.ValueExpressionCompiler
}

type PlanCommandRecoverer interface {
	RecoverPlanCommands(ctx context.Context, limit int) (PlanCommandRecoveryResult, error)
}

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

type PlanCommandRecoveryLoopConfig struct {
	Interval           time.Duration
	Limit              int
	RecoverImmediately bool
}

type PlanCommandRecoveryObserver interface {
	PlanCommandRecoverySucceeded(PlanCommandRecoveryResult)
	PlanCommandRecoveryFailed(error)
}

type PlanCommandRecoveryResult struct {
	Scanned   int
	Delivered int
	Failed    int
}

type PlanNodeStarter interface {
	StartPlanNode(ctx context.Context, planID, nodeID string, spec *agentos.RunSpec) (agentos.RunStatus, error)
}

type ProcessActivities struct {
	Runtime *agentosprocess.Runtime
}

type PublishPlanArtifactsOutput struct {
	Artifacts []agentoscore.ArtifactRef
}

type ResolvePlanNodeInputOutput struct {
	Input map[string]any
	Trace agentosplan.InputResolutionTrace
}

type RunBackendIndex = agentosruntime.RunBackendIndex

type RunBackendSelector interface {
	Select(ctx context.Context, spec *agentos.RunSpec) (agentos.BackendRef, error)
}

type RuntimeConfig struct {
	TemporalAddress          string
	TemporalNamespace        string
	TemporalTaskQueues       TaskQueues
	PostgresURL              string
	PostgresPoolMax          int
	RedisURL                 string
	ArtifactStore            ArtifactStoreConfig
	TemporalExternalBackends []ExternalBackendConfig
	HTTPBackends             []HTTPBackendConfig
	GRPCBackends             []GRPCBackendConfig
}

type RuntimeOption func(*runtimeOptions)

type S3ArtifactStoreConfig struct {
	Bucket          string
	Region          string
	Endpoint        string
	AccessKeyID     string
	SecretAccessKey string
	SessionToken    string
	ForcePathStyle  bool
}

type StartPlanNodeOutput struct {
	Status agentos.RunStatus
}

type StatusPlanNodeOutput struct {
	Status agentos.RunStatus
}

type TaskQueues struct {
	PlanControl     string
	PlanActivity    string
	ProcessControl  string
	ProcessActivity string
	NativeControl   string
	NativeLLM       string
	NativeTool      string
	Stream          string
	Trigger         string
}

type ValidatePlanOutput struct {
	Plan               agentosplan.ExecutablePlan
	ControlsByNode     map[string][]agentoscore.ControlOperation
	CapabilitiesByNode map[string]agentosplan.CapabilitySelectionTrace
}

type WorkerConfig struct {
	TemporalAddress    string
	TemporalNamespace  string
	TemporalTaskQueues TaskQueues
	PostgresURL        string
	PostgresPoolMax    int
	RedisURL           string
	LLMConfigPath      string
	LogLevel           string
	ArtifactStore      ArtifactStoreConfig

	TemporalExternalBackends []ExternalBackendConfig
	HTTPBackends             []HTTPBackendConfig
	GRPCBackends             []GRPCBackendConfig
	Capabilities             []agentos.Capability
	ArtifactSchemas          []agentos.ArtifactSchema

	RegisterEnvTools      bool
	EnsureDefaultTemplate bool
}

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

type WorkerSet struct {
	PlanControl     worker.Worker
	PlanActivity    worker.Worker
	ProcessControl  worker.Worker
	ProcessActivity worker.Worker
	NativeControl   worker.Worker
	NativeLLM       worker.Worker
	NativeTool      worker.Worker
	Stream          worker.Worker
	Trigger         worker.Worker
}