visibility

package
v1.23.1 Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2024 License: MIT Imports: 33 Imported by: 1

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 added in v1.20.0 

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

func DefaultAdvancedVisibilityWritingMode added in v1.13.0 

func DefaultAdvancedVisibilityWritingMode(advancedVisibilityConfigExist bool) string

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

func GetEnableReadFromSecondaryVisibilityConfig added in v1.21.0 

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

func GetSecondaryVisibilityWritingModeConfig added in v1.21.0 

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

func GetVisibilityPersistenceMaxReadQPS added in v1.21.0 

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

func GetVisibilityPersistenceMaxWriteQPS added in v1.21.0 

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

func NewManager added in v1.13.0 

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

	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 NewVisibilityManagerMetrics added in v1.13.0 

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

func NewVisibilityManagerRateLimited added in v1.13.0 

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

Types

type MockmanagerSelector added in v1.23.0 

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

MockmanagerSelector is a mock of managerSelector interface.

func NewMockmanagerSelector added in v1.23.0 

func NewMockmanagerSelector(ctrl *gomock.Controller) *MockmanagerSelector

NewMockmanagerSelector creates a new mock instance.

func (*MockmanagerSelector) EXPECT added in v1.23.0 

func (m *MockmanagerSelector) EXPECT() *MockmanagerSelectorMockRecorder

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

type MockmanagerSelectorMockRecorder added in v1.23.0 

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

MockmanagerSelectorMockRecorder is the mock recorder for MockmanagerSelector.

type VisibilityManagerDual added in v1.23.0 

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

func NewVisibilityManagerDual added in v1.13.0 

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 (*VisibilityManagerDual) Close added in v1.23.0 

func (v *VisibilityManagerDual) Close()

func (*VisibilityManagerDual) CountWorkflowExecutions added in v1.23.0 

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

func (*VisibilityManagerDual) DeleteWorkflowExecution added in v1.23.0 

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

func (*VisibilityManagerDual) GetIndexName added in v1.23.0 

func (v *VisibilityManagerDual) GetIndexName() string

func (*VisibilityManagerDual) GetPrimaryVisibility added in v1.23.0 

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

func (*VisibilityManagerDual) GetReadStoreName added in v1.23.0 

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

func (*VisibilityManagerDual) GetSecondaryVisibility added in v1.23.0 

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

func (*VisibilityManagerDual) GetStoreNames added in v1.23.0 

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

func (*VisibilityManagerDual) GetWorkflowExecution added in v1.23.0 

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

func (*VisibilityManagerDual) HasStoreName added in v1.23.0 

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

func (*VisibilityManagerDual) ListClosedWorkflowExecutions added in v1.23.0 

func (v *VisibilityManagerDual) ListClosedWorkflowExecutions(
	ctx context.Context,
	request *manager.ListWorkflowExecutionsRequest,
) (*manager.ListWorkflowExecutionsResponse, error)

func (*VisibilityManagerDual) ListClosedWorkflowExecutionsByStatus added in v1.23.0 

func (v *VisibilityManagerDual) ListClosedWorkflowExecutionsByStatus(
	ctx context.Context,
	request *manager.ListClosedWorkflowExecutionsByStatusRequest,
) (*manager.ListWorkflowExecutionsResponse, error)

func (*VisibilityManagerDual) ListClosedWorkflowExecutionsByType added in v1.23.0 

func (v *VisibilityManagerDual) ListClosedWorkflowExecutionsByType(
	ctx context.Context,
	request *manager.ListWorkflowExecutionsByTypeRequest,
) (*manager.ListWorkflowExecutionsResponse, error)

func (*VisibilityManagerDual) ListClosedWorkflowExecutionsByWorkflowID added in v1.23.0 

func (v *VisibilityManagerDual) ListClosedWorkflowExecutionsByWorkflowID(
	ctx context.Context,
	request *manager.ListWorkflowExecutionsByWorkflowIDRequest,
) (*manager.ListWorkflowExecutionsResponse, error)

func (*VisibilityManagerDual) ListOpenWorkflowExecutions added in v1.23.0 

func (v *VisibilityManagerDual) ListOpenWorkflowExecutions(
	ctx context.Context,
	request *manager.ListWorkflowExecutionsRequest,
) (*manager.ListWorkflowExecutionsResponse, error)

func (*VisibilityManagerDual) ListOpenWorkflowExecutionsByType added in v1.23.0 

func (v *VisibilityManagerDual) ListOpenWorkflowExecutionsByType(
	ctx context.Context,
	request *manager.ListWorkflowExecutionsByTypeRequest,
) (*manager.ListWorkflowExecutionsResponse, error)

func (*VisibilityManagerDual) ListOpenWorkflowExecutionsByWorkflowID added in v1.23.0 

func (v *VisibilityManagerDual) ListOpenWorkflowExecutionsByWorkflowID(
	ctx context.Context,
	request *manager.ListWorkflowExecutionsByWorkflowIDRequest,
) (*manager.ListWorkflowExecutionsResponse, error)

func (*VisibilityManagerDual) ListWorkflowExecutions added in v1.23.0 

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

func (*VisibilityManagerDual) RecordWorkflowExecutionClosed added in v1.23.0 

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

func (*VisibilityManagerDual) RecordWorkflowExecutionStarted added in v1.23.0 

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

func (*VisibilityManagerDual) ScanWorkflowExecutions added in v1.23.0 

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

func (*VisibilityManagerDual) UpsertWorkflowExecution added in v1.23.0 

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

func (*VisibilityManagerDual) ValidateCustomSearchAttributes added in v1.23.0 

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

type VisibilityStoreFactory added in v1.23.0 

type VisibilityStoreFactory interface {
	NewVisibilityStore(
		cfg config.CustomDatastoreConfig,
		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
standard
standard/cassandra
standard/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.