mocks

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Aug 5, 2025 License: MIT Imports: 11 Imported by: 0

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeA2AServer 

type FakeA2AServer struct {
	GetAgentStub func() server.OpenAICompatibleAgent

	GetAgentCardStub func() *types.AgentCard

	GetTaskHandlerStub func() server.TaskHandler

	LoadAgentCardFromFileStub func(string, map[string]interface{}) error

	SetAgentStub func(server.OpenAICompatibleAgent)

	SetAgentCardStub func(types.AgentCard)

	SetAgentDescriptionStub func(string)

	SetAgentNameStub func(string)

	SetAgentURLStub func(string)

	SetAgentVersionStub func(string)

	SetTaskHandlerStub func(server.TaskHandler)

	StartStub func(context.Context) error

	StartTaskProcessorStub func(context.Context)

	StopStub func(context.Context) error
	// contains filtered or unexported fields
}

func (*FakeA2AServer) GetAgent 

func (fake *FakeA2AServer) GetAgent() server.OpenAICompatibleAgent

func (*FakeA2AServer) GetAgentCallCount 

func (fake *FakeA2AServer) GetAgentCallCount() int

func (*FakeA2AServer) GetAgentCalls 

func (fake *FakeA2AServer) GetAgentCalls(stub func() server.OpenAICompatibleAgent)

func (*FakeA2AServer) GetAgentCard 

func (fake *FakeA2AServer) GetAgentCard() *types.AgentCard

func (*FakeA2AServer) GetAgentCardCallCount 

func (fake *FakeA2AServer) GetAgentCardCallCount() int

func (*FakeA2AServer) GetAgentCardCalls 

func (fake *FakeA2AServer) GetAgentCardCalls(stub func() *types.AgentCard)

func (*FakeA2AServer) GetAgentCardReturns 

func (fake *FakeA2AServer) GetAgentCardReturns(result1 *types.AgentCard)

func (*FakeA2AServer) GetAgentCardReturnsOnCall 

func (fake *FakeA2AServer) GetAgentCardReturnsOnCall(i int, result1 *types.AgentCard)

func (*FakeA2AServer) GetAgentReturns 

func (fake *FakeA2AServer) GetAgentReturns(result1 server.OpenAICompatibleAgent)

func (*FakeA2AServer) GetAgentReturnsOnCall 

func (fake *FakeA2AServer) GetAgentReturnsOnCall(i int, result1 server.OpenAICompatibleAgent)

func (*FakeA2AServer) GetTaskHandler 

func (fake *FakeA2AServer) GetTaskHandler() server.TaskHandler

func (*FakeA2AServer) GetTaskHandlerCallCount 

func (fake *FakeA2AServer) GetTaskHandlerCallCount() int

func (*FakeA2AServer) GetTaskHandlerCalls 

func (fake *FakeA2AServer) GetTaskHandlerCalls(stub func() server.TaskHandler)

func (*FakeA2AServer) GetTaskHandlerReturns 

func (fake *FakeA2AServer) GetTaskHandlerReturns(result1 server.TaskHandler)

func (*FakeA2AServer) GetTaskHandlerReturnsOnCall 

func (fake *FakeA2AServer) GetTaskHandlerReturnsOnCall(i int, result1 server.TaskHandler)

func (*FakeA2AServer) Invocations 

func (fake *FakeA2AServer) Invocations() map[string][][]interface{}

func (*FakeA2AServer) LoadAgentCardFromFile 

func (fake *FakeA2AServer) LoadAgentCardFromFile(arg1 string, arg2 map[string]interface{}) error

func (*FakeA2AServer) LoadAgentCardFromFileArgsForCall 

func (fake *FakeA2AServer) LoadAgentCardFromFileArgsForCall(i int) (string, map[string]interface{})

func (*FakeA2AServer) LoadAgentCardFromFileCallCount 

func (fake *FakeA2AServer) LoadAgentCardFromFileCallCount() int

func (*FakeA2AServer) LoadAgentCardFromFileCalls 

func (fake *FakeA2AServer) LoadAgentCardFromFileCalls(stub func(string, map[string]interface{}) error)

func (*FakeA2AServer) LoadAgentCardFromFileReturns 

func (fake *FakeA2AServer) LoadAgentCardFromFileReturns(result1 error)

func (*FakeA2AServer) LoadAgentCardFromFileReturnsOnCall 

func (fake *FakeA2AServer) LoadAgentCardFromFileReturnsOnCall(i int, result1 error)

func (*FakeA2AServer) SetAgent 

func (fake *FakeA2AServer) SetAgent(arg1 server.OpenAICompatibleAgent)

func (*FakeA2AServer) SetAgentArgsForCall 

func (fake *FakeA2AServer) SetAgentArgsForCall(i int) server.OpenAICompatibleAgent

func (*FakeA2AServer) SetAgentCallCount 

func (fake *FakeA2AServer) SetAgentCallCount() int

func (*FakeA2AServer) SetAgentCalls 

func (fake *FakeA2AServer) SetAgentCalls(stub func(server.OpenAICompatibleAgent))

func (*FakeA2AServer) SetAgentCard 

func (fake *FakeA2AServer) SetAgentCard(arg1 types.AgentCard)

func (*FakeA2AServer) SetAgentCardArgsForCall 

func (fake *FakeA2AServer) SetAgentCardArgsForCall(i int) types.AgentCard

func (*FakeA2AServer) SetAgentCardCallCount 

func (fake *FakeA2AServer) SetAgentCardCallCount() int

func (*FakeA2AServer) SetAgentCardCalls 

func (fake *FakeA2AServer) SetAgentCardCalls(stub func(types.AgentCard))

func (*FakeA2AServer) SetAgentDescription 

func (fake *FakeA2AServer) SetAgentDescription(arg1 string)

func (*FakeA2AServer) SetAgentDescriptionArgsForCall 

func (fake *FakeA2AServer) SetAgentDescriptionArgsForCall(i int) string

func (*FakeA2AServer) SetAgentDescriptionCallCount 

func (fake *FakeA2AServer) SetAgentDescriptionCallCount() int

func (*FakeA2AServer) SetAgentDescriptionCalls 

func (fake *FakeA2AServer) SetAgentDescriptionCalls(stub func(string))

func (*FakeA2AServer) SetAgentName 

func (fake *FakeA2AServer) SetAgentName(arg1 string)

func (*FakeA2AServer) SetAgentNameArgsForCall 

func (fake *FakeA2AServer) SetAgentNameArgsForCall(i int) string

func (*FakeA2AServer) SetAgentNameCallCount 

func (fake *FakeA2AServer) SetAgentNameCallCount() int

func (*FakeA2AServer) SetAgentNameCalls 

func (fake *FakeA2AServer) SetAgentNameCalls(stub func(string))

func (*FakeA2AServer) SetAgentURL 

func (fake *FakeA2AServer) SetAgentURL(arg1 string)

func (*FakeA2AServer) SetAgentURLArgsForCall 

func (fake *FakeA2AServer) SetAgentURLArgsForCall(i int) string

func (*FakeA2AServer) SetAgentURLCallCount 

func (fake *FakeA2AServer) SetAgentURLCallCount() int

func (*FakeA2AServer) SetAgentURLCalls 

func (fake *FakeA2AServer) SetAgentURLCalls(stub func(string))

func (*FakeA2AServer) SetAgentVersion 

func (fake *FakeA2AServer) SetAgentVersion(arg1 string)

func (*FakeA2AServer) SetAgentVersionArgsForCall 

func (fake *FakeA2AServer) SetAgentVersionArgsForCall(i int) string

func (*FakeA2AServer) SetAgentVersionCallCount 

func (fake *FakeA2AServer) SetAgentVersionCallCount() int

func (*FakeA2AServer) SetAgentVersionCalls 

func (fake *FakeA2AServer) SetAgentVersionCalls(stub func(string))

func (*FakeA2AServer) SetTaskHandler 

func (fake *FakeA2AServer) SetTaskHandler(arg1 server.TaskHandler)

func (*FakeA2AServer) SetTaskHandlerArgsForCall 

func (fake *FakeA2AServer) SetTaskHandlerArgsForCall(i int) server.TaskHandler

func (*FakeA2AServer) SetTaskHandlerCallCount 

func (fake *FakeA2AServer) SetTaskHandlerCallCount() int

func (*FakeA2AServer) SetTaskHandlerCalls 

func (fake *FakeA2AServer) SetTaskHandlerCalls(stub func(server.TaskHandler))

func (*FakeA2AServer) Start 

func (fake *FakeA2AServer) Start(arg1 context.Context) error

func (*FakeA2AServer) StartArgsForCall 

func (fake *FakeA2AServer) StartArgsForCall(i int) context.Context

func (*FakeA2AServer) StartCallCount 

func (fake *FakeA2AServer) StartCallCount() int

func (*FakeA2AServer) StartCalls 

func (fake *FakeA2AServer) StartCalls(stub func(context.Context) error)

func (*FakeA2AServer) StartReturns 

func (fake *FakeA2AServer) StartReturns(result1 error)

func (*FakeA2AServer) StartReturnsOnCall 

func (fake *FakeA2AServer) StartReturnsOnCall(i int, result1 error)

func (*FakeA2AServer) StartTaskProcessor 

func (fake *FakeA2AServer) StartTaskProcessor(arg1 context.Context)

func (*FakeA2AServer) StartTaskProcessorArgsForCall 

func (fake *FakeA2AServer) StartTaskProcessorArgsForCall(i int) context.Context

func (*FakeA2AServer) StartTaskProcessorCallCount 

func (fake *FakeA2AServer) StartTaskProcessorCallCount() int

func (*FakeA2AServer) StartTaskProcessorCalls 

func (fake *FakeA2AServer) StartTaskProcessorCalls(stub func(context.Context))

func (*FakeA2AServer) Stop 

func (fake *FakeA2AServer) Stop(arg1 context.Context) error

func (*FakeA2AServer) StopArgsForCall 

func (fake *FakeA2AServer) StopArgsForCall(i int) context.Context

func (*FakeA2AServer) StopCallCount 

func (fake *FakeA2AServer) StopCallCount() int

func (*FakeA2AServer) StopCalls 

func (fake *FakeA2AServer) StopCalls(stub func(context.Context) error)

func (*FakeA2AServer) StopReturns 

func (fake *FakeA2AServer) StopReturns(result1 error)

func (*FakeA2AServer) StopReturnsOnCall 

func (fake *FakeA2AServer) StopReturnsOnCall(i int, result1 error)

type FakeA2AServerBuilder 

type FakeA2AServerBuilder struct {
	BuildStub func() (server.A2AServer, error)

	WithAgentStub func(server.OpenAICompatibleAgent) server.A2AServerBuilder

	WithAgentCardStub func(types.AgentCard) server.A2AServerBuilder

	WithAgentCardFromFileStub func(string, map[string]interface{}) server.A2AServerBuilder

	WithLoggerStub func(*zap.Logger) server.A2AServerBuilder

	WithTaskHandlerStub func(server.TaskHandler) server.A2AServerBuilder

	WithTaskResultProcessorStub func(server.TaskResultProcessor) server.A2AServerBuilder
	// contains filtered or unexported fields
}

func (*FakeA2AServerBuilder) Build 

func (fake *FakeA2AServerBuilder) Build() (server.A2AServer, error)

func (*FakeA2AServerBuilder) BuildCallCount 

func (fake *FakeA2AServerBuilder) BuildCallCount() int

func (*FakeA2AServerBuilder) BuildCalls 

func (fake *FakeA2AServerBuilder) BuildCalls(stub func() (server.A2AServer, error))

func (*FakeA2AServerBuilder) BuildReturns 

func (fake *FakeA2AServerBuilder) BuildReturns(result1 server.A2AServer, result2 error)

func (*FakeA2AServerBuilder) BuildReturnsOnCall 

func (fake *FakeA2AServerBuilder) BuildReturnsOnCall(i int, result1 server.A2AServer, result2 error)

func (*FakeA2AServerBuilder) Invocations 

func (fake *FakeA2AServerBuilder) Invocations() map[string][][]interface{}

func (*FakeA2AServerBuilder) WithAgent 

func (fake *FakeA2AServerBuilder) WithAgent(arg1 server.OpenAICompatibleAgent) server.A2AServerBuilder

func (*FakeA2AServerBuilder) WithAgentArgsForCall 

func (fake *FakeA2AServerBuilder) WithAgentArgsForCall(i int) server.OpenAICompatibleAgent

func (*FakeA2AServerBuilder) WithAgentCallCount 

func (fake *FakeA2AServerBuilder) WithAgentCallCount() int

func (*FakeA2AServerBuilder) WithAgentCalls 

func (fake *FakeA2AServerBuilder) WithAgentCalls(stub func(server.OpenAICompatibleAgent) server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithAgentCard 

func (fake *FakeA2AServerBuilder) WithAgentCard(arg1 types.AgentCard) server.A2AServerBuilder

func (*FakeA2AServerBuilder) WithAgentCardArgsForCall 

func (fake *FakeA2AServerBuilder) WithAgentCardArgsForCall(i int) types.AgentCard

func (*FakeA2AServerBuilder) WithAgentCardCallCount 

func (fake *FakeA2AServerBuilder) WithAgentCardCallCount() int

func (*FakeA2AServerBuilder) WithAgentCardCalls 

func (fake *FakeA2AServerBuilder) WithAgentCardCalls(stub func(types.AgentCard) server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithAgentCardFromFile 

func (fake *FakeA2AServerBuilder) WithAgentCardFromFile(arg1 string, arg2 map[string]interface{}) server.A2AServerBuilder

func (*FakeA2AServerBuilder) WithAgentCardFromFileArgsForCall 

func (fake *FakeA2AServerBuilder) WithAgentCardFromFileArgsForCall(i int) (string, map[string]interface{})

func (*FakeA2AServerBuilder) WithAgentCardFromFileCallCount 

func (fake *FakeA2AServerBuilder) WithAgentCardFromFileCallCount() int

func (*FakeA2AServerBuilder) WithAgentCardFromFileCalls 

func (fake *FakeA2AServerBuilder) WithAgentCardFromFileCalls(stub func(string, map[string]interface{}) server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithAgentCardFromFileReturns 

func (fake *FakeA2AServerBuilder) WithAgentCardFromFileReturns(result1 server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithAgentCardFromFileReturnsOnCall 

func (fake *FakeA2AServerBuilder) WithAgentCardFromFileReturnsOnCall(i int, result1 server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithAgentCardReturns 

func (fake *FakeA2AServerBuilder) WithAgentCardReturns(result1 server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithAgentCardReturnsOnCall 

func (fake *FakeA2AServerBuilder) WithAgentCardReturnsOnCall(i int, result1 server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithAgentReturns 

func (fake *FakeA2AServerBuilder) WithAgentReturns(result1 server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithAgentReturnsOnCall 

func (fake *FakeA2AServerBuilder) WithAgentReturnsOnCall(i int, result1 server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithLogger 

func (fake *FakeA2AServerBuilder) WithLogger(arg1 *zap.Logger) server.A2AServerBuilder

func (*FakeA2AServerBuilder) WithLoggerArgsForCall 

func (fake *FakeA2AServerBuilder) WithLoggerArgsForCall(i int) *zap.Logger

func (*FakeA2AServerBuilder) WithLoggerCallCount 

func (fake *FakeA2AServerBuilder) WithLoggerCallCount() int

func (*FakeA2AServerBuilder) WithLoggerCalls 

func (fake *FakeA2AServerBuilder) WithLoggerCalls(stub func(*zap.Logger) server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithLoggerReturns 

func (fake *FakeA2AServerBuilder) WithLoggerReturns(result1 server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithLoggerReturnsOnCall 

func (fake *FakeA2AServerBuilder) WithLoggerReturnsOnCall(i int, result1 server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithTaskHandler 

func (fake *FakeA2AServerBuilder) WithTaskHandler(arg1 server.TaskHandler) server.A2AServerBuilder

func (*FakeA2AServerBuilder) WithTaskHandlerArgsForCall 

func (fake *FakeA2AServerBuilder) WithTaskHandlerArgsForCall(i int) server.TaskHandler

func (*FakeA2AServerBuilder) WithTaskHandlerCallCount 

func (fake *FakeA2AServerBuilder) WithTaskHandlerCallCount() int

func (*FakeA2AServerBuilder) WithTaskHandlerCalls 

func (fake *FakeA2AServerBuilder) WithTaskHandlerCalls(stub func(server.TaskHandler) server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithTaskHandlerReturns 

func (fake *FakeA2AServerBuilder) WithTaskHandlerReturns(result1 server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithTaskHandlerReturnsOnCall 

func (fake *FakeA2AServerBuilder) WithTaskHandlerReturnsOnCall(i int, result1 server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithTaskResultProcessor 

func (fake *FakeA2AServerBuilder) WithTaskResultProcessor(arg1 server.TaskResultProcessor) server.A2AServerBuilder

func (*FakeA2AServerBuilder) WithTaskResultProcessorArgsForCall 

func (fake *FakeA2AServerBuilder) WithTaskResultProcessorArgsForCall(i int) server.TaskResultProcessor

func (*FakeA2AServerBuilder) WithTaskResultProcessorCallCount 

func (fake *FakeA2AServerBuilder) WithTaskResultProcessorCallCount() int

func (*FakeA2AServerBuilder) WithTaskResultProcessorCalls 

func (fake *FakeA2AServerBuilder) WithTaskResultProcessorCalls(stub func(server.TaskResultProcessor) server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithTaskResultProcessorReturns 

func (fake *FakeA2AServerBuilder) WithTaskResultProcessorReturns(result1 server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithTaskResultProcessorReturnsOnCall 

func (fake *FakeA2AServerBuilder) WithTaskResultProcessorReturnsOnCall(i int, result1 server.A2AServerBuilder)

type FakeAgentBuilder 

type FakeAgentBuilder struct {
	BuildStub func() (*server.OpenAICompatibleAgentImpl, error)

	GetConfigStub func() *config.AgentConfig

	WithConfigStub func(*config.AgentConfig) server.AgentBuilder

	WithLLMClientStub func(server.LLMClient) server.AgentBuilder

	WithMaxChatCompletionStub func(int) server.AgentBuilder

	WithMaxConversationHistoryStub func(int) server.AgentBuilder

	WithSystemPromptStub func(string) server.AgentBuilder

	WithToolBoxStub func(server.ToolBox) server.AgentBuilder
	// contains filtered or unexported fields
}

func (*FakeAgentBuilder) Build 

func (fake *FakeAgentBuilder) Build() (*server.OpenAICompatibleAgentImpl, error)

func (*FakeAgentBuilder) BuildCallCount 

func (fake *FakeAgentBuilder) BuildCallCount() int

func (*FakeAgentBuilder) BuildCalls 

func (fake *FakeAgentBuilder) BuildCalls(stub func() (*server.OpenAICompatibleAgentImpl, error))

func (*FakeAgentBuilder) BuildReturns 

func (fake *FakeAgentBuilder) BuildReturns(result1 *server.OpenAICompatibleAgentImpl, result2 error)

func (*FakeAgentBuilder) BuildReturnsOnCall 

func (fake *FakeAgentBuilder) BuildReturnsOnCall(i int, result1 *server.OpenAICompatibleAgentImpl, result2 error)

func (*FakeAgentBuilder) GetConfig 

func (fake *FakeAgentBuilder) GetConfig() *config.AgentConfig

func (*FakeAgentBuilder) GetConfigCallCount 

func (fake *FakeAgentBuilder) GetConfigCallCount() int

func (*FakeAgentBuilder) GetConfigCalls 

func (fake *FakeAgentBuilder) GetConfigCalls(stub func() *config.AgentConfig)

func (*FakeAgentBuilder) GetConfigReturns 

func (fake *FakeAgentBuilder) GetConfigReturns(result1 *config.AgentConfig)

func (*FakeAgentBuilder) GetConfigReturnsOnCall 

func (fake *FakeAgentBuilder) GetConfigReturnsOnCall(i int, result1 *config.AgentConfig)

func (*FakeAgentBuilder) Invocations 

func (fake *FakeAgentBuilder) Invocations() map[string][][]interface{}

func (*FakeAgentBuilder) WithConfig 

func (fake *FakeAgentBuilder) WithConfig(arg1 *config.AgentConfig) server.AgentBuilder

func (*FakeAgentBuilder) WithConfigArgsForCall 

func (fake *FakeAgentBuilder) WithConfigArgsForCall(i int) *config.AgentConfig

func (*FakeAgentBuilder) WithConfigCallCount 

func (fake *FakeAgentBuilder) WithConfigCallCount() int

func (*FakeAgentBuilder) WithConfigCalls 

func (fake *FakeAgentBuilder) WithConfigCalls(stub func(*config.AgentConfig) server.AgentBuilder)

func (*FakeAgentBuilder) WithConfigReturns 

func (fake *FakeAgentBuilder) WithConfigReturns(result1 server.AgentBuilder)

func (*FakeAgentBuilder) WithConfigReturnsOnCall 

func (fake *FakeAgentBuilder) WithConfigReturnsOnCall(i int, result1 server.AgentBuilder)

func (*FakeAgentBuilder) WithLLMClient 

func (fake *FakeAgentBuilder) WithLLMClient(arg1 server.LLMClient) server.AgentBuilder

func (*FakeAgentBuilder) WithLLMClientArgsForCall 

func (fake *FakeAgentBuilder) WithLLMClientArgsForCall(i int) server.LLMClient

func (*FakeAgentBuilder) WithLLMClientCallCount 

func (fake *FakeAgentBuilder) WithLLMClientCallCount() int

func (*FakeAgentBuilder) WithLLMClientCalls 

func (fake *FakeAgentBuilder) WithLLMClientCalls(stub func(server.LLMClient) server.AgentBuilder)

func (*FakeAgentBuilder) WithLLMClientReturns 

func (fake *FakeAgentBuilder) WithLLMClientReturns(result1 server.AgentBuilder)

func (*FakeAgentBuilder) WithLLMClientReturnsOnCall 

func (fake *FakeAgentBuilder) WithLLMClientReturnsOnCall(i int, result1 server.AgentBuilder)

func (*FakeAgentBuilder) WithMaxChatCompletion 

func (fake *FakeAgentBuilder) WithMaxChatCompletion(arg1 int) server.AgentBuilder

func (*FakeAgentBuilder) WithMaxChatCompletionArgsForCall 

func (fake *FakeAgentBuilder) WithMaxChatCompletionArgsForCall(i int) int

func (*FakeAgentBuilder) WithMaxChatCompletionCallCount 

func (fake *FakeAgentBuilder) WithMaxChatCompletionCallCount() int

func (*FakeAgentBuilder) WithMaxChatCompletionCalls 

func (fake *FakeAgentBuilder) WithMaxChatCompletionCalls(stub func(int) server.AgentBuilder)

func (*FakeAgentBuilder) WithMaxChatCompletionReturns 

func (fake *FakeAgentBuilder) WithMaxChatCompletionReturns(result1 server.AgentBuilder)

func (*FakeAgentBuilder) WithMaxChatCompletionReturnsOnCall 

func (fake *FakeAgentBuilder) WithMaxChatCompletionReturnsOnCall(i int, result1 server.AgentBuilder)

func (*FakeAgentBuilder) WithMaxConversationHistory 

func (fake *FakeAgentBuilder) WithMaxConversationHistory(arg1 int) server.AgentBuilder

func (*FakeAgentBuilder) WithMaxConversationHistoryArgsForCall 

func (fake *FakeAgentBuilder) WithMaxConversationHistoryArgsForCall(i int) int

func (*FakeAgentBuilder) WithMaxConversationHistoryCallCount 

func (fake *FakeAgentBuilder) WithMaxConversationHistoryCallCount() int

func (*FakeAgentBuilder) WithMaxConversationHistoryCalls 

func (fake *FakeAgentBuilder) WithMaxConversationHistoryCalls(stub func(int) server.AgentBuilder)

func (*FakeAgentBuilder) WithMaxConversationHistoryReturns 

func (fake *FakeAgentBuilder) WithMaxConversationHistoryReturns(result1 server.AgentBuilder)

func (*FakeAgentBuilder) WithMaxConversationHistoryReturnsOnCall 

func (fake *FakeAgentBuilder) WithMaxConversationHistoryReturnsOnCall(i int, result1 server.AgentBuilder)

func (*FakeAgentBuilder) WithSystemPrompt 

func (fake *FakeAgentBuilder) WithSystemPrompt(arg1 string) server.AgentBuilder

func (*FakeAgentBuilder) WithSystemPromptArgsForCall 

func (fake *FakeAgentBuilder) WithSystemPromptArgsForCall(i int) string

func (*FakeAgentBuilder) WithSystemPromptCallCount 

func (fake *FakeAgentBuilder) WithSystemPromptCallCount() int

func (*FakeAgentBuilder) WithSystemPromptCalls 

func (fake *FakeAgentBuilder) WithSystemPromptCalls(stub func(string) server.AgentBuilder)

func (*FakeAgentBuilder) WithSystemPromptReturns 

func (fake *FakeAgentBuilder) WithSystemPromptReturns(result1 server.AgentBuilder)

func (*FakeAgentBuilder) WithSystemPromptReturnsOnCall 

func (fake *FakeAgentBuilder) WithSystemPromptReturnsOnCall(i int, result1 server.AgentBuilder)

func (*FakeAgentBuilder) WithToolBox 

func (fake *FakeAgentBuilder) WithToolBox(arg1 server.ToolBox) server.AgentBuilder

func (*FakeAgentBuilder) WithToolBoxArgsForCall 

func (fake *FakeAgentBuilder) WithToolBoxArgsForCall(i int) server.ToolBox

func (*FakeAgentBuilder) WithToolBoxCallCount 

func (fake *FakeAgentBuilder) WithToolBoxCallCount() int

func (*FakeAgentBuilder) WithToolBoxCalls 

func (fake *FakeAgentBuilder) WithToolBoxCalls(stub func(server.ToolBox) server.AgentBuilder)

func (*FakeAgentBuilder) WithToolBoxReturns 

func (fake *FakeAgentBuilder) WithToolBoxReturns(result1 server.AgentBuilder)

func (*FakeAgentBuilder) WithToolBoxReturnsOnCall 

func (fake *FakeAgentBuilder) WithToolBoxReturnsOnCall(i int, result1 server.AgentBuilder)

type FakeLLMClient 

type FakeLLMClient struct {
	CreateChatCompletionStub func(context.Context, []sdk.Message, ...sdk.ChatCompletionTool) (*sdk.CreateChatCompletionResponse, error)

	CreateStreamingChatCompletionStub func(context.Context, []sdk.Message, ...sdk.ChatCompletionTool) (<-chan *sdk.CreateChatCompletionStreamResponse, <-chan error)
	// contains filtered or unexported fields
}

func (*FakeLLMClient) CreateChatCompletion 

func (fake *FakeLLMClient) CreateChatCompletion(arg1 context.Context, arg2 []sdk.Message, arg3 ...sdk.ChatCompletionTool) (*sdk.CreateChatCompletionResponse, error)

func (*FakeLLMClient) CreateChatCompletionArgsForCall 

func (fake *FakeLLMClient) CreateChatCompletionArgsForCall(i int) (context.Context, []sdk.Message, []sdk.ChatCompletionTool)

func (*FakeLLMClient) CreateChatCompletionCallCount 

func (fake *FakeLLMClient) CreateChatCompletionCallCount() int

func (*FakeLLMClient) CreateChatCompletionCalls 

func (fake *FakeLLMClient) CreateChatCompletionCalls(stub func(context.Context, []sdk.Message, ...sdk.ChatCompletionTool) (*sdk.CreateChatCompletionResponse, error))

func (*FakeLLMClient) CreateChatCompletionReturns 

func (fake *FakeLLMClient) CreateChatCompletionReturns(result1 *sdk.CreateChatCompletionResponse, result2 error)

func (*FakeLLMClient) CreateChatCompletionReturnsOnCall 

func (fake *FakeLLMClient) CreateChatCompletionReturnsOnCall(i int, result1 *sdk.CreateChatCompletionResponse, result2 error)

func (*FakeLLMClient) CreateStreamingChatCompletion 

func (fake *FakeLLMClient) CreateStreamingChatCompletion(arg1 context.Context, arg2 []sdk.Message, arg3 ...sdk.ChatCompletionTool) (<-chan *sdk.CreateChatCompletionStreamResponse, <-chan error)

func (*FakeLLMClient) CreateStreamingChatCompletionArgsForCall 

func (fake *FakeLLMClient) CreateStreamingChatCompletionArgsForCall(i int) (context.Context, []sdk.Message, []sdk.ChatCompletionTool)

func (*FakeLLMClient) CreateStreamingChatCompletionCallCount 

func (fake *FakeLLMClient) CreateStreamingChatCompletionCallCount() int

func (*FakeLLMClient) CreateStreamingChatCompletionCalls 

func (fake *FakeLLMClient) CreateStreamingChatCompletionCalls(stub func(context.Context, []sdk.Message, ...sdk.ChatCompletionTool) (<-chan *sdk.CreateChatCompletionStreamResponse, <-chan error))

func (*FakeLLMClient) CreateStreamingChatCompletionReturns 

func (fake *FakeLLMClient) CreateStreamingChatCompletionReturns(result1 <-chan *sdk.CreateChatCompletionStreamResponse, result2 <-chan error)

func (*FakeLLMClient) CreateStreamingChatCompletionReturnsOnCall 

func (fake *FakeLLMClient) CreateStreamingChatCompletionReturnsOnCall(i int, result1 <-chan *sdk.CreateChatCompletionStreamResponse, result2 <-chan error)

func (*FakeLLMClient) Invocations 

func (fake *FakeLLMClient) Invocations() map[string][][]interface{}

type FakeMessageHandler 

type FakeMessageHandler struct {
	HandleMessageSendStub func(context.Context, types.MessageSendParams) (*types.Task, error)

	HandleMessageStreamStub func(context.Context, types.MessageSendParams, chan<- types.SendStreamingMessageResponse) error
	// contains filtered or unexported fields
}

func (*FakeMessageHandler) HandleMessageSend 

func (fake *FakeMessageHandler) HandleMessageSend(arg1 context.Context, arg2 types.MessageSendParams) (*types.Task, error)

func (*FakeMessageHandler) HandleMessageSendArgsForCall 

func (fake *FakeMessageHandler) HandleMessageSendArgsForCall(i int) (context.Context, types.MessageSendParams)

func (*FakeMessageHandler) HandleMessageSendCallCount 

func (fake *FakeMessageHandler) HandleMessageSendCallCount() int

func (*FakeMessageHandler) HandleMessageSendCalls 

func (fake *FakeMessageHandler) HandleMessageSendCalls(stub func(context.Context, types.MessageSendParams) (*types.Task, error))

func (*FakeMessageHandler) HandleMessageSendReturns 

func (fake *FakeMessageHandler) HandleMessageSendReturns(result1 *types.Task, result2 error)

func (*FakeMessageHandler) HandleMessageSendReturnsOnCall 

func (fake *FakeMessageHandler) HandleMessageSendReturnsOnCall(i int, result1 *types.Task, result2 error)

func (*FakeMessageHandler) HandleMessageStream 

func (fake *FakeMessageHandler) HandleMessageStream(arg1 context.Context, arg2 types.MessageSendParams, arg3 chan<- types.SendStreamingMessageResponse) error

func (*FakeMessageHandler) HandleMessageStreamArgsForCall 

func (fake *FakeMessageHandler) HandleMessageStreamArgsForCall(i int) (context.Context, types.MessageSendParams, chan<- types.SendStreamingMessageResponse)

func (*FakeMessageHandler) HandleMessageStreamCallCount 

func (fake *FakeMessageHandler) HandleMessageStreamCallCount() int

func (*FakeMessageHandler) HandleMessageStreamCalls 

func (fake *FakeMessageHandler) HandleMessageStreamCalls(stub func(context.Context, types.MessageSendParams, chan<- types.SendStreamingMessageResponse) error)

func (*FakeMessageHandler) HandleMessageStreamReturns 

func (fake *FakeMessageHandler) HandleMessageStreamReturns(result1 error)

func (*FakeMessageHandler) HandleMessageStreamReturnsOnCall 

func (fake *FakeMessageHandler) HandleMessageStreamReturnsOnCall(i int, result1 error)

func (*FakeMessageHandler) Invocations 

func (fake *FakeMessageHandler) Invocations() map[string][][]interface{}

type FakeOIDCAuthenticator 

type FakeOIDCAuthenticator struct {
	MiddlewareStub func() gin.HandlerFunc
	// contains filtered or unexported fields
}

func (*FakeOIDCAuthenticator) Invocations 

func (fake *FakeOIDCAuthenticator) Invocations() map[string][][]interface{}

func (*FakeOIDCAuthenticator) Middleware 

func (fake *FakeOIDCAuthenticator) Middleware() gin.HandlerFunc

func (*FakeOIDCAuthenticator) MiddlewareCallCount 

func (fake *FakeOIDCAuthenticator) MiddlewareCallCount() int

func (*FakeOIDCAuthenticator) MiddlewareCalls 

func (fake *FakeOIDCAuthenticator) MiddlewareCalls(stub func() gin.HandlerFunc)

func (*FakeOIDCAuthenticator) MiddlewareReturns 

func (fake *FakeOIDCAuthenticator) MiddlewareReturns(result1 gin.HandlerFunc)

func (*FakeOIDCAuthenticator) MiddlewareReturnsOnCall 

func (fake *FakeOIDCAuthenticator) MiddlewareReturnsOnCall(i int, result1 gin.HandlerFunc)

type FakeOpenAICompatibleAgent added in v0.8.0 

type FakeOpenAICompatibleAgent struct {
	RunStub func(context.Context, []types.Message) (*server.AgentResponse, error)

	RunWithStreamStub func(context.Context, []types.Message) (<-chan *types.Message, error)
	// contains filtered or unexported fields
}

func (*FakeOpenAICompatibleAgent) Invocations added in v0.8.0 

func (fake *FakeOpenAICompatibleAgent) Invocations() map[string][][]interface{}

func (*FakeOpenAICompatibleAgent) Run added in v0.8.0 

func (fake *FakeOpenAICompatibleAgent) Run(arg1 context.Context, arg2 []types.Message) (*server.AgentResponse, error)

func (*FakeOpenAICompatibleAgent) RunArgsForCall added in v0.8.0 

func (fake *FakeOpenAICompatibleAgent) RunArgsForCall(i int) (context.Context, []types.Message)

func (*FakeOpenAICompatibleAgent) RunCallCount added in v0.8.0 

func (fake *FakeOpenAICompatibleAgent) RunCallCount() int

func (*FakeOpenAICompatibleAgent) RunCalls added in v0.8.0 

func (fake *FakeOpenAICompatibleAgent) RunCalls(stub func(context.Context, []types.Message) (*server.AgentResponse, error))

func (*FakeOpenAICompatibleAgent) RunReturns added in v0.8.0 

func (fake *FakeOpenAICompatibleAgent) RunReturns(result1 *server.AgentResponse, result2 error)

func (*FakeOpenAICompatibleAgent) RunReturnsOnCall added in v0.8.0 

func (fake *FakeOpenAICompatibleAgent) RunReturnsOnCall(i int, result1 *server.AgentResponse, result2 error)

func (*FakeOpenAICompatibleAgent) RunWithStream added in v0.8.0 

func (fake *FakeOpenAICompatibleAgent) RunWithStream(arg1 context.Context, arg2 []types.Message) (<-chan *types.Message, error)

func (*FakeOpenAICompatibleAgent) RunWithStreamArgsForCall added in v0.8.0 

func (fake *FakeOpenAICompatibleAgent) RunWithStreamArgsForCall(i int) (context.Context, []types.Message)

func (*FakeOpenAICompatibleAgent) RunWithStreamCallCount added in v0.8.0 

func (fake *FakeOpenAICompatibleAgent) RunWithStreamCallCount() int

func (*FakeOpenAICompatibleAgent) RunWithStreamCalls added in v0.8.0 

func (fake *FakeOpenAICompatibleAgent) RunWithStreamCalls(stub func(context.Context, []types.Message) (<-chan *types.Message, error))

func (*FakeOpenAICompatibleAgent) RunWithStreamReturns added in v0.8.0 

func (fake *FakeOpenAICompatibleAgent) RunWithStreamReturns(result1 <-chan *types.Message, result2 error)

func (*FakeOpenAICompatibleAgent) RunWithStreamReturnsOnCall added in v0.8.0 

func (fake *FakeOpenAICompatibleAgent) RunWithStreamReturnsOnCall(i int, result1 <-chan *types.Message, result2 error)

type FakeOpenTelemetry 

type FakeOpenTelemetry struct {
	RecordRequestCountStub func(context.Context, otel.TelemetryAttributes, string)

	RecordRequestDurationStub func(context.Context, otel.TelemetryAttributes, string, string, float64)

	RecordResponseStatusStub func(context.Context, otel.TelemetryAttributes, string, string, int)

	RecordTaskCompletedStub func(context.Context, otel.TelemetryAttributes, bool)

	RecordTaskFailureStub func(context.Context, otel.TelemetryAttributes, string, string)

	RecordTaskQueuedStub func(context.Context, otel.TelemetryAttributes)

	RecordTokenUsageStub func(context.Context, otel.TelemetryAttributes, sdk.CompletionUsage)

	RecordToolCallFailureStub func(context.Context, otel.TelemetryAttributes, string, string)

	ShutDownStub func(context.Context) error
	// contains filtered or unexported fields
}

func (*FakeOpenTelemetry) Invocations 

func (fake *FakeOpenTelemetry) Invocations() map[string][][]interface{}

func (*FakeOpenTelemetry) RecordRequestCount 

func (fake *FakeOpenTelemetry) RecordRequestCount(arg1 context.Context, arg2 otel.TelemetryAttributes, arg3 string)

func (*FakeOpenTelemetry) RecordRequestCountArgsForCall 

func (fake *FakeOpenTelemetry) RecordRequestCountArgsForCall(i int) (context.Context, otel.TelemetryAttributes, string)

func (*FakeOpenTelemetry) RecordRequestCountCallCount 

func (fake *FakeOpenTelemetry) RecordRequestCountCallCount() int

func (*FakeOpenTelemetry) RecordRequestCountCalls 

func (fake *FakeOpenTelemetry) RecordRequestCountCalls(stub func(context.Context, otel.TelemetryAttributes, string))

func (*FakeOpenTelemetry) RecordRequestDuration 

func (fake *FakeOpenTelemetry) RecordRequestDuration(arg1 context.Context, arg2 otel.TelemetryAttributes, arg3 string, arg4 string, arg5 float64)

func (*FakeOpenTelemetry) RecordRequestDurationArgsForCall 

func (fake *FakeOpenTelemetry) RecordRequestDurationArgsForCall(i int) (context.Context, otel.TelemetryAttributes, string, string, float64)

func (*FakeOpenTelemetry) RecordRequestDurationCallCount 

func (fake *FakeOpenTelemetry) RecordRequestDurationCallCount() int

func (*FakeOpenTelemetry) RecordRequestDurationCalls 

func (fake *FakeOpenTelemetry) RecordRequestDurationCalls(stub func(context.Context, otel.TelemetryAttributes, string, string, float64))

func (*FakeOpenTelemetry) RecordResponseStatus 

func (fake *FakeOpenTelemetry) RecordResponseStatus(arg1 context.Context, arg2 otel.TelemetryAttributes, arg3 string, arg4 string, arg5 int)

func (*FakeOpenTelemetry) RecordResponseStatusArgsForCall 

func (fake *FakeOpenTelemetry) RecordResponseStatusArgsForCall(i int) (context.Context, otel.TelemetryAttributes, string, string, int)

func (*FakeOpenTelemetry) RecordResponseStatusCallCount 

func (fake *FakeOpenTelemetry) RecordResponseStatusCallCount() int

func (*FakeOpenTelemetry) RecordResponseStatusCalls 

func (fake *FakeOpenTelemetry) RecordResponseStatusCalls(stub func(context.Context, otel.TelemetryAttributes, string, string, int))

func (*FakeOpenTelemetry) RecordTaskCompleted 

func (fake *FakeOpenTelemetry) RecordTaskCompleted(arg1 context.Context, arg2 otel.TelemetryAttributes, arg3 bool)

func (*FakeOpenTelemetry) RecordTaskCompletedArgsForCall 

func (fake *FakeOpenTelemetry) RecordTaskCompletedArgsForCall(i int) (context.Context, otel.TelemetryAttributes, bool)

func (*FakeOpenTelemetry) RecordTaskCompletedCallCount 

func (fake *FakeOpenTelemetry) RecordTaskCompletedCallCount() int

func (*FakeOpenTelemetry) RecordTaskCompletedCalls 

func (fake *FakeOpenTelemetry) RecordTaskCompletedCalls(stub func(context.Context, otel.TelemetryAttributes, bool))

func (*FakeOpenTelemetry) RecordTaskFailure 

func (fake *FakeOpenTelemetry) RecordTaskFailure(arg1 context.Context, arg2 otel.TelemetryAttributes, arg3 string, arg4 string)

func (*FakeOpenTelemetry) RecordTaskFailureArgsForCall 

func (fake *FakeOpenTelemetry) RecordTaskFailureArgsForCall(i int) (context.Context, otel.TelemetryAttributes, string, string)

func (*FakeOpenTelemetry) RecordTaskFailureCallCount 

func (fake *FakeOpenTelemetry) RecordTaskFailureCallCount() int

func (*FakeOpenTelemetry) RecordTaskFailureCalls 

func (fake *FakeOpenTelemetry) RecordTaskFailureCalls(stub func(context.Context, otel.TelemetryAttributes, string, string))

func (*FakeOpenTelemetry) RecordTaskQueued 

func (fake *FakeOpenTelemetry) RecordTaskQueued(arg1 context.Context, arg2 otel.TelemetryAttributes)

func (*FakeOpenTelemetry) RecordTaskQueuedArgsForCall 

func (fake *FakeOpenTelemetry) RecordTaskQueuedArgsForCall(i int) (context.Context, otel.TelemetryAttributes)

func (*FakeOpenTelemetry) RecordTaskQueuedCallCount 

func (fake *FakeOpenTelemetry) RecordTaskQueuedCallCount() int

func (*FakeOpenTelemetry) RecordTaskQueuedCalls 

func (fake *FakeOpenTelemetry) RecordTaskQueuedCalls(stub func(context.Context, otel.TelemetryAttributes))

func (*FakeOpenTelemetry) RecordTokenUsage 

func (fake *FakeOpenTelemetry) RecordTokenUsage(arg1 context.Context, arg2 otel.TelemetryAttributes, arg3 sdk.CompletionUsage)

func (*FakeOpenTelemetry) RecordTokenUsageArgsForCall 

func (fake *FakeOpenTelemetry) RecordTokenUsageArgsForCall(i int) (context.Context, otel.TelemetryAttributes, sdk.CompletionUsage)

func (*FakeOpenTelemetry) RecordTokenUsageCallCount 

func (fake *FakeOpenTelemetry) RecordTokenUsageCallCount() int

func (*FakeOpenTelemetry) RecordTokenUsageCalls 

func (fake *FakeOpenTelemetry) RecordTokenUsageCalls(stub func(context.Context, otel.TelemetryAttributes, sdk.CompletionUsage))

func (*FakeOpenTelemetry) RecordToolCallFailure 

func (fake *FakeOpenTelemetry) RecordToolCallFailure(arg1 context.Context, arg2 otel.TelemetryAttributes, arg3 string, arg4 string)

func (*FakeOpenTelemetry) RecordToolCallFailureArgsForCall 

func (fake *FakeOpenTelemetry) RecordToolCallFailureArgsForCall(i int) (context.Context, otel.TelemetryAttributes, string, string)

func (*FakeOpenTelemetry) RecordToolCallFailureCallCount 

func (fake *FakeOpenTelemetry) RecordToolCallFailureCallCount() int

func (*FakeOpenTelemetry) RecordToolCallFailureCalls 

func (fake *FakeOpenTelemetry) RecordToolCallFailureCalls(stub func(context.Context, otel.TelemetryAttributes, string, string))

func (*FakeOpenTelemetry) ShutDown 

func (fake *FakeOpenTelemetry) ShutDown(arg1 context.Context) error

func (*FakeOpenTelemetry) ShutDownArgsForCall 

func (fake *FakeOpenTelemetry) ShutDownArgsForCall(i int) context.Context

func (*FakeOpenTelemetry) ShutDownCallCount 

func (fake *FakeOpenTelemetry) ShutDownCallCount() int

func (*FakeOpenTelemetry) ShutDownCalls 

func (fake *FakeOpenTelemetry) ShutDownCalls(stub func(context.Context) error)

func (*FakeOpenTelemetry) ShutDownReturns 

func (fake *FakeOpenTelemetry) ShutDownReturns(result1 error)

func (*FakeOpenTelemetry) ShutDownReturnsOnCall 

func (fake *FakeOpenTelemetry) ShutDownReturnsOnCall(i int, result1 error)

type FakeResponseSender 

type FakeResponseSender struct {
	SendErrorStub func(*gin.Context, interface{}, int, string)

	SendSuccessStub func(*gin.Context, interface{}, interface{})
	// contains filtered or unexported fields
}

func (*FakeResponseSender) Invocations 

func (fake *FakeResponseSender) Invocations() map[string][][]interface{}

func (*FakeResponseSender) SendError 

func (fake *FakeResponseSender) SendError(arg1 *gin.Context, arg2 interface{}, arg3 int, arg4 string)

func (*FakeResponseSender) SendErrorArgsForCall 

func (fake *FakeResponseSender) SendErrorArgsForCall(i int) (*gin.Context, interface{}, int, string)

func (*FakeResponseSender) SendErrorCallCount 

func (fake *FakeResponseSender) SendErrorCallCount() int

func (*FakeResponseSender) SendErrorCalls 

func (fake *FakeResponseSender) SendErrorCalls(stub func(*gin.Context, interface{}, int, string))

func (*FakeResponseSender) SendSuccess 

func (fake *FakeResponseSender) SendSuccess(arg1 *gin.Context, arg2 interface{}, arg3 interface{})

func (*FakeResponseSender) SendSuccessArgsForCall 

func (fake *FakeResponseSender) SendSuccessArgsForCall(i int) (*gin.Context, interface{}, interface{})

func (*FakeResponseSender) SendSuccessCallCount 

func (fake *FakeResponseSender) SendSuccessCallCount() int

func (*FakeResponseSender) SendSuccessCalls 

func (fake *FakeResponseSender) SendSuccessCalls(stub func(*gin.Context, interface{}, interface{}))

type FakeStorage added in v0.8.0 

type FakeStorage struct {
	CleanupCompletedTasksStub func() int

	CleanupTasksWithRetentionStub func(int, int) int

	ClearQueueStub func() error

	CreateActiveTaskStub func(*types.Task) error

	DeleteContextStub func(string) error

	DeleteContextAndTasksStub func(string) error

	DeleteTaskStub func(string) error

	DequeueTaskStub func(context.Context) (*server.QueuedTask, error)

	EnqueueTaskStub func(*types.Task, interface{}) error

	GetActiveTaskStub func(string) (*types.Task, error)

	GetContextsStub func() []string

	GetContextsWithTasksStub func() []string

	GetQueueLengthStub func() int

	GetStatsStub func() server.StorageStats

	GetTaskStub func(string) (*types.Task, bool)

	GetTaskByContextAndIDStub func(string, string) (*types.Task, bool)

	ListTasksStub func(server.TaskFilter) ([]*types.Task, error)

	ListTasksByContextStub func(string, server.TaskFilter) ([]*types.Task, error)

	StoreDeadLetterTaskStub func(*types.Task) error

	UpdateActiveTaskStub func(*types.Task) error
	// contains filtered or unexported fields
}

func (*FakeStorage) CleanupCompletedTasks added in v0.8.0 

func (fake *FakeStorage) CleanupCompletedTasks() int

func (*FakeStorage) CleanupCompletedTasksCallCount added in v0.8.0 

func (fake *FakeStorage) CleanupCompletedTasksCallCount() int

func (*FakeStorage) CleanupCompletedTasksCalls added in v0.8.0 

func (fake *FakeStorage) CleanupCompletedTasksCalls(stub func() int)

func (*FakeStorage) CleanupCompletedTasksReturns added in v0.8.0 

func (fake *FakeStorage) CleanupCompletedTasksReturns(result1 int)

func (*FakeStorage) CleanupCompletedTasksReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) CleanupCompletedTasksReturnsOnCall(i int, result1 int)

func (*FakeStorage) CleanupTasksWithRetention added in v0.8.0 

func (fake *FakeStorage) CleanupTasksWithRetention(arg1 int, arg2 int) int

func (*FakeStorage) CleanupTasksWithRetentionArgsForCall added in v0.8.0 

func (fake *FakeStorage) CleanupTasksWithRetentionArgsForCall(i int) (int, int)

func (*FakeStorage) CleanupTasksWithRetentionCallCount added in v0.8.0 

func (fake *FakeStorage) CleanupTasksWithRetentionCallCount() int

func (*FakeStorage) CleanupTasksWithRetentionCalls added in v0.8.0 

func (fake *FakeStorage) CleanupTasksWithRetentionCalls(stub func(int, int) int)

func (*FakeStorage) CleanupTasksWithRetentionReturns added in v0.8.0 

func (fake *FakeStorage) CleanupTasksWithRetentionReturns(result1 int)

func (*FakeStorage) CleanupTasksWithRetentionReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) CleanupTasksWithRetentionReturnsOnCall(i int, result1 int)

func (*FakeStorage) ClearQueue added in v0.8.0 

func (fake *FakeStorage) ClearQueue() error

func (*FakeStorage) ClearQueueCallCount added in v0.8.0 

func (fake *FakeStorage) ClearQueueCallCount() int

func (*FakeStorage) ClearQueueCalls added in v0.8.0 

func (fake *FakeStorage) ClearQueueCalls(stub func() error)

func (*FakeStorage) ClearQueueReturns added in v0.8.0 

func (fake *FakeStorage) ClearQueueReturns(result1 error)

func (*FakeStorage) ClearQueueReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) ClearQueueReturnsOnCall(i int, result1 error)

func (*FakeStorage) CreateActiveTask added in v0.8.0 

func (fake *FakeStorage) CreateActiveTask(arg1 *types.Task) error

func (*FakeStorage) CreateActiveTaskArgsForCall added in v0.8.0 

func (fake *FakeStorage) CreateActiveTaskArgsForCall(i int) *types.Task

func (*FakeStorage) CreateActiveTaskCallCount added in v0.8.0 

func (fake *FakeStorage) CreateActiveTaskCallCount() int

func (*FakeStorage) CreateActiveTaskCalls added in v0.8.0 

func (fake *FakeStorage) CreateActiveTaskCalls(stub func(*types.Task) error)

func (*FakeStorage) CreateActiveTaskReturns added in v0.8.0 

func (fake *FakeStorage) CreateActiveTaskReturns(result1 error)

func (*FakeStorage) CreateActiveTaskReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) CreateActiveTaskReturnsOnCall(i int, result1 error)

func (*FakeStorage) DeleteContext added in v0.8.0 

func (fake *FakeStorage) DeleteContext(arg1 string) error

func (*FakeStorage) DeleteContextAndTasks added in v0.8.0 

func (fake *FakeStorage) DeleteContextAndTasks(arg1 string) error

func (*FakeStorage) DeleteContextAndTasksArgsForCall added in v0.8.0 

func (fake *FakeStorage) DeleteContextAndTasksArgsForCall(i int) string

func (*FakeStorage) DeleteContextAndTasksCallCount added in v0.8.0 

func (fake *FakeStorage) DeleteContextAndTasksCallCount() int

func (*FakeStorage) DeleteContextAndTasksCalls added in v0.8.0 

func (fake *FakeStorage) DeleteContextAndTasksCalls(stub func(string) error)

func (*FakeStorage) DeleteContextAndTasksReturns added in v0.8.0 

func (fake *FakeStorage) DeleteContextAndTasksReturns(result1 error)

func (*FakeStorage) DeleteContextAndTasksReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) DeleteContextAndTasksReturnsOnCall(i int, result1 error)

func (*FakeStorage) DeleteContextArgsForCall added in v0.8.0 

func (fake *FakeStorage) DeleteContextArgsForCall(i int) string

func (*FakeStorage) DeleteContextCallCount added in v0.8.0 

func (fake *FakeStorage) DeleteContextCallCount() int

func (*FakeStorage) DeleteContextCalls added in v0.8.0 

func (fake *FakeStorage) DeleteContextCalls(stub func(string) error)

func (*FakeStorage) DeleteContextReturns added in v0.8.0 

func (fake *FakeStorage) DeleteContextReturns(result1 error)

func (*FakeStorage) DeleteContextReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) DeleteContextReturnsOnCall(i int, result1 error)

func (*FakeStorage) DeleteTask added in v0.8.0 

func (fake *FakeStorage) DeleteTask(arg1 string) error

func (*FakeStorage) DeleteTaskArgsForCall added in v0.8.0 

func (fake *FakeStorage) DeleteTaskArgsForCall(i int) string

func (*FakeStorage) DeleteTaskCallCount added in v0.8.0 

func (fake *FakeStorage) DeleteTaskCallCount() int

func (*FakeStorage) DeleteTaskCalls added in v0.8.0 

func (fake *FakeStorage) DeleteTaskCalls(stub func(string) error)

func (*FakeStorage) DeleteTaskReturns added in v0.8.0 

func (fake *FakeStorage) DeleteTaskReturns(result1 error)

func (*FakeStorage) DeleteTaskReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) DeleteTaskReturnsOnCall(i int, result1 error)

func (*FakeStorage) DequeueTask added in v0.8.0 

func (fake *FakeStorage) DequeueTask(arg1 context.Context) (*server.QueuedTask, error)

func (*FakeStorage) DequeueTaskArgsForCall added in v0.8.0 

func (fake *FakeStorage) DequeueTaskArgsForCall(i int) context.Context

func (*FakeStorage) DequeueTaskCallCount added in v0.8.0 

func (fake *FakeStorage) DequeueTaskCallCount() int

func (*FakeStorage) DequeueTaskCalls added in v0.8.0 

func (fake *FakeStorage) DequeueTaskCalls(stub func(context.Context) (*server.QueuedTask, error))

func (*FakeStorage) DequeueTaskReturns added in v0.8.0 

func (fake *FakeStorage) DequeueTaskReturns(result1 *server.QueuedTask, result2 error)

func (*FakeStorage) DequeueTaskReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) DequeueTaskReturnsOnCall(i int, result1 *server.QueuedTask, result2 error)

func (*FakeStorage) EnqueueTask added in v0.8.0 

func (fake *FakeStorage) EnqueueTask(arg1 *types.Task, arg2 interface{}) error

func (*FakeStorage) EnqueueTaskArgsForCall added in v0.8.0 

func (fake *FakeStorage) EnqueueTaskArgsForCall(i int) (*types.Task, interface{})

func (*FakeStorage) EnqueueTaskCallCount added in v0.8.0 

func (fake *FakeStorage) EnqueueTaskCallCount() int

func (*FakeStorage) EnqueueTaskCalls added in v0.8.0 

func (fake *FakeStorage) EnqueueTaskCalls(stub func(*types.Task, interface{}) error)

func (*FakeStorage) EnqueueTaskReturns added in v0.8.0 

func (fake *FakeStorage) EnqueueTaskReturns(result1 error)

func (*FakeStorage) EnqueueTaskReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) EnqueueTaskReturnsOnCall(i int, result1 error)

func (*FakeStorage) GetActiveTask added in v0.8.0 

func (fake *FakeStorage) GetActiveTask(arg1 string) (*types.Task, error)

func (*FakeStorage) GetActiveTaskArgsForCall added in v0.8.0 

func (fake *FakeStorage) GetActiveTaskArgsForCall(i int) string

func (*FakeStorage) GetActiveTaskCallCount added in v0.8.0 

func (fake *FakeStorage) GetActiveTaskCallCount() int

func (*FakeStorage) GetActiveTaskCalls added in v0.8.0 

func (fake *FakeStorage) GetActiveTaskCalls(stub func(string) (*types.Task, error))

func (*FakeStorage) GetActiveTaskReturns added in v0.8.0 

func (fake *FakeStorage) GetActiveTaskReturns(result1 *types.Task, result2 error)

func (*FakeStorage) GetActiveTaskReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) GetActiveTaskReturnsOnCall(i int, result1 *types.Task, result2 error)

func (*FakeStorage) GetContexts added in v0.8.0 

func (fake *FakeStorage) GetContexts() []string

func (*FakeStorage) GetContextsCallCount added in v0.8.0 

func (fake *FakeStorage) GetContextsCallCount() int

func (*FakeStorage) GetContextsCalls added in v0.8.0 

func (fake *FakeStorage) GetContextsCalls(stub func() []string)

func (*FakeStorage) GetContextsReturns added in v0.8.0 

func (fake *FakeStorage) GetContextsReturns(result1 []string)

func (*FakeStorage) GetContextsReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) GetContextsReturnsOnCall(i int, result1 []string)

func (*FakeStorage) GetContextsWithTasks added in v0.8.0 

func (fake *FakeStorage) GetContextsWithTasks() []string

func (*FakeStorage) GetContextsWithTasksCallCount added in v0.8.0 

func (fake *FakeStorage) GetContextsWithTasksCallCount() int

func (*FakeStorage) GetContextsWithTasksCalls added in v0.8.0 

func (fake *FakeStorage) GetContextsWithTasksCalls(stub func() []string)

func (*FakeStorage) GetContextsWithTasksReturns added in v0.8.0 

func (fake *FakeStorage) GetContextsWithTasksReturns(result1 []string)

func (*FakeStorage) GetContextsWithTasksReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) GetContextsWithTasksReturnsOnCall(i int, result1 []string)

func (*FakeStorage) GetQueueLength added in v0.8.0 

func (fake *FakeStorage) GetQueueLength() int

func (*FakeStorage) GetQueueLengthCallCount added in v0.8.0 

func (fake *FakeStorage) GetQueueLengthCallCount() int

func (*FakeStorage) GetQueueLengthCalls added in v0.8.0 

func (fake *FakeStorage) GetQueueLengthCalls(stub func() int)

func (*FakeStorage) GetQueueLengthReturns added in v0.8.0 

func (fake *FakeStorage) GetQueueLengthReturns(result1 int)

func (*FakeStorage) GetQueueLengthReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) GetQueueLengthReturnsOnCall(i int, result1 int)

func (*FakeStorage) GetStats added in v0.8.0 

func (fake *FakeStorage) GetStats() server.StorageStats

func (*FakeStorage) GetStatsCallCount added in v0.8.0 

func (fake *FakeStorage) GetStatsCallCount() int

func (*FakeStorage) GetStatsCalls added in v0.8.0 

func (fake *FakeStorage) GetStatsCalls(stub func() server.StorageStats)

func (*FakeStorage) GetStatsReturns added in v0.8.0 

func (fake *FakeStorage) GetStatsReturns(result1 server.StorageStats)

func (*FakeStorage) GetStatsReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) GetStatsReturnsOnCall(i int, result1 server.StorageStats)

func (*FakeStorage) GetTask added in v0.8.0 

func (fake *FakeStorage) GetTask(arg1 string) (*types.Task, bool)

func (*FakeStorage) GetTaskArgsForCall added in v0.8.0 

func (fake *FakeStorage) GetTaskArgsForCall(i int) string

func (*FakeStorage) GetTaskByContextAndID added in v0.8.0 

func (fake *FakeStorage) GetTaskByContextAndID(arg1 string, arg2 string) (*types.Task, bool)

func (*FakeStorage) GetTaskByContextAndIDArgsForCall added in v0.8.0 

func (fake *FakeStorage) GetTaskByContextAndIDArgsForCall(i int) (string, string)

func (*FakeStorage) GetTaskByContextAndIDCallCount added in v0.8.0 

func (fake *FakeStorage) GetTaskByContextAndIDCallCount() int

func (*FakeStorage) GetTaskByContextAndIDCalls added in v0.8.0 

func (fake *FakeStorage) GetTaskByContextAndIDCalls(stub func(string, string) (*types.Task, bool))

func (*FakeStorage) GetTaskByContextAndIDReturns added in v0.8.0 

func (fake *FakeStorage) GetTaskByContextAndIDReturns(result1 *types.Task, result2 bool)

func (*FakeStorage) GetTaskByContextAndIDReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) GetTaskByContextAndIDReturnsOnCall(i int, result1 *types.Task, result2 bool)

func (*FakeStorage) GetTaskCallCount added in v0.8.0 

func (fake *FakeStorage) GetTaskCallCount() int

func (*FakeStorage) GetTaskCalls added in v0.8.0 

func (fake *FakeStorage) GetTaskCalls(stub func(string) (*types.Task, bool))

func (*FakeStorage) GetTaskReturns added in v0.8.0 

func (fake *FakeStorage) GetTaskReturns(result1 *types.Task, result2 bool)

func (*FakeStorage) GetTaskReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) GetTaskReturnsOnCall(i int, result1 *types.Task, result2 bool)

func (*FakeStorage) Invocations added in v0.8.0 

func (fake *FakeStorage) Invocations() map[string][][]interface{}

func (*FakeStorage) ListTasks added in v0.8.0 

func (fake *FakeStorage) ListTasks(arg1 server.TaskFilter) ([]*types.Task, error)

func (*FakeStorage) ListTasksArgsForCall added in v0.8.0 

func (fake *FakeStorage) ListTasksArgsForCall(i int) server.TaskFilter

func (*FakeStorage) ListTasksByContext added in v0.8.0 

func (fake *FakeStorage) ListTasksByContext(arg1 string, arg2 server.TaskFilter) ([]*types.Task, error)

func (*FakeStorage) ListTasksByContextArgsForCall added in v0.8.0 

func (fake *FakeStorage) ListTasksByContextArgsForCall(i int) (string, server.TaskFilter)

func (*FakeStorage) ListTasksByContextCallCount added in v0.8.0 

func (fake *FakeStorage) ListTasksByContextCallCount() int

func (*FakeStorage) ListTasksByContextCalls added in v0.8.0 

func (fake *FakeStorage) ListTasksByContextCalls(stub func(string, server.TaskFilter) ([]*types.Task, error))

func (*FakeStorage) ListTasksByContextReturns added in v0.8.0 

func (fake *FakeStorage) ListTasksByContextReturns(result1 []*types.Task, result2 error)

func (*FakeStorage) ListTasksByContextReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) ListTasksByContextReturnsOnCall(i int, result1 []*types.Task, result2 error)

func (*FakeStorage) ListTasksCallCount added in v0.8.0 

func (fake *FakeStorage) ListTasksCallCount() int

func (*FakeStorage) ListTasksCalls added in v0.8.0 

func (fake *FakeStorage) ListTasksCalls(stub func(server.TaskFilter) ([]*types.Task, error))

func (*FakeStorage) ListTasksReturns added in v0.8.0 

func (fake *FakeStorage) ListTasksReturns(result1 []*types.Task, result2 error)

func (*FakeStorage) ListTasksReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) ListTasksReturnsOnCall(i int, result1 []*types.Task, result2 error)

func (*FakeStorage) StoreDeadLetterTask added in v0.8.0 

func (fake *FakeStorage) StoreDeadLetterTask(arg1 *types.Task) error

func (*FakeStorage) StoreDeadLetterTaskArgsForCall added in v0.8.0 

func (fake *FakeStorage) StoreDeadLetterTaskArgsForCall(i int) *types.Task

func (*FakeStorage) StoreDeadLetterTaskCallCount added in v0.8.0 

func (fake *FakeStorage) StoreDeadLetterTaskCallCount() int

func (*FakeStorage) StoreDeadLetterTaskCalls added in v0.8.0 

func (fake *FakeStorage) StoreDeadLetterTaskCalls(stub func(*types.Task) error)

func (*FakeStorage) StoreDeadLetterTaskReturns added in v0.8.0 

func (fake *FakeStorage) StoreDeadLetterTaskReturns(result1 error)

func (*FakeStorage) StoreDeadLetterTaskReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) StoreDeadLetterTaskReturnsOnCall(i int, result1 error)

func (*FakeStorage) UpdateActiveTask added in v0.8.0 

func (fake *FakeStorage) UpdateActiveTask(arg1 *types.Task) error

func (*FakeStorage) UpdateActiveTaskArgsForCall added in v0.8.0 

func (fake *FakeStorage) UpdateActiveTaskArgsForCall(i int) *types.Task

func (*FakeStorage) UpdateActiveTaskCallCount added in v0.8.0 

func (fake *FakeStorage) UpdateActiveTaskCallCount() int

func (*FakeStorage) UpdateActiveTaskCalls added in v0.8.0 

func (fake *FakeStorage) UpdateActiveTaskCalls(stub func(*types.Task) error)

func (*FakeStorage) UpdateActiveTaskReturns added in v0.8.0 

func (fake *FakeStorage) UpdateActiveTaskReturns(result1 error)

func (*FakeStorage) UpdateActiveTaskReturnsOnCall added in v0.8.0 

func (fake *FakeStorage) UpdateActiveTaskReturnsOnCall(i int, result1 error)

type FakeTaskHandler 

type FakeTaskHandler struct {
	HandleTaskStub func(context.Context, *types.Task, *types.Message, server.OpenAICompatibleAgent) (*types.Task, error)
	// contains filtered or unexported fields
}

func (*FakeTaskHandler) HandleTask 

func (fake *FakeTaskHandler) HandleTask(arg1 context.Context, arg2 *types.Task, arg3 *types.Message, arg4 server.OpenAICompatibleAgent) (*types.Task, error)

func (*FakeTaskHandler) HandleTaskArgsForCall 

func (fake *FakeTaskHandler) HandleTaskArgsForCall(i int) (context.Context, *types.Task, *types.Message, server.OpenAICompatibleAgent)

func (*FakeTaskHandler) HandleTaskCallCount 

func (fake *FakeTaskHandler) HandleTaskCallCount() int

func (*FakeTaskHandler) HandleTaskCalls 

func (fake *FakeTaskHandler) HandleTaskCalls(stub func(context.Context, *types.Task, *types.Message, server.OpenAICompatibleAgent) (*types.Task, error))

func (*FakeTaskHandler) HandleTaskReturns 

func (fake *FakeTaskHandler) HandleTaskReturns(result1 *types.Task, result2 error)

func (*FakeTaskHandler) HandleTaskReturnsOnCall 

func (fake *FakeTaskHandler) HandleTaskReturnsOnCall(i int, result1 *types.Task, result2 error)

func (*FakeTaskHandler) Invocations 

func (fake *FakeTaskHandler) Invocations() map[string][][]interface{}

type FakeTaskManager 

type FakeTaskManager struct {
	CancelTaskStub func(string) error

	CleanupCompletedTasksStub func()

	CreateTaskStub func(string, types.TaskState, *types.Message) *types.Task

	CreateTaskWithHistoryStub func(string, types.TaskState, *types.Message, []types.Message) *types.Task

	DeleteTaskPushNotificationConfigStub func(types.DeleteTaskPushNotificationConfigParams) error

	GetConversationHistoryStub func(string) []types.Message

	GetTaskStub func(string) (*types.Task, bool)

	GetTaskPushNotificationConfigStub func(types.GetTaskPushNotificationConfigParams) (*types.TaskPushNotificationConfig, error)

	IsTaskPausedStub func(string) (bool, error)

	ListTaskPushNotificationConfigsStub func(types.ListTaskPushNotificationConfigParams) ([]types.TaskPushNotificationConfig, error)

	ListTasksStub func(types.TaskListParams) (*types.TaskList, error)

	PauseTaskForInputStub func(string, *types.Message) error

	PollTaskStatusStub func(string, time.Duration, time.Duration) (*types.Task, error)

	ResumeTaskWithInputStub func(string, *types.Message) error

	SetRetentionConfigStub func(config.TaskRetentionConfig)

	SetTaskPushNotificationConfigStub func(types.TaskPushNotificationConfig) (*types.TaskPushNotificationConfig, error)

	StopCleanupStub func()

	UpdateConversationHistoryStub func(string, []types.Message)

	UpdateErrorStub func(string, *types.Message) error

	UpdateStateStub func(string, types.TaskState) error

	UpdateTaskStub func(*types.Task) error
	// contains filtered or unexported fields
}

func (*FakeTaskManager) CancelTask 

func (fake *FakeTaskManager) CancelTask(arg1 string) error

func (*FakeTaskManager) CancelTaskArgsForCall 

func (fake *FakeTaskManager) CancelTaskArgsForCall(i int) string

func (*FakeTaskManager) CancelTaskCallCount 

func (fake *FakeTaskManager) CancelTaskCallCount() int

func (*FakeTaskManager) CancelTaskCalls 

func (fake *FakeTaskManager) CancelTaskCalls(stub func(string) error)

func (*FakeTaskManager) CancelTaskReturns 

func (fake *FakeTaskManager) CancelTaskReturns(result1 error)

func (*FakeTaskManager) CancelTaskReturnsOnCall 

func (fake *FakeTaskManager) CancelTaskReturnsOnCall(i int, result1 error)

func (*FakeTaskManager) CleanupCompletedTasks 

func (fake *FakeTaskManager) CleanupCompletedTasks()

func (*FakeTaskManager) CleanupCompletedTasksCallCount 

func (fake *FakeTaskManager) CleanupCompletedTasksCallCount() int

func (*FakeTaskManager) CleanupCompletedTasksCalls 

func (fake *FakeTaskManager) CleanupCompletedTasksCalls(stub func())

func (*FakeTaskManager) CreateTask 

func (fake *FakeTaskManager) CreateTask(arg1 string, arg2 types.TaskState, arg3 *types.Message) *types.Task

func (*FakeTaskManager) CreateTaskArgsForCall 

func (fake *FakeTaskManager) CreateTaskArgsForCall(i int) (string, types.TaskState, *types.Message)

func (*FakeTaskManager) CreateTaskCallCount 

func (fake *FakeTaskManager) CreateTaskCallCount() int

func (*FakeTaskManager) CreateTaskCalls 

func (fake *FakeTaskManager) CreateTaskCalls(stub func(string, types.TaskState, *types.Message) *types.Task)

func (*FakeTaskManager) CreateTaskReturns 

func (fake *FakeTaskManager) CreateTaskReturns(result1 *types.Task)

func (*FakeTaskManager) CreateTaskReturnsOnCall 

func (fake *FakeTaskManager) CreateTaskReturnsOnCall(i int, result1 *types.Task)

func (*FakeTaskManager) CreateTaskWithHistory added in v0.8.0 

func (fake *FakeTaskManager) CreateTaskWithHistory(arg1 string, arg2 types.TaskState, arg3 *types.Message, arg4 []types.Message) *types.Task

func (*FakeTaskManager) CreateTaskWithHistoryArgsForCall added in v0.8.0 

func (fake *FakeTaskManager) CreateTaskWithHistoryArgsForCall(i int) (string, types.TaskState, *types.Message, []types.Message)

func (*FakeTaskManager) CreateTaskWithHistoryCallCount added in v0.8.0 

func (fake *FakeTaskManager) CreateTaskWithHistoryCallCount() int

func (*FakeTaskManager) CreateTaskWithHistoryCalls added in v0.8.0 

func (fake *FakeTaskManager) CreateTaskWithHistoryCalls(stub func(string, types.TaskState, *types.Message, []types.Message) *types.Task)

func (*FakeTaskManager) CreateTaskWithHistoryReturns added in v0.8.0 

func (fake *FakeTaskManager) CreateTaskWithHistoryReturns(result1 *types.Task)

func (*FakeTaskManager) CreateTaskWithHistoryReturnsOnCall added in v0.8.0 

func (fake *FakeTaskManager) CreateTaskWithHistoryReturnsOnCall(i int, result1 *types.Task)

func (*FakeTaskManager) DeleteTaskPushNotificationConfig 

func (fake *FakeTaskManager) DeleteTaskPushNotificationConfig(arg1 types.DeleteTaskPushNotificationConfigParams) error

func (*FakeTaskManager) DeleteTaskPushNotificationConfigArgsForCall 

func (fake *FakeTaskManager) DeleteTaskPushNotificationConfigArgsForCall(i int) types.DeleteTaskPushNotificationConfigParams

func (*FakeTaskManager) DeleteTaskPushNotificationConfigCallCount 

func (fake *FakeTaskManager) DeleteTaskPushNotificationConfigCallCount() int

func (*FakeTaskManager) DeleteTaskPushNotificationConfigCalls 

func (fake *FakeTaskManager) DeleteTaskPushNotificationConfigCalls(stub func(types.DeleteTaskPushNotificationConfigParams) error)

func (*FakeTaskManager) DeleteTaskPushNotificationConfigReturns 

func (fake *FakeTaskManager) DeleteTaskPushNotificationConfigReturns(result1 error)

func (*FakeTaskManager) DeleteTaskPushNotificationConfigReturnsOnCall 

func (fake *FakeTaskManager) DeleteTaskPushNotificationConfigReturnsOnCall(i int, result1 error)

func (*FakeTaskManager) GetConversationHistory 

func (fake *FakeTaskManager) GetConversationHistory(arg1 string) []types.Message

func (*FakeTaskManager) GetConversationHistoryArgsForCall 

func (fake *FakeTaskManager) GetConversationHistoryArgsForCall(i int) string

func (*FakeTaskManager) GetConversationHistoryCallCount 

func (fake *FakeTaskManager) GetConversationHistoryCallCount() int

func (*FakeTaskManager) GetConversationHistoryCalls 

func (fake *FakeTaskManager) GetConversationHistoryCalls(stub func(string) []types.Message)

func (*FakeTaskManager) GetConversationHistoryReturns 

func (fake *FakeTaskManager) GetConversationHistoryReturns(result1 []types.Message)

func (*FakeTaskManager) GetConversationHistoryReturnsOnCall 

func (fake *FakeTaskManager) GetConversationHistoryReturnsOnCall(i int, result1 []types.Message)

func (*FakeTaskManager) GetTask 

func (fake *FakeTaskManager) GetTask(arg1 string) (*types.Task, bool)

func (*FakeTaskManager) GetTaskArgsForCall 

func (fake *FakeTaskManager) GetTaskArgsForCall(i int) string

func (*FakeTaskManager) GetTaskCallCount 

func (fake *FakeTaskManager) GetTaskCallCount() int

func (*FakeTaskManager) GetTaskCalls 

func (fake *FakeTaskManager) GetTaskCalls(stub func(string) (*types.Task, bool))

func (*FakeTaskManager) GetTaskPushNotificationConfig 

func (fake *FakeTaskManager) GetTaskPushNotificationConfig(arg1 types.GetTaskPushNotificationConfigParams) (*types.TaskPushNotificationConfig, error)

func (*FakeTaskManager) GetTaskPushNotificationConfigArgsForCall 

func (fake *FakeTaskManager) GetTaskPushNotificationConfigArgsForCall(i int) types.GetTaskPushNotificationConfigParams

func (*FakeTaskManager) GetTaskPushNotificationConfigCallCount 

func (fake *FakeTaskManager) GetTaskPushNotificationConfigCallCount() int

func (*FakeTaskManager) GetTaskPushNotificationConfigCalls 

func (fake *FakeTaskManager) GetTaskPushNotificationConfigCalls(stub func(types.GetTaskPushNotificationConfigParams) (*types.TaskPushNotificationConfig, error))

func (*FakeTaskManager) GetTaskPushNotificationConfigReturns 

func (fake *FakeTaskManager) GetTaskPushNotificationConfigReturns(result1 *types.TaskPushNotificationConfig, result2 error)

func (*FakeTaskManager) GetTaskPushNotificationConfigReturnsOnCall 

func (fake *FakeTaskManager) GetTaskPushNotificationConfigReturnsOnCall(i int, result1 *types.TaskPushNotificationConfig, result2 error)

func (*FakeTaskManager) GetTaskReturns 

func (fake *FakeTaskManager) GetTaskReturns(result1 *types.Task, result2 bool)

func (*FakeTaskManager) GetTaskReturnsOnCall 

func (fake *FakeTaskManager) GetTaskReturnsOnCall(i int, result1 *types.Task, result2 bool)

func (*FakeTaskManager) Invocations 

func (fake *FakeTaskManager) Invocations() map[string][][]interface{}

func (*FakeTaskManager) IsTaskPaused added in v0.8.0 

func (fake *FakeTaskManager) IsTaskPaused(arg1 string) (bool, error)

func (*FakeTaskManager) IsTaskPausedArgsForCall added in v0.8.0 

func (fake *FakeTaskManager) IsTaskPausedArgsForCall(i int) string

func (*FakeTaskManager) IsTaskPausedCallCount added in v0.8.0 

func (fake *FakeTaskManager) IsTaskPausedCallCount() int

func (*FakeTaskManager) IsTaskPausedCalls added in v0.8.0 

func (fake *FakeTaskManager) IsTaskPausedCalls(stub func(string) (bool, error))

func (*FakeTaskManager) IsTaskPausedReturns added in v0.8.0 

func (fake *FakeTaskManager) IsTaskPausedReturns(result1 bool, result2 error)

func (*FakeTaskManager) IsTaskPausedReturnsOnCall added in v0.8.0 

func (fake *FakeTaskManager) IsTaskPausedReturnsOnCall(i int, result1 bool, result2 error)

func (*FakeTaskManager) ListTaskPushNotificationConfigs 

func (fake *FakeTaskManager) ListTaskPushNotificationConfigs(arg1 types.ListTaskPushNotificationConfigParams) ([]types.TaskPushNotificationConfig, error)

func (*FakeTaskManager) ListTaskPushNotificationConfigsArgsForCall 

func (fake *FakeTaskManager) ListTaskPushNotificationConfigsArgsForCall(i int) types.ListTaskPushNotificationConfigParams

func (*FakeTaskManager) ListTaskPushNotificationConfigsCallCount 

func (fake *FakeTaskManager) ListTaskPushNotificationConfigsCallCount() int

func (*FakeTaskManager) ListTaskPushNotificationConfigsCalls 

func (fake *FakeTaskManager) ListTaskPushNotificationConfigsCalls(stub func(types.ListTaskPushNotificationConfigParams) ([]types.TaskPushNotificationConfig, error))

func (*FakeTaskManager) ListTaskPushNotificationConfigsReturns 

func (fake *FakeTaskManager) ListTaskPushNotificationConfigsReturns(result1 []types.TaskPushNotificationConfig, result2 error)

func (*FakeTaskManager) ListTaskPushNotificationConfigsReturnsOnCall 

func (fake *FakeTaskManager) ListTaskPushNotificationConfigsReturnsOnCall(i int, result1 []types.TaskPushNotificationConfig, result2 error)

func (*FakeTaskManager) ListTasks 

func (fake *FakeTaskManager) ListTasks(arg1 types.TaskListParams) (*types.TaskList, error)

func (*FakeTaskManager) ListTasksArgsForCall 

func (fake *FakeTaskManager) ListTasksArgsForCall(i int) types.TaskListParams

func (*FakeTaskManager) ListTasksCallCount 

func (fake *FakeTaskManager) ListTasksCallCount() int

func (*FakeTaskManager) ListTasksCalls 

func (fake *FakeTaskManager) ListTasksCalls(stub func(types.TaskListParams) (*types.TaskList, error))

func (*FakeTaskManager) ListTasksReturns 

func (fake *FakeTaskManager) ListTasksReturns(result1 *types.TaskList, result2 error)

func (*FakeTaskManager) ListTasksReturnsOnCall 

func (fake *FakeTaskManager) ListTasksReturnsOnCall(i int, result1 *types.TaskList, result2 error)

func (*FakeTaskManager) PauseTaskForInput added in v0.8.0 

func (fake *FakeTaskManager) PauseTaskForInput(arg1 string, arg2 *types.Message) error

func (*FakeTaskManager) PauseTaskForInputArgsForCall added in v0.8.0 

func (fake *FakeTaskManager) PauseTaskForInputArgsForCall(i int) (string, *types.Message)

func (*FakeTaskManager) PauseTaskForInputCallCount added in v0.8.0 

func (fake *FakeTaskManager) PauseTaskForInputCallCount() int

func (*FakeTaskManager) PauseTaskForInputCalls added in v0.8.0 

func (fake *FakeTaskManager) PauseTaskForInputCalls(stub func(string, *types.Message) error)

func (*FakeTaskManager) PauseTaskForInputReturns added in v0.8.0 

func (fake *FakeTaskManager) PauseTaskForInputReturns(result1 error)

func (*FakeTaskManager) PauseTaskForInputReturnsOnCall added in v0.8.0 

func (fake *FakeTaskManager) PauseTaskForInputReturnsOnCall(i int, result1 error)

func (*FakeTaskManager) PollTaskStatus 

func (fake *FakeTaskManager) PollTaskStatus(arg1 string, arg2 time.Duration, arg3 time.Duration) (*types.Task, error)

func (*FakeTaskManager) PollTaskStatusArgsForCall 

func (fake *FakeTaskManager) PollTaskStatusArgsForCall(i int) (string, time.Duration, time.Duration)

func (*FakeTaskManager) PollTaskStatusCallCount 

func (fake *FakeTaskManager) PollTaskStatusCallCount() int

func (*FakeTaskManager) PollTaskStatusCalls 

func (fake *FakeTaskManager) PollTaskStatusCalls(stub func(string, time.Duration, time.Duration) (*types.Task, error))

func (*FakeTaskManager) PollTaskStatusReturns 

func (fake *FakeTaskManager) PollTaskStatusReturns(result1 *types.Task, result2 error)

func (*FakeTaskManager) PollTaskStatusReturnsOnCall 

func (fake *FakeTaskManager) PollTaskStatusReturnsOnCall(i int, result1 *types.Task, result2 error)

func (*FakeTaskManager) ResumeTaskWithInput added in v0.8.0 

func (fake *FakeTaskManager) ResumeTaskWithInput(arg1 string, arg2 *types.Message) error

func (*FakeTaskManager) ResumeTaskWithInputArgsForCall added in v0.8.0 

func (fake *FakeTaskManager) ResumeTaskWithInputArgsForCall(i int) (string, *types.Message)

func (*FakeTaskManager) ResumeTaskWithInputCallCount added in v0.8.0 

func (fake *FakeTaskManager) ResumeTaskWithInputCallCount() int

func (*FakeTaskManager) ResumeTaskWithInputCalls added in v0.8.0 

func (fake *FakeTaskManager) ResumeTaskWithInputCalls(stub func(string, *types.Message) error)

func (*FakeTaskManager) ResumeTaskWithInputReturns added in v0.8.0 

func (fake *FakeTaskManager) ResumeTaskWithInputReturns(result1 error)

func (*FakeTaskManager) ResumeTaskWithInputReturnsOnCall added in v0.8.0 

func (fake *FakeTaskManager) ResumeTaskWithInputReturnsOnCall(i int, result1 error)

func (*FakeTaskManager) SetRetentionConfig added in v0.8.0 

func (fake *FakeTaskManager) SetRetentionConfig(arg1 config.TaskRetentionConfig)

func (*FakeTaskManager) SetRetentionConfigArgsForCall added in v0.8.0 

func (fake *FakeTaskManager) SetRetentionConfigArgsForCall(i int) config.TaskRetentionConfig

func (*FakeTaskManager) SetRetentionConfigCallCount added in v0.8.0 

func (fake *FakeTaskManager) SetRetentionConfigCallCount() int

func (*FakeTaskManager) SetRetentionConfigCalls added in v0.8.0 

func (fake *FakeTaskManager) SetRetentionConfigCalls(stub func(config.TaskRetentionConfig))

func (*FakeTaskManager) SetTaskPushNotificationConfig 

func (fake *FakeTaskManager) SetTaskPushNotificationConfig(arg1 types.TaskPushNotificationConfig) (*types.TaskPushNotificationConfig, error)

func (*FakeTaskManager) SetTaskPushNotificationConfigArgsForCall 

func (fake *FakeTaskManager) SetTaskPushNotificationConfigArgsForCall(i int) types.TaskPushNotificationConfig

func (*FakeTaskManager) SetTaskPushNotificationConfigCallCount 

func (fake *FakeTaskManager) SetTaskPushNotificationConfigCallCount() int

func (*FakeTaskManager) SetTaskPushNotificationConfigCalls 

func (fake *FakeTaskManager) SetTaskPushNotificationConfigCalls(stub func(types.TaskPushNotificationConfig) (*types.TaskPushNotificationConfig, error))

func (*FakeTaskManager) SetTaskPushNotificationConfigReturns 

func (fake *FakeTaskManager) SetTaskPushNotificationConfigReturns(result1 *types.TaskPushNotificationConfig, result2 error)

func (*FakeTaskManager) SetTaskPushNotificationConfigReturnsOnCall 

func (fake *FakeTaskManager) SetTaskPushNotificationConfigReturnsOnCall(i int, result1 *types.TaskPushNotificationConfig, result2 error)

func (*FakeTaskManager) StopCleanup added in v0.8.0 

func (fake *FakeTaskManager) StopCleanup()

func (*FakeTaskManager) StopCleanupCallCount added in v0.8.0 

func (fake *FakeTaskManager) StopCleanupCallCount() int

func (*FakeTaskManager) StopCleanupCalls added in v0.8.0 

func (fake *FakeTaskManager) StopCleanupCalls(stub func())

func (*FakeTaskManager) UpdateConversationHistory 

func (fake *FakeTaskManager) UpdateConversationHistory(arg1 string, arg2 []types.Message)

func (*FakeTaskManager) UpdateConversationHistoryArgsForCall 

func (fake *FakeTaskManager) UpdateConversationHistoryArgsForCall(i int) (string, []types.Message)

func (*FakeTaskManager) UpdateConversationHistoryCallCount 

func (fake *FakeTaskManager) UpdateConversationHistoryCallCount() int

func (*FakeTaskManager) UpdateConversationHistoryCalls 

func (fake *FakeTaskManager) UpdateConversationHistoryCalls(stub func(string, []types.Message))

func (*FakeTaskManager) UpdateError added in v0.8.0 

func (fake *FakeTaskManager) UpdateError(arg1 string, arg2 *types.Message) error

func (*FakeTaskManager) UpdateErrorArgsForCall added in v0.8.0 

func (fake *FakeTaskManager) UpdateErrorArgsForCall(i int) (string, *types.Message)

func (*FakeTaskManager) UpdateErrorCallCount added in v0.8.0 

func (fake *FakeTaskManager) UpdateErrorCallCount() int

func (*FakeTaskManager) UpdateErrorCalls added in v0.8.0 

func (fake *FakeTaskManager) UpdateErrorCalls(stub func(string, *types.Message) error)

func (*FakeTaskManager) UpdateErrorReturns added in v0.8.0 

func (fake *FakeTaskManager) UpdateErrorReturns(result1 error)

func (*FakeTaskManager) UpdateErrorReturnsOnCall added in v0.8.0 

func (fake *FakeTaskManager) UpdateErrorReturnsOnCall(i int, result1 error)

func (*FakeTaskManager) UpdateState added in v0.8.0 

func (fake *FakeTaskManager) UpdateState(arg1 string, arg2 types.TaskState) error

func (*FakeTaskManager) UpdateStateArgsForCall added in v0.8.0 

func (fake *FakeTaskManager) UpdateStateArgsForCall(i int) (string, types.TaskState)

func (*FakeTaskManager) UpdateStateCallCount added in v0.8.0 

func (fake *FakeTaskManager) UpdateStateCallCount() int

func (*FakeTaskManager) UpdateStateCalls added in v0.8.0 

func (fake *FakeTaskManager) UpdateStateCalls(stub func(string, types.TaskState) error)

func (*FakeTaskManager) UpdateStateReturns added in v0.8.0 

func (fake *FakeTaskManager) UpdateStateReturns(result1 error)

func (*FakeTaskManager) UpdateStateReturnsOnCall added in v0.8.0 

func (fake *FakeTaskManager) UpdateStateReturnsOnCall(i int, result1 error)

func (*FakeTaskManager) UpdateTask 

func (fake *FakeTaskManager) UpdateTask(arg1 *types.Task) error

func (*FakeTaskManager) UpdateTaskArgsForCall 

func (fake *FakeTaskManager) UpdateTaskArgsForCall(i int) *types.Task

func (*FakeTaskManager) UpdateTaskCallCount 

func (fake *FakeTaskManager) UpdateTaskCallCount() int

func (*FakeTaskManager) UpdateTaskCalls 

func (fake *FakeTaskManager) UpdateTaskCalls(stub func(*types.Task) error)

func (*FakeTaskManager) UpdateTaskReturns 

func (fake *FakeTaskManager) UpdateTaskReturns(result1 error)

func (*FakeTaskManager) UpdateTaskReturnsOnCall 

func (fake *FakeTaskManager) UpdateTaskReturnsOnCall(i int, result1 error)

type FakeTaskResultProcessor 

type FakeTaskResultProcessor struct {
	ProcessToolResultStub func(string) *types.Message
	// contains filtered or unexported fields
}

func (*FakeTaskResultProcessor) Invocations 

func (fake *FakeTaskResultProcessor) Invocations() map[string][][]interface{}

func (*FakeTaskResultProcessor) ProcessToolResult 

func (fake *FakeTaskResultProcessor) ProcessToolResult(arg1 string) *types.Message

func (*FakeTaskResultProcessor) ProcessToolResultArgsForCall 

func (fake *FakeTaskResultProcessor) ProcessToolResultArgsForCall(i int) string

func (*FakeTaskResultProcessor) ProcessToolResultCallCount 

func (fake *FakeTaskResultProcessor) ProcessToolResultCallCount() int

func (*FakeTaskResultProcessor) ProcessToolResultCalls 

func (fake *FakeTaskResultProcessor) ProcessToolResultCalls(stub func(string) *types.Message)

func (*FakeTaskResultProcessor) ProcessToolResultReturns 

func (fake *FakeTaskResultProcessor) ProcessToolResultReturns(result1 *types.Message)

func (*FakeTaskResultProcessor) ProcessToolResultReturnsOnCall 

func (fake *FakeTaskResultProcessor) ProcessToolResultReturnsOnCall(i int, result1 *types.Message)

type FakeTelemetry 

type FakeTelemetry struct {
	MiddlewareStub func() gin.HandlerFunc
	// contains filtered or unexported fields
}

func (*FakeTelemetry) Invocations 

func (fake *FakeTelemetry) Invocations() map[string][][]interface{}

func (*FakeTelemetry) Middleware 

func (fake *FakeTelemetry) Middleware() gin.HandlerFunc

func (*FakeTelemetry) MiddlewareCallCount 

func (fake *FakeTelemetry) MiddlewareCallCount() int

func (*FakeTelemetry) MiddlewareCalls 

func (fake *FakeTelemetry) MiddlewareCalls(stub func() gin.HandlerFunc)

func (*FakeTelemetry) MiddlewareReturns 

func (fake *FakeTelemetry) MiddlewareReturns(result1 gin.HandlerFunc)

func (*FakeTelemetry) MiddlewareReturnsOnCall 

func (fake *FakeTelemetry) MiddlewareReturnsOnCall(i int, result1 gin.HandlerFunc)

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.