Documentation ¶
Index ¶
- type ElasticBulkProcessor
- func (_m *ElasticBulkProcessor) Add(request elastic.BulkableRequest)
- func (_m *ElasticBulkProcessor) Close() error
- func (_m *ElasticBulkProcessor) Flush() error
- func (_m *ElasticBulkProcessor) Start(ctx context.Context) error
- func (_m *ElasticBulkProcessor) Stats() elastic.BulkProcessorStats
- func (_m *ElasticBulkProcessor) Stop() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ElasticBulkProcessor ¶
ElasticBulkProcessor is an autogenerated mock type for the ElasticBulkProcessor type
func (*ElasticBulkProcessor) Add ¶
func (_m *ElasticBulkProcessor) Add(request elastic.BulkableRequest)
Add provides a mock function with given fields: request
func (*ElasticBulkProcessor) Close ¶
func (_m *ElasticBulkProcessor) Close() error
Close provides a mock function with given fields:
func (*ElasticBulkProcessor) Flush ¶
func (_m *ElasticBulkProcessor) Flush() error
Flush provides a mock function with given fields:
func (*ElasticBulkProcessor) Start ¶
func (_m *ElasticBulkProcessor) Start(ctx context.Context) error
Start provides a mock function with given fields: ctx
func (*ElasticBulkProcessor) Stats ¶
func (_m *ElasticBulkProcessor) Stats() elastic.BulkProcessorStats
Stats provides a mock function with given fields:
func (*ElasticBulkProcessor) Stop ¶
func (_m *ElasticBulkProcessor) Stop() error
Stop provides a mock function with given fields:
Click to show internal directories.
Click to hide internal directories.