elasticsearch

Documentation

Overview

Package elasticsearch is a generated GoMock package.

Index

• func NewProcessor(cfg *ProcessorConfig, esClient client.Client, logger log.Logger, ...) *processorImpl
• func NewValuesInterceptor() *valuesInterceptor
• func NewVisibilityStore(esClient client.Client, index string, ...) *visibilityStore
• type MockProcessor
  • func NewMockProcessor(ctrl *gomock.Controller) *MockProcessor
  • func (m *MockProcessor) Add(request *client.BulkableRequest, visibilityTaskKey string) <-chan bool
  • func (m *MockProcessor) EXPECT() *MockProcessorMockRecorder
  • func (m *MockProcessor) Start()
  • func (m *MockProcessor) Stop()
• type MockProcessorMockRecorder
  • func (mr *MockProcessorMockRecorder) Add(request, visibilityTaskKey interface{}) *gomock.Call
  • func (mr *MockProcessorMockRecorder) Start() *gomock.Call
  • func (mr *MockProcessorMockRecorder) Stop() *gomock.Call
• type Processor
• type ProcessorConfig

Functions

func NewProcessor

func NewProcessor(
	cfg *ProcessorConfig,
	esClient client.Client,
	logger log.Logger,
	metricsClient metrics.Client,
) *processorImpl

NewProcessor create new processorImpl

func NewValuesInterceptor

func NewValuesInterceptor() *valuesInterceptor

func NewVisibilityStore

func NewVisibilityStore(
	esClient client.Client,
	index string,
	searchAttributesProvider searchattribute.Provider,
	searchAttributesMapper searchattribute.Mapper,
	processor Processor,
	processorAckTimeout dynamicconfig.DurationPropertyFn,
	metricsClient metrics.Client,
) *visibilityStore

NewVisibilityStore create a visibility store connecting to ElasticSearch

Types

type MockProcessor

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

MockProcessor is a mock of Processor interface.

func NewMockProcessor

func NewMockProcessor(ctrl *gomock.Controller) *MockProcessor

NewMockProcessor creates a new mock instance.

func (*MockProcessor) Add

func (m *MockProcessor) Add(request *client.BulkableRequest, visibilityTaskKey string) <-chan bool

Add mocks base method.

func (*MockProcessor) EXPECT

func (m *MockProcessor) EXPECT() *MockProcessorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockProcessor) Start

func (m *MockProcessor) Start()

Start mocks base method.

func (*MockProcessor) Stop

func (m *MockProcessor) Stop()

Stop mocks base method.

type MockProcessorMockRecorder

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

MockProcessorMockRecorder is the mock recorder for MockProcessor.

func (*MockProcessorMockRecorder) Add

func (mr *MockProcessorMockRecorder) Add(request, visibilityTaskKey interface{}) *gomock.Call

Add indicates an expected call of Add.

func (*MockProcessorMockRecorder) Start

func (mr *MockProcessorMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockProcessorMockRecorder) Stop

func (mr *MockProcessorMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

type Processor

type Processor interface {
	common.Daemon

	// Add request to bulk processor.
	Add(request *client.BulkableRequest, visibilityTaskKey string) <-chan bool
}

Processor is interface for Elasticsearch bulk processor

type ProcessorConfig

type ProcessorConfig struct {
	IndexerConcurrency dynamicconfig.IntPropertyFn
	// TODO: remove ESProcessor prefix
	ESProcessorNumOfWorkers  dynamicconfig.IntPropertyFn
	ESProcessorBulkActions   dynamicconfig.IntPropertyFn // max number of requests in bulk
	ESProcessorBulkSize      dynamicconfig.IntPropertyFn // max total size of bytes in bulk
	ESProcessorFlushInterval dynamicconfig.DurationPropertyFn

	ESProcessorAckTimeout dynamicconfig.DurationPropertyFn
}

ProcessorConfig contains all configs for processor