mocks

package
v0.17.0 Latest Latest
Warning

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

 Go to latest Published: Dec 30, 2025 License: MIT Imports: 13 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.

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 FakeA2AProtocolHandler added in v0.9.4 

type FakeA2AProtocolHandler struct {
	HandleMessageSendStub func(*gin.Context, types.JSONRPCRequest)

	HandleMessageStreamStub func(*gin.Context, types.JSONRPCRequest, server.StreamableTaskHandler)

	HandleTaskCancelStub func(*gin.Context, types.JSONRPCRequest)

	HandleTaskGetStub func(*gin.Context, types.JSONRPCRequest)

	HandleTaskListStub func(*gin.Context, types.JSONRPCRequest)

	HandleTaskPushNotificationConfigDeleteStub func(*gin.Context, types.JSONRPCRequest)

	HandleTaskPushNotificationConfigGetStub func(*gin.Context, types.JSONRPCRequest)

	HandleTaskPushNotificationConfigListStub func(*gin.Context, types.JSONRPCRequest)

	HandleTaskPushNotificationConfigSetStub func(*gin.Context, types.JSONRPCRequest)
	// contains filtered or unexported fields
}

func (*FakeA2AProtocolHandler) HandleMessageSend added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleMessageSend(arg1 *gin.Context, arg2 types.JSONRPCRequest)

func (*FakeA2AProtocolHandler) HandleMessageSendArgsForCall added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleMessageSendArgsForCall(i int) (*gin.Context, types.JSONRPCRequest)

func (*FakeA2AProtocolHandler) HandleMessageSendCallCount added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleMessageSendCallCount() int

func (*FakeA2AProtocolHandler) HandleMessageSendCalls added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleMessageSendCalls(stub func(*gin.Context, types.JSONRPCRequest))

func (*FakeA2AProtocolHandler) HandleMessageStream added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleMessageStream(arg1 *gin.Context, arg2 types.JSONRPCRequest, arg3 server.StreamableTaskHandler)

func (*FakeA2AProtocolHandler) HandleMessageStreamArgsForCall added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleMessageStreamArgsForCall(i int) (*gin.Context, types.JSONRPCRequest, server.StreamableTaskHandler)

func (*FakeA2AProtocolHandler) HandleMessageStreamCallCount added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleMessageStreamCallCount() int

func (*FakeA2AProtocolHandler) HandleMessageStreamCalls added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleMessageStreamCalls(stub func(*gin.Context, types.JSONRPCRequest, server.StreamableTaskHandler))

func (*FakeA2AProtocolHandler) HandleTaskCancel added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskCancel(arg1 *gin.Context, arg2 types.JSONRPCRequest)

func (*FakeA2AProtocolHandler) HandleTaskCancelArgsForCall added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskCancelArgsForCall(i int) (*gin.Context, types.JSONRPCRequest)

func (*FakeA2AProtocolHandler) HandleTaskCancelCallCount added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskCancelCallCount() int

func (*FakeA2AProtocolHandler) HandleTaskCancelCalls added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskCancelCalls(stub func(*gin.Context, types.JSONRPCRequest))

func (*FakeA2AProtocolHandler) HandleTaskGet added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskGet(arg1 *gin.Context, arg2 types.JSONRPCRequest)

func (*FakeA2AProtocolHandler) HandleTaskGetArgsForCall added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskGetArgsForCall(i int) (*gin.Context, types.JSONRPCRequest)

func (*FakeA2AProtocolHandler) HandleTaskGetCallCount added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskGetCallCount() int

func (*FakeA2AProtocolHandler) HandleTaskGetCalls added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskGetCalls(stub func(*gin.Context, types.JSONRPCRequest))

func (*FakeA2AProtocolHandler) HandleTaskList added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskList(arg1 *gin.Context, arg2 types.JSONRPCRequest)

func (*FakeA2AProtocolHandler) HandleTaskListArgsForCall added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskListArgsForCall(i int) (*gin.Context, types.JSONRPCRequest)

func (*FakeA2AProtocolHandler) HandleTaskListCallCount added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskListCallCount() int

func (*FakeA2AProtocolHandler) HandleTaskListCalls added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskListCalls(stub func(*gin.Context, types.JSONRPCRequest))

func (*FakeA2AProtocolHandler) HandleTaskPushNotificationConfigDelete added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskPushNotificationConfigDelete(arg1 *gin.Context, arg2 types.JSONRPCRequest)

func (*FakeA2AProtocolHandler) HandleTaskPushNotificationConfigDeleteArgsForCall added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskPushNotificationConfigDeleteArgsForCall(i int) (*gin.Context, types.JSONRPCRequest)

func (*FakeA2AProtocolHandler) HandleTaskPushNotificationConfigDeleteCallCount added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskPushNotificationConfigDeleteCallCount() int

func (*FakeA2AProtocolHandler) HandleTaskPushNotificationConfigDeleteCalls added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskPushNotificationConfigDeleteCalls(stub func(*gin.Context, types.JSONRPCRequest))

func (*FakeA2AProtocolHandler) HandleTaskPushNotificationConfigGet added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskPushNotificationConfigGet(arg1 *gin.Context, arg2 types.JSONRPCRequest)

func (*FakeA2AProtocolHandler) HandleTaskPushNotificationConfigGetArgsForCall added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskPushNotificationConfigGetArgsForCall(i int) (*gin.Context, types.JSONRPCRequest)

func (*FakeA2AProtocolHandler) HandleTaskPushNotificationConfigGetCallCount added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskPushNotificationConfigGetCallCount() int

func (*FakeA2AProtocolHandler) HandleTaskPushNotificationConfigGetCalls added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskPushNotificationConfigGetCalls(stub func(*gin.Context, types.JSONRPCRequest))

func (*FakeA2AProtocolHandler) HandleTaskPushNotificationConfigList added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskPushNotificationConfigList(arg1 *gin.Context, arg2 types.JSONRPCRequest)

func (*FakeA2AProtocolHandler) HandleTaskPushNotificationConfigListArgsForCall added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskPushNotificationConfigListArgsForCall(i int) (*gin.Context, types.JSONRPCRequest)

func (*FakeA2AProtocolHandler) HandleTaskPushNotificationConfigListCallCount added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskPushNotificationConfigListCallCount() int

func (*FakeA2AProtocolHandler) HandleTaskPushNotificationConfigListCalls added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskPushNotificationConfigListCalls(stub func(*gin.Context, types.JSONRPCRequest))

func (*FakeA2AProtocolHandler) HandleTaskPushNotificationConfigSet added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskPushNotificationConfigSet(arg1 *gin.Context, arg2 types.JSONRPCRequest)

func (*FakeA2AProtocolHandler) HandleTaskPushNotificationConfigSetArgsForCall added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskPushNotificationConfigSetArgsForCall(i int) (*gin.Context, types.JSONRPCRequest)

func (*FakeA2AProtocolHandler) HandleTaskPushNotificationConfigSetCallCount added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskPushNotificationConfigSetCallCount() int

func (*FakeA2AProtocolHandler) HandleTaskPushNotificationConfigSetCalls added in v0.9.4 

func (fake *FakeA2AProtocolHandler) HandleTaskPushNotificationConfigSetCalls(stub func(*gin.Context, types.JSONRPCRequest))

func (*FakeA2AProtocolHandler) Invocations added in v0.9.4 

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

type FakeA2AServer 

type FakeA2AServer struct {
	GetAgentStub func() server.OpenAICompatibleAgent

	GetAgentCardStub func() *types.AgentCard

	GetBackgroundTaskHandlerStub func() server.TaskHandler

	GetStreamingTaskHandlerStub func() server.StreamableTaskHandler

	LoadAgentCardFromFileStub func(string, map[string]any) error

	SetAgentStub func(server.OpenAICompatibleAgent)

	SetAgentCardStub func(types.AgentCard)

	SetAgentDescriptionStub func(string)

	SetAgentNameStub func(string)

	SetAgentURLStub func(string)

	SetAgentVersionStub func(string)

	SetBackgroundTaskHandlerStub func(server.TaskHandler)

	SetStreamingTaskHandlerStub func(server.StreamableTaskHandler)

	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) GetBackgroundTaskHandler added in v0.9.0 

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

func (*FakeA2AServer) GetBackgroundTaskHandlerCallCount added in v0.9.0 

func (fake *FakeA2AServer) GetBackgroundTaskHandlerCallCount() int

func (*FakeA2AServer) GetBackgroundTaskHandlerCalls added in v0.9.0 

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

func (*FakeA2AServer) GetBackgroundTaskHandlerReturns added in v0.9.0 

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

func (*FakeA2AServer) GetBackgroundTaskHandlerReturnsOnCall added in v0.9.0 

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

func (*FakeA2AServer) GetStreamingTaskHandler added in v0.9.0 

func (fake *FakeA2AServer) GetStreamingTaskHandler() server.StreamableTaskHandler

func (*FakeA2AServer) GetStreamingTaskHandlerCallCount added in v0.9.0 

func (fake *FakeA2AServer) GetStreamingTaskHandlerCallCount() int

func (*FakeA2AServer) GetStreamingTaskHandlerCalls added in v0.9.0 

func (fake *FakeA2AServer) GetStreamingTaskHandlerCalls(stub func() server.StreamableTaskHandler)

func (*FakeA2AServer) GetStreamingTaskHandlerReturns added in v0.9.0 

func (fake *FakeA2AServer) GetStreamingTaskHandlerReturns(result1 server.StreamableTaskHandler)

func (*FakeA2AServer) GetStreamingTaskHandlerReturnsOnCall added in v0.9.0 

func (fake *FakeA2AServer) GetStreamingTaskHandlerReturnsOnCall(i int, result1 server.StreamableTaskHandler)

func (*FakeA2AServer) Invocations 

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

func (*FakeA2AServer) LoadAgentCardFromFile 

func (fake *FakeA2AServer) LoadAgentCardFromFile(arg1 string, arg2 map[string]any) error

func (*FakeA2AServer) LoadAgentCardFromFileArgsForCall 

func (fake *FakeA2AServer) LoadAgentCardFromFileArgsForCall(i int) (string, map[string]any)

func (*FakeA2AServer) LoadAgentCardFromFileCallCount 

func (fake *FakeA2AServer) LoadAgentCardFromFileCallCount() int

func (*FakeA2AServer) LoadAgentCardFromFileCalls 

func (fake *FakeA2AServer) LoadAgentCardFromFileCalls(stub func(string, map[string]any) 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) SetBackgroundTaskHandler added in v0.9.0 

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

func (*FakeA2AServer) SetBackgroundTaskHandlerArgsForCall added in v0.9.0 

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

func (*FakeA2AServer) SetBackgroundTaskHandlerCallCount added in v0.9.0 

func (fake *FakeA2AServer) SetBackgroundTaskHandlerCallCount() int

func (*FakeA2AServer) SetBackgroundTaskHandlerCalls added in v0.9.0 

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

func (*FakeA2AServer) SetStreamingTaskHandler added in v0.9.0 

func (fake *FakeA2AServer) SetStreamingTaskHandler(arg1 server.StreamableTaskHandler)

func (*FakeA2AServer) SetStreamingTaskHandlerArgsForCall added in v0.9.0 

func (fake *FakeA2AServer) SetStreamingTaskHandlerArgsForCall(i int) server.StreamableTaskHandler

func (*FakeA2AServer) SetStreamingTaskHandlerCallCount added in v0.9.0 

func (fake *FakeA2AServer) SetStreamingTaskHandlerCallCount() int

func (*FakeA2AServer) SetStreamingTaskHandlerCalls added in v0.9.0 

func (fake *FakeA2AServer) SetStreamingTaskHandlerCalls(stub func(server.StreamableTaskHandler))

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]any) server.A2AServerBuilder

	WithArtifactServiceStub func(server.ArtifactService) server.A2AServerBuilder

	WithBackgroundTaskHandlerStub func(server.TaskHandler) server.A2AServerBuilder

	WithDefaultBackgroundTaskHandlerStub func() server.A2AServerBuilder

	WithDefaultStreamingTaskHandlerStub func() server.A2AServerBuilder

	WithDefaultTaskHandlersStub func() server.A2AServerBuilder

	WithLoggerStub func(*zap.Logger) server.A2AServerBuilder

	WithStreamingTaskHandlerStub func(server.StreamableTaskHandler) 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]any) server.A2AServerBuilder

func (*FakeA2AServerBuilder) WithAgentCardFromFileArgsForCall 

func (fake *FakeA2AServerBuilder) WithAgentCardFromFileArgsForCall(i int) (string, map[string]any)

func (*FakeA2AServerBuilder) WithAgentCardFromFileCallCount 

func (fake *FakeA2AServerBuilder) WithAgentCardFromFileCallCount() int

func (*FakeA2AServerBuilder) WithAgentCardFromFileCalls 

func (fake *FakeA2AServerBuilder) WithAgentCardFromFileCalls(stub func(string, map[string]any) 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) WithArtifactService added in v0.15.0 

func (fake *FakeA2AServerBuilder) WithArtifactService(arg1 server.ArtifactService) server.A2AServerBuilder

func (*FakeA2AServerBuilder) WithArtifactServiceArgsForCall added in v0.15.0 

func (fake *FakeA2AServerBuilder) WithArtifactServiceArgsForCall(i int) server.ArtifactService

func (*FakeA2AServerBuilder) WithArtifactServiceCallCount added in v0.15.0 

func (fake *FakeA2AServerBuilder) WithArtifactServiceCallCount() int

func (*FakeA2AServerBuilder) WithArtifactServiceCalls added in v0.15.0 

func (fake *FakeA2AServerBuilder) WithArtifactServiceCalls(stub func(server.ArtifactService) server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithArtifactServiceReturns added in v0.15.0 

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

func (*FakeA2AServerBuilder) WithArtifactServiceReturnsOnCall added in v0.15.0 

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

func (*FakeA2AServerBuilder) WithBackgroundTaskHandler added in v0.9.0 

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

func (*FakeA2AServerBuilder) WithBackgroundTaskHandlerArgsForCall added in v0.9.0 

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

func (*FakeA2AServerBuilder) WithBackgroundTaskHandlerCallCount added in v0.9.0 

func (fake *FakeA2AServerBuilder) WithBackgroundTaskHandlerCallCount() int

func (*FakeA2AServerBuilder) WithBackgroundTaskHandlerCalls added in v0.9.0 

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

func (*FakeA2AServerBuilder) WithBackgroundTaskHandlerReturns added in v0.9.0 

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

func (*FakeA2AServerBuilder) WithBackgroundTaskHandlerReturnsOnCall added in v0.9.0 

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

func (*FakeA2AServerBuilder) WithDefaultBackgroundTaskHandler added in v0.9.0 

func (fake *FakeA2AServerBuilder) WithDefaultBackgroundTaskHandler() server.A2AServerBuilder

func (*FakeA2AServerBuilder) WithDefaultBackgroundTaskHandlerCallCount added in v0.9.0 

func (fake *FakeA2AServerBuilder) WithDefaultBackgroundTaskHandlerCallCount() int

func (*FakeA2AServerBuilder) WithDefaultBackgroundTaskHandlerCalls added in v0.9.0 

func (fake *FakeA2AServerBuilder) WithDefaultBackgroundTaskHandlerCalls(stub func() server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithDefaultBackgroundTaskHandlerReturns added in v0.9.0 

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

func (*FakeA2AServerBuilder) WithDefaultBackgroundTaskHandlerReturnsOnCall added in v0.9.0 

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

func (*FakeA2AServerBuilder) WithDefaultStreamingTaskHandler added in v0.9.0 

func (fake *FakeA2AServerBuilder) WithDefaultStreamingTaskHandler() server.A2AServerBuilder

func (*FakeA2AServerBuilder) WithDefaultStreamingTaskHandlerCallCount added in v0.9.0 

func (fake *FakeA2AServerBuilder) WithDefaultStreamingTaskHandlerCallCount() int

func (*FakeA2AServerBuilder) WithDefaultStreamingTaskHandlerCalls added in v0.9.0 

func (fake *FakeA2AServerBuilder) WithDefaultStreamingTaskHandlerCalls(stub func() server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithDefaultStreamingTaskHandlerReturns added in v0.9.0 

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

func (*FakeA2AServerBuilder) WithDefaultStreamingTaskHandlerReturnsOnCall added in v0.9.0 

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

func (*FakeA2AServerBuilder) WithDefaultTaskHandlers added in v0.9.0 

func (fake *FakeA2AServerBuilder) WithDefaultTaskHandlers() server.A2AServerBuilder

func (*FakeA2AServerBuilder) WithDefaultTaskHandlersCallCount added in v0.9.0 

func (fake *FakeA2AServerBuilder) WithDefaultTaskHandlersCallCount() int

func (*FakeA2AServerBuilder) WithDefaultTaskHandlersCalls added in v0.9.0 

func (fake *FakeA2AServerBuilder) WithDefaultTaskHandlersCalls(stub func() server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithDefaultTaskHandlersReturns added in v0.9.0 

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

func (*FakeA2AServerBuilder) WithDefaultTaskHandlersReturnsOnCall added in v0.9.0 

func (fake *FakeA2AServerBuilder) WithDefaultTaskHandlersReturnsOnCall(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) WithStreamingTaskHandler added in v0.9.0 

func (fake *FakeA2AServerBuilder) WithStreamingTaskHandler(arg1 server.StreamableTaskHandler) server.A2AServerBuilder

func (*FakeA2AServerBuilder) WithStreamingTaskHandlerArgsForCall added in v0.9.0 

func (fake *FakeA2AServerBuilder) WithStreamingTaskHandlerArgsForCall(i int) server.StreamableTaskHandler

func (*FakeA2AServerBuilder) WithStreamingTaskHandlerCallCount added in v0.9.0 

func (fake *FakeA2AServerBuilder) WithStreamingTaskHandlerCallCount() int

func (*FakeA2AServerBuilder) WithStreamingTaskHandlerCalls added in v0.9.0 

func (fake *FakeA2AServerBuilder) WithStreamingTaskHandlerCalls(stub func(server.StreamableTaskHandler) server.A2AServerBuilder)

func (*FakeA2AServerBuilder) WithStreamingTaskHandlerReturns added in v0.9.0 

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

func (*FakeA2AServerBuilder) WithStreamingTaskHandlerReturnsOnCall added in v0.9.0 

func (fake *FakeA2AServerBuilder) WithStreamingTaskHandlerReturnsOnCall(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

	WithCallbacksStub func(*server.CallbackConfig) server.AgentBuilder

	WithConfigStub func(*config.AgentConfig) server.AgentBuilder

	WithDefaultToolBoxStub func() 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) WithCallbacks added in v0.16.0 

func (fake *FakeAgentBuilder) WithCallbacks(arg1 *server.CallbackConfig) server.AgentBuilder

func (*FakeAgentBuilder) WithCallbacksArgsForCall added in v0.16.0 

func (fake *FakeAgentBuilder) WithCallbacksArgsForCall(i int) *server.CallbackConfig

func (*FakeAgentBuilder) WithCallbacksCallCount added in v0.16.0 

func (fake *FakeAgentBuilder) WithCallbacksCallCount() int

func (*FakeAgentBuilder) WithCallbacksCalls added in v0.16.0 

func (fake *FakeAgentBuilder) WithCallbacksCalls(stub func(*server.CallbackConfig) server.AgentBuilder)

func (*FakeAgentBuilder) WithCallbacksReturns added in v0.16.0 

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

func (*FakeAgentBuilder) WithCallbacksReturnsOnCall added in v0.16.0 

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

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) WithDefaultToolBox added in v0.15.0 

func (fake *FakeAgentBuilder) WithDefaultToolBox() server.AgentBuilder

func (*FakeAgentBuilder) WithDefaultToolBoxCallCount added in v0.15.0 

func (fake *FakeAgentBuilder) WithDefaultToolBoxCallCount() int

func (*FakeAgentBuilder) WithDefaultToolBoxCalls added in v0.15.0 

func (fake *FakeAgentBuilder) WithDefaultToolBoxCalls(stub func() server.AgentBuilder)

func (*FakeAgentBuilder) WithDefaultToolBoxReturns added in v0.15.0 

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

func (*FakeAgentBuilder) WithDefaultToolBoxReturnsOnCall added in v0.15.0 

func (fake *FakeAgentBuilder) WithDefaultToolBoxReturnsOnCall(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 FakeArtifactService added in v0.15.0 

type FakeArtifactService struct {
	AddArtifactToTaskStub func(*types.Task, types.Artifact)

	AddArtifactsToTaskStub func(*types.Task, []types.Artifact)

	CleanupExpiredArtifactsStub func(context.Context, time.Duration) (int, error)

	CleanupOldestArtifactsStub func(context.Context, int) (int, error)

	CloseStub func() error

	CreateDataArtifactStub func(string, string, map[string]any) types.Artifact

	CreateFileArtifactStub func(string, string, string, []byte, *string) (types.Artifact, error)

	CreateFileArtifactFromURIStub func(string, string, string, string, *string) types.Artifact

	CreateMultiPartArtifactStub func(string, string, []types.Part) types.Artifact

	CreateTaskArtifactUpdateEventStub func(string, string, types.Artifact, *bool, *bool) types.TaskArtifactUpdateEvent

	CreateTextArtifactStub func(string, string, string) types.Artifact

	ExistsStub func(context.Context, string, string) (bool, error)

	GetArtifactByIDStub func(*types.Task, string) (*types.Artifact, bool)

	GetArtifactsByTypeStub func(*types.Task, string) []types.Artifact

	GetMimeTypeFromExtensionStub func(string) *string

	RetrieveStub func(context.Context, string, string) (io.ReadCloser, error)

	ValidateArtifactStub func(types.Artifact) error
	// contains filtered or unexported fields
}

func (*FakeArtifactService) AddArtifactToTask added in v0.15.0 

func (fake *FakeArtifactService) AddArtifactToTask(arg1 *types.Task, arg2 types.Artifact)

func (*FakeArtifactService) AddArtifactToTaskArgsForCall added in v0.15.0 

func (fake *FakeArtifactService) AddArtifactToTaskArgsForCall(i int) (*types.Task, types.Artifact)

func (*FakeArtifactService) AddArtifactToTaskCallCount added in v0.15.0 

func (fake *FakeArtifactService) AddArtifactToTaskCallCount() int

func (*FakeArtifactService) AddArtifactToTaskCalls added in v0.15.0 

func (fake *FakeArtifactService) AddArtifactToTaskCalls(stub func(*types.Task, types.Artifact))

func (*FakeArtifactService) AddArtifactsToTask added in v0.15.0 

func (fake *FakeArtifactService) AddArtifactsToTask(arg1 *types.Task, arg2 []types.Artifact)

func (*FakeArtifactService) AddArtifactsToTaskArgsForCall added in v0.15.0 

func (fake *FakeArtifactService) AddArtifactsToTaskArgsForCall(i int) (*types.Task, []types.Artifact)

func (*FakeArtifactService) AddArtifactsToTaskCallCount added in v0.15.0 

func (fake *FakeArtifactService) AddArtifactsToTaskCallCount() int

func (*FakeArtifactService) AddArtifactsToTaskCalls added in v0.15.0 

func (fake *FakeArtifactService) AddArtifactsToTaskCalls(stub func(*types.Task, []types.Artifact))

func (*FakeArtifactService) CleanupExpiredArtifacts added in v0.15.0 

func (fake *FakeArtifactService) CleanupExpiredArtifacts(arg1 context.Context, arg2 time.Duration) (int, error)

func (*FakeArtifactService) CleanupExpiredArtifactsArgsForCall added in v0.15.0 

func (fake *FakeArtifactService) CleanupExpiredArtifactsArgsForCall(i int) (context.Context, time.Duration)

func (*FakeArtifactService) CleanupExpiredArtifactsCallCount added in v0.15.0 

func (fake *FakeArtifactService) CleanupExpiredArtifactsCallCount() int

func (*FakeArtifactService) CleanupExpiredArtifactsCalls added in v0.15.0 

func (fake *FakeArtifactService) CleanupExpiredArtifactsCalls(stub func(context.Context, time.Duration) (int, error))

func (*FakeArtifactService) CleanupExpiredArtifactsReturns added in v0.15.0 

func (fake *FakeArtifactService) CleanupExpiredArtifactsReturns(result1 int, result2 error)

func (*FakeArtifactService) CleanupExpiredArtifactsReturnsOnCall added in v0.15.0 

func (fake *FakeArtifactService) CleanupExpiredArtifactsReturnsOnCall(i int, result1 int, result2 error)

func (*FakeArtifactService) CleanupOldestArtifacts added in v0.15.0 

func (fake *FakeArtifactService) CleanupOldestArtifacts(arg1 context.Context, arg2 int) (int, error)

func (*FakeArtifactService) CleanupOldestArtifactsArgsForCall added in v0.15.0 

func (fake *FakeArtifactService) CleanupOldestArtifactsArgsForCall(i int) (context.Context, int)

func (*FakeArtifactService) CleanupOldestArtifactsCallCount added in v0.15.0 

func (fake *FakeArtifactService) CleanupOldestArtifactsCallCount() int

func (*FakeArtifactService) CleanupOldestArtifactsCalls added in v0.15.0 

func (fake *FakeArtifactService) CleanupOldestArtifactsCalls(stub func(context.Context, int) (int, error))

func (*FakeArtifactService) CleanupOldestArtifactsReturns added in v0.15.0 

func (fake *FakeArtifactService) CleanupOldestArtifactsReturns(result1 int, result2 error)

func (*FakeArtifactService) CleanupOldestArtifactsReturnsOnCall added in v0.15.0 

func (fake *FakeArtifactService) CleanupOldestArtifactsReturnsOnCall(i int, result1 int, result2 error)

func (*FakeArtifactService) Close added in v0.15.0 

func (fake *FakeArtifactService) Close() error

func (*FakeArtifactService) CloseCallCount added in v0.15.0 

func (fake *FakeArtifactService) CloseCallCount() int

func (*FakeArtifactService) CloseCalls added in v0.15.0 

func (fake *FakeArtifactService) CloseCalls(stub func() error)

func (*FakeArtifactService) CloseReturns added in v0.15.0 

func (fake *FakeArtifactService) CloseReturns(result1 error)

func (*FakeArtifactService) CloseReturnsOnCall added in v0.15.0 

func (fake *FakeArtifactService) CloseReturnsOnCall(i int, result1 error)

func (*FakeArtifactService) CreateDataArtifact added in v0.15.0 

func (fake *FakeArtifactService) CreateDataArtifact(arg1 string, arg2 string, arg3 map[string]any) types.Artifact

func (*FakeArtifactService) CreateDataArtifactArgsForCall added in v0.15.0 

func (fake *FakeArtifactService) CreateDataArtifactArgsForCall(i int) (string, string, map[string]any)

func (*FakeArtifactService) CreateDataArtifactCallCount added in v0.15.0 

func (fake *FakeArtifactService) CreateDataArtifactCallCount() int

func (*FakeArtifactService) CreateDataArtifactCalls added in v0.15.0 

func (fake *FakeArtifactService) CreateDataArtifactCalls(stub func(string, string, map[string]any) types.Artifact)

func (*FakeArtifactService) CreateDataArtifactReturns added in v0.15.0 

func (fake *FakeArtifactService) CreateDataArtifactReturns(result1 types.Artifact)

func (*FakeArtifactService) CreateDataArtifactReturnsOnCall added in v0.15.0 

func (fake *FakeArtifactService) CreateDataArtifactReturnsOnCall(i int, result1 types.Artifact)

func (*FakeArtifactService) CreateFileArtifact added in v0.15.0 

func (fake *FakeArtifactService) CreateFileArtifact(arg1 string, arg2 string, arg3 string, arg4 []byte, arg5 *string) (types.Artifact, error)

func (*FakeArtifactService) CreateFileArtifactArgsForCall added in v0.15.0 

func (fake *FakeArtifactService) CreateFileArtifactArgsForCall(i int) (string, string, string, []byte, *string)

func (*FakeArtifactService) CreateFileArtifactCallCount added in v0.15.0 

func (fake *FakeArtifactService) CreateFileArtifactCallCount() int

func (*FakeArtifactService) CreateFileArtifactCalls added in v0.15.0 

func (fake *FakeArtifactService) CreateFileArtifactCalls(stub func(string, string, string, []byte, *string) (types.Artifact, error))

func (*FakeArtifactService) CreateFileArtifactFromURI added in v0.15.0 

func (fake *FakeArtifactService) CreateFileArtifactFromURI(arg1 string, arg2 string, arg3 string, arg4 string, arg5 *string) types.Artifact

func (*FakeArtifactService) CreateFileArtifactFromURIArgsForCall added in v0.15.0 

func (fake *FakeArtifactService) CreateFileArtifactFromURIArgsForCall(i int) (string, string, string, string, *string)

func (*FakeArtifactService) CreateFileArtifactFromURICallCount added in v0.15.0 

func (fake *FakeArtifactService) CreateFileArtifactFromURICallCount() int

func (*FakeArtifactService) CreateFileArtifactFromURICalls added in v0.15.0 

func (fake *FakeArtifactService) CreateFileArtifactFromURICalls(stub func(string, string, string, string, *string) types.Artifact)

func (*FakeArtifactService) CreateFileArtifactFromURIReturns added in v0.15.0 

func (fake *FakeArtifactService) CreateFileArtifactFromURIReturns(result1 types.Artifact)

func (*FakeArtifactService) CreateFileArtifactFromURIReturnsOnCall added in v0.15.0 

func (fake *FakeArtifactService) CreateFileArtifactFromURIReturnsOnCall(i int, result1 types.Artifact)

func (*FakeArtifactService) CreateFileArtifactReturns added in v0.15.0 

func (fake *FakeArtifactService) CreateFileArtifactReturns(result1 types.Artifact, result2 error)

func (*FakeArtifactService) CreateFileArtifactReturnsOnCall added in v0.15.0 

func (fake *FakeArtifactService) CreateFileArtifactReturnsOnCall(i int, result1 types.Artifact, result2 error)

func (*FakeArtifactService) CreateMultiPartArtifact added in v0.15.0 

func (fake *FakeArtifactService) CreateMultiPartArtifact(arg1 string, arg2 string, arg3 []types.Part) types.Artifact

func (*FakeArtifactService) CreateMultiPartArtifactArgsForCall added in v0.15.0 

func (fake *FakeArtifactService) CreateMultiPartArtifactArgsForCall(i int) (string, string, []types.Part)

func (*FakeArtifactService) CreateMultiPartArtifactCallCount added in v0.15.0 

func (fake *FakeArtifactService) CreateMultiPartArtifactCallCount() int

func (*FakeArtifactService) CreateMultiPartArtifactCalls added in v0.15.0 

func (fake *FakeArtifactService) CreateMultiPartArtifactCalls(stub func(string, string, []types.Part) types.Artifact)

func (*FakeArtifactService) CreateMultiPartArtifactReturns added in v0.15.0 

func (fake *FakeArtifactService) CreateMultiPartArtifactReturns(result1 types.Artifact)

func (*FakeArtifactService) CreateMultiPartArtifactReturnsOnCall added in v0.15.0 

func (fake *FakeArtifactService) CreateMultiPartArtifactReturnsOnCall(i int, result1 types.Artifact)

func (*FakeArtifactService) CreateTaskArtifactUpdateEvent added in v0.15.0 

func (fake *FakeArtifactService) CreateTaskArtifactUpdateEvent(arg1 string, arg2 string, arg3 types.Artifact, arg4 *bool, arg5 *bool) types.TaskArtifactUpdateEvent

func (*FakeArtifactService) CreateTaskArtifactUpdateEventArgsForCall added in v0.15.0 

func (fake *FakeArtifactService) CreateTaskArtifactUpdateEventArgsForCall(i int) (string, string, types.Artifact, *bool, *bool)

func (*FakeArtifactService) CreateTaskArtifactUpdateEventCallCount added in v0.15.0 

func (fake *FakeArtifactService) CreateTaskArtifactUpdateEventCallCount() int

func (*FakeArtifactService) CreateTaskArtifactUpdateEventCalls added in v0.15.0 

func (fake *FakeArtifactService) CreateTaskArtifactUpdateEventCalls(stub func(string, string, types.Artifact, *bool, *bool) types.TaskArtifactUpdateEvent)

func (*FakeArtifactService) CreateTaskArtifactUpdateEventReturns added in v0.15.0 

func (fake *FakeArtifactService) CreateTaskArtifactUpdateEventReturns(result1 types.TaskArtifactUpdateEvent)

func (*FakeArtifactService) CreateTaskArtifactUpdateEventReturnsOnCall added in v0.15.0 

func (fake *FakeArtifactService) CreateTaskArtifactUpdateEventReturnsOnCall(i int, result1 types.TaskArtifactUpdateEvent)

func (*FakeArtifactService) CreateTextArtifact added in v0.15.0 

func (fake *FakeArtifactService) CreateTextArtifact(arg1 string, arg2 string, arg3 string) types.Artifact

func (*FakeArtifactService) CreateTextArtifactArgsForCall added in v0.15.0 

func (fake *FakeArtifactService) CreateTextArtifactArgsForCall(i int) (string, string, string)

func (*FakeArtifactService) CreateTextArtifactCallCount added in v0.15.0 

func (fake *FakeArtifactService) CreateTextArtifactCallCount() int

func (*FakeArtifactService) CreateTextArtifactCalls added in v0.15.0 

func (fake *FakeArtifactService) CreateTextArtifactCalls(stub func(string, string, string) types.Artifact)

func (*FakeArtifactService) CreateTextArtifactReturns added in v0.15.0 

func (fake *FakeArtifactService) CreateTextArtifactReturns(result1 types.Artifact)

func (*FakeArtifactService) CreateTextArtifactReturnsOnCall added in v0.15.0 

func (fake *FakeArtifactService) CreateTextArtifactReturnsOnCall(i int, result1 types.Artifact)

func (*FakeArtifactService) Exists added in v0.15.0 

func (fake *FakeArtifactService) Exists(arg1 context.Context, arg2 string, arg3 string) (bool, error)

func (*FakeArtifactService) ExistsArgsForCall added in v0.15.0 

func (fake *FakeArtifactService) ExistsArgsForCall(i int) (context.Context, string, string)

func (*FakeArtifactService) ExistsCallCount added in v0.15.0 

func (fake *FakeArtifactService) ExistsCallCount() int

func (*FakeArtifactService) ExistsCalls added in v0.15.0 

func (fake *FakeArtifactService) ExistsCalls(stub func(context.Context, string, string) (bool, error))

func (*FakeArtifactService) ExistsReturns added in v0.15.0 

func (fake *FakeArtifactService) ExistsReturns(result1 bool, result2 error)

func (*FakeArtifactService) ExistsReturnsOnCall added in v0.15.0 

func (fake *FakeArtifactService) ExistsReturnsOnCall(i int, result1 bool, result2 error)

func (*FakeArtifactService) GetArtifactByID added in v0.15.0 

func (fake *FakeArtifactService) GetArtifactByID(arg1 *types.Task, arg2 string) (*types.Artifact, bool)

func (*FakeArtifactService) GetArtifactByIDArgsForCall added in v0.15.0 

func (fake *FakeArtifactService) GetArtifactByIDArgsForCall(i int) (*types.Task, string)

func (*FakeArtifactService) GetArtifactByIDCallCount added in v0.15.0 

func (fake *FakeArtifactService) GetArtifactByIDCallCount() int

func (*FakeArtifactService) GetArtifactByIDCalls added in v0.15.0 

func (fake *FakeArtifactService) GetArtifactByIDCalls(stub func(*types.Task, string) (*types.Artifact, bool))

func (*FakeArtifactService) GetArtifactByIDReturns added in v0.15.0 

func (fake *FakeArtifactService) GetArtifactByIDReturns(result1 *types.Artifact, result2 bool)

func (*FakeArtifactService) GetArtifactByIDReturnsOnCall added in v0.15.0 

func (fake *FakeArtifactService) GetArtifactByIDReturnsOnCall(i int, result1 *types.Artifact, result2 bool)

func (*FakeArtifactService) GetArtifactsByType added in v0.15.0 

func (fake *FakeArtifactService) GetArtifactsByType(arg1 *types.Task, arg2 string) []types.Artifact

func (*FakeArtifactService) GetArtifactsByTypeArgsForCall added in v0.15.0 

func (fake *FakeArtifactService) GetArtifactsByTypeArgsForCall(i int) (*types.Task, string)

func (*FakeArtifactService) GetArtifactsByTypeCallCount added in v0.15.0 

func (fake *FakeArtifactService) GetArtifactsByTypeCallCount() int

func (*FakeArtifactService) GetArtifactsByTypeCalls added in v0.15.0 

func (fake *FakeArtifactService) GetArtifactsByTypeCalls(stub func(*types.Task, string) []types.Artifact)

func (*FakeArtifactService) GetArtifactsByTypeReturns added in v0.15.0 

func (fake *FakeArtifactService) GetArtifactsByTypeReturns(result1 []types.Artifact)

func (*FakeArtifactService) GetArtifactsByTypeReturnsOnCall added in v0.15.0 

func (fake *FakeArtifactService) GetArtifactsByTypeReturnsOnCall(i int, result1 []types.Artifact)

func (*FakeArtifactService) GetMimeTypeFromExtension added in v0.15.0 

func (fake *FakeArtifactService) GetMimeTypeFromExtension(arg1 string) *string

func (*FakeArtifactService) GetMimeTypeFromExtensionArgsForCall added in v0.15.0 

func (fake *FakeArtifactService) GetMimeTypeFromExtensionArgsForCall(i int) string

func (*FakeArtifactService) GetMimeTypeFromExtensionCallCount added in v0.15.0 

func (fake *FakeArtifactService) GetMimeTypeFromExtensionCallCount() int

func (*FakeArtifactService) GetMimeTypeFromExtensionCalls added in v0.15.0 

func (fake *FakeArtifactService) GetMimeTypeFromExtensionCalls(stub func(string) *string)

func (*FakeArtifactService) GetMimeTypeFromExtensionReturns added in v0.15.0 

func (fake *FakeArtifactService) GetMimeTypeFromExtensionReturns(result1 *string)

func (*FakeArtifactService) GetMimeTypeFromExtensionReturnsOnCall added in v0.15.0 

func (fake *FakeArtifactService) GetMimeTypeFromExtensionReturnsOnCall(i int, result1 *string)

func (*FakeArtifactService) Invocations added in v0.15.0 

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

func (*FakeArtifactService) Retrieve added in v0.15.0 

func (fake *FakeArtifactService) Retrieve(arg1 context.Context, arg2 string, arg3 string) (io.ReadCloser, error)

func (*FakeArtifactService) RetrieveArgsForCall added in v0.15.0 

func (fake *FakeArtifactService) RetrieveArgsForCall(i int) (context.Context, string, string)

func (*FakeArtifactService) RetrieveCallCount added in v0.15.0 

func (fake *FakeArtifactService) RetrieveCallCount() int

func (*FakeArtifactService) RetrieveCalls added in v0.15.0 

func (fake *FakeArtifactService) RetrieveCalls(stub func(context.Context, string, string) (io.ReadCloser, error))

func (*FakeArtifactService) RetrieveReturns added in v0.15.0 

func (fake *FakeArtifactService) RetrieveReturns(result1 io.ReadCloser, result2 error)

func (*FakeArtifactService) RetrieveReturnsOnCall added in v0.15.0 

func (fake *FakeArtifactService) RetrieveReturnsOnCall(i int, result1 io.ReadCloser, result2 error)

func (*FakeArtifactService) ValidateArtifact added in v0.15.0 

func (fake *FakeArtifactService) ValidateArtifact(arg1 types.Artifact) error

func (*FakeArtifactService) ValidateArtifactArgsForCall added in v0.15.0 

func (fake *FakeArtifactService) ValidateArtifactArgsForCall(i int) types.Artifact

func (*FakeArtifactService) ValidateArtifactCallCount added in v0.15.0 

func (fake *FakeArtifactService) ValidateArtifactCallCount() int

func (*FakeArtifactService) ValidateArtifactCalls added in v0.15.0 

func (fake *FakeArtifactService) ValidateArtifactCalls(stub func(types.Artifact) error)

func (*FakeArtifactService) ValidateArtifactReturns added in v0.15.0 

func (fake *FakeArtifactService) ValidateArtifactReturns(result1 error)

func (*FakeArtifactService) ValidateArtifactReturnsOnCall added in v0.15.0 

func (fake *FakeArtifactService) ValidateArtifactReturnsOnCall(i int, result1 error)

type FakeArtifactStorageProvider added in v0.12.0 

type FakeArtifactStorageProvider struct {
	CleanupExpiredArtifactsStub func(context.Context, time.Duration) (int, error)

	CleanupOldestArtifactsStub func(context.Context, int) (int, error)

	CloseStub func() error

	DeleteStub func(context.Context, string, string) error

	ExistsStub func(context.Context, string, string) (bool, error)

	GetURLStub func(string, string) string

	RetrieveStub func(context.Context, string, string) (io.ReadCloser, error)

	StoreStub func(context.Context, string, string, io.Reader) (string, error)
	// contains filtered or unexported fields
}

func (*FakeArtifactStorageProvider) CleanupExpiredArtifacts added in v0.12.0 

func (fake *FakeArtifactStorageProvider) CleanupExpiredArtifacts(arg1 context.Context, arg2 time.Duration) (int, error)

func (*FakeArtifactStorageProvider) CleanupExpiredArtifactsArgsForCall added in v0.12.0 

func (fake *FakeArtifactStorageProvider) CleanupExpiredArtifactsArgsForCall(i int) (context.Context, time.Duration)

func (*FakeArtifactStorageProvider) CleanupExpiredArtifactsCallCount added in v0.12.0 

func (fake *FakeArtifactStorageProvider) CleanupExpiredArtifactsCallCount() int

func (*FakeArtifactStorageProvider) CleanupExpiredArtifactsCalls added in v0.12.0 

func (fake *FakeArtifactStorageProvider) CleanupExpiredArtifactsCalls(stub func(context.Context, time.Duration) (int, error))

func (*FakeArtifactStorageProvider) CleanupExpiredArtifactsReturns added in v0.12.0 

func (fake *FakeArtifactStorageProvider) CleanupExpiredArtifactsReturns(result1 int, result2 error)

func (*FakeArtifactStorageProvider) CleanupExpiredArtifactsReturnsOnCall added in v0.12.0 

func (fake *FakeArtifactStorageProvider) CleanupExpiredArtifactsReturnsOnCall(i int, result1 int, result2 error)

func (*FakeArtifactStorageProvider) CleanupOldestArtifacts added in v0.12.0 

func (fake *FakeArtifactStorageProvider) CleanupOldestArtifacts(arg1 context.Context, arg2 int) (int, error)

func (*FakeArtifactStorageProvider) CleanupOldestArtifactsArgsForCall added in v0.12.0 

func (fake *FakeArtifactStorageProvider) CleanupOldestArtifactsArgsForCall(i int) (context.Context, int)

func (*FakeArtifactStorageProvider) CleanupOldestArtifactsCallCount added in v0.12.0 

func (fake *FakeArtifactStorageProvider) CleanupOldestArtifactsCallCount() int

func (*FakeArtifactStorageProvider) CleanupOldestArtifactsCalls added in v0.12.0 

func (fake *FakeArtifactStorageProvider) CleanupOldestArtifactsCalls(stub func(context.Context, int) (int, error))

func (*FakeArtifactStorageProvider) CleanupOldestArtifactsReturns added in v0.12.0 

func (fake *FakeArtifactStorageProvider) CleanupOldestArtifactsReturns(result1 int, result2 error)

func (*FakeArtifactStorageProvider) CleanupOldestArtifactsReturnsOnCall added in v0.12.0 

func (fake *FakeArtifactStorageProvider) CleanupOldestArtifactsReturnsOnCall(i int, result1 int, result2 error)

func (*FakeArtifactStorageProvider) Close added in v0.12.0 

func (fake *FakeArtifactStorageProvider) Close() error

func (*FakeArtifactStorageProvider) CloseCallCount added in v0.12.0 

func (fake *FakeArtifactStorageProvider) CloseCallCount() int

func (*FakeArtifactStorageProvider) CloseCalls added in v0.12.0 

func (fake *FakeArtifactStorageProvider) CloseCalls(stub func() error)

func (*FakeArtifactStorageProvider) CloseReturns added in v0.12.0 

func (fake *FakeArtifactStorageProvider) CloseReturns(result1 error)

func (*FakeArtifactStorageProvider) CloseReturnsOnCall added in v0.12.0 

func (fake *FakeArtifactStorageProvider) CloseReturnsOnCall(i int, result1 error)

func (*FakeArtifactStorageProvider) Delete added in v0.12.0 

func (fake *FakeArtifactStorageProvider) Delete(arg1 context.Context, arg2 string, arg3 string) error

func (*FakeArtifactStorageProvider) DeleteArgsForCall added in v0.12.0 

func (fake *FakeArtifactStorageProvider) DeleteArgsForCall(i int) (context.Context, string, string)

func (*FakeArtifactStorageProvider) DeleteCallCount added in v0.12.0 

func (fake *FakeArtifactStorageProvider) DeleteCallCount() int

func (*FakeArtifactStorageProvider) DeleteCalls added in v0.12.0 

func (fake *FakeArtifactStorageProvider) DeleteCalls(stub func(context.Context, string, string) error)

func (*FakeArtifactStorageProvider) DeleteReturns added in v0.12.0 

func (fake *FakeArtifactStorageProvider) DeleteReturns(result1 error)

func (*FakeArtifactStorageProvider) DeleteReturnsOnCall added in v0.12.0 

func (fake *FakeArtifactStorageProvider) DeleteReturnsOnCall(i int, result1 error)

func (*FakeArtifactStorageProvider) Exists added in v0.12.0 

func (fake *FakeArtifactStorageProvider) Exists(arg1 context.Context, arg2 string, arg3 string) (bool, error)

func (*FakeArtifactStorageProvider) ExistsArgsForCall added in v0.12.0 

func (fake *FakeArtifactStorageProvider) ExistsArgsForCall(i int) (context.Context, string, string)

func (*FakeArtifactStorageProvider) ExistsCallCount added in v0.12.0 

func (fake *FakeArtifactStorageProvider) ExistsCallCount() int

func (*FakeArtifactStorageProvider) ExistsCalls added in v0.12.0 

func (fake *FakeArtifactStorageProvider) ExistsCalls(stub func(context.Context, string, string) (bool, error))

func (*FakeArtifactStorageProvider) ExistsReturns added in v0.12.0 

func (fake *FakeArtifactStorageProvider) ExistsReturns(result1 bool, result2 error)

func (*FakeArtifactStorageProvider) ExistsReturnsOnCall added in v0.12.0 

func (fake *FakeArtifactStorageProvider) ExistsReturnsOnCall(i int, result1 bool, result2 error)

func (*FakeArtifactStorageProvider) GetURL added in v0.12.0 

func (fake *FakeArtifactStorageProvider) GetURL(arg1 string, arg2 string) string

func (*FakeArtifactStorageProvider) GetURLArgsForCall added in v0.12.0 

func (fake *FakeArtifactStorageProvider) GetURLArgsForCall(i int) (string, string)

func (*FakeArtifactStorageProvider) GetURLCallCount added in v0.12.0 

func (fake *FakeArtifactStorageProvider) GetURLCallCount() int

func (*FakeArtifactStorageProvider) GetURLCalls added in v0.12.0 

func (fake *FakeArtifactStorageProvider) GetURLCalls(stub func(string, string) string)

func (*FakeArtifactStorageProvider) GetURLReturns added in v0.12.0 

func (fake *FakeArtifactStorageProvider) GetURLReturns(result1 string)

func (*FakeArtifactStorageProvider) GetURLReturnsOnCall added in v0.12.0 

func (fake *FakeArtifactStorageProvider) GetURLReturnsOnCall(i int, result1 string)

func (*FakeArtifactStorageProvider) Invocations added in v0.12.0 

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

func (*FakeArtifactStorageProvider) Retrieve added in v0.12.0 

func (fake *FakeArtifactStorageProvider) Retrieve(arg1 context.Context, arg2 string, arg3 string) (io.ReadCloser, error)

func (*FakeArtifactStorageProvider) RetrieveArgsForCall added in v0.12.0 

func (fake *FakeArtifactStorageProvider) RetrieveArgsForCall(i int) (context.Context, string, string)

func (*FakeArtifactStorageProvider) RetrieveCallCount added in v0.12.0 

func (fake *FakeArtifactStorageProvider) RetrieveCallCount() int

func (*FakeArtifactStorageProvider) RetrieveCalls added in v0.12.0 

func (fake *FakeArtifactStorageProvider) RetrieveCalls(stub func(context.Context, string, string) (io.ReadCloser, error))

func (*FakeArtifactStorageProvider) RetrieveReturns added in v0.12.0 

func (fake *FakeArtifactStorageProvider) RetrieveReturns(result1 io.ReadCloser, result2 error)

func (*FakeArtifactStorageProvider) RetrieveReturnsOnCall added in v0.12.0 

func (fake *FakeArtifactStorageProvider) RetrieveReturnsOnCall(i int, result1 io.ReadCloser, result2 error)

func (*FakeArtifactStorageProvider) Store added in v0.12.0 

func (fake *FakeArtifactStorageProvider) Store(arg1 context.Context, arg2 string, arg3 string, arg4 io.Reader) (string, error)

func (*FakeArtifactStorageProvider) StoreArgsForCall added in v0.12.0 

func (fake *FakeArtifactStorageProvider) StoreArgsForCall(i int) (context.Context, string, string, io.Reader)

func (*FakeArtifactStorageProvider) StoreCallCount added in v0.12.0 

func (fake *FakeArtifactStorageProvider) StoreCallCount() int

func (*FakeArtifactStorageProvider) StoreCalls added in v0.12.0 

func (fake *FakeArtifactStorageProvider) StoreCalls(stub func(context.Context, string, string, io.Reader) (string, error))

func (*FakeArtifactStorageProvider) StoreReturns added in v0.12.0 

func (fake *FakeArtifactStorageProvider) StoreReturns(result1 string, result2 error)

func (*FakeArtifactStorageProvider) StoreReturnsOnCall added in v0.12.0 

func (fake *FakeArtifactStorageProvider) StoreReturnsOnCall(i int, result1 string, result2 error)

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 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 {
	RunWithStreamStub func(context.Context, []types.Message) (<-chan v2.Event, error)
	// contains filtered or unexported fields
}

func (*FakeOpenAICompatibleAgent) Invocations added in v0.8.0 

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

func (*FakeOpenAICompatibleAgent) RunWithStream added in v0.8.0 

func (fake *FakeOpenAICompatibleAgent) RunWithStream(arg1 context.Context, arg2 []types.Message) (<-chan v2.Event, 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 v2.Event, error))

func (*FakeOpenAICompatibleAgent) RunWithStreamReturns added in v0.8.0 

func (fake *FakeOpenAICompatibleAgent) RunWithStreamReturns(result1 <-chan v2.Event, result2 error)

func (*FakeOpenAICompatibleAgent) RunWithStreamReturnsOnCall added in v0.8.0 

func (fake *FakeOpenAICompatibleAgent) RunWithStreamReturnsOnCall(i int, result1 <-chan v2.Event, 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, any, int, string)

	SendSuccessStub func(*gin.Context, any, any)
	// 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 any, arg3 int, arg4 string)

func (*FakeResponseSender) SendErrorArgsForCall 

func (fake *FakeResponseSender) SendErrorArgsForCall(i int) (*gin.Context, any, int, string)

func (*FakeResponseSender) SendErrorCallCount 

func (fake *FakeResponseSender) SendErrorCallCount() int

func (*FakeResponseSender) SendErrorCalls 

func (fake *FakeResponseSender) SendErrorCalls(stub func(*gin.Context, any, int, string))

func (*FakeResponseSender) SendSuccess 

func (fake *FakeResponseSender) SendSuccess(arg1 *gin.Context, arg2 any, arg3 any)

func (*FakeResponseSender) SendSuccessArgsForCall 

func (fake *FakeResponseSender) SendSuccessArgsForCall(i int) (*gin.Context, any, any)

func (*FakeResponseSender) SendSuccessCallCount 

func (fake *FakeResponseSender) SendSuccessCallCount() int

func (*FakeResponseSender) SendSuccessCalls 

func (fake *FakeResponseSender) SendSuccessCalls(stub func(*gin.Context, any, any))

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, any) 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 any) error

func (*FakeStorage) EnqueueTaskArgsForCall added in v0.8.0 

func (fake *FakeStorage) EnqueueTaskArgsForCall(i int) (*types.Task, any)

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, any) 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 FakeStreamableTaskHandler added in v0.9.4 

type FakeStreamableTaskHandler struct {
	GetAgentStub func() server.OpenAICompatibleAgent

	HandleStreamingTaskStub func(context.Context, *types.Task, *types.Message) (<-chan v2.Event, error)

	SetAgentStub func(server.OpenAICompatibleAgent)
	// contains filtered or unexported fields
}

func (*FakeStreamableTaskHandler) GetAgent added in v0.9.4 

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

func (*FakeStreamableTaskHandler) GetAgentCallCount added in v0.9.4 

func (fake *FakeStreamableTaskHandler) GetAgentCallCount() int

func (*FakeStreamableTaskHandler) GetAgentCalls added in v0.9.4 

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

func (*FakeStreamableTaskHandler) GetAgentReturns added in v0.9.4 

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

func (*FakeStreamableTaskHandler) GetAgentReturnsOnCall added in v0.9.4 

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

func (*FakeStreamableTaskHandler) HandleStreamingTask added in v0.9.4 

func (fake *FakeStreamableTaskHandler) HandleStreamingTask(arg1 context.Context, arg2 *types.Task, arg3 *types.Message) (<-chan v2.Event, error)

func (*FakeStreamableTaskHandler) HandleStreamingTaskArgsForCall added in v0.9.4 

func (fake *FakeStreamableTaskHandler) HandleStreamingTaskArgsForCall(i int) (context.Context, *types.Task, *types.Message)

func (*FakeStreamableTaskHandler) HandleStreamingTaskCallCount added in v0.9.4 

func (fake *FakeStreamableTaskHandler) HandleStreamingTaskCallCount() int

func (*FakeStreamableTaskHandler) HandleStreamingTaskCalls added in v0.9.4 

func (fake *FakeStreamableTaskHandler) HandleStreamingTaskCalls(stub func(context.Context, *types.Task, *types.Message) (<-chan v2.Event, error))

func (*FakeStreamableTaskHandler) HandleStreamingTaskReturns added in v0.9.4 

func (fake *FakeStreamableTaskHandler) HandleStreamingTaskReturns(result1 <-chan v2.Event, result2 error)

func (*FakeStreamableTaskHandler) HandleStreamingTaskReturnsOnCall added in v0.9.4 

func (fake *FakeStreamableTaskHandler) HandleStreamingTaskReturnsOnCall(i int, result1 <-chan v2.Event, result2 error)

func (*FakeStreamableTaskHandler) Invocations added in v0.9.4 

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

func (*FakeStreamableTaskHandler) SetAgent added in v0.9.4 

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

func (*FakeStreamableTaskHandler) SetAgentArgsForCall added in v0.9.4 

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

func (*FakeStreamableTaskHandler) SetAgentCallCount added in v0.9.4 

func (fake *FakeStreamableTaskHandler) SetAgentCallCount() int

func (*FakeStreamableTaskHandler) SetAgentCalls added in v0.9.4 

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

type FakeTaskHandler 

type FakeTaskHandler struct {
	GetAgentStub func() server.OpenAICompatibleAgent

	HandleTaskStub func(context.Context, *types.Task, *types.Message) (*types.Task, error)

	SetAgentStub func(server.OpenAICompatibleAgent)
	// contains filtered or unexported fields
}

func (*FakeTaskHandler) GetAgent added in v0.9.0 

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

func (*FakeTaskHandler) GetAgentCallCount added in v0.9.0 

func (fake *FakeTaskHandler) GetAgentCallCount() int

func (*FakeTaskHandler) GetAgentCalls added in v0.9.0 

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

func (*FakeTaskHandler) GetAgentReturns added in v0.9.0 

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

func (*FakeTaskHandler) GetAgentReturnsOnCall added in v0.9.0 

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

func (*FakeTaskHandler) HandleTask 

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

func (*FakeTaskHandler) HandleTaskArgsForCall 

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

func (*FakeTaskHandler) HandleTaskCallCount 

func (fake *FakeTaskHandler) HandleTaskCallCount() int

func (*FakeTaskHandler) HandleTaskCalls 

func (fake *FakeTaskHandler) HandleTaskCalls(stub func(context.Context, *types.Task, *types.Message) (*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{}

func (*FakeTaskHandler) SetAgent added in v0.9.0 

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

func (*FakeTaskHandler) SetAgentArgsForCall added in v0.9.0 

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

func (*FakeTaskHandler) SetAgentCallCount added in v0.9.0 

func (fake *FakeTaskHandler) SetAgentCallCount() int

func (*FakeTaskHandler) SetAgentCalls added in v0.9.0 

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

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)

type FakeToolBox added in v0.9.5 

type FakeToolBox struct {
	ExecuteToolStub func(context.Context, string, map[string]any) (string, error)

	GetToolStub func(string) (server.Tool, bool)

	GetToolNamesStub func() []string

	GetToolsStub func() []sdk.ChatCompletionTool

	HasToolStub func(string) bool
	// contains filtered or unexported fields
}

func (*FakeToolBox) ExecuteTool added in v0.9.5 

func (fake *FakeToolBox) ExecuteTool(arg1 context.Context, arg2 string, arg3 map[string]any) (string, error)

func (*FakeToolBox) ExecuteToolArgsForCall added in v0.9.5 

func (fake *FakeToolBox) ExecuteToolArgsForCall(i int) (context.Context, string, map[string]any)

func (*FakeToolBox) ExecuteToolCallCount added in v0.9.5 

func (fake *FakeToolBox) ExecuteToolCallCount() int

func (*FakeToolBox) ExecuteToolCalls added in v0.9.5 

func (fake *FakeToolBox) ExecuteToolCalls(stub func(context.Context, string, map[string]any) (string, error))

func (*FakeToolBox) ExecuteToolReturns added in v0.9.5 

func (fake *FakeToolBox) ExecuteToolReturns(result1 string, result2 error)

func (*FakeToolBox) ExecuteToolReturnsOnCall added in v0.9.5 

func (fake *FakeToolBox) ExecuteToolReturnsOnCall(i int, result1 string, result2 error)

func (*FakeToolBox) GetTool added in v0.16.0 

func (fake *FakeToolBox) GetTool(arg1 string) (server.Tool, bool)

func (*FakeToolBox) GetToolArgsForCall added in v0.16.0 

func (fake *FakeToolBox) GetToolArgsForCall(i int) string

func (*FakeToolBox) GetToolCallCount added in v0.16.0 

func (fake *FakeToolBox) GetToolCallCount() int

func (*FakeToolBox) GetToolCalls added in v0.16.0 

func (fake *FakeToolBox) GetToolCalls(stub func(string) (server.Tool, bool))

func (*FakeToolBox) GetToolNames added in v0.9.5 

func (fake *FakeToolBox) GetToolNames() []string

func (*FakeToolBox) GetToolNamesCallCount added in v0.9.5 

func (fake *FakeToolBox) GetToolNamesCallCount() int

func (*FakeToolBox) GetToolNamesCalls added in v0.9.5 

func (fake *FakeToolBox) GetToolNamesCalls(stub func() []string)

func (*FakeToolBox) GetToolNamesReturns added in v0.9.5 

func (fake *FakeToolBox) GetToolNamesReturns(result1 []string)

func (*FakeToolBox) GetToolNamesReturnsOnCall added in v0.9.5 

func (fake *FakeToolBox) GetToolNamesReturnsOnCall(i int, result1 []string)

func (*FakeToolBox) GetToolReturns added in v0.16.0 

func (fake *FakeToolBox) GetToolReturns(result1 server.Tool, result2 bool)

func (*FakeToolBox) GetToolReturnsOnCall added in v0.16.0 

func (fake *FakeToolBox) GetToolReturnsOnCall(i int, result1 server.Tool, result2 bool)

func (*FakeToolBox) GetTools added in v0.9.5 

func (fake *FakeToolBox) GetTools() []sdk.ChatCompletionTool

func (*FakeToolBox) GetToolsCallCount added in v0.9.5 

func (fake *FakeToolBox) GetToolsCallCount() int

func (*FakeToolBox) GetToolsCalls added in v0.9.5 

func (fake *FakeToolBox) GetToolsCalls(stub func() []sdk.ChatCompletionTool)

func (*FakeToolBox) GetToolsReturns added in v0.9.5 

func (fake *FakeToolBox) GetToolsReturns(result1 []sdk.ChatCompletionTool)

func (*FakeToolBox) GetToolsReturnsOnCall added in v0.9.5 

func (fake *FakeToolBox) GetToolsReturnsOnCall(i int, result1 []sdk.ChatCompletionTool)

func (*FakeToolBox) HasTool added in v0.9.5 

func (fake *FakeToolBox) HasTool(arg1 string) bool

func (*FakeToolBox) HasToolArgsForCall added in v0.9.5 

func (fake *FakeToolBox) HasToolArgsForCall(i int) string

func (*FakeToolBox) HasToolCallCount added in v0.9.5 

func (fake *FakeToolBox) HasToolCallCount() int

func (*FakeToolBox) HasToolCalls added in v0.9.5 

func (fake *FakeToolBox) HasToolCalls(stub func(string) bool)

func (*FakeToolBox) HasToolReturns added in v0.9.5 

func (fake *FakeToolBox) HasToolReturns(result1 bool)

func (*FakeToolBox) HasToolReturnsOnCall added in v0.9.5 

func (fake *FakeToolBox) HasToolReturnsOnCall(i int, result1 bool)

func (*FakeToolBox) Invocations added in v0.9.5 

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

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.