Documentation ¶
Index ¶
- type GenericClient
- func (_m *GenericClient) CountByQuery(ctx context.Context, index string, query string) (int64, error)
- func (_m *GenericClient) CreateIndex(ctx context.Context, index string) error
- func (_m *GenericClient) IsNotFoundError(err error) bool
- func (_m *GenericClient) PutMapping(ctx context.Context, index string, root string, key string, valueType string) error
- func (_m *GenericClient) RunBulkProcessor(ctx context.Context, p *bulk.BulkProcessorParameters) (bulk.GenericBulkProcessor, error)
- func (_m *GenericClient) ScanByQuery(ctx context.Context, request *elasticsearch.ScanByQueryRequest) (*persistence.InternalListWorkflowExecutionsResponse, error)
- func (_m *GenericClient) Search(ctx context.Context, request *elasticsearch.SearchRequest) (*persistence.InternalListWorkflowExecutionsResponse, error)
- func (_m *GenericClient) SearchByQuery(ctx context.Context, request *elasticsearch.SearchByQueryRequest) (*persistence.InternalListWorkflowExecutionsResponse, error)
- func (_m *GenericClient) SearchForOneClosedExecution(ctx context.Context, index string, ...) (*persistence.InternalGetClosedWorkflowExecutionResponse, error)
- func (_m *GenericClient) SearchRaw(ctx context.Context, index string, query string) (*elasticsearch.RawResponse, error)
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 (*GenericClient) CountByQuery ¶ added in v0.17.0
func (_m *GenericClient) CountByQuery(ctx context.Context, index string, query string) (int64, error)
CountByQuery provides a mock function with given fields: ctx, index, query
func (*GenericClient) CreateIndex ¶ added in v0.17.0
func (_m *GenericClient) CreateIndex(ctx context.Context, index string) error
CreateIndex provides a mock function with given fields: ctx, index
func (*GenericClient) IsNotFoundError ¶ added in v0.17.0
func (_m *GenericClient) IsNotFoundError(err error) bool
IsNotFoundError provides a mock function with given fields: err
func (*GenericClient) PutMapping ¶ added in v0.17.0
func (_m *GenericClient) PutMapping(ctx context.Context, index string, root string, key string, valueType string) error
PutMapping provides a mock function with given fields: ctx, index, root, key, valueType
func (*GenericClient) RunBulkProcessor ¶ added in v0.17.0
func (_m *GenericClient) RunBulkProcessor(ctx context.Context, p *bulk.BulkProcessorParameters) (bulk.GenericBulkProcessor, error)
RunBulkProcessor provides a mock function with given fields: ctx, p
func (*GenericClient) ScanByQuery ¶ added in v0.17.0
func (_m *GenericClient) ScanByQuery(ctx context.Context, request *elasticsearch.ScanByQueryRequest) (*persistence.InternalListWorkflowExecutionsResponse, error)
ScanByQuery provides a mock function with given fields: ctx, request
func (*GenericClient) Search ¶ added in v0.17.0
func (_m *GenericClient) Search(ctx context.Context, request *elasticsearch.SearchRequest) (*persistence.InternalListWorkflowExecutionsResponse, error)
Search provides a mock function with given fields: ctx, request
func (*GenericClient) SearchByQuery ¶ added in v0.17.0
func (_m *GenericClient) SearchByQuery(ctx context.Context, request *elasticsearch.SearchByQueryRequest) (*persistence.InternalListWorkflowExecutionsResponse, error)
SearchByQuery provides a mock function with given fields: ctx, request
func (*GenericClient) SearchForOneClosedExecution ¶ added in v0.17.0
func (_m *GenericClient) SearchForOneClosedExecution(ctx context.Context, index string, request *persistence.InternalGetClosedWorkflowExecutionRequest) (*persistence.InternalGetClosedWorkflowExecutionResponse, error)
SearchForOneClosedExecution provides a mock function with given fields: ctx, index, request
func (*GenericClient) SearchRaw ¶ added in v0.24.0
func (_m *GenericClient) SearchRaw(ctx context.Context, index string, query string) (*elasticsearch.RawResponse, error)