temporal

package

Go to main page

Versions in this module

v0

v0.1.7

Apr 30, 2026

Changes in this version

type AgentFingerprintPayload

+ AgentToolExecutionMode string

type Option

+ func WithAgentToolExecutionMode(mode types.AgentToolExecutionMode) Option

type TemporalRuntimeConfig

+ AgentToolExecutionMode types.AgentToolExecutionMode

v0.1.6

Apr 28, 2026

Changes in this version

type AgentEventUpdate

+ EventJSON json.RawMessage

type AgentLLMInput

+ AgentName string

+ EventTaskQueue string

+ EventWorkflowID string

+ LocalChannelName string

+ MessageID string

type AgentToolApprovalInput

+ AgentName string

type Option

+ func WithDisableFingerprintCheck(disable bool) Option

type SendAgentEventActivityInput

+ EventType events.AgentEventType

type TemporalRuntimeConfig

+ DisableFingerprintCheck bool

v0.1.4

Apr 25, 2026

Changes in this version

type AgentToolApprovalInput

+ ToolDisplayName string

type ToolCallRequest

+ ToolDisplayName string

v0.1.3

Apr 19, 2026

Changes in this version

type AgentFingerprintPayload

+ AgentMode string

+ type AgentToolAuthorizeInput struct

+ AgentFingerprint string

+ Args map[string]any

+ ToolCallID string

+ ToolName string

+ type AgentToolAuthorizeResult struct

+ Allowed bool

+ Reason string

type Option

+ func WithAgentMode(mode string) Option

+ func WithDisableLocalWorker(disable bool) Option

type TemporalRuntime

+ func (rt *TemporalRuntime) AgentToolAuthorizeActivity(ctx context.Context, input AgentToolAuthorizeInput) (AgentToolAuthorizeResult, error)

type TemporalRuntimeConfig

+ AgentMode string

+ DisableLocalWorker bool

v0.1.2

Apr 13, 2026

Changes in this version

type AgentFingerprintPayload

+ MCPFingerprint string

type Option

+ func WithMCPFingerprint(fp string) Option

type TemporalRuntimeConfig

+ MCPFingerprint string

v0.1.1

Apr 8, 2026

Changes in this version

type AgentLLMStreamInput

+ EventTaskQueue string

type AgentToolApprovalInput

+ EventTaskQueue string

type AgentWorkflowInput

+ EventTaskQueue string

+ type SendAgentEventActivityInput struct

+ EventTaskQueue string

+ EventWorkflowID string

+ Update *AgentEventUpdate

+ type SendAgentEventResult struct

+ StreamUnavailable bool

v0.1.0

Apr 6, 2026

v0.0.10

Apr 5, 2026

Changes in this version

+ var ErrAgentAlreadyRunning = errors.New("agent already has an active run")

+ var ErrAgentFingerprintMismatch = errors.New(...)

+ func ComputeAgentFingerprint(m AgentFingerprintPayload) string

+ func NewLogAdapter(l logger.Logger) tlog.Logger

+ func ToolNamesFromTools(tools []interfaces.Tool) []string

+ type AddConversationMessagesInput struct

+ AgentFingerprint string

+ ConversationID string

+ Messages []interfaces.Message

+ type AgentEventUpdate struct

+ AgentName string

+ Event *types.AgentEvent

+ LocalChannelName string

+ type AgentFingerprintPayload struct

+ ApprovalTimeoutNs int64

+ Description string

+ MaxIterations int

+ Name string

+ PolicyFingerprint string

+ ResponseFormat ...

+ Sampling *sdkruntime.LLMSampling

+ SessionSize int

+ SystemPrompt string

+ TimeoutNs int64

+ ToolNames []string

+ Version int

+ func BuildAgentFingerprintPayload(spec sdkruntime.AgentSpec, toolNames []string, policyFingerprint string, ...) AgentFingerprintPayload

+ type AgentLLMInput struct

+ AgentFingerprint string

+ ConversationID string

+ Messages []interfaces.Message

+ SkipTools bool

+ type AgentLLMResult struct

+ Content string

+ ToolCalls []ToolCallRequest

+ Usage *interfaces.LLMUsage

+ type AgentLLMStreamInput struct

+ AgentFingerprint string

+ AgentName string

+ ConversationID string

+ EventWorkflowID string

+ LocalChannelName string

+ Messages []interfaces.Message

+ SkipTools bool

+ type AgentToolApprovalInput struct

+ AgentFingerprint string

+ Args map[string]any

+ EventWorkflowID string

+ LocalChannelName string

+ SubAgentName string

+ ToolCallID string

+ ToolName string

+ type AgentToolExecuteInput struct

+ AgentFingerprint string

+ Args map[string]any

+ ConversationID string

+ Messages []interfaces.Message

+ ToolCallID string

+ ToolName string

+ type AgentWorkflowInput struct

+ AgentFingerprint string

+ ConversationID string

+ EventTypes []types.AgentEventType

+ EventWorkflowID string

+ LocalChannelName string

+ MaxSubAgentDepth int

+ StreamingEnabled bool

+ SubAgentDepth int

+ SubAgentRoutes map[string]types.SubAgentRoute

+ UserPrompt string

+ type Option func(*TemporalRuntimeConfig)

+ func WithAgentExecution(exec sdkruntime.AgentExecution) Option

+ func WithAgentSpec(spec sdkruntime.AgentSpec) Option

+ func WithEnableRemoteWorkers(enableRemoteWorkers bool) Option

+ func WithInstanceId(instanceId string) Option

+ func WithLogger(logger logger.Logger) Option

+ func WithPolicyFingerprint(fp string) Option

+ func WithRemoteWorker(remoteWorker bool) Option

+ func WithTemporalClient(client client.Client, taskQueue string) Option

+ func WithTemporalConfig(config *TemporalConfig) Option

+ type TemporalConfig struct

+ Host string

+ Namespace string

+ Port int

+ TaskQueue string

+ type TemporalRuntime struct

+ func NewTemporalRuntime(opts ...Option) (*TemporalRuntime, error)

+ func (rt *TemporalRuntime) AddConversationMessagesActivity(ctx context.Context, input AddConversationMessagesInput) error

+ func (rt *TemporalRuntime) AgentEventWorkflow(ctx workflow.Context) error

+ func (rt *TemporalRuntime) AgentLLMActivity(ctx context.Context, input AgentLLMInput) (*AgentLLMResult, error)

+ func (rt *TemporalRuntime) AgentLLMStreamActivity(ctx context.Context, input AgentLLMStreamInput) (*AgentLLMResult, error)

+ func (rt *TemporalRuntime) AgentToolApprovalActivity(ctx context.Context, input AgentToolApprovalInput) (types.ApprovalStatus, error)

+ func (rt *TemporalRuntime) AgentToolExecuteActivity(ctx context.Context, input AgentToolExecuteInput) (string, error)

+ func (rt *TemporalRuntime) AgentWorkflow(ctx workflow.Context, input AgentWorkflowInput) (*types.AgentResponse, error)

+ func (rt *TemporalRuntime) Approve(ctx context.Context, approvalToken string, status types.ApprovalStatus) error

+ func (rt *TemporalRuntime) Close()

+ func (rt *TemporalRuntime) EventPublishActivity(ctx context.Context, channel string, event *types.AgentEvent) error

+ func (rt *TemporalRuntime) Execute(ctx context.Context, req *runtime.ExecuteRequest) (*types.AgentResponse, error)

+ func (rt *TemporalRuntime) ExecuteStream(ctx context.Context, req *runtime.ExecuteRequest) (chan *types.AgentEvent, error)

+ func (rt *TemporalRuntime) GetEventBus() eventbus.EventBus

+ func (rt *TemporalRuntime) OnApproval(ctx context.Context, approvalToken string, status types.ApprovalStatus) error

+ func (rt *TemporalRuntime) SendAgentEventUpdateActivity(ctx context.Context, eventWorkflowID string, upd *AgentEventUpdate) error

+ func (rt *TemporalRuntime) SetEventBus(eventbus eventbus.EventBus)

+ func (rt *TemporalRuntime) Start(ctx context.Context) error

+ func (rt *TemporalRuntime) Stop()

+ type TemporalRuntimeConfig struct

+ AgentExecution sdkruntime.AgentExecution

+ AgentSpec sdkruntime.AgentSpec

+ PolicyFingerprint string

+ type ToolCallRequest struct

+ Args map[string]any

+ NeedsApproval bool

+ ToolCallID string

+ ToolName string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL