sql

Documentation

Index

• type QueryConverter
  • func NewQueryConverter(pluginName string, namespaceName namespace.Name, namespaceID namespace.ID, ...) *QueryConverter
  • func (c *QueryConverter) BuildCountStmt() (*sqlplugin.VisibilitySelectFilter, error)
  • func (c *QueryConverter) BuildSelectStmt(pageSize int, nextPageToken []byte) (*sqlplugin.VisibilitySelectFilter, 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 QueryConverter

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

func NewQueryConverter

func NewQueryConverter(
	pluginName string,
	namespaceName namespace.Name,
	namespaceID namespace.ID,
	saTypeMap searchattribute.NameTypeMap,
	saMapper searchattribute.Mapper,
	queryString string,
) *QueryConverter

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 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,
) (*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)