mocks

Documentation

Index

• type GenericBulkProcessor
  • func (_m *GenericBulkProcessor) Add(request *elasticsearch.GenericBulkableAddRequest)
  • func (_m *GenericBulkProcessor) Close() error
  • func (_m *GenericBulkProcessor) Flush() error
  • func (_m *GenericBulkProcessor) RetrieveKafkaKey(request elasticsearch.GenericBulkableRequest, logger log.Logger, ...) string
  • func (_m *GenericBulkProcessor) Start(ctx context.Context) error
  • func (_m *GenericBulkProcessor) Stop() error
• type GenericBulkableRequest
  • func (_m *GenericBulkableRequest) Source() ([]string, error)
  • func (_m *GenericBulkableRequest) String() string
• 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 *elasticsearch.BulkProcessorParameters) (elasticsearch.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)

Types

type GenericBulkProcessor

type GenericBulkProcessor struct {
	mock.Mock
}

GenericBulkProcessor is an autogenerated mock type for the GenericBulkProcessor type

func (*GenericBulkProcessor) Add

func (_m *GenericBulkProcessor) Add(request *elasticsearch.GenericBulkableAddRequest)

Add provides a mock function with given fields: request

func (*GenericBulkProcessor) Close

func (_m *GenericBulkProcessor) Close() error

Close provides a mock function with given fields:

func (*GenericBulkProcessor) Flush

func (_m *GenericBulkProcessor) Flush() error

Flush provides a mock function with given fields:

func (*GenericBulkProcessor) RetrieveKafkaKey

func (_m *GenericBulkProcessor) RetrieveKafkaKey(request elasticsearch.GenericBulkableRequest, logger log.Logger, client metrics.Client) string

RetrieveKafkaKey provides a mock function with given fields: request, logger, client

func (*GenericBulkProcessor) Start

func (_m *GenericBulkProcessor) Start(ctx context.Context) error

Start provides a mock function with given fields: ctx

func (*GenericBulkProcessor) Stop

func (_m *GenericBulkProcessor) Stop() error

Stop provides a mock function with given fields:

type GenericBulkableRequest

type GenericBulkableRequest struct {
	mock.Mock
}

GenericBulkableRequest is an autogenerated mock type for the GenericBulkableRequest type

func (*GenericBulkableRequest) Source

func (_m *GenericBulkableRequest) Source() ([]string, error)

Source provides a mock function with given fields:

func (*GenericBulkableRequest) String

func (_m *GenericBulkableRequest) String() string

String provides a mock function with given fields:

type GenericClient

type GenericClient struct {
	mock.Mock
}

GenericClient is an autogenerated mock type for the GenericClient type

func (*GenericClient) CountByQuery

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

func (_m *GenericClient) CreateIndex(ctx context.Context, index string) error

CreateIndex provides a mock function with given fields: ctx, index

func (*GenericClient) IsNotFoundError

func (_m *GenericClient) IsNotFoundError(err error) bool

IsNotFoundError provides a mock function with given fields: err

func (*GenericClient) PutMapping

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

func (_m *GenericClient) RunBulkProcessor(ctx context.Context, p *elasticsearch.BulkProcessorParameters) (elasticsearch.GenericBulkProcessor, error)

RunBulkProcessor provides a mock function with given fields: ctx, p

func (*GenericClient) ScanByQuery

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

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

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

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