visibility

Documentation

Index

• Constants
• func DefaultAdvancedVisibilityWritingMode(advancedVisibilityConfigExist bool) string
• func NewAdvancedManager(defaultIndexName string, esClient esclient.Client, ...) (manager.VisibilityManager, error)
• func NewESManagerSelector(visibilityManager manager.VisibilityManager, ...) *esManagerSelector
• func NewManager(persistenceCfg config.Persistence, ...) (manager.VisibilityManager, error)
• func NewSQLToESManagerSelector(stdVisibilityManager manager.VisibilityManager, ...) *sqlToESManagerSelector
• func NewStandardManager(persistenceCfg config.Persistence, ...) (manager.VisibilityManager, error)
• func NewVisibilityManagerDual(visibilityManager manager.VisibilityManager, ...) *visibilityManagerDual
• func NewVisibilityManagerMetrics(delegate manager.VisibilityManager, metricClient metrics.Client, ...) *visibilityManagerMetrics
• func NewVisibilityManagerRateLimited(delegate manager.VisibilityManager, readMaxQPS dynamicconfig.IntPropertyFn, ...) *visibilityManagerRateLimited

Constants

const (
	// AdvancedVisibilityWritingModeOff means do not write to advanced visibility store
	AdvancedVisibilityWritingModeOff = "off"
	// AdvancedVisibilityWritingModeOn means only write to advanced visibility store
	AdvancedVisibilityWritingModeOn = "on"
	// AdvancedVisibilityWritingModeDual means write to both normal visibility and advanced visibility store
	AdvancedVisibilityWritingModeDual = "dual"
)

const (
	// MemoEncoding is default encoding for visibility memo.
	MemoEncoding = enumspb.ENCODING_TYPE_PROTO3
)

Functions

func DefaultAdvancedVisibilityWritingMode

func DefaultAdvancedVisibilityWritingMode(advancedVisibilityConfigExist bool) string

DefaultAdvancedVisibilityWritingMode returns default advancedVisibilityWritingMode based on whether related config exists in static config file.

func NewAdvancedManager

func NewAdvancedManager(
	defaultIndexName string,
	esClient esclient.Client,
	esProcessorConfig *elasticsearch.ProcessorConfig,
	searchAttributesProvider searchattribute.Provider,
	searchAttributesMapper searchattribute.Mapper,

	advancedVisibilityPersistenceMaxReadQPS dynamicconfig.IntPropertyFn,
	advancedVisibilityPersistenceMaxWriteQPS dynamicconfig.IntPropertyFn,

	metricsClient metrics.Client,
	logger log.Logger,
) (manager.VisibilityManager, error)

func NewESManagerSelector

func NewESManagerSelector(
	visibilityManager manager.VisibilityManager,
	secondaryVisibilityManager manager.VisibilityManager,
	enableReadFromSecondaryVisibility dynamicconfig.BoolPropertyFnWithNamespaceFilter,
	enableWriteToSecondaryVisibility dynamicconfig.BoolPropertyFn,
) *esManagerSelector

func NewManager

func NewManager(
	persistenceCfg config.Persistence,
	persistenceResolver resolver.ServiceResolver,

	defaultIndexName string,
	secondaryVisibilityIndexName string,
	esClient esclient.Client,
	esProcessorConfig *elasticsearch.ProcessorConfig,
	searchAttributesProvider searchattribute.Provider,
	searchAttributesMapper searchattribute.Mapper,

	standardVisibilityPersistenceMaxReadQPS dynamicconfig.IntPropertyFn,
	standardVisibilityPersistenceMaxWriteQPS dynamicconfig.IntPropertyFn,
	advancedVisibilityPersistenceMaxReadQPS dynamicconfig.IntPropertyFn,
	advancedVisibilityPersistenceMaxWriteQPS dynamicconfig.IntPropertyFn,
	enableAdvancedVisibilityRead dynamicconfig.BoolPropertyFnWithNamespaceFilter,
	advancedVisibilityWritingMode dynamicconfig.StringPropertyFn,
	enableReadFromSecondaryAdvancedVisibility dynamicconfig.BoolPropertyFnWithNamespaceFilter,
	enableWriteToSecondaryAdvancedVisibility dynamicconfig.BoolPropertyFn,

	metricsClient metrics.Client,
	logger log.Logger,
) (manager.VisibilityManager, error)

func NewSQLToESManagerSelector

func NewSQLToESManagerSelector(
	stdVisibilityManager manager.VisibilityManager,
	advVisibilityManager manager.VisibilityManager,
	enableAdvancedVisibilityRead dynamicconfig.BoolPropertyFnWithNamespaceFilter,
	advancedVisibilityWritingMode dynamicconfig.StringPropertyFn,
) *sqlToESManagerSelector

func NewStandardManager

func NewStandardManager(
	persistenceCfg config.Persistence,
	persistenceResolver resolver.ServiceResolver,

	standardVisibilityPersistenceMaxReadQPS dynamicconfig.IntPropertyFn,
	standardVisibilityPersistenceMaxWriteQPS dynamicconfig.IntPropertyFn,

	metricsClient metrics.Client,
	logger log.Logger,
) (manager.VisibilityManager, error)

func NewVisibilityManagerDual

func NewVisibilityManagerDual(
	visibilityManager manager.VisibilityManager,
	secondaryVisibilityManager manager.VisibilityManager,
	managerSelector managerSelector,
) *visibilityManagerDual

NewVisibilityManagerDual create a visibility manager that operate on multiple manager implementations based on dynamic config.

func NewVisibilityManagerMetrics

func NewVisibilityManagerMetrics(
	delegate manager.VisibilityManager,
	metricClient metrics.Client,
	logger log.Logger,
	visibilityTypeMetricsTag metrics.Tag,
) *visibilityManagerMetrics

func NewVisibilityManagerRateLimited

func NewVisibilityManagerRateLimited(
	delegate manager.VisibilityManager,
	readMaxQPS dynamicconfig.IntPropertyFn,
	writeMaxQPS dynamicconfig.IntPropertyFn,
) *visibilityManagerRateLimited