Help us shape the future of Go! Take the 2026 Go Developer Survey

visibility

package
v0.0.2 Latest Latest
Warning

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

 Go to latest Published: Aug 20, 2026 License: MIT Imports: 40 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,
	nsRegistry namespace.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,
	nsRegistry namespace.Registry,
	visibilityMgr manager.VisibilityManager,
) *ChasmVisibilityManager

func (*ChasmVisibilityManager) CountExecutions 

func (e *ChasmVisibilityManager) CountExecutions(
	ctx context.Context,
	archetypeType reflect.Type,
	request *chasm.CountExecutionsRequest,
) (*visibilityservice.CountChasmExecutionsResponse, 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,
) (*visibilityservice.ListChasmExecutionsResponse, 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 *visibilityservice.CountChasmExecutionsRequest,
) (*visibilityservice.CountChasmExecutionsResponse, 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 *visibilityservice.ListChasmExecutionsRequest,
) (*visibilityservice.ListChasmExecutionsResponse, 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.