Documentation
¶
Index ¶
- type GenericClient
- func (_mock *GenericClient) CountByQuery(ctx context.Context, index string, query string) (int64, error)
- func (_mock *GenericClient) CreateIndex(ctx context.Context, index string) error
- func (_m *GenericClient) EXPECT() *GenericClient_Expecter
- func (_mock *GenericClient) IsNotFoundError(err error) bool
- func (_mock *GenericClient) PutMapping(ctx context.Context, index string, root string, key string, valueType string) error
- func (_mock *GenericClient) RunBulkProcessor(ctx context.Context, p *bulk.BulkProcessorParameters) (bulk.GenericBulkProcessor, error)
- func (_mock *GenericClient) ScanByQuery(ctx context.Context, request *elasticsearch.ScanByQueryRequest) (*elasticsearch.SearchResponse, error)
- func (_mock *GenericClient) Search(ctx context.Context, request *elasticsearch.SearchRequest) (*elasticsearch.SearchResponse, error)
- func (_mock *GenericClient) SearchByQuery(ctx context.Context, request *elasticsearch.SearchByQueryRequest) (*elasticsearch.SearchResponse, error)
- func (_mock *GenericClient) SearchForOneClosedExecution(ctx context.Context, index string, ...) (*elasticsearch.SearchForOneClosedExecutionResponse, error)
- func (_mock *GenericClient) SearchRaw(ctx context.Context, index string, query string) (*elasticsearch.RawResponse, error)
- type GenericClient_CountByQuery_Call
- func (_c *GenericClient_CountByQuery_Call) Return(n int64, err error) *GenericClient_CountByQuery_Call
- func (_c *GenericClient_CountByQuery_Call) Run(run func(ctx context.Context, index string, query string)) *GenericClient_CountByQuery_Call
- func (_c *GenericClient_CountByQuery_Call) RunAndReturn(run func(ctx context.Context, index string, query string) (int64, error)) *GenericClient_CountByQuery_Call
- type GenericClient_CreateIndex_Call
- func (_c *GenericClient_CreateIndex_Call) Return(err error) *GenericClient_CreateIndex_Call
- func (_c *GenericClient_CreateIndex_Call) Run(run func(ctx context.Context, index string)) *GenericClient_CreateIndex_Call
- func (_c *GenericClient_CreateIndex_Call) RunAndReturn(run func(ctx context.Context, index string) error) *GenericClient_CreateIndex_Call
- type GenericClient_Expecter
- func (_e *GenericClient_Expecter) CountByQuery(ctx interface{}, index interface{}, query interface{}) *GenericClient_CountByQuery_Call
- func (_e *GenericClient_Expecter) CreateIndex(ctx interface{}, index interface{}) *GenericClient_CreateIndex_Call
- func (_e *GenericClient_Expecter) IsNotFoundError(err interface{}) *GenericClient_IsNotFoundError_Call
- func (_e *GenericClient_Expecter) PutMapping(ctx interface{}, index interface{}, root interface{}, key interface{}, ...) *GenericClient_PutMapping_Call
- func (_e *GenericClient_Expecter) RunBulkProcessor(ctx interface{}, p interface{}) *GenericClient_RunBulkProcessor_Call
- func (_e *GenericClient_Expecter) ScanByQuery(ctx interface{}, request interface{}) *GenericClient_ScanByQuery_Call
- func (_e *GenericClient_Expecter) Search(ctx interface{}, request interface{}) *GenericClient_Search_Call
- func (_e *GenericClient_Expecter) SearchByQuery(ctx interface{}, request interface{}) *GenericClient_SearchByQuery_Call
- func (_e *GenericClient_Expecter) SearchForOneClosedExecution(ctx interface{}, index interface{}, request interface{}) *GenericClient_SearchForOneClosedExecution_Call
- func (_e *GenericClient_Expecter) SearchRaw(ctx interface{}, index interface{}, query interface{}) *GenericClient_SearchRaw_Call
- type GenericClient_IsNotFoundError_Call
- func (_c *GenericClient_IsNotFoundError_Call) Return(b bool) *GenericClient_IsNotFoundError_Call
- func (_c *GenericClient_IsNotFoundError_Call) Run(run func(err error)) *GenericClient_IsNotFoundError_Call
- func (_c *GenericClient_IsNotFoundError_Call) RunAndReturn(run func(err error) bool) *GenericClient_IsNotFoundError_Call
- type GenericClient_PutMapping_Call
- type GenericClient_RunBulkProcessor_Call
- func (_c *GenericClient_RunBulkProcessor_Call) Return(genericBulkProcessor bulk.GenericBulkProcessor, err error) *GenericClient_RunBulkProcessor_Call
- func (_c *GenericClient_RunBulkProcessor_Call) Run(run func(ctx context.Context, p *bulk.BulkProcessorParameters)) *GenericClient_RunBulkProcessor_Call
- func (_c *GenericClient_RunBulkProcessor_Call) RunAndReturn(...) *GenericClient_RunBulkProcessor_Call
- type GenericClient_ScanByQuery_Call
- func (_c *GenericClient_ScanByQuery_Call) Return(v *elasticsearch.SearchResponse, err error) *GenericClient_ScanByQuery_Call
- func (_c *GenericClient_ScanByQuery_Call) Run(run func(ctx context.Context, request *elasticsearch.ScanByQueryRequest)) *GenericClient_ScanByQuery_Call
- func (_c *GenericClient_ScanByQuery_Call) RunAndReturn(...) *GenericClient_ScanByQuery_Call
- type GenericClient_SearchByQuery_Call
- func (_c *GenericClient_SearchByQuery_Call) Return(v *elasticsearch.SearchResponse, err error) *GenericClient_SearchByQuery_Call
- func (_c *GenericClient_SearchByQuery_Call) Run(run func(ctx context.Context, request *elasticsearch.SearchByQueryRequest)) *GenericClient_SearchByQuery_Call
- func (_c *GenericClient_SearchByQuery_Call) RunAndReturn(...) *GenericClient_SearchByQuery_Call
- type GenericClient_SearchForOneClosedExecution_Call
- func (_c *GenericClient_SearchForOneClosedExecution_Call) Return(v *elasticsearch.SearchForOneClosedExecutionResponse, err error) *GenericClient_SearchForOneClosedExecution_Call
- func (_c *GenericClient_SearchForOneClosedExecution_Call) Run(run func(ctx context.Context, index string, ...)) *GenericClient_SearchForOneClosedExecution_Call
- func (_c *GenericClient_SearchForOneClosedExecution_Call) RunAndReturn(...) *GenericClient_SearchForOneClosedExecution_Call
- type GenericClient_SearchRaw_Call
- func (_c *GenericClient_SearchRaw_Call) Return(rawResponse *elasticsearch.RawResponse, err error) *GenericClient_SearchRaw_Call
- func (_c *GenericClient_SearchRaw_Call) Run(run func(ctx context.Context, index string, query string)) *GenericClient_SearchRaw_Call
- func (_c *GenericClient_SearchRaw_Call) RunAndReturn(...) *GenericClient_SearchRaw_Call
- type GenericClient_Search_Call
- func (_c *GenericClient_Search_Call) Return(v *elasticsearch.SearchResponse, err error) *GenericClient_Search_Call
- func (_c *GenericClient_Search_Call) Run(run func(ctx context.Context, request *elasticsearch.SearchRequest)) *GenericClient_Search_Call
- func (_c *GenericClient_Search_Call) RunAndReturn(...) *GenericClient_Search_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GenericClient ¶ added in v0.17.0
GenericClient is an autogenerated mock type for the GenericClient type
func NewGenericClient ¶
func NewGenericClient(t interface {
mock.TestingT
Cleanup(func())
}) *GenericClient
NewGenericClient creates a new instance of GenericClient. 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 (*GenericClient) CountByQuery ¶ added in v0.17.0
func (_mock *GenericClient) CountByQuery(ctx context.Context, index string, query string) (int64, error)
CountByQuery provides a mock function for the type GenericClient
func (*GenericClient) CreateIndex ¶ added in v0.17.0
func (_mock *GenericClient) CreateIndex(ctx context.Context, index string) error
CreateIndex provides a mock function for the type GenericClient
func (*GenericClient) EXPECT ¶
func (_m *GenericClient) EXPECT() *GenericClient_Expecter
func (*GenericClient) IsNotFoundError ¶ added in v0.17.0
func (_mock *GenericClient) IsNotFoundError(err error) bool
IsNotFoundError provides a mock function for the type GenericClient
func (*GenericClient) PutMapping ¶ added in v0.17.0
func (_mock *GenericClient) PutMapping(ctx context.Context, index string, root string, key string, valueType string) error
PutMapping provides a mock function for the type GenericClient
func (*GenericClient) RunBulkProcessor ¶ added in v0.17.0
func (_mock *GenericClient) RunBulkProcessor(ctx context.Context, p *bulk.BulkProcessorParameters) (bulk.GenericBulkProcessor, error)
RunBulkProcessor provides a mock function for the type GenericClient
func (*GenericClient) ScanByQuery ¶ added in v0.17.0
func (_mock *GenericClient) ScanByQuery(ctx context.Context, request *elasticsearch.ScanByQueryRequest) (*elasticsearch.SearchResponse, error)
ScanByQuery provides a mock function for the type GenericClient
func (*GenericClient) Search ¶ added in v0.17.0
func (_mock *GenericClient) Search(ctx context.Context, request *elasticsearch.SearchRequest) (*elasticsearch.SearchResponse, error)
Search provides a mock function for the type GenericClient
func (*GenericClient) SearchByQuery ¶ added in v0.17.0
func (_mock *GenericClient) SearchByQuery(ctx context.Context, request *elasticsearch.SearchByQueryRequest) (*elasticsearch.SearchResponse, error)
SearchByQuery provides a mock function for the type GenericClient
func (*GenericClient) SearchForOneClosedExecution ¶ added in v0.17.0
func (_mock *GenericClient) SearchForOneClosedExecution(ctx context.Context, index string, request *elasticsearch.SearchForOneClosedExecutionRequest) (*elasticsearch.SearchForOneClosedExecutionResponse, error)
SearchForOneClosedExecution provides a mock function for the type GenericClient
func (*GenericClient) SearchRaw ¶ added in v0.24.0
func (_mock *GenericClient) SearchRaw(ctx context.Context, index string, query string) (*elasticsearch.RawResponse, error)
SearchRaw provides a mock function for the type GenericClient
type GenericClient_CountByQuery_Call ¶
GenericClient_CountByQuery_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CountByQuery'
func (*GenericClient_CountByQuery_Call) Return ¶
func (_c *GenericClient_CountByQuery_Call) Return(n int64, err error) *GenericClient_CountByQuery_Call
func (*GenericClient_CountByQuery_Call) Run ¶
func (_c *GenericClient_CountByQuery_Call) Run(run func(ctx context.Context, index string, query string)) *GenericClient_CountByQuery_Call
func (*GenericClient_CountByQuery_Call) RunAndReturn ¶
func (_c *GenericClient_CountByQuery_Call) RunAndReturn(run func(ctx context.Context, index string, query string) (int64, error)) *GenericClient_CountByQuery_Call
type GenericClient_CreateIndex_Call ¶
GenericClient_CreateIndex_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateIndex'
func (*GenericClient_CreateIndex_Call) Return ¶
func (_c *GenericClient_CreateIndex_Call) Return(err error) *GenericClient_CreateIndex_Call
func (*GenericClient_CreateIndex_Call) Run ¶
func (_c *GenericClient_CreateIndex_Call) Run(run func(ctx context.Context, index string)) *GenericClient_CreateIndex_Call
func (*GenericClient_CreateIndex_Call) RunAndReturn ¶
func (_c *GenericClient_CreateIndex_Call) RunAndReturn(run func(ctx context.Context, index string) error) *GenericClient_CreateIndex_Call
type GenericClient_Expecter ¶
type GenericClient_Expecter struct {
// contains filtered or unexported fields
}
func (*GenericClient_Expecter) CountByQuery ¶
func (_e *GenericClient_Expecter) CountByQuery(ctx interface{}, index interface{}, query interface{}) *GenericClient_CountByQuery_Call
CountByQuery is a helper method to define mock.On call
- ctx context.Context
- index string
- query string
func (*GenericClient_Expecter) CreateIndex ¶
func (_e *GenericClient_Expecter) CreateIndex(ctx interface{}, index interface{}) *GenericClient_CreateIndex_Call
CreateIndex is a helper method to define mock.On call
- ctx context.Context
- index string
func (*GenericClient_Expecter) IsNotFoundError ¶
func (_e *GenericClient_Expecter) IsNotFoundError(err interface{}) *GenericClient_IsNotFoundError_Call
IsNotFoundError is a helper method to define mock.On call
- err error
func (*GenericClient_Expecter) PutMapping ¶
func (_e *GenericClient_Expecter) PutMapping(ctx interface{}, index interface{}, root interface{}, key interface{}, valueType interface{}) *GenericClient_PutMapping_Call
PutMapping is a helper method to define mock.On call
- ctx context.Context
- index string
- root string
- key string
- valueType string
func (*GenericClient_Expecter) RunBulkProcessor ¶
func (_e *GenericClient_Expecter) RunBulkProcessor(ctx interface{}, p interface{}) *GenericClient_RunBulkProcessor_Call
RunBulkProcessor is a helper method to define mock.On call
- ctx context.Context
- p *bulk.BulkProcessorParameters
func (*GenericClient_Expecter) ScanByQuery ¶
func (_e *GenericClient_Expecter) ScanByQuery(ctx interface{}, request interface{}) *GenericClient_ScanByQuery_Call
ScanByQuery is a helper method to define mock.On call
- ctx context.Context
- request *elasticsearch.ScanByQueryRequest
func (*GenericClient_Expecter) Search ¶
func (_e *GenericClient_Expecter) Search(ctx interface{}, request interface{}) *GenericClient_Search_Call
Search is a helper method to define mock.On call
- ctx context.Context
- request *elasticsearch.SearchRequest
func (*GenericClient_Expecter) SearchByQuery ¶
func (_e *GenericClient_Expecter) SearchByQuery(ctx interface{}, request interface{}) *GenericClient_SearchByQuery_Call
SearchByQuery is a helper method to define mock.On call
- ctx context.Context
- request *elasticsearch.SearchByQueryRequest
func (*GenericClient_Expecter) SearchForOneClosedExecution ¶
func (_e *GenericClient_Expecter) SearchForOneClosedExecution(ctx interface{}, index interface{}, request interface{}) *GenericClient_SearchForOneClosedExecution_Call
SearchForOneClosedExecution is a helper method to define mock.On call
- ctx context.Context
- index string
- request *elasticsearch.SearchForOneClosedExecutionRequest
func (*GenericClient_Expecter) SearchRaw ¶
func (_e *GenericClient_Expecter) SearchRaw(ctx interface{}, index interface{}, query interface{}) *GenericClient_SearchRaw_Call
SearchRaw is a helper method to define mock.On call
- ctx context.Context
- index string
- query string
type GenericClient_IsNotFoundError_Call ¶
GenericClient_IsNotFoundError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsNotFoundError'
func (*GenericClient_IsNotFoundError_Call) Return ¶
func (_c *GenericClient_IsNotFoundError_Call) Return(b bool) *GenericClient_IsNotFoundError_Call
func (*GenericClient_IsNotFoundError_Call) Run ¶
func (_c *GenericClient_IsNotFoundError_Call) Run(run func(err error)) *GenericClient_IsNotFoundError_Call
func (*GenericClient_IsNotFoundError_Call) RunAndReturn ¶
func (_c *GenericClient_IsNotFoundError_Call) RunAndReturn(run func(err error) bool) *GenericClient_IsNotFoundError_Call
type GenericClient_PutMapping_Call ¶
GenericClient_PutMapping_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutMapping'
func (*GenericClient_PutMapping_Call) Return ¶
func (_c *GenericClient_PutMapping_Call) Return(err error) *GenericClient_PutMapping_Call
func (*GenericClient_PutMapping_Call) Run ¶
func (_c *GenericClient_PutMapping_Call) Run(run func(ctx context.Context, index string, root string, key string, valueType string)) *GenericClient_PutMapping_Call
func (*GenericClient_PutMapping_Call) RunAndReturn ¶
func (_c *GenericClient_PutMapping_Call) RunAndReturn(run func(ctx context.Context, index string, root string, key string, valueType string) error) *GenericClient_PutMapping_Call
type GenericClient_RunBulkProcessor_Call ¶
GenericClient_RunBulkProcessor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RunBulkProcessor'
func (*GenericClient_RunBulkProcessor_Call) Return ¶
func (_c *GenericClient_RunBulkProcessor_Call) Return(genericBulkProcessor bulk.GenericBulkProcessor, err error) *GenericClient_RunBulkProcessor_Call
func (*GenericClient_RunBulkProcessor_Call) Run ¶
func (_c *GenericClient_RunBulkProcessor_Call) Run(run func(ctx context.Context, p *bulk.BulkProcessorParameters)) *GenericClient_RunBulkProcessor_Call
func (*GenericClient_RunBulkProcessor_Call) RunAndReturn ¶
func (_c *GenericClient_RunBulkProcessor_Call) RunAndReturn(run func(ctx context.Context, p *bulk.BulkProcessorParameters) (bulk.GenericBulkProcessor, error)) *GenericClient_RunBulkProcessor_Call
type GenericClient_ScanByQuery_Call ¶
GenericClient_ScanByQuery_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ScanByQuery'
func (*GenericClient_ScanByQuery_Call) Return ¶
func (_c *GenericClient_ScanByQuery_Call) Return(v *elasticsearch.SearchResponse, err error) *GenericClient_ScanByQuery_Call
func (*GenericClient_ScanByQuery_Call) Run ¶
func (_c *GenericClient_ScanByQuery_Call) Run(run func(ctx context.Context, request *elasticsearch.ScanByQueryRequest)) *GenericClient_ScanByQuery_Call
func (*GenericClient_ScanByQuery_Call) RunAndReturn ¶
func (_c *GenericClient_ScanByQuery_Call) RunAndReturn(run func(ctx context.Context, request *elasticsearch.ScanByQueryRequest) (*elasticsearch.SearchResponse, error)) *GenericClient_ScanByQuery_Call
type GenericClient_SearchByQuery_Call ¶
GenericClient_SearchByQuery_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SearchByQuery'
func (*GenericClient_SearchByQuery_Call) Return ¶
func (_c *GenericClient_SearchByQuery_Call) Return(v *elasticsearch.SearchResponse, err error) *GenericClient_SearchByQuery_Call
func (*GenericClient_SearchByQuery_Call) Run ¶
func (_c *GenericClient_SearchByQuery_Call) Run(run func(ctx context.Context, request *elasticsearch.SearchByQueryRequest)) *GenericClient_SearchByQuery_Call
func (*GenericClient_SearchByQuery_Call) RunAndReturn ¶
func (_c *GenericClient_SearchByQuery_Call) RunAndReturn(run func(ctx context.Context, request *elasticsearch.SearchByQueryRequest) (*elasticsearch.SearchResponse, error)) *GenericClient_SearchByQuery_Call
type GenericClient_SearchForOneClosedExecution_Call ¶
GenericClient_SearchForOneClosedExecution_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SearchForOneClosedExecution'
func (*GenericClient_SearchForOneClosedExecution_Call) Run ¶
func (_c *GenericClient_SearchForOneClosedExecution_Call) Run(run func(ctx context.Context, index string, request *elasticsearch.SearchForOneClosedExecutionRequest)) *GenericClient_SearchForOneClosedExecution_Call
func (*GenericClient_SearchForOneClosedExecution_Call) RunAndReturn ¶
func (_c *GenericClient_SearchForOneClosedExecution_Call) RunAndReturn(run func(ctx context.Context, index string, request *elasticsearch.SearchForOneClosedExecutionRequest) (*elasticsearch.SearchForOneClosedExecutionResponse, error)) *GenericClient_SearchForOneClosedExecution_Call
type GenericClient_SearchRaw_Call ¶
GenericClient_SearchRaw_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SearchRaw'
func (*GenericClient_SearchRaw_Call) Return ¶
func (_c *GenericClient_SearchRaw_Call) Return(rawResponse *elasticsearch.RawResponse, err error) *GenericClient_SearchRaw_Call
func (*GenericClient_SearchRaw_Call) Run ¶
func (_c *GenericClient_SearchRaw_Call) Run(run func(ctx context.Context, index string, query string)) *GenericClient_SearchRaw_Call
func (*GenericClient_SearchRaw_Call) RunAndReturn ¶
func (_c *GenericClient_SearchRaw_Call) RunAndReturn(run func(ctx context.Context, index string, query string) (*elasticsearch.RawResponse, error)) *GenericClient_SearchRaw_Call
type GenericClient_Search_Call ¶
GenericClient_Search_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Search'
func (*GenericClient_Search_Call) Return ¶
func (_c *GenericClient_Search_Call) Return(v *elasticsearch.SearchResponse, err error) *GenericClient_Search_Call
func (*GenericClient_Search_Call) Run ¶
func (_c *GenericClient_Search_Call) Run(run func(ctx context.Context, request *elasticsearch.SearchRequest)) *GenericClient_Search_Call
func (*GenericClient_Search_Call) RunAndReturn ¶
func (_c *GenericClient_Search_Call) RunAndReturn(run func(ctx context.Context, request *elasticsearch.SearchRequest) (*elasticsearch.SearchResponse, error)) *GenericClient_Search_Call