visibility

package
v1.9.4 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2026 License: MIT Imports: 38 Imported by: 0

Documentation

Overview

Package visibility is a generated GoMock package.

Index

Constants

View Source 
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"
)
View Source 
const (
	// MemoEncoding is default encoding for visibility memo.
	MemoEncoding = enumspb.ENCODING_TYPE_PROTO3
)
View Source 
const (
	// OperatorPriority is used to give precedence to calls coming from web UI or tctl
	OperatorPriority = 0
)
View Source 
const (
	RateLimitDefaultToken = 1
)

Variables

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

Functions

func AllowListForValidation 

func AllowListForValidation(
	storeNames []string,
	allowList dynamicconfig.BoolPropertyFnWithNamespaceFilter,
) dynamicconfig.BoolPropertyFnWithNamespaceFilter

func ChasmVisibilityManagerProvider 

func ChasmVisibilityManagerProvider(
	registry *chasm.Registry,
	visibilityMgr manager.VisibilityManager,
) chasm.VisibilityManager

func NewManager 

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

	esProcessorConfig *elasticsearch.ProcessorConfig,
	searchAttributesProvider searchattribute.Provider,
	searchAttributesMapperProvider searchattribute.MapperProvider,
	namespaceRegistry namespace.Registry,
	chasmRegistry *chasm.Registry,

	maxReadQPS dynamicconfig.IntPropertyFn,
	maxWriteQPS dynamicconfig.IntPropertyFn,
	operatorRPSRatio dynamicconfig.FloatPropertyFn,
	slowQueryThreshold dynamicconfig.DurationPropertyFn,
	enableReadFromSecondaryVisibility dynamicconfig.BoolPropertyFnWithNamespaceFilter,
	visibilityEnableShadowReadMode dynamicconfig.BoolPropertyFn,
	secondaryVisibilityWritingMode dynamicconfig.StringPropertyFn,
	visibilityDisableOrderByClause dynamicconfig.BoolPropertyFnWithNamespaceFilter,
	visibilityEnableManualPagination dynamicconfig.BoolPropertyFnWithNamespaceFilter,
	visibilityEnableUnifiedQueryConverter dynamicconfig.BoolPropertyFn,

	metricsHandler metrics.Handler,
	logger log.Logger,
	serializer serialization.Serializer,
) (manager.VisibilityManager, error)

func NewVisibilityManagerMetrics 

func NewVisibilityManagerMetrics(
	delegate manager.VisibilityManager,
	metricHandler metrics.Handler,
	logger log.Logger,
	slowQueryThreshold dynamicconfig.DurationPropertyFn,
	visibilityPluginNameMetricsTag metrics.Tag,
	visibilityIndexNameMetricsTag metrics.Tag,
) *visibilityManagerMetrics

func NewVisibilityManagerRateLimited 

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

Types

type ChasmVisibilityManager 

type ChasmVisibilityManager struct {
	// contains filtered or unexported fields
}

func NewChasmVisibilityManager 

func NewChasmVisibilityManager(
	registry *chasm.Registry,
	visibilityMgr manager.VisibilityManager,
) *ChasmVisibilityManager

func (*ChasmVisibilityManager) CountExecutions 

func (e *ChasmVisibilityManager) CountExecutions(
	ctx context.Context,
	archetypeType reflect.Type,
	request *chasm.CountExecutionsRequest,
) (*chasm.CountExecutionsResponse, error)

CountExecutions implements the Engine interface for visibility queries.

func (*ChasmVisibilityManager) ListExecutions 

func (e *ChasmVisibilityManager) ListExecutions(
	ctx context.Context,
	archetypeType reflect.Type,
	request *chasm.ListExecutionsRequest,
) (*chasm.ListExecutionsResponse[*commonpb.Payload], error)

ListExecutions implements the Engine interface for visibility queries.

type MockmanagerSelector 

type MockmanagerSelector struct {
	// contains filtered or unexported fields
}

MockmanagerSelector is a mock of managerSelector interface.

func NewMockmanagerSelector 

func NewMockmanagerSelector(ctrl *gomock.Controller) *MockmanagerSelector

NewMockmanagerSelector creates a new mock instance.

func (*MockmanagerSelector) EXPECT 

func (m *MockmanagerSelector) EXPECT() *MockmanagerSelectorMockRecorder

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

type MockmanagerSelectorMockRecorder 

type MockmanagerSelectorMockRecorder struct {
	// contains filtered or unexported fields
}

MockmanagerSelectorMockRecorder is the mock recorder for MockmanagerSelector.

type VisibilityManagerDual 

type VisibilityManagerDual struct {
	// contains filtered or unexported fields
}

func NewVisibilityManagerDual 

func NewVisibilityManagerDual(
	visibilityManager manager.VisibilityManager,
	secondaryVisibilityManager manager.VisibilityManager,
	managerSelector managerSelector,
	enableShadowReadMode dynamicconfig.BoolPropertyFn,
) *VisibilityManagerDual

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

func (*VisibilityManagerDual) AddSearchAttributes 

func (v *VisibilityManagerDual) AddSearchAttributes(
	ctx context.Context,
	request *manager.AddSearchAttributesRequest,
) error

func (*VisibilityManagerDual) Close 

func (v *VisibilityManagerDual) Close()

func (*VisibilityManagerDual) CountChasmExecutions 

func (v *VisibilityManagerDual) CountChasmExecutions(
	ctx context.Context,
	request *manager.CountChasmExecutionsRequest,
) (*chasm.CountExecutionsResponse, error)

func (*VisibilityManagerDual) CountWorkflowExecutions 

func (v *VisibilityManagerDual) CountWorkflowExecutions(
	ctx context.Context,
	request *manager.CountWorkflowExecutionsRequest,
) (*manager.CountWorkflowExecutionsResponse, error)

func (*VisibilityManagerDual) DeleteWorkflowExecution 

func (v *VisibilityManagerDual) DeleteWorkflowExecution(
	ctx context.Context,
	request *manager.VisibilityDeleteWorkflowExecutionRequest,
) error

func (*VisibilityManagerDual) GetIndexName 

func (v *VisibilityManagerDual) GetIndexName() string

func (*VisibilityManagerDual) GetPrimaryVisibility 

func (v *VisibilityManagerDual) GetPrimaryVisibility() manager.VisibilityManager

func (*VisibilityManagerDual) GetReadStoreName 

func (v *VisibilityManagerDual) GetReadStoreName(nsName namespace.Name) string

func (*VisibilityManagerDual) GetSecondaryVisibility 

func (v *VisibilityManagerDual) GetSecondaryVisibility() manager.VisibilityManager

func (*VisibilityManagerDual) GetStoreNames 

func (v *VisibilityManagerDual) GetStoreNames() []string

func (*VisibilityManagerDual) GetWorkflowExecution 

func (v *VisibilityManagerDual) GetWorkflowExecution(
	ctx context.Context,
	request *manager.GetWorkflowExecutionRequest,
) (*manager.GetWorkflowExecutionResponse, error)

func (*VisibilityManagerDual) HasStoreName 

func (v *VisibilityManagerDual) HasStoreName(stName string) bool

func (*VisibilityManagerDual) ListChasmExecutions 

func (v *VisibilityManagerDual) ListChasmExecutions(
	ctx context.Context,
	request *manager.ListChasmExecutionsRequest,
) (*chasm.ListExecutionsResponse[*commonpb.Payload], error)

func (*VisibilityManagerDual) ListWorkflowExecutions 

func (v *VisibilityManagerDual) ListWorkflowExecutions(
	ctx context.Context,
	request *manager.ListWorkflowExecutionsRequestV2,
) (*manager.ListWorkflowExecutionsResponse, error)

func (*VisibilityManagerDual) RecordWorkflowExecutionClosed 

func (v *VisibilityManagerDual) RecordWorkflowExecutionClosed(
	ctx context.Context,
	request *manager.RecordWorkflowExecutionClosedRequest,
) error

func (*VisibilityManagerDual) RecordWorkflowExecutionStarted 

func (v *VisibilityManagerDual) RecordWorkflowExecutionStarted(
	ctx context.Context,
	request *manager.RecordWorkflowExecutionStartedRequest,
) error

func (*VisibilityManagerDual) UpsertWorkflowExecution 

func (v *VisibilityManagerDual) UpsertWorkflowExecution(
	ctx context.Context,
	request *manager.UpsertWorkflowExecutionRequest,
) error

func (*VisibilityManagerDual) ValidateCustomSearchAttributes 

func (v *VisibilityManagerDual) ValidateCustomSearchAttributes(
	searchAttributes map[string]any,
) (map[string]any, error)

type VisibilityStoreFactory 

type VisibilityStoreFactory interface {
	NewVisibilityStore(
		cfg config.CustomDatastoreConfig,
		saProvider searchattribute.Provider,
		saMapperProvider searchattribute.MapperProvider,
		nsRegistry namespace.Registry,
		chasmRegistry *chasm.Registry,
		r resolver.ServiceResolver,
		logger log.Logger,
		metricsHandler metrics.Handler,
	) (store.VisibilityStore, error)
}

Source Files

View all Source files

Directories

Path Synopsis
Package manager is a generated GoMock package.
 Package manager is a generated GoMock package.
Package store is a generated GoMock package.
 Package store is a generated GoMock package.
elasticsearch
Package elasticsearch is a generated GoMock package.
 Package elasticsearch is a generated GoMock package.
elasticsearch/client
Package client is a generated GoMock package.
 Package client is a generated GoMock package.
query
Package query is inspired and partially copied from by github.com/cch123/elasticsql.
 Package query is inspired and partially copied from by github.com/cch123/elasticsql.
sql

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.