elasticsearch

Documentation

Overview

Package elasticsearch is a generated GoMock package.

Index

• func NewESVisibilityManager(indexName string, esClient es.Client, cfg *config.VisibilityConfig, ...) p.VisibilityManager
• func NewElasticSearchVisibilityStore(esClient es.Client, index string, producer messaging.Producer, ...) *esVisibilityStore
• func NewProcessor(cfg *ProcessorConfig, client elasticsearch.Client, logger log.Logger, ...) *esProcessorImpl
• func NewVisibilityMetricsClient(persistence p.VisibilityManager, metricClient metrics.Client, ...) p.VisibilityManager
• type MockProcessor
  • func NewMockProcessor(ctrl *gomock.Controller) *MockProcessor
  • func (m *MockProcessor) Add(request *elasticsearch.BulkableRequest, visibilityTaskKey string, ...)
  • func (m *MockProcessor) EXPECT() *MockProcessorMockRecorder
  • func (m *MockProcessor) Start()
  • func (m *MockProcessor) Stop()
• type MockProcessorMockRecorder
  • func (mr *MockProcessorMockRecorder) Add(request, visibilityTaskKey, ackCh interface{}) *gomock.Call
  • func (mr *MockProcessorMockRecorder) Start() *gomock.Call
  • func (mr *MockProcessorMockRecorder) Stop() *gomock.Call
• type Processor
• type ProcessorConfig
• type VisibilityTaskAckTimeoutError
  • func (v *VisibilityTaskAckTimeoutError) Error() string
• type VisibilityTaskNAckError
  • func (v *VisibilityTaskNAckError) Error() string

Functions

func NewESVisibilityManager

func NewESVisibilityManager(
	indexName string,
	esClient es.Client,
	cfg *config.VisibilityConfig,
	producer messaging.Producer,
	processor Processor,
	metricsClient metrics.Client,
	log log.Logger,
) p.VisibilityManager

NewESVisibilityManager create a visibility manager for ElasticSearch In history, it only needs kafka producer for writing data; In frontend, it only needs ES client and related config for reading data

func NewElasticSearchVisibilityStore

func NewElasticSearchVisibilityStore(
	esClient es.Client,
	index string,
	producer messaging.Producer,
	processor Processor,
	cfg *config.VisibilityConfig,
	logger log.Logger,
	metricsClient metrics.Client,
) *esVisibilityStore

NewElasticSearchVisibilityStore create a visibility store connecting to ElasticSearch

func NewProcessor

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

NewProcessor create new esProcessorImpl

func NewVisibilityMetricsClient

func NewVisibilityMetricsClient(persistence p.VisibilityManager, metricClient metrics.Client, logger log.Logger) p.VisibilityManager

NewVisibilityMetricsClient wrap visibility client with metrics

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 *elasticsearch.BulkableRequest, visibilityTaskKey string, ackCh 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, ackCh 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, and record kafka message in map with provided key
	// This call will be blocked when downstream has issues
	Add(request *elasticsearch.BulkableRequest, visibilityTaskKey string, ackCh chan<- bool)
}

Processor is interface for elastic search bulk processor

type ProcessorConfig

type ProcessorConfig struct {
	IndexerConcurrency       dynamicconfig.IntPropertyFn
	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
	ValidSearchAttributes    dynamicconfig.MapPropertyFn
}

ProcessorConfig contains all configs for processor

type VisibilityTaskAckTimeoutError

type VisibilityTaskAckTimeoutError struct {
	VisibilityTaskKey string
	Timeout           time.Duration
}

func (*VisibilityTaskAckTimeoutError) Error

func (v *VisibilityTaskAckTimeoutError) Error() string

type VisibilityTaskNAckError

type VisibilityTaskNAckError struct {
	VisibilityTaskKey string
}

func (*VisibilityTaskNAckError) Error

func (v *VisibilityTaskNAckError) Error() string