temporal_runtime

package
v0.1.17 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 20, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewTemporalConversationPersistenceProxy 

func NewTemporalConversationPersistenceProxy(workflowCtx workflow.Context, prefix string) history.ConversationPersistenceAdapter

func NewTemporalConversationSummarizerProxy 

func NewTemporalConversationSummarizerProxy(workflowCtx workflow.Context, prefix string) core.HistorySummarizer

func NewTemporalLLMProxy 

func NewTemporalLLMProxy(workflowCtx workflow.Context, prefix string, broker core.StreamBroker) agents.LLM

func NewTemporalPromptProxy 

func NewTemporalPromptProxy(workflowCtx workflow.Context, prefix string) core.SystemPromptProvider

func NewTemporalToolProxy 

func NewTemporalToolProxy(workflowCtx workflow.Context, prefix string, wrappedTool core.Tool) core.Tool

Types

type TemporalAgentV2 

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

func NewTemporalAgent 

func NewTemporalAgent(options *agents.AgentOptions, broker core.StreamBroker) *TemporalAgentV2

func (*TemporalAgentV2) Execute 

func (a *TemporalAgentV2) Execute(ctx workflow.Context, in *agents.AgentInput) (*agents.AgentOutput, error)

func (*TemporalAgentV2) GetActivities 

func (a *TemporalAgentV2) GetActivities() map[string]interface{}

type TemporalConversationPersistenceProxy 

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

func (*TemporalConversationPersistenceProxy) LoadMessages 

func (t *TemporalConversationPersistenceProxy) LoadMessages(ctx context.Context, namespace string, previousMessageID string) ([]conversation.ConversationMessage, error)

func (*TemporalConversationPersistenceProxy) NewRunID 

func (t *TemporalConversationPersistenceProxy) NewRunID(ctx context.Context) string

func (*TemporalConversationPersistenceProxy) SaveMessages 

func (t *TemporalConversationPersistenceProxy) SaveMessages(ctx context.Context, namespace, msgId, previousMsgId, conversationId string, messages []responses.InputMessageUnion, meta map[string]any) error

func (*TemporalConversationPersistenceProxy) SaveSummary 

func (t *TemporalConversationPersistenceProxy) SaveSummary(ctx context.Context, namespace string, summary conversation.Summary) error

type TemporalConversationSummarizer 

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

func NewTemporalConversationSummarizer 

func NewTemporalConversationSummarizer(wrappedSummarizer core.HistorySummarizer) *TemporalConversationSummarizer

func (*TemporalConversationSummarizer) Summarize 

func (t *TemporalConversationSummarizer) Summarize(ctx context.Context, msgIdToRunId map[string]string, messages []responses.InputMessageUnion, usage *responses.Usage) (*core.SummaryResult, error)

type TemporalConversationSummarizerProxy 

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

func (*TemporalConversationSummarizerProxy) Summarize 

func (t *TemporalConversationSummarizerProxy) Summarize(ctx context.Context, msgIdToRunId map[string]string, messages []responses.InputMessageUnion, usage *responses.Usage) (*core.SummaryResult, error)

type TemporalHistory 

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

func NewTemporalConversationPersistence 

func NewTemporalConversationPersistence(wrappedPersistence history.ConversationPersistenceAdapter) *TemporalHistory

func (*TemporalHistory) LoadMessages 

func (t *TemporalHistory) LoadMessages(ctx context.Context, namespace string, previousMessageID string) ([]conversation.ConversationMessage, error)

func (*TemporalHistory) SaveMessages 

func (t *TemporalHistory) SaveMessages(ctx context.Context, namespace, msgId, previousMsgId, conversationId string, messages []responses.InputMessageUnion, meta map[string]any) error

func (*TemporalHistory) SaveSummary 

func (t *TemporalHistory) SaveSummary(ctx context.Context, namespace string, summary conversation.Summary) error

type TemporalLLM 

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

func NewTemporalLLM 

func NewTemporalLLM(wrappedLLM llm.Provider, broker core.StreamBroker) *TemporalLLM

func (*TemporalLLM) NewStreamingResponsesActivity 

func (l *TemporalLLM) NewStreamingResponsesActivity(ctx context.Context, in *responses.Request) (*responses.Response, error)

type TemporalLLMProxy 

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

func (*TemporalLLMProxy) NewStreamingResponses 

func (l *TemporalLLMProxy) NewStreamingResponses(ctx context.Context, in *responses.Request, cb func(chunk *responses.ResponseChunk)) (*responses.Response, error)

type TemporalMCPProxy 

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

func NewTemporalMCPProxy 

func NewTemporalMCPProxy(workflowCtx workflow.Context, prefix string) *TemporalMCPProxy

func (*TemporalMCPProxy) GetName 

func (t *TemporalMCPProxy) GetName() string

func (*TemporalMCPProxy) ListTools 

func (t *TemporalMCPProxy) ListTools(ctx context.Context, runContext map[string]any) ([]core.Tool, error)

type TemporalMCPServer 

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

func NewTemporalMCPServer 

func NewTemporalMCPServer(wrappedMcpServer agents.MCPToolset) *TemporalMCPServer

func (*TemporalMCPServer) ExecuteTool 

func (t *TemporalMCPServer) ExecuteTool(ctx context.Context, params *responses.FunctionCallMessage, runContext map[string]any) (*responses.FunctionCallOutputMessage, error)

func (*TemporalMCPServer) ListTools 

func (t *TemporalMCPServer) ListTools(ctx context.Context, runContext map[string]any) ([]core.BaseTool, error)

type TemporalMCPToolProxy 

type TemporalMCPToolProxy struct {
	*core.BaseTool
	// contains filtered or unexported fields
}

func NewTemporalMCPToolProxy 

func NewTemporalMCPToolProxy(workflowCtx workflow.Context, prefix string, runContext map[string]any, baseTool core.BaseTool) *TemporalMCPToolProxy

func (*TemporalMCPToolProxy) Execute 

func (t *TemporalMCPToolProxy) Execute(ctx context.Context, params *responses.FunctionCallMessage) (*responses.FunctionCallOutputMessage, error)

type TemporalPrompt 

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

func NewTemporalPrompt 

func NewTemporalPrompt(wrappedPrompt core.SystemPromptProvider) *TemporalPrompt

func (*TemporalPrompt) GetPrompt 

func (p *TemporalPrompt) GetPrompt(ctx context.Context, data map[string]any) (string, error)

type TemporalPromptProxy 

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

func (*TemporalPromptProxy) GetPrompt 

func (p *TemporalPromptProxy) GetPrompt(ctx context.Context, data map[string]any) (string, error)

type TemporalRuntime 

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

func NewTemporalRuntime 

func NewTemporalRuntime(endpoint string, broker core.StreamBroker) *TemporalRuntime

func (*TemporalRuntime) Run 

func (r *TemporalRuntime) Run(ctx context.Context, agent *agents.Agent, in *agents.AgentInput) (*agents.AgentOutput, error)

type TemporalTool 

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

func NewTemporalTool 

func NewTemporalTool(wrappedTool core.Tool) *TemporalTool

func (*TemporalTool) Execute 

func (t *TemporalTool) Execute(ctx context.Context, params *responses.FunctionCallMessage) (*responses.FunctionCallOutputMessage, error)

type TemporalToolProxy 

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

func (*TemporalToolProxy) Execute 

func (t *TemporalToolProxy) Execute(ctx context.Context, params *responses.FunctionCallMessage) (*responses.FunctionCallOutputMessage, error)

func (*TemporalToolProxy) NeedApproval 

func (t *TemporalToolProxy) NeedApproval() bool

func (*TemporalToolProxy) Tool 

func (t *TemporalToolProxy) Tool(ctx context.Context) *responses.ToolUnion

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.