temporal_agent_builder

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: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewTemporalConversationSummarizerProxy 

func NewTemporalConversationSummarizerProxy(workflowCtx workflow.Context, projectID uuid.UUID, config *agent_config.HistoryConfig, key string) core.HistorySummarizer

func NewTemporalLLMProxy 

func NewTemporalLLMProxy(workflowCtx workflow.Context, config *agent_config.ModelConfig, key string) agents.LLM

Types

type AgentBuilder 

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

func NewAgentBuilder 

func NewAgentBuilder(svc *services.Services, llmGateway *gateway.LLMGateway, broker core.StreamBroker) *AgentBuilder

func (*AgentBuilder) BuildAndExecuteAgent 

func (b *AgentBuilder) BuildAndExecuteAgent(ctx workflow.Context, agentConfig *agent_config.AgentConfig, in *agents.AgentInput, key string) (*agents.AgentOutput, error)

func (*AgentBuilder) GetPrompt 

func (b *AgentBuilder) GetPrompt(ctx context.Context, projectID uuid.UUID, config *agent_config.PromptConfig, runContext map[string]any) (string, error)

func (*AgentBuilder) LLMCall 

func (b *AgentBuilder) LLMCall(ctx context.Context, config *agent_config.ModelConfig, in *responses.Request, key string) (*responses.Response, error)

func (*AgentBuilder) LoadMessages 

func (b *AgentBuilder) LoadMessages(ctx context.Context, projectID uuid.UUID, config *agent_config.HistoryConfig, namespace string, previousMessageId string) ([]conversation.ConversationMessage, error)

func (*AgentBuilder) MCPCallTool 

func (b *AgentBuilder) MCPCallTool(ctx context.Context, config *agent_config.MCPServerConfig, params *responses.FunctionCallMessage, runContext map[string]any) (*responses.FunctionCallOutputMessage, error)

func (*AgentBuilder) MCPListTools 

func (b *AgentBuilder) MCPListTools(ctx context.Context, config *agent_config.MCPServerConfig, runContext map[string]any) ([]core.BaseTool, error)

func (*AgentBuilder) SaveMessages 

func (b *AgentBuilder) SaveMessages(ctx context.Context, projectID uuid.UUID, config *agent_config.HistoryConfig, namespace, msgId, previousMsgId, conversationId string, messages []responses.InputMessageUnion, meta map[string]any) error

func (*AgentBuilder) SaveSummary 

func (b *AgentBuilder) SaveSummary(ctx context.Context, projectID uuid.UUID, config *agent_config.HistoryConfig, namespace string, summary conversation.Summary) error

func (*AgentBuilder) Summarize 

func (b *AgentBuilder) Summarize(ctx context.Context, projectID uuid.UUID, config *agent_config.HistoryConfig, msgIdToRunId map[string]string, messages []responses.InputMessageUnion, usage *responses.Usage, key string) (*core.SummaryResult, error)

type TemporalConversationPersistenceProxy 

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

func NewTemporalConversationPersistenceProxy 

func NewTemporalConversationPersistenceProxy(workflowCtx workflow.Context, projectID uuid.UUID, config *agent_config.HistoryConfig) *TemporalConversationPersistenceProxy

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 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 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, config *agent_config.MCPServerConfig) *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 TemporalMCPToolProxy 

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

func NewTemporalMCPToolProxy 

func NewTemporalMCPToolProxy(workflowCtx workflow.Context, config *agent_config.MCPServerConfig, 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 TemporalPromptProxy 

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

func NewTemporalPromptProxy 

func NewTemporalPromptProxy(workflowCtx workflow.Context, projectID uuid.UUID, config *agent_config.PromptConfig) *TemporalPromptProxy

func (*TemporalPromptProxy) GetPrompt 

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

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.