elasticsearch

Documentation

Overview

Package elasticsearch is a generated GoMock package.

Index

• Constants
• func NewProcessor(cfg *ProcessorConfig, esClient client.Client, logger log.Logger, ...) *processorImpl
• func NewQueryConverter(fnInterceptor query.FieldNameInterceptor, ...) *query.Converter
• func NewValuesInterceptor(namespaceName namespace.Name, saTypeMap searchattribute.NameTypeMap, ...) *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) *future.FutureImpl[bool]
  • func (m *MockProcessor) EXPECT() *MockProcessorMockRecorder
  • func (m *MockProcessor) Remove(visibilityTaskKey string)
  • func (m *MockProcessor) Start()
  • func (m *MockProcessor) Stop()
• type MockProcessorMockRecorder
  • func (mr *MockProcessorMockRecorder) Add(request, visibilityTaskKey interface{}) *gomock.Call
  • func (mr *MockProcessorMockRecorder) Remove(visibilityTaskKey interface{}) *gomock.Call
  • func (mr *MockProcessorMockRecorder) Start() *gomock.Call
  • func (mr *MockProcessorMockRecorder) Stop() *gomock.Call
• type Processor
• type ProcessorConfig

Constants

const (
	PersistenceName = "elasticsearch"
)

Functions

func NewProcessor

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

NewProcessor create new processorImpl

func NewQueryConverter

func NewQueryConverter(
	fnInterceptor query.FieldNameInterceptor,
	fvInterceptor query.FieldValuesInterceptor,
) *query.Converter

func NewValuesInterceptor

func NewValuesInterceptor(
	namespaceName namespace.Name,
	saTypeMap searchattribute.NameTypeMap,
	searchAttributesMapperProvider searchattribute.MapperProvider,
) *valuesInterceptor

func NewVisibilityStore

func NewVisibilityStore(
	esClient client.Client,
	index string,
	searchAttributesProvider searchattribute.Provider,
	searchAttributesMapperProvider searchattribute.MapperProvider,
	processor Processor,
	processorAckTimeout dynamicconfig.DurationPropertyFn,
	disableOrderByClause dynamicconfig.BoolPropertyFnWithNamespaceFilter,
	enableManualPagination dynamicconfig.BoolPropertyFnWithNamespaceFilter,
	metricsHandler metrics.Handler,
) *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) *future.FutureImpl[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) Remove

func (m *MockProcessor) Remove(visibilityTaskKey string)

Remove mocks base method.

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) Remove

func (mr *MockProcessorMockRecorder) Remove(visibilityTaskKey interface{}) *gomock.Call

Remove indicates an expected call of Remove.

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 {
	// Add request to bulk processor.
	Add(request *client.BulkableRequest, visibilityTaskKey string) *future.FutureImpl[bool]
	Start()
	Stop()
}

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