visibility

Documentation

Index

• type Converter
• type PluginQueryConverter
• type QueryConverter
  • func (c *QueryConverter) BuildCountStmt() (*sqlplugin.VisibilitySelectFilter, error)
  • func (c *QueryConverter) BuildSelectStmt(pageSize int, nextPageToken []byte) (*sqlplugin.VisibilitySelectFilter, error)
• type QueryConverterFactory
  • func NewParadeDbConverterFactory() QueryConverterFactory
• type SqlCustomVisibilityStore
  • func CustomSqlVisibilityFactory(qc QueryConverterFactory) SqlCustomVisibilityStore
  • func (c SqlCustomVisibilityStore) NewVisibilityStore(cfg config.CustomDatastoreConfig, saProvider searchattribute.Provider, ...) (store.VisibilityStore, error)
• type VisibilityStore
  • func NewSQLVisibilityStore(cfg config.SQL, r resolver.ServiceResolver, ...) (*VisibilityStore, error)
  • func (s *VisibilityStore) Close()
  • func (s *VisibilityStore) CountWorkflowExecutions(ctx context.Context, request *manager.CountWorkflowExecutionsRequest) (*manager.CountWorkflowExecutionsResponse, error)
  • func (s *VisibilityStore) DeleteWorkflowExecution(ctx context.Context, request *manager.VisibilityDeleteWorkflowExecutionRequest) error
  • func (s *VisibilityStore) GetIndexName() string
  • func (s *VisibilityStore) GetName() string
  • func (s *VisibilityStore) GetWorkflowExecution(ctx context.Context, request *manager.GetWorkflowExecutionRequest) (*store.InternalGetWorkflowExecutionResponse, error)
  • func (s *VisibilityStore) ListWorkflowExecutions(ctx context.Context, request *manager.ListWorkflowExecutionsRequestV2) (*store.InternalListWorkflowExecutionsResponse, error)
  • func (s *VisibilityStore) RecordWorkflowExecutionClosed(ctx context.Context, ...) error
  • func (s *VisibilityStore) RecordWorkflowExecutionStarted(ctx context.Context, ...) error
  • func (s *VisibilityStore) ScanWorkflowExecutions(ctx context.Context, request *manager.ListWorkflowExecutionsRequestV2) (*store.InternalListWorkflowExecutionsResponse, error)
  • func (s *VisibilityStore) UpsertWorkflowExecution(ctx context.Context, request *store.InternalUpsertWorkflowExecutionRequest) error
  • func (s *VisibilityStore) ValidateCustomSearchAttributes(searchAttributes map[string]any) (map[string]any, error)

Types

type Converter

type Converter interface {
	PluginQueryConverter
	BuildCountStmt() (*sqlplugin.VisibilitySelectFilter, error)
	BuildSelectStmt(
		pageSize int,
		nextPageToken []byte,
	) (*sqlplugin.VisibilitySelectFilter, error)
}

Converter TODO refactor — simplify design and decouple everything etc

type PluginQueryConverter

type PluginQueryConverter interface {
	// contains filtered or unexported methods
}

type QueryConverter

type QueryConverter struct {
	PluginQueryConverter
	// contains filtered or unexported fields
}

func (*QueryConverter) BuildCountStmt

func (c *QueryConverter) BuildCountStmt() (*sqlplugin.VisibilitySelectFilter, error)

func (*QueryConverter) BuildSelectStmt

func (c *QueryConverter) BuildSelectStmt(
	pageSize int,
	nextPageToken []byte,
) (*sqlplugin.VisibilitySelectFilter, error)

type QueryConverterFactory

type QueryConverterFactory interface {
	NewQueryConverter(
		pluginName string,
		namespaceName namespace.Name,
		namespaceID namespace.ID,
		saTypeMap searchattribute.NameTypeMap,
		saMapper searchattribute.Mapper,
		queryString string,
	) Converter
}

func NewParadeDbConverterFactory

func NewParadeDbConverterFactory() QueryConverterFactory

type SqlCustomVisibilityStore

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

func CustomSqlVisibilityFactory

func CustomSqlVisibilityFactory(qc QueryConverterFactory) SqlCustomVisibilityStore

func (SqlCustomVisibilityStore) NewVisibilityStore

func (c SqlCustomVisibilityStore) NewVisibilityStore(
	cfg config.CustomDatastoreConfig,
	saProvider searchattribute.Provider,
	saMapperProvider searchattribute.MapperProvider,
	_ namespace.Registry,
	r resolver.ServiceResolver,
	logger log.Logger,
	metricsHandler metrics.Handler,
) (store.VisibilityStore, error)

type VisibilityStore

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

func NewSQLVisibilityStore

func NewSQLVisibilityStore(
	cfg config.SQL,
	r resolver.ServiceResolver,
	searchAttributesProvider searchattribute.Provider,
	searchAttributesMapperProvider searchattribute.MapperProvider,
	logger log.Logger,
	metricsHandler metrics.Handler,
	queryConverter QueryConverterFactory,
) (*VisibilityStore, error)

NewSQLVisibilityStore creates an instance of VisibilityStore

func (*VisibilityStore) Close

func (s *VisibilityStore) Close()

func (*VisibilityStore) CountWorkflowExecutions

func (s *VisibilityStore) CountWorkflowExecutions(
	ctx context.Context,
	request *manager.CountWorkflowExecutionsRequest,
) (*manager.CountWorkflowExecutionsResponse, error)

func (*VisibilityStore) DeleteWorkflowExecution

func (s *VisibilityStore) DeleteWorkflowExecution(
	ctx context.Context,
	request *manager.VisibilityDeleteWorkflowExecutionRequest,
) error

func (*VisibilityStore) GetIndexName

func (s *VisibilityStore) GetIndexName() string

func (*VisibilityStore) GetName

func (s *VisibilityStore) GetName() string

func (*VisibilityStore) GetWorkflowExecution

func (s *VisibilityStore) GetWorkflowExecution(
	ctx context.Context,
	request *manager.GetWorkflowExecutionRequest,
) (*store.InternalGetWorkflowExecutionResponse, error)

func (*VisibilityStore) ListWorkflowExecutions

func (s *VisibilityStore) ListWorkflowExecutions(
	ctx context.Context,
	request *manager.ListWorkflowExecutionsRequestV2,
) (*store.InternalListWorkflowExecutionsResponse, error)

func (*VisibilityStore) RecordWorkflowExecutionClosed

func (s *VisibilityStore) RecordWorkflowExecutionClosed(
	ctx context.Context,
	request *store.InternalRecordWorkflowExecutionClosedRequest,
) error

func (*VisibilityStore) RecordWorkflowExecutionStarted

func (s *VisibilityStore) RecordWorkflowExecutionStarted(
	ctx context.Context,
	request *store.InternalRecordWorkflowExecutionStartedRequest,
) error

func (*VisibilityStore) ScanWorkflowExecutions

func (s *VisibilityStore) ScanWorkflowExecutions(
	ctx context.Context,
	request *manager.ListWorkflowExecutionsRequestV2,
) (*store.InternalListWorkflowExecutionsResponse, error)

func (*VisibilityStore) UpsertWorkflowExecution

func (s *VisibilityStore) UpsertWorkflowExecution(
	ctx context.Context,
	request *store.InternalUpsertWorkflowExecutionRequest,
) error

func (*VisibilityStore) ValidateCustomSearchAttributes

func (s *VisibilityStore) ValidateCustomSearchAttributes(
	searchAttributes map[string]any,
) (map[string]any, error)