mocks

package
v0.10.3-0...-f06509b Latest Latest
Warning

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

 Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockQueryNode 

type MockQueryNode struct {
	*MockQueryNodeServer

	ID int64
	// contains filtered or unexported fields
}

func NewMockQueryNode 

func NewMockQueryNode(t *testing.T, etcdCli *clientv3.Client, nodeID int64) *MockQueryNode

func (*MockQueryNode) Start 

func (node *MockQueryNode) Start() error

func (*MockQueryNode) Stop 

func (node *MockQueryNode) Stop()

func (*MockQueryNode) Stopping 

func (node *MockQueryNode) Stopping()

type MockQueryNodeServer 

type MockQueryNodeServer struct {
	mock.Mock
}

MockQueryNodeServer is an autogenerated mock type for the QueryNodeServer type

func NewMockQueryNodeServer 

func NewMockQueryNodeServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockQueryNodeServer

NewMockQueryNodeServer creates a new instance of MockQueryNodeServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockQueryNodeServer) Delete 

func (_m *MockQueryNodeServer) Delete(_a0 context.Context, _a1 *querypb.DeleteRequest) (*commonpb.Status, error)

Delete provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) EXPECT 

func (_m *MockQueryNodeServer) EXPECT() *MockQueryNodeServer_Expecter

func (*MockQueryNodeServer) GetComponentStates 

func (_m *MockQueryNodeServer) GetComponentStates(_a0 context.Context, _a1 *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error)

GetComponentStates provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) GetDataDistribution 

func (_m *MockQueryNodeServer) GetDataDistribution(_a0 context.Context, _a1 *querypb.GetDataDistributionRequest) (*querypb.GetDataDistributionResponse, error)

GetDataDistribution provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) GetMetrics 

func (_m *MockQueryNodeServer) GetMetrics(_a0 context.Context, _a1 *milvuspb.GetMetricsRequest) (*milvuspb.GetMetricsResponse, error)

GetMetrics provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) GetSegmentInfo 

func (_m *MockQueryNodeServer) GetSegmentInfo(_a0 context.Context, _a1 *querypb.GetSegmentInfoRequest) (*querypb.GetSegmentInfoResponse, error)

GetSegmentInfo provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) GetStatistics 

func (_m *MockQueryNodeServer) GetStatistics(_a0 context.Context, _a1 *querypb.GetStatisticsRequest) (*internalpb.GetStatisticsResponse, error)

GetStatistics provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) GetStatisticsChannel 

func (_m *MockQueryNodeServer) GetStatisticsChannel(_a0 context.Context, _a1 *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error)

GetStatisticsChannel provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) GetTimeTickChannel 

func (_m *MockQueryNodeServer) GetTimeTickChannel(_a0 context.Context, _a1 *internalpb.GetTimeTickChannelRequest) (*milvuspb.StringResponse, error)

GetTimeTickChannel provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) LoadPartitions 

func (_m *MockQueryNodeServer) LoadPartitions(_a0 context.Context, _a1 *querypb.LoadPartitionsRequest) (*commonpb.Status, error)

LoadPartitions provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) LoadSegments 

func (_m *MockQueryNodeServer) LoadSegments(_a0 context.Context, _a1 *querypb.LoadSegmentsRequest) (*commonpb.Status, error)

LoadSegments provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) Query 

func (_m *MockQueryNodeServer) Query(_a0 context.Context, _a1 *querypb.QueryRequest) (*internalpb.RetrieveResults, error)

Query provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) QuerySegments 

func (_m *MockQueryNodeServer) QuerySegments(_a0 context.Context, _a1 *querypb.QueryRequest) (*internalpb.RetrieveResults, error)

QuerySegments provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) QueryStream 

func (_m *MockQueryNodeServer) QueryStream(_a0 *querypb.QueryRequest, _a1 querypb.QueryNode_QueryStreamServer) error

QueryStream provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) QueryStreamSegments 

func (_m *MockQueryNodeServer) QueryStreamSegments(_a0 *querypb.QueryRequest, _a1 querypb.QueryNode_QueryStreamSegmentsServer) error

QueryStreamSegments provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) ReleaseCollection 

func (_m *MockQueryNodeServer) ReleaseCollection(_a0 context.Context, _a1 *querypb.ReleaseCollectionRequest) (*commonpb.Status, error)

ReleaseCollection provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) ReleasePartitions 

func (_m *MockQueryNodeServer) ReleasePartitions(_a0 context.Context, _a1 *querypb.ReleasePartitionsRequest) (*commonpb.Status, error)

ReleasePartitions provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) ReleaseSegments 

func (_m *MockQueryNodeServer) ReleaseSegments(_a0 context.Context, _a1 *querypb.ReleaseSegmentsRequest) (*commonpb.Status, error)

ReleaseSegments provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) Search 

func (_m *MockQueryNodeServer) Search(_a0 context.Context, _a1 *querypb.SearchRequest) (*internalpb.SearchResults, error)

Search provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) SearchSegments 

func (_m *MockQueryNodeServer) SearchSegments(_a0 context.Context, _a1 *querypb.SearchRequest) (*internalpb.SearchResults, error)

SearchSegments provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) ShowConfigurations 

func (_m *MockQueryNodeServer) ShowConfigurations(_a0 context.Context, _a1 *internalpb.ShowConfigurationsRequest) (*internalpb.ShowConfigurationsResponse, error)

ShowConfigurations provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) SyncDistribution 

func (_m *MockQueryNodeServer) SyncDistribution(_a0 context.Context, _a1 *querypb.SyncDistributionRequest) (*commonpb.Status, error)

SyncDistribution provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) SyncReplicaSegments 

func (_m *MockQueryNodeServer) SyncReplicaSegments(_a0 context.Context, _a1 *querypb.SyncReplicaSegmentsRequest) (*commonpb.Status, error)

SyncReplicaSegments provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) UnsubDmChannel 

func (_m *MockQueryNodeServer) UnsubDmChannel(_a0 context.Context, _a1 *querypb.UnsubDmChannelRequest) (*commonpb.Status, error)

UnsubDmChannel provides a mock function with given fields: _a0, _a1

func (*MockQueryNodeServer) WatchDmChannels 

func (_m *MockQueryNodeServer) WatchDmChannels(_a0 context.Context, _a1 *querypb.WatchDmChannelsRequest) (*commonpb.Status, error)

WatchDmChannels provides a mock function with given fields: _a0, _a1

type MockQueryNodeServer_Delete_Call 

type MockQueryNodeServer_Delete_Call struct {
	*mock.Call
}

MockQueryNodeServer_Delete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Delete'

func (*MockQueryNodeServer_Delete_Call) Return 

func (_c *MockQueryNodeServer_Delete_Call) Return(_a0 *commonpb.Status, _a1 error) *MockQueryNodeServer_Delete_Call

func (*MockQueryNodeServer_Delete_Call) Run 

func (_c *MockQueryNodeServer_Delete_Call) Run(run func(_a0 context.Context, _a1 *querypb.DeleteRequest)) *MockQueryNodeServer_Delete_Call

func (*MockQueryNodeServer_Delete_Call) RunAndReturn 

func (_c *MockQueryNodeServer_Delete_Call) RunAndReturn(run func(context.Context, *querypb.DeleteRequest) (*commonpb.Status, error)) *MockQueryNodeServer_Delete_Call

type MockQueryNodeServer_Expecter 

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

func (*MockQueryNodeServer_Expecter) Delete 

func (_e *MockQueryNodeServer_Expecter) Delete(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_Delete_Call

Delete is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.DeleteRequest

func (*MockQueryNodeServer_Expecter) GetComponentStates 

func (_e *MockQueryNodeServer_Expecter) GetComponentStates(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_GetComponentStates_Call

GetComponentStates is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *milvuspb.GetComponentStatesRequest

func (*MockQueryNodeServer_Expecter) GetDataDistribution 

func (_e *MockQueryNodeServer_Expecter) GetDataDistribution(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_GetDataDistribution_Call

GetDataDistribution is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.GetDataDistributionRequest

func (*MockQueryNodeServer_Expecter) GetMetrics 

func (_e *MockQueryNodeServer_Expecter) GetMetrics(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_GetMetrics_Call

GetMetrics is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *milvuspb.GetMetricsRequest

func (*MockQueryNodeServer_Expecter) GetSegmentInfo 

func (_e *MockQueryNodeServer_Expecter) GetSegmentInfo(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_GetSegmentInfo_Call

GetSegmentInfo is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.GetSegmentInfoRequest

func (*MockQueryNodeServer_Expecter) GetStatistics 

func (_e *MockQueryNodeServer_Expecter) GetStatistics(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_GetStatistics_Call

GetStatistics is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.GetStatisticsRequest

func (*MockQueryNodeServer_Expecter) GetStatisticsChannel 

func (_e *MockQueryNodeServer_Expecter) GetStatisticsChannel(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_GetStatisticsChannel_Call

GetStatisticsChannel is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *internalpb.GetStatisticsChannelRequest

func (*MockQueryNodeServer_Expecter) GetTimeTickChannel 

func (_e *MockQueryNodeServer_Expecter) GetTimeTickChannel(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_GetTimeTickChannel_Call

GetTimeTickChannel is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *internalpb.GetTimeTickChannelRequest

func (*MockQueryNodeServer_Expecter) LoadPartitions 

func (_e *MockQueryNodeServer_Expecter) LoadPartitions(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_LoadPartitions_Call

LoadPartitions is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.LoadPartitionsRequest

func (*MockQueryNodeServer_Expecter) LoadSegments 

func (_e *MockQueryNodeServer_Expecter) LoadSegments(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_LoadSegments_Call

LoadSegments is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.LoadSegmentsRequest

func (*MockQueryNodeServer_Expecter) Query 

func (_e *MockQueryNodeServer_Expecter) Query(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_Query_Call

Query is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.QueryRequest

func (*MockQueryNodeServer_Expecter) QuerySegments 

func (_e *MockQueryNodeServer_Expecter) QuerySegments(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_QuerySegments_Call

QuerySegments is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.QueryRequest

func (*MockQueryNodeServer_Expecter) QueryStream 

func (_e *MockQueryNodeServer_Expecter) QueryStream(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_QueryStream_Call

QueryStream is a helper method to define mock.On call

  • _a0 *querypb.QueryRequest
  • _a1 querypb.QueryNode_QueryStreamServer

func (*MockQueryNodeServer_Expecter) QueryStreamSegments 

func (_e *MockQueryNodeServer_Expecter) QueryStreamSegments(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_QueryStreamSegments_Call

QueryStreamSegments is a helper method to define mock.On call

  • _a0 *querypb.QueryRequest
  • _a1 querypb.QueryNode_QueryStreamSegmentsServer

func (*MockQueryNodeServer_Expecter) ReleaseCollection 

func (_e *MockQueryNodeServer_Expecter) ReleaseCollection(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_ReleaseCollection_Call

ReleaseCollection is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.ReleaseCollectionRequest

func (*MockQueryNodeServer_Expecter) ReleasePartitions 

func (_e *MockQueryNodeServer_Expecter) ReleasePartitions(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_ReleasePartitions_Call

ReleasePartitions is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.ReleasePartitionsRequest

func (*MockQueryNodeServer_Expecter) ReleaseSegments 

func (_e *MockQueryNodeServer_Expecter) ReleaseSegments(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_ReleaseSegments_Call

ReleaseSegments is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.ReleaseSegmentsRequest

func (*MockQueryNodeServer_Expecter) Search 

func (_e *MockQueryNodeServer_Expecter) Search(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_Search_Call

Search is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.SearchRequest

func (*MockQueryNodeServer_Expecter) SearchSegments 

func (_e *MockQueryNodeServer_Expecter) SearchSegments(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_SearchSegments_Call

SearchSegments is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.SearchRequest

func (*MockQueryNodeServer_Expecter) ShowConfigurations 

func (_e *MockQueryNodeServer_Expecter) ShowConfigurations(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_ShowConfigurations_Call

ShowConfigurations is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *internalpb.ShowConfigurationsRequest

func (*MockQueryNodeServer_Expecter) SyncDistribution 

func (_e *MockQueryNodeServer_Expecter) SyncDistribution(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_SyncDistribution_Call

SyncDistribution is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.SyncDistributionRequest

func (*MockQueryNodeServer_Expecter) SyncReplicaSegments 

func (_e *MockQueryNodeServer_Expecter) SyncReplicaSegments(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_SyncReplicaSegments_Call

SyncReplicaSegments is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.SyncReplicaSegmentsRequest

func (*MockQueryNodeServer_Expecter) UnsubDmChannel 

func (_e *MockQueryNodeServer_Expecter) UnsubDmChannel(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_UnsubDmChannel_Call

UnsubDmChannel is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.UnsubDmChannelRequest

func (*MockQueryNodeServer_Expecter) WatchDmChannels 

func (_e *MockQueryNodeServer_Expecter) WatchDmChannels(_a0 interface{}, _a1 interface{}) *MockQueryNodeServer_WatchDmChannels_Call

WatchDmChannels is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *querypb.WatchDmChannelsRequest

type MockQueryNodeServer_GetComponentStates_Call 

type MockQueryNodeServer_GetComponentStates_Call struct {
	*mock.Call
}

MockQueryNodeServer_GetComponentStates_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetComponentStates'

func (*MockQueryNodeServer_GetComponentStates_Call) Return 

func (_c *MockQueryNodeServer_GetComponentStates_Call) Return(_a0 *milvuspb.ComponentStates, _a1 error) *MockQueryNodeServer_GetComponentStates_Call

func (*MockQueryNodeServer_GetComponentStates_Call) Run 

func (_c *MockQueryNodeServer_GetComponentStates_Call) Run(run func(_a0 context.Context, _a1 *milvuspb.GetComponentStatesRequest)) *MockQueryNodeServer_GetComponentStates_Call

func (*MockQueryNodeServer_GetComponentStates_Call) RunAndReturn 

func (_c *MockQueryNodeServer_GetComponentStates_Call) RunAndReturn(run func(context.Context, *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error)) *MockQueryNodeServer_GetComponentStates_Call

type MockQueryNodeServer_GetDataDistribution_Call 

type MockQueryNodeServer_GetDataDistribution_Call struct {
	*mock.Call
}

MockQueryNodeServer_GetDataDistribution_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetDataDistribution'

func (*MockQueryNodeServer_GetDataDistribution_Call) Return 

func (_c *MockQueryNodeServer_GetDataDistribution_Call) Return(_a0 *querypb.GetDataDistributionResponse, _a1 error) *MockQueryNodeServer_GetDataDistribution_Call

func (*MockQueryNodeServer_GetDataDistribution_Call) Run 

func (_c *MockQueryNodeServer_GetDataDistribution_Call) Run(run func(_a0 context.Context, _a1 *querypb.GetDataDistributionRequest)) *MockQueryNodeServer_GetDataDistribution_Call

func (*MockQueryNodeServer_GetDataDistribution_Call) RunAndReturn 

func (_c *MockQueryNodeServer_GetDataDistribution_Call) RunAndReturn(run func(context.Context, *querypb.GetDataDistributionRequest) (*querypb.GetDataDistributionResponse, error)) *MockQueryNodeServer_GetDataDistribution_Call

type MockQueryNodeServer_GetMetrics_Call 

type MockQueryNodeServer_GetMetrics_Call struct {
	*mock.Call
}

MockQueryNodeServer_GetMetrics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetMetrics'

func (*MockQueryNodeServer_GetMetrics_Call) Return 

func (_c *MockQueryNodeServer_GetMetrics_Call) Return(_a0 *milvuspb.GetMetricsResponse, _a1 error) *MockQueryNodeServer_GetMetrics_Call

func (*MockQueryNodeServer_GetMetrics_Call) Run 

func (_c *MockQueryNodeServer_GetMetrics_Call) Run(run func(_a0 context.Context, _a1 *milvuspb.GetMetricsRequest)) *MockQueryNodeServer_GetMetrics_Call

func (*MockQueryNodeServer_GetMetrics_Call) RunAndReturn 

func (_c *MockQueryNodeServer_GetMetrics_Call) RunAndReturn(run func(context.Context, *milvuspb.GetMetricsRequest) (*milvuspb.GetMetricsResponse, error)) *MockQueryNodeServer_GetMetrics_Call

type MockQueryNodeServer_GetSegmentInfo_Call 

type MockQueryNodeServer_GetSegmentInfo_Call struct {
	*mock.Call
}

MockQueryNodeServer_GetSegmentInfo_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSegmentInfo'

func (*MockQueryNodeServer_GetSegmentInfo_Call) Return 

func (_c *MockQueryNodeServer_GetSegmentInfo_Call) Return(_a0 *querypb.GetSegmentInfoResponse, _a1 error) *MockQueryNodeServer_GetSegmentInfo_Call

func (*MockQueryNodeServer_GetSegmentInfo_Call) Run 

func (_c *MockQueryNodeServer_GetSegmentInfo_Call) Run(run func(_a0 context.Context, _a1 *querypb.GetSegmentInfoRequest)) *MockQueryNodeServer_GetSegmentInfo_Call

func (*MockQueryNodeServer_GetSegmentInfo_Call) RunAndReturn 

func (_c *MockQueryNodeServer_GetSegmentInfo_Call) RunAndReturn(run func(context.Context, *querypb.GetSegmentInfoRequest) (*querypb.GetSegmentInfoResponse, error)) *MockQueryNodeServer_GetSegmentInfo_Call

type MockQueryNodeServer_GetStatisticsChannel_Call 

type MockQueryNodeServer_GetStatisticsChannel_Call struct {
	*mock.Call
}

MockQueryNodeServer_GetStatisticsChannel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetStatisticsChannel'

func (*MockQueryNodeServer_GetStatisticsChannel_Call) Return 

func (_c *MockQueryNodeServer_GetStatisticsChannel_Call) Return(_a0 *milvuspb.StringResponse, _a1 error) *MockQueryNodeServer_GetStatisticsChannel_Call

func (*MockQueryNodeServer_GetStatisticsChannel_Call) Run 

func (_c *MockQueryNodeServer_GetStatisticsChannel_Call) Run(run func(_a0 context.Context, _a1 *internalpb.GetStatisticsChannelRequest)) *MockQueryNodeServer_GetStatisticsChannel_Call

func (*MockQueryNodeServer_GetStatisticsChannel_Call) RunAndReturn 

func (_c *MockQueryNodeServer_GetStatisticsChannel_Call) RunAndReturn(run func(context.Context, *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error)) *MockQueryNodeServer_GetStatisticsChannel_Call

type MockQueryNodeServer_GetStatistics_Call 

type MockQueryNodeServer_GetStatistics_Call struct {
	*mock.Call
}

MockQueryNodeServer_GetStatistics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetStatistics'

func (*MockQueryNodeServer_GetStatistics_Call) Return 

func (_c *MockQueryNodeServer_GetStatistics_Call) Return(_a0 *internalpb.GetStatisticsResponse, _a1 error) *MockQueryNodeServer_GetStatistics_Call

func (*MockQueryNodeServer_GetStatistics_Call) Run 

func (_c *MockQueryNodeServer_GetStatistics_Call) Run(run func(_a0 context.Context, _a1 *querypb.GetStatisticsRequest)) *MockQueryNodeServer_GetStatistics_Call

func (*MockQueryNodeServer_GetStatistics_Call) RunAndReturn 

func (_c *MockQueryNodeServer_GetStatistics_Call) RunAndReturn(run func(context.Context, *querypb.GetStatisticsRequest) (*internalpb.GetStatisticsResponse, error)) *MockQueryNodeServer_GetStatistics_Call

type MockQueryNodeServer_GetTimeTickChannel_Call 

type MockQueryNodeServer_GetTimeTickChannel_Call struct {
	*mock.Call
}

MockQueryNodeServer_GetTimeTickChannel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTimeTickChannel'

func (*MockQueryNodeServer_GetTimeTickChannel_Call) Return 

func (_c *MockQueryNodeServer_GetTimeTickChannel_Call) Return(_a0 *milvuspb.StringResponse, _a1 error) *MockQueryNodeServer_GetTimeTickChannel_Call

func (*MockQueryNodeServer_GetTimeTickChannel_Call) Run 

func (_c *MockQueryNodeServer_GetTimeTickChannel_Call) Run(run func(_a0 context.Context, _a1 *internalpb.GetTimeTickChannelRequest)) *MockQueryNodeServer_GetTimeTickChannel_Call

func (*MockQueryNodeServer_GetTimeTickChannel_Call) RunAndReturn 

func (_c *MockQueryNodeServer_GetTimeTickChannel_Call) RunAndReturn(run func(context.Context, *internalpb.GetTimeTickChannelRequest) (*milvuspb.StringResponse, error)) *MockQueryNodeServer_GetTimeTickChannel_Call

type MockQueryNodeServer_LoadPartitions_Call 

type MockQueryNodeServer_LoadPartitions_Call struct {
	*mock.Call
}

MockQueryNodeServer_LoadPartitions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LoadPartitions'

func (*MockQueryNodeServer_LoadPartitions_Call) Return 

func (_c *MockQueryNodeServer_LoadPartitions_Call) Return(_a0 *commonpb.Status, _a1 error) *MockQueryNodeServer_LoadPartitions_Call

func (*MockQueryNodeServer_LoadPartitions_Call) Run 

func (_c *MockQueryNodeServer_LoadPartitions_Call) Run(run func(_a0 context.Context, _a1 *querypb.LoadPartitionsRequest)) *MockQueryNodeServer_LoadPartitions_Call

func (*MockQueryNodeServer_LoadPartitions_Call) RunAndReturn 

func (_c *MockQueryNodeServer_LoadPartitions_Call) RunAndReturn(run func(context.Context, *querypb.LoadPartitionsRequest) (*commonpb.Status, error)) *MockQueryNodeServer_LoadPartitions_Call

type MockQueryNodeServer_LoadSegments_Call 

type MockQueryNodeServer_LoadSegments_Call struct {
	*mock.Call
}

MockQueryNodeServer_LoadSegments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LoadSegments'

func (*MockQueryNodeServer_LoadSegments_Call) Return 

func (_c *MockQueryNodeServer_LoadSegments_Call) Return(_a0 *commonpb.Status, _a1 error) *MockQueryNodeServer_LoadSegments_Call

func (*MockQueryNodeServer_LoadSegments_Call) Run 

func (_c *MockQueryNodeServer_LoadSegments_Call) Run(run func(_a0 context.Context, _a1 *querypb.LoadSegmentsRequest)) *MockQueryNodeServer_LoadSegments_Call

func (*MockQueryNodeServer_LoadSegments_Call) RunAndReturn 

func (_c *MockQueryNodeServer_LoadSegments_Call) RunAndReturn(run func(context.Context, *querypb.LoadSegmentsRequest) (*commonpb.Status, error)) *MockQueryNodeServer_LoadSegments_Call

type MockQueryNodeServer_QuerySegments_Call 

type MockQueryNodeServer_QuerySegments_Call struct {
	*mock.Call
}

MockQueryNodeServer_QuerySegments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'QuerySegments'

func (*MockQueryNodeServer_QuerySegments_Call) Return 

func (_c *MockQueryNodeServer_QuerySegments_Call) Return(_a0 *internalpb.RetrieveResults, _a1 error) *MockQueryNodeServer_QuerySegments_Call

func (*MockQueryNodeServer_QuerySegments_Call) Run 

func (_c *MockQueryNodeServer_QuerySegments_Call) Run(run func(_a0 context.Context, _a1 *querypb.QueryRequest)) *MockQueryNodeServer_QuerySegments_Call

func (*MockQueryNodeServer_QuerySegments_Call) RunAndReturn 

func (_c *MockQueryNodeServer_QuerySegments_Call) RunAndReturn(run func(context.Context, *querypb.QueryRequest) (*internalpb.RetrieveResults, error)) *MockQueryNodeServer_QuerySegments_Call

type MockQueryNodeServer_QueryStreamSegments_Call 

type MockQueryNodeServer_QueryStreamSegments_Call struct {
	*mock.Call
}

MockQueryNodeServer_QueryStreamSegments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'QueryStreamSegments'

func (*MockQueryNodeServer_QueryStreamSegments_Call) Return 

func (_c *MockQueryNodeServer_QueryStreamSegments_Call) Return(_a0 error) *MockQueryNodeServer_QueryStreamSegments_Call

func (*MockQueryNodeServer_QueryStreamSegments_Call) Run 

func (_c *MockQueryNodeServer_QueryStreamSegments_Call) Run(run func(_a0 *querypb.QueryRequest, _a1 querypb.QueryNode_QueryStreamSegmentsServer)) *MockQueryNodeServer_QueryStreamSegments_Call

func (*MockQueryNodeServer_QueryStreamSegments_Call) RunAndReturn 

func (_c *MockQueryNodeServer_QueryStreamSegments_Call) RunAndReturn(run func(*querypb.QueryRequest, querypb.QueryNode_QueryStreamSegmentsServer) error) *MockQueryNodeServer_QueryStreamSegments_Call

type MockQueryNodeServer_QueryStream_Call 

type MockQueryNodeServer_QueryStream_Call struct {
	*mock.Call
}

MockQueryNodeServer_QueryStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'QueryStream'

func (*MockQueryNodeServer_QueryStream_Call) Return 

func (_c *MockQueryNodeServer_QueryStream_Call) Return(_a0 error) *MockQueryNodeServer_QueryStream_Call

func (*MockQueryNodeServer_QueryStream_Call) Run 

func (_c *MockQueryNodeServer_QueryStream_Call) Run(run func(_a0 *querypb.QueryRequest, _a1 querypb.QueryNode_QueryStreamServer)) *MockQueryNodeServer_QueryStream_Call

func (*MockQueryNodeServer_QueryStream_Call) RunAndReturn 

func (_c *MockQueryNodeServer_QueryStream_Call) RunAndReturn(run func(*querypb.QueryRequest, querypb.QueryNode_QueryStreamServer) error) *MockQueryNodeServer_QueryStream_Call

type MockQueryNodeServer_Query_Call 

type MockQueryNodeServer_Query_Call struct {
	*mock.Call
}

MockQueryNodeServer_Query_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Query'

func (*MockQueryNodeServer_Query_Call) Return 

func (_c *MockQueryNodeServer_Query_Call) Return(_a0 *internalpb.RetrieveResults, _a1 error) *MockQueryNodeServer_Query_Call

func (*MockQueryNodeServer_Query_Call) Run 

func (_c *MockQueryNodeServer_Query_Call) Run(run func(_a0 context.Context, _a1 *querypb.QueryRequest)) *MockQueryNodeServer_Query_Call

func (*MockQueryNodeServer_Query_Call) RunAndReturn 

func (_c *MockQueryNodeServer_Query_Call) RunAndReturn(run func(context.Context, *querypb.QueryRequest) (*internalpb.RetrieveResults, error)) *MockQueryNodeServer_Query_Call

type MockQueryNodeServer_ReleaseCollection_Call 

type MockQueryNodeServer_ReleaseCollection_Call struct {
	*mock.Call
}

MockQueryNodeServer_ReleaseCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReleaseCollection'

func (*MockQueryNodeServer_ReleaseCollection_Call) Return 

func (_c *MockQueryNodeServer_ReleaseCollection_Call) Return(_a0 *commonpb.Status, _a1 error) *MockQueryNodeServer_ReleaseCollection_Call

func (*MockQueryNodeServer_ReleaseCollection_Call) Run 

func (_c *MockQueryNodeServer_ReleaseCollection_Call) Run(run func(_a0 context.Context, _a1 *querypb.ReleaseCollectionRequest)) *MockQueryNodeServer_ReleaseCollection_Call

func (*MockQueryNodeServer_ReleaseCollection_Call) RunAndReturn 

func (_c *MockQueryNodeServer_ReleaseCollection_Call) RunAndReturn(run func(context.Context, *querypb.ReleaseCollectionRequest) (*commonpb.Status, error)) *MockQueryNodeServer_ReleaseCollection_Call

type MockQueryNodeServer_ReleasePartitions_Call 

type MockQueryNodeServer_ReleasePartitions_Call struct {
	*mock.Call
}

MockQueryNodeServer_ReleasePartitions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReleasePartitions'

func (*MockQueryNodeServer_ReleasePartitions_Call) Return 

func (_c *MockQueryNodeServer_ReleasePartitions_Call) Return(_a0 *commonpb.Status, _a1 error) *MockQueryNodeServer_ReleasePartitions_Call

func (*MockQueryNodeServer_ReleasePartitions_Call) Run 

func (_c *MockQueryNodeServer_ReleasePartitions_Call) Run(run func(_a0 context.Context, _a1 *querypb.ReleasePartitionsRequest)) *MockQueryNodeServer_ReleasePartitions_Call

func (*MockQueryNodeServer_ReleasePartitions_Call) RunAndReturn 

func (_c *MockQueryNodeServer_ReleasePartitions_Call) RunAndReturn(run func(context.Context, *querypb.ReleasePartitionsRequest) (*commonpb.Status, error)) *MockQueryNodeServer_ReleasePartitions_Call

type MockQueryNodeServer_ReleaseSegments_Call 

type MockQueryNodeServer_ReleaseSegments_Call struct {
	*mock.Call
}

MockQueryNodeServer_ReleaseSegments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReleaseSegments'

func (*MockQueryNodeServer_ReleaseSegments_Call) Return 

func (_c *MockQueryNodeServer_ReleaseSegments_Call) Return(_a0 *commonpb.Status, _a1 error) *MockQueryNodeServer_ReleaseSegments_Call

func (*MockQueryNodeServer_ReleaseSegments_Call) Run 

func (_c *MockQueryNodeServer_ReleaseSegments_Call) Run(run func(_a0 context.Context, _a1 *querypb.ReleaseSegmentsRequest)) *MockQueryNodeServer_ReleaseSegments_Call

func (*MockQueryNodeServer_ReleaseSegments_Call) RunAndReturn 

func (_c *MockQueryNodeServer_ReleaseSegments_Call) RunAndReturn(run func(context.Context, *querypb.ReleaseSegmentsRequest) (*commonpb.Status, error)) *MockQueryNodeServer_ReleaseSegments_Call

type MockQueryNodeServer_SearchSegments_Call 

type MockQueryNodeServer_SearchSegments_Call struct {
	*mock.Call
}

MockQueryNodeServer_SearchSegments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SearchSegments'

func (*MockQueryNodeServer_SearchSegments_Call) Return 

func (_c *MockQueryNodeServer_SearchSegments_Call) Return(_a0 *internalpb.SearchResults, _a1 error) *MockQueryNodeServer_SearchSegments_Call

func (*MockQueryNodeServer_SearchSegments_Call) Run 

func (_c *MockQueryNodeServer_SearchSegments_Call) Run(run func(_a0 context.Context, _a1 *querypb.SearchRequest)) *MockQueryNodeServer_SearchSegments_Call

func (*MockQueryNodeServer_SearchSegments_Call) RunAndReturn 

func (_c *MockQueryNodeServer_SearchSegments_Call) RunAndReturn(run func(context.Context, *querypb.SearchRequest) (*internalpb.SearchResults, error)) *MockQueryNodeServer_SearchSegments_Call

type MockQueryNodeServer_Search_Call 

type MockQueryNodeServer_Search_Call struct {
	*mock.Call
}

MockQueryNodeServer_Search_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Search'

func (*MockQueryNodeServer_Search_Call) Return 

func (_c *MockQueryNodeServer_Search_Call) Return(_a0 *internalpb.SearchResults, _a1 error) *MockQueryNodeServer_Search_Call

func (*MockQueryNodeServer_Search_Call) Run 

func (_c *MockQueryNodeServer_Search_Call) Run(run func(_a0 context.Context, _a1 *querypb.SearchRequest)) *MockQueryNodeServer_Search_Call

func (*MockQueryNodeServer_Search_Call) RunAndReturn 

func (_c *MockQueryNodeServer_Search_Call) RunAndReturn(run func(context.Context, *querypb.SearchRequest) (*internalpb.SearchResults, error)) *MockQueryNodeServer_Search_Call

type MockQueryNodeServer_ShowConfigurations_Call 

type MockQueryNodeServer_ShowConfigurations_Call struct {
	*mock.Call
}

MockQueryNodeServer_ShowConfigurations_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ShowConfigurations'

func (*MockQueryNodeServer_ShowConfigurations_Call) Return 

func (_c *MockQueryNodeServer_ShowConfigurations_Call) Return(_a0 *internalpb.ShowConfigurationsResponse, _a1 error) *MockQueryNodeServer_ShowConfigurations_Call

func (*MockQueryNodeServer_ShowConfigurations_Call) Run 

func (_c *MockQueryNodeServer_ShowConfigurations_Call) Run(run func(_a0 context.Context, _a1 *internalpb.ShowConfigurationsRequest)) *MockQueryNodeServer_ShowConfigurations_Call

func (*MockQueryNodeServer_ShowConfigurations_Call) RunAndReturn 

func (_c *MockQueryNodeServer_ShowConfigurations_Call) RunAndReturn(run func(context.Context, *internalpb.ShowConfigurationsRequest) (*internalpb.ShowConfigurationsResponse, error)) *MockQueryNodeServer_ShowConfigurations_Call

type MockQueryNodeServer_SyncDistribution_Call 

type MockQueryNodeServer_SyncDistribution_Call struct {
	*mock.Call
}

MockQueryNodeServer_SyncDistribution_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SyncDistribution'

func (*MockQueryNodeServer_SyncDistribution_Call) Return 

func (_c *MockQueryNodeServer_SyncDistribution_Call) Return(_a0 *commonpb.Status, _a1 error) *MockQueryNodeServer_SyncDistribution_Call

func (*MockQueryNodeServer_SyncDistribution_Call) Run 

func (_c *MockQueryNodeServer_SyncDistribution_Call) Run(run func(_a0 context.Context, _a1 *querypb.SyncDistributionRequest)) *MockQueryNodeServer_SyncDistribution_Call

func (*MockQueryNodeServer_SyncDistribution_Call) RunAndReturn 

func (_c *MockQueryNodeServer_SyncDistribution_Call) RunAndReturn(run func(context.Context, *querypb.SyncDistributionRequest) (*commonpb.Status, error)) *MockQueryNodeServer_SyncDistribution_Call

type MockQueryNodeServer_SyncReplicaSegments_Call 

type MockQueryNodeServer_SyncReplicaSegments_Call struct {
	*mock.Call
}

MockQueryNodeServer_SyncReplicaSegments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SyncReplicaSegments'

func (*MockQueryNodeServer_SyncReplicaSegments_Call) Return 

func (_c *MockQueryNodeServer_SyncReplicaSegments_Call) Return(_a0 *commonpb.Status, _a1 error) *MockQueryNodeServer_SyncReplicaSegments_Call

func (*MockQueryNodeServer_SyncReplicaSegments_Call) Run 

func (_c *MockQueryNodeServer_SyncReplicaSegments_Call) Run(run func(_a0 context.Context, _a1 *querypb.SyncReplicaSegmentsRequest)) *MockQueryNodeServer_SyncReplicaSegments_Call

func (*MockQueryNodeServer_SyncReplicaSegments_Call) RunAndReturn 

func (_c *MockQueryNodeServer_SyncReplicaSegments_Call) RunAndReturn(run func(context.Context, *querypb.SyncReplicaSegmentsRequest) (*commonpb.Status, error)) *MockQueryNodeServer_SyncReplicaSegments_Call

type MockQueryNodeServer_UnsubDmChannel_Call 

type MockQueryNodeServer_UnsubDmChannel_Call struct {
	*mock.Call
}

MockQueryNodeServer_UnsubDmChannel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UnsubDmChannel'

func (*MockQueryNodeServer_UnsubDmChannel_Call) Return 

func (_c *MockQueryNodeServer_UnsubDmChannel_Call) Return(_a0 *commonpb.Status, _a1 error) *MockQueryNodeServer_UnsubDmChannel_Call

func (*MockQueryNodeServer_UnsubDmChannel_Call) Run 

func (_c *MockQueryNodeServer_UnsubDmChannel_Call) Run(run func(_a0 context.Context, _a1 *querypb.UnsubDmChannelRequest)) *MockQueryNodeServer_UnsubDmChannel_Call

func (*MockQueryNodeServer_UnsubDmChannel_Call) RunAndReturn 

func (_c *MockQueryNodeServer_UnsubDmChannel_Call) RunAndReturn(run func(context.Context, *querypb.UnsubDmChannelRequest) (*commonpb.Status, error)) *MockQueryNodeServer_UnsubDmChannel_Call

type MockQueryNodeServer_WatchDmChannels_Call 

type MockQueryNodeServer_WatchDmChannels_Call struct {
	*mock.Call
}

MockQueryNodeServer_WatchDmChannels_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WatchDmChannels'

func (*MockQueryNodeServer_WatchDmChannels_Call) Return 

func (_c *MockQueryNodeServer_WatchDmChannels_Call) Return(_a0 *commonpb.Status, _a1 error) *MockQueryNodeServer_WatchDmChannels_Call

func (*MockQueryNodeServer_WatchDmChannels_Call) Run 

func (_c *MockQueryNodeServer_WatchDmChannels_Call) Run(run func(_a0 context.Context, _a1 *querypb.WatchDmChannelsRequest)) *MockQueryNodeServer_WatchDmChannels_Call

func (*MockQueryNodeServer_WatchDmChannels_Call) RunAndReturn 

func (_c *MockQueryNodeServer_WatchDmChannels_Call) RunAndReturn(run func(context.Context, *querypb.WatchDmChannelsRequest) (*commonpb.Status, error)) *MockQueryNodeServer_WatchDmChannels_Call

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.