Documentation
¶
Overview ¶
Package csfmocks is a generated GoMock package.
Package csfmocks is a generated GoMock package.
Package csfmocks is a generated GoMock package.
Package csfmocks is a generated GoMock package.
Package csfmocks is a generated GoMock package.
Package csfmocks is a generated GoMock package.
Index ¶
- type MockIAgentConfigurationStore
- func (m *MockIAgentConfigurationStore) EXPECT() *MockIAgentConfigurationStoreMockRecorder
- func (m *MockIAgentConfigurationStore) GetAgentConfiguration(ctx context.Context, agentID string) (*brainspinev1.AgentConfiguration, error)
- func (m *MockIAgentConfigurationStore) PutAgentConfiguration(ctx context.Context, agentID string, expectedRevision uint32, ...) (*brainspinev1.AgentConfiguration, error)
- type MockIAgentConfigurationStoreMockRecorder
- type MockIAgentSessions
- func (m *MockIAgentSessions) Cancel(ctx context.Context, request *harnessv1.CancelAgentSessionRequest) (*harnessv1.CancelAgentSessionResponse, error)
- func (m *MockIAgentSessions) EXPECT() *MockIAgentSessionsMockRecorder
- func (m *MockIAgentSessions) Get(ctx context.Context, request *harnessv1.GetAgentSessionRequest) (*harnessv1.GetAgentSessionResponse, error)
- func (m *MockIAgentSessions) List(ctx context.Context, request *harnessv1.ListAgentSessionsRequest) (*harnessv1.ListAgentSessionsResponse, error)
- func (m *MockIAgentSessions) Send(ctx context.Context, request *harnessv1.SendAgentSessionMessageRequest) (*harnessv1.SendAgentSessionMessageResponse, error)
- func (m *MockIAgentSessions) Stop(ctx context.Context, request *harnessv1.StopHarnessRequest) (*harnessv1.StopHarnessResponse, error)
- func (m *MockIAgentSessions) Submit(ctx context.Context, request *harnessv1.SubmitAgentSessionRequest) (*harnessv1.SubmitAgentSessionResponse, error)
- type MockIAgentSessionsMockRecorder
- func (mr *MockIAgentSessionsMockRecorder) Cancel(ctx, request any) *gomock.Call
- func (mr *MockIAgentSessionsMockRecorder) Get(ctx, request any) *gomock.Call
- func (mr *MockIAgentSessionsMockRecorder) List(ctx, request any) *gomock.Call
- func (mr *MockIAgentSessionsMockRecorder) Send(ctx, request any) *gomock.Call
- func (mr *MockIAgentSessionsMockRecorder) Stop(ctx, request any) *gomock.Call
- func (mr *MockIAgentSessionsMockRecorder) Submit(ctx, request any) *gomock.Call
- type MockIDispatch
- func (m *MockIDispatch) DeclareIntent(ctx context.Context, request *dispatchv1.DeclareIntentRequest) (*dispatchv1.DeclareIntentResponse, error)
- func (m *MockIDispatch) EXPECT() *MockIDispatchMockRecorder
- func (m *MockIDispatch) Enqueue(ctx context.Context, request *dispatchv1.EnqueueSliceRequest) (*dispatchv1.EnqueueSliceResponse, error)
- func (m *MockIDispatch) Frontier(ctx context.Context, request *dispatchv1.GetFrontierRequest) (*dispatchv1.GetFrontierResponse, error)
- func (m *MockIDispatch) List(ctx context.Context, request *dispatchv1.ListSlicesRequest) (*dispatchv1.ListSlicesResponse, error)
- func (m *MockIDispatch) MarkMerged(ctx context.Context, request *dispatchv1.MarkSliceMergedRequest) (*dispatchv1.MarkSliceMergedResponse, error)
- func (m *MockIDispatch) Reprioritize(ctx context.Context, request *dispatchv1.ReprioritizeRequest) (*dispatchv1.ReprioritizeResponse, error)
- func (m *MockIDispatch) Route(ctx context.Context, request *dispatchv1.RouteMessageRequest) (*dispatchv1.RouteMessageResponse, error)
- type MockIDispatchMockRecorder
- func (mr *MockIDispatchMockRecorder) DeclareIntent(ctx, request any) *gomock.Call
- func (mr *MockIDispatchMockRecorder) Enqueue(ctx, request any) *gomock.Call
- func (mr *MockIDispatchMockRecorder) Frontier(ctx, request any) *gomock.Call
- func (mr *MockIDispatchMockRecorder) List(ctx, request any) *gomock.Call
- func (mr *MockIDispatchMockRecorder) MarkMerged(ctx, request any) *gomock.Call
- func (mr *MockIDispatchMockRecorder) Reprioritize(ctx, request any) *gomock.Call
- func (mr *MockIDispatchMockRecorder) Route(ctx, request any) *gomock.Call
- type MockIHTTPDoer
- type MockIHTTPDoerMockRecorder
- type MockIKnowledgeIndex
- func (m *MockIKnowledgeIndex) EXPECT() *MockIKnowledgeIndexMockRecorder
- func (m *MockIKnowledgeIndex) Index(ctx context.Context, document *brainspinev1.SourceDocument, text string) error
- func (m *MockIKnowledgeIndex) Search(ctx context.Context, request *brainspinev1.SearchRequest) (*brainspinev1.SearchResult, error)
- type MockIKnowledgeIndexMockRecorder
- type MockIKnowledgeStore
- func (m *MockIKnowledgeStore) ClaimProjection(ctx context.Context) (*brainspinev1.ProjectionTask, error)
- func (m *MockIKnowledgeStore) CompleteProjection(ctx context.Context, task *brainspinev1.ProjectionTask) error
- func (m *MockIKnowledgeStore) CountProjections(ctx context.Context) ([]*brainspinev1.ProjectionCount, error)
- func (m *MockIKnowledgeStore) EXPECT() *MockIKnowledgeStoreMockRecorder
- func (m *MockIKnowledgeStore) FailProjection(ctx context.Context, task *brainspinev1.ProjectionTask, problem string) error
- func (m *MockIKnowledgeStore) GetDocument(ctx context.Context, request *brainspinev1.DocumentRequest) (*brainspinev1.SourceDocument, error)
- func (m *MockIKnowledgeStore) GetGraph(ctx context.Context, request *brainspinev1.GraphRequest) (*brainspinev1.GraphSnapshot, error)
- func (m *MockIKnowledgeStore) GetProjection(ctx context.Context, request *brainspinev1.DocumentRequest) (*brainspinev1.ProjectionTask, error)
- func (m *MockIKnowledgeStore) PutDocument(ctx context.Context, document *brainspinev1.SourceDocument) (*brainspinev1.SourceDocument, error)
- func (m *MockIKnowledgeStore) PutEdge(ctx context.Context, edge *brainspinev1.KnowledgeEdge) (*brainspinev1.KnowledgeEdge, error)
- func (m *MockIKnowledgeStore) PutNode(ctx context.Context, node *brainspinev1.KnowledgeNode) (*brainspinev1.KnowledgeNode, error)
- type MockIKnowledgeStoreMockRecorder
- func (mr *MockIKnowledgeStoreMockRecorder) ClaimProjection(ctx any) *gomock.Call
- func (mr *MockIKnowledgeStoreMockRecorder) CompleteProjection(ctx, task any) *gomock.Call
- func (mr *MockIKnowledgeStoreMockRecorder) CountProjections(ctx any) *gomock.Call
- func (mr *MockIKnowledgeStoreMockRecorder) FailProjection(ctx, task, problem any) *gomock.Call
- func (mr *MockIKnowledgeStoreMockRecorder) GetDocument(ctx, request any) *gomock.Call
- func (mr *MockIKnowledgeStoreMockRecorder) GetGraph(ctx, request any) *gomock.Call
- func (mr *MockIKnowledgeStoreMockRecorder) GetProjection(ctx, request any) *gomock.Call
- func (mr *MockIKnowledgeStoreMockRecorder) PutDocument(ctx, document any) *gomock.Call
- func (mr *MockIKnowledgeStoreMockRecorder) PutEdge(ctx, edge any) *gomock.Call
- func (mr *MockIKnowledgeStoreMockRecorder) PutNode(ctx, node any) *gomock.Call
- type MockIOpenSearchClient
- func (m *MockIOpenSearchClient) EXPECT() *MockIOpenSearchClientMockRecorder
- func (m *MockIOpenSearchClient) Index(ctx context.Context, req opensearchapi.IndexReq) (*opensearchapi.IndexResp, error)
- func (m *MockIOpenSearchClient) Search(ctx context.Context, req *opensearchapi.SearchReq) (*opensearchapi.SearchResp, error)
- type MockIOpenSearchClientMockRecorder
- type MockISimulationTraces
- func (m *MockISimulationTraces) EXPECT() *MockISimulationTracesMockRecorder
- func (m *MockISimulationTraces) Start(ctx context.Context) error
- func (m *MockISimulationTraces) Stop(ctx context.Context) error
- func (m *MockISimulationTraces) UploadTraces(ctx context.Context, spans []*v1.ResourceSpans) error
- type MockISimulationTracesMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockIAgentConfigurationStore ¶
type MockIAgentConfigurationStore struct {
// contains filtered or unexported fields
}
MockIAgentConfigurationStore is a mock of IAgentConfigurationStore interface.
func NewMockIAgentConfigurationStore ¶
func NewMockIAgentConfigurationStore(ctrl *gomock.Controller) *MockIAgentConfigurationStore
NewMockIAgentConfigurationStore creates a new mock instance.
func (*MockIAgentConfigurationStore) EXPECT ¶
func (m *MockIAgentConfigurationStore) EXPECT() *MockIAgentConfigurationStoreMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIAgentConfigurationStore) GetAgentConfiguration ¶
func (m *MockIAgentConfigurationStore) GetAgentConfiguration(ctx context.Context, agentID string) (*brainspinev1.AgentConfiguration, error)
GetAgentConfiguration mocks base method.
func (*MockIAgentConfigurationStore) PutAgentConfiguration ¶
func (m *MockIAgentConfigurationStore) PutAgentConfiguration(ctx context.Context, agentID string, expectedRevision uint32, configuration *brainspinev1.AgentConfigurationInput) (*brainspinev1.AgentConfiguration, error)
PutAgentConfiguration mocks base method.
type MockIAgentConfigurationStoreMockRecorder ¶
type MockIAgentConfigurationStoreMockRecorder struct {
// contains filtered or unexported fields
}
MockIAgentConfigurationStoreMockRecorder is the mock recorder for MockIAgentConfigurationStore.
func (*MockIAgentConfigurationStoreMockRecorder) GetAgentConfiguration ¶
func (mr *MockIAgentConfigurationStoreMockRecorder) GetAgentConfiguration(ctx, agentID any) *gomock.Call
GetAgentConfiguration indicates an expected call of GetAgentConfiguration.
func (*MockIAgentConfigurationStoreMockRecorder) PutAgentConfiguration ¶
func (mr *MockIAgentConfigurationStoreMockRecorder) PutAgentConfiguration(ctx, agentID, expectedRevision, configuration any) *gomock.Call
PutAgentConfiguration indicates an expected call of PutAgentConfiguration.
type MockIAgentSessions ¶ added in v0.2.0
type MockIAgentSessions struct {
// contains filtered or unexported fields
}
MockIAgentSessions is a mock of IAgentSessions interface.
func NewMockIAgentSessions ¶ added in v0.2.0
func NewMockIAgentSessions(ctrl *gomock.Controller) *MockIAgentSessions
NewMockIAgentSessions creates a new mock instance.
func (*MockIAgentSessions) Cancel ¶ added in v0.2.0
func (m *MockIAgentSessions) Cancel(ctx context.Context, request *harnessv1.CancelAgentSessionRequest) (*harnessv1.CancelAgentSessionResponse, error)
Cancel mocks base method.
func (*MockIAgentSessions) EXPECT ¶ added in v0.2.0
func (m *MockIAgentSessions) EXPECT() *MockIAgentSessionsMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIAgentSessions) Get ¶ added in v0.2.0
func (m *MockIAgentSessions) Get(ctx context.Context, request *harnessv1.GetAgentSessionRequest) (*harnessv1.GetAgentSessionResponse, error)
Get mocks base method.
func (*MockIAgentSessions) List ¶ added in v0.2.0
func (m *MockIAgentSessions) List(ctx context.Context, request *harnessv1.ListAgentSessionsRequest) (*harnessv1.ListAgentSessionsResponse, error)
List mocks base method.
func (*MockIAgentSessions) Send ¶ added in v0.2.0
func (m *MockIAgentSessions) Send(ctx context.Context, request *harnessv1.SendAgentSessionMessageRequest) (*harnessv1.SendAgentSessionMessageResponse, error)
Send mocks base method.
func (*MockIAgentSessions) Stop ¶ added in v0.2.0
func (m *MockIAgentSessions) Stop(ctx context.Context, request *harnessv1.StopHarnessRequest) (*harnessv1.StopHarnessResponse, error)
Stop mocks base method.
func (*MockIAgentSessions) Submit ¶ added in v0.2.0
func (m *MockIAgentSessions) Submit(ctx context.Context, request *harnessv1.SubmitAgentSessionRequest) (*harnessv1.SubmitAgentSessionResponse, error)
Submit mocks base method.
type MockIAgentSessionsMockRecorder ¶ added in v0.2.0
type MockIAgentSessionsMockRecorder struct {
// contains filtered or unexported fields
}
MockIAgentSessionsMockRecorder is the mock recorder for MockIAgentSessions.
func (*MockIAgentSessionsMockRecorder) Cancel ¶ added in v0.2.0
func (mr *MockIAgentSessionsMockRecorder) Cancel(ctx, request any) *gomock.Call
Cancel indicates an expected call of Cancel.
func (*MockIAgentSessionsMockRecorder) Get ¶ added in v0.2.0
func (mr *MockIAgentSessionsMockRecorder) Get(ctx, request any) *gomock.Call
Get indicates an expected call of Get.
func (*MockIAgentSessionsMockRecorder) List ¶ added in v0.2.0
func (mr *MockIAgentSessionsMockRecorder) List(ctx, request any) *gomock.Call
List indicates an expected call of List.
func (*MockIAgentSessionsMockRecorder) Send ¶ added in v0.2.0
func (mr *MockIAgentSessionsMockRecorder) Send(ctx, request any) *gomock.Call
Send indicates an expected call of Send.
type MockIDispatch ¶ added in v0.2.0
type MockIDispatch struct {
// contains filtered or unexported fields
}
MockIDispatch is a mock of IDispatch interface.
func NewMockIDispatch ¶ added in v0.2.0
func NewMockIDispatch(ctrl *gomock.Controller) *MockIDispatch
NewMockIDispatch creates a new mock instance.
func (*MockIDispatch) DeclareIntent ¶ added in v0.2.0
func (m *MockIDispatch) DeclareIntent(ctx context.Context, request *dispatchv1.DeclareIntentRequest) (*dispatchv1.DeclareIntentResponse, error)
DeclareIntent mocks base method.
func (*MockIDispatch) EXPECT ¶ added in v0.2.0
func (m *MockIDispatch) EXPECT() *MockIDispatchMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIDispatch) Enqueue ¶ added in v0.2.0
func (m *MockIDispatch) Enqueue(ctx context.Context, request *dispatchv1.EnqueueSliceRequest) (*dispatchv1.EnqueueSliceResponse, error)
Enqueue mocks base method.
func (*MockIDispatch) Frontier ¶ added in v0.2.0
func (m *MockIDispatch) Frontier(ctx context.Context, request *dispatchv1.GetFrontierRequest) (*dispatchv1.GetFrontierResponse, error)
Frontier mocks base method.
func (*MockIDispatch) List ¶ added in v0.2.0
func (m *MockIDispatch) List(ctx context.Context, request *dispatchv1.ListSlicesRequest) (*dispatchv1.ListSlicesResponse, error)
List mocks base method.
func (*MockIDispatch) MarkMerged ¶ added in v0.2.0
func (m *MockIDispatch) MarkMerged(ctx context.Context, request *dispatchv1.MarkSliceMergedRequest) (*dispatchv1.MarkSliceMergedResponse, error)
MarkMerged mocks base method.
func (*MockIDispatch) Reprioritize ¶ added in v0.2.0
func (m *MockIDispatch) Reprioritize(ctx context.Context, request *dispatchv1.ReprioritizeRequest) (*dispatchv1.ReprioritizeResponse, error)
Reprioritize mocks base method.
func (*MockIDispatch) Route ¶ added in v0.2.0
func (m *MockIDispatch) Route(ctx context.Context, request *dispatchv1.RouteMessageRequest) (*dispatchv1.RouteMessageResponse, error)
Route mocks base method.
type MockIDispatchMockRecorder ¶ added in v0.2.0
type MockIDispatchMockRecorder struct {
// contains filtered or unexported fields
}
MockIDispatchMockRecorder is the mock recorder for MockIDispatch.
func (*MockIDispatchMockRecorder) DeclareIntent ¶ added in v0.2.0
func (mr *MockIDispatchMockRecorder) DeclareIntent(ctx, request any) *gomock.Call
DeclareIntent indicates an expected call of DeclareIntent.
func (*MockIDispatchMockRecorder) Enqueue ¶ added in v0.2.0
func (mr *MockIDispatchMockRecorder) Enqueue(ctx, request any) *gomock.Call
Enqueue indicates an expected call of Enqueue.
func (*MockIDispatchMockRecorder) Frontier ¶ added in v0.2.0
func (mr *MockIDispatchMockRecorder) Frontier(ctx, request any) *gomock.Call
Frontier indicates an expected call of Frontier.
func (*MockIDispatchMockRecorder) List ¶ added in v0.2.0
func (mr *MockIDispatchMockRecorder) List(ctx, request any) *gomock.Call
List indicates an expected call of List.
func (*MockIDispatchMockRecorder) MarkMerged ¶ added in v0.2.0
func (mr *MockIDispatchMockRecorder) MarkMerged(ctx, request any) *gomock.Call
MarkMerged indicates an expected call of MarkMerged.
func (*MockIDispatchMockRecorder) Reprioritize ¶ added in v0.2.0
func (mr *MockIDispatchMockRecorder) Reprioritize(ctx, request any) *gomock.Call
Reprioritize indicates an expected call of Reprioritize.
type MockIHTTPDoer ¶
type MockIHTTPDoer struct {
// contains filtered or unexported fields
}
MockIHTTPDoer is a mock of IHTTPDoer interface.
func NewMockIHTTPDoer ¶
func NewMockIHTTPDoer(ctrl *gomock.Controller) *MockIHTTPDoer
NewMockIHTTPDoer creates a new mock instance.
func (*MockIHTTPDoer) EXPECT ¶
func (m *MockIHTTPDoer) EXPECT() *MockIHTTPDoerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockIHTTPDoerMockRecorder ¶
type MockIHTTPDoerMockRecorder struct {
// contains filtered or unexported fields
}
MockIHTTPDoerMockRecorder is the mock recorder for MockIHTTPDoer.
type MockIKnowledgeIndex ¶
type MockIKnowledgeIndex struct {
// contains filtered or unexported fields
}
MockIKnowledgeIndex is a mock of IKnowledgeIndex interface.
func NewMockIKnowledgeIndex ¶
func NewMockIKnowledgeIndex(ctrl *gomock.Controller) *MockIKnowledgeIndex
NewMockIKnowledgeIndex creates a new mock instance.
func (*MockIKnowledgeIndex) EXPECT ¶
func (m *MockIKnowledgeIndex) EXPECT() *MockIKnowledgeIndexMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIKnowledgeIndex) Index ¶
func (m *MockIKnowledgeIndex) Index(ctx context.Context, document *brainspinev1.SourceDocument, text string) error
Index mocks base method.
func (*MockIKnowledgeIndex) Search ¶
func (m *MockIKnowledgeIndex) Search(ctx context.Context, request *brainspinev1.SearchRequest) (*brainspinev1.SearchResult, error)
Search mocks base method.
type MockIKnowledgeIndexMockRecorder ¶
type MockIKnowledgeIndexMockRecorder struct {
// contains filtered or unexported fields
}
MockIKnowledgeIndexMockRecorder is the mock recorder for MockIKnowledgeIndex.
type MockIKnowledgeStore ¶
type MockIKnowledgeStore struct {
// contains filtered or unexported fields
}
MockIKnowledgeStore is a mock of IKnowledgeStore interface.
func NewMockIKnowledgeStore ¶
func NewMockIKnowledgeStore(ctrl *gomock.Controller) *MockIKnowledgeStore
NewMockIKnowledgeStore creates a new mock instance.
func (*MockIKnowledgeStore) ClaimProjection ¶
func (m *MockIKnowledgeStore) ClaimProjection(ctx context.Context) (*brainspinev1.ProjectionTask, error)
ClaimProjection mocks base method.
func (*MockIKnowledgeStore) CompleteProjection ¶
func (m *MockIKnowledgeStore) CompleteProjection(ctx context.Context, task *brainspinev1.ProjectionTask) error
CompleteProjection mocks base method.
func (*MockIKnowledgeStore) CountProjections ¶
func (m *MockIKnowledgeStore) CountProjections(ctx context.Context) ([]*brainspinev1.ProjectionCount, error)
CountProjections mocks base method.
func (*MockIKnowledgeStore) EXPECT ¶
func (m *MockIKnowledgeStore) EXPECT() *MockIKnowledgeStoreMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIKnowledgeStore) FailProjection ¶
func (m *MockIKnowledgeStore) FailProjection(ctx context.Context, task *brainspinev1.ProjectionTask, problem string) error
FailProjection mocks base method.
func (*MockIKnowledgeStore) GetDocument ¶
func (m *MockIKnowledgeStore) GetDocument(ctx context.Context, request *brainspinev1.DocumentRequest) (*brainspinev1.SourceDocument, error)
GetDocument mocks base method.
func (*MockIKnowledgeStore) GetGraph ¶
func (m *MockIKnowledgeStore) GetGraph(ctx context.Context, request *brainspinev1.GraphRequest) (*brainspinev1.GraphSnapshot, error)
GetGraph mocks base method.
func (*MockIKnowledgeStore) GetProjection ¶
func (m *MockIKnowledgeStore) GetProjection(ctx context.Context, request *brainspinev1.DocumentRequest) (*brainspinev1.ProjectionTask, error)
GetProjection mocks base method.
func (*MockIKnowledgeStore) PutDocument ¶
func (m *MockIKnowledgeStore) PutDocument(ctx context.Context, document *brainspinev1.SourceDocument) (*brainspinev1.SourceDocument, error)
PutDocument mocks base method.
func (*MockIKnowledgeStore) PutEdge ¶
func (m *MockIKnowledgeStore) PutEdge(ctx context.Context, edge *brainspinev1.KnowledgeEdge) (*brainspinev1.KnowledgeEdge, error)
PutEdge mocks base method.
func (*MockIKnowledgeStore) PutNode ¶
func (m *MockIKnowledgeStore) PutNode(ctx context.Context, node *brainspinev1.KnowledgeNode) (*brainspinev1.KnowledgeNode, error)
PutNode mocks base method.
type MockIKnowledgeStoreMockRecorder ¶
type MockIKnowledgeStoreMockRecorder struct {
// contains filtered or unexported fields
}
MockIKnowledgeStoreMockRecorder is the mock recorder for MockIKnowledgeStore.
func (*MockIKnowledgeStoreMockRecorder) ClaimProjection ¶
func (mr *MockIKnowledgeStoreMockRecorder) ClaimProjection(ctx any) *gomock.Call
ClaimProjection indicates an expected call of ClaimProjection.
func (*MockIKnowledgeStoreMockRecorder) CompleteProjection ¶
func (mr *MockIKnowledgeStoreMockRecorder) CompleteProjection(ctx, task any) *gomock.Call
CompleteProjection indicates an expected call of CompleteProjection.
func (*MockIKnowledgeStoreMockRecorder) CountProjections ¶
func (mr *MockIKnowledgeStoreMockRecorder) CountProjections(ctx any) *gomock.Call
CountProjections indicates an expected call of CountProjections.
func (*MockIKnowledgeStoreMockRecorder) FailProjection ¶
func (mr *MockIKnowledgeStoreMockRecorder) FailProjection(ctx, task, problem any) *gomock.Call
FailProjection indicates an expected call of FailProjection.
func (*MockIKnowledgeStoreMockRecorder) GetDocument ¶
func (mr *MockIKnowledgeStoreMockRecorder) GetDocument(ctx, request any) *gomock.Call
GetDocument indicates an expected call of GetDocument.
func (*MockIKnowledgeStoreMockRecorder) GetGraph ¶
func (mr *MockIKnowledgeStoreMockRecorder) GetGraph(ctx, request any) *gomock.Call
GetGraph indicates an expected call of GetGraph.
func (*MockIKnowledgeStoreMockRecorder) GetProjection ¶
func (mr *MockIKnowledgeStoreMockRecorder) GetProjection(ctx, request any) *gomock.Call
GetProjection indicates an expected call of GetProjection.
func (*MockIKnowledgeStoreMockRecorder) PutDocument ¶
func (mr *MockIKnowledgeStoreMockRecorder) PutDocument(ctx, document any) *gomock.Call
PutDocument indicates an expected call of PutDocument.
type MockIOpenSearchClient ¶
type MockIOpenSearchClient struct {
// contains filtered or unexported fields
}
MockIOpenSearchClient is a mock of IOpenSearchClient interface.
func NewMockIOpenSearchClient ¶
func NewMockIOpenSearchClient(ctrl *gomock.Controller) *MockIOpenSearchClient
NewMockIOpenSearchClient creates a new mock instance.
func (*MockIOpenSearchClient) EXPECT ¶
func (m *MockIOpenSearchClient) EXPECT() *MockIOpenSearchClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIOpenSearchClient) Index ¶
func (m *MockIOpenSearchClient) Index(ctx context.Context, req opensearchapi.IndexReq) (*opensearchapi.IndexResp, error)
Index mocks base method.
func (*MockIOpenSearchClient) Search ¶
func (m *MockIOpenSearchClient) Search(ctx context.Context, req *opensearchapi.SearchReq) (*opensearchapi.SearchResp, error)
Search mocks base method.
type MockIOpenSearchClientMockRecorder ¶
type MockIOpenSearchClientMockRecorder struct {
// contains filtered or unexported fields
}
MockIOpenSearchClientMockRecorder is the mock recorder for MockIOpenSearchClient.
type MockISimulationTraces ¶
type MockISimulationTraces struct {
// contains filtered or unexported fields
}
MockISimulationTraces is a mock of ISimulationTraces interface.
func NewMockISimulationTraces ¶
func NewMockISimulationTraces(ctrl *gomock.Controller) *MockISimulationTraces
NewMockISimulationTraces creates a new mock instance.
func (*MockISimulationTraces) EXPECT ¶
func (m *MockISimulationTraces) EXPECT() *MockISimulationTracesMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockISimulationTraces) Start ¶
func (m *MockISimulationTraces) Start(ctx context.Context) error
Start mocks base method.
func (*MockISimulationTraces) Stop ¶
func (m *MockISimulationTraces) Stop(ctx context.Context) error
Stop mocks base method.
func (*MockISimulationTraces) UploadTraces ¶
func (m *MockISimulationTraces) UploadTraces(ctx context.Context, spans []*v1.ResourceSpans) error
UploadTraces mocks base method.
type MockISimulationTracesMockRecorder ¶
type MockISimulationTracesMockRecorder struct {
// contains filtered or unexported fields
}
MockISimulationTracesMockRecorder is the mock recorder for MockISimulationTraces.
func (*MockISimulationTracesMockRecorder) Start ¶
func (mr *MockISimulationTracesMockRecorder) Start(ctx any) *gomock.Call
Start indicates an expected call of Start.
func (*MockISimulationTracesMockRecorder) Stop ¶
func (mr *MockISimulationTracesMockRecorder) Stop(ctx any) *gomock.Call
Stop indicates an expected call of Stop.
func (*MockISimulationTracesMockRecorder) UploadTraces ¶
func (mr *MockISimulationTracesMockRecorder) UploadTraces(ctx, spans any) *gomock.Call
UploadTraces indicates an expected call of UploadTraces.