visibility

Documentation

Index

• Constants
• Variables
• func AllowListForValidation(storeNames []string) bool
• func DefaultAdvancedVisibilityWritingMode(advancedVisibilityConfigExist bool) string
• func GetEnableReadFromSecondaryVisibilityConfig(dc *dynamicconfig.Collection, visibilityStoreConfigExists bool, ...) dynamicconfig.BoolPropertyFnWithNamespaceFilter
• func GetSecondaryVisibilityWritingModeConfig(dc *dynamicconfig.Collection, visibilityStoreConfigExists bool, ...) dynamicconfig.StringPropertyFn
• func GetVisibilityPersistenceMaxReadQPS(dc *dynamicconfig.Collection, advancedVisibilityStoreConfigExists bool) dynamicconfig.IntPropertyFn
• func GetVisibilityPersistenceMaxWriteQPS(dc *dynamicconfig.Collection, advancedVisibilityStoreConfigExists bool) dynamicconfig.IntPropertyFn
• func NewManager(persistenceCfg config.Persistence, ...) (manager.VisibilityManager, error)
• func NewVisibilityManagerDual(visibilityManager manager.VisibilityManager, ...) *visibilityManagerDual
• func NewVisibilityManagerMetrics(delegate manager.VisibilityManager, metricHandler metrics.Handler, ...) *visibilityManagerMetrics
• func NewVisibilityManagerRateLimited(delegate manager.VisibilityManager, readMaxQPS dynamicconfig.IntPropertyFn, ...) *visibilityManagerRateLimited

Constants

const (
	// SecondaryVisibilityWritingModeOff means do not write to advanced visibility store
	SecondaryVisibilityWritingModeOff = "off"
	// SecondaryVisibilityWritingModeOn means only write to advanced visibility store
	SecondaryVisibilityWritingModeOn = "on"
	// SecondaryVisibilityWritingModeDual means write to both normal visibility and advanced visibility store
	SecondaryVisibilityWritingModeDual = "dual"
)

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

const (
	// OperatorPriority is used to give precedence to calls coming from web UI or tctl
	OperatorPriority = 0
)

const (
	RateLimitDefaultToken = 1
)

Variables

var (
	PrioritiesOrdered = []int{OperatorPriority, 1}
)

Functions

func AllowListForValidation

func AllowListForValidation(storeNames []string) bool

func DefaultAdvancedVisibilityWritingMode

func DefaultAdvancedVisibilityWritingMode(advancedVisibilityConfigExist bool) string

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

func GetEnableReadFromSecondaryVisibilityConfig

func GetEnableReadFromSecondaryVisibilityConfig(
	dc *dynamicconfig.Collection,
	visibilityStoreConfigExists bool,
	advancedVisibilityStoreConfigExists bool,
) dynamicconfig.BoolPropertyFnWithNamespaceFilter

func GetSecondaryVisibilityWritingModeConfig

func GetSecondaryVisibilityWritingModeConfig(
	dc *dynamicconfig.Collection,
	visibilityStoreConfigExists bool,
	advancedVisibilityStoreConfigExists bool,
) dynamicconfig.StringPropertyFn

func GetVisibilityPersistenceMaxReadQPS

func GetVisibilityPersistenceMaxReadQPS(
	dc *dynamicconfig.Collection,
	advancedVisibilityStoreConfigExists bool,
) dynamicconfig.IntPropertyFn

func GetVisibilityPersistenceMaxWriteQPS

func GetVisibilityPersistenceMaxWriteQPS(
	dc *dynamicconfig.Collection,
	advancedVisibilityStoreConfigExists bool,
) dynamicconfig.IntPropertyFn

func NewManager

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

	esClient esclient.Client,
	esProcessorConfig *elasticsearch.ProcessorConfig,
	searchAttributesProvider searchattribute.Provider,
	searchAttributesMapperProvider searchattribute.MapperProvider,

	maxReadQPS dynamicconfig.IntPropertyFn,
	maxWriteQPS dynamicconfig.IntPropertyFn,
	operatorRPSRatio dynamicconfig.FloatPropertyFn,
	enableReadFromSecondaryVisibility dynamicconfig.BoolPropertyFnWithNamespaceFilter,
	secondaryVisibilityWritingMode dynamicconfig.StringPropertyFn,
	visibilityDisableOrderByClause dynamicconfig.BoolPropertyFnWithNamespaceFilter,
	visibilityEnableManualPagination dynamicconfig.BoolPropertyFnWithNamespaceFilter,

	metricsHandler metrics.Handler,
	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,
	metricHandler metrics.Handler,
	logger log.Logger,
	visibilityTypeMetricsTag metrics.Tag,
) *visibilityManagerMetrics

func NewVisibilityManagerRateLimited

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