elasticsearch

package
v1.23.0-rc7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 1, 2024 License: MIT Imports: 37 Imported by: 0

Documentation

Overview

Package elasticsearch is a generated GoMock package.

Index

Constants

View Source
const (
	PersistenceName = "elasticsearch"
)

Variables

This section is empty.

Functions

func NewProcessor

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

NewProcessor create new processorImpl

func NewValuesInterceptor added in v1.14.0

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

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

func (*MockProcessor) Remove added in v1.17.0

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 added in v1.17.0

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

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

Directories

Path Synopsis
Package client is a generated GoMock package.
Package client is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL