sql

package
v1.21.4 Latest Latest
Warning

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

Go to latest
Published: Jul 28, 2023 License: MIT Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type QueryConverter added in v1.20.0

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

func NewQueryConverter added in v1.20.0

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

func (*QueryConverter) BuildCountStmt added in v1.20.0

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

func (*QueryConverter) BuildSelectStmt added in v1.20.0

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

type VisibilityStore added in v1.20.0

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

NewSQLVisibilityStore creates an instance of VisibilityStore

func (*VisibilityStore) Close added in v1.20.0

func (s *VisibilityStore) Close()

func (*VisibilityStore) CountWorkflowExecutions added in v1.20.0

func (*VisibilityStore) DeleteWorkflowExecution added in v1.20.0

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

func (*VisibilityStore) GetIndexName added in v1.20.0

func (s *VisibilityStore) GetIndexName() string

func (*VisibilityStore) GetName added in v1.20.0

func (s *VisibilityStore) GetName() string

func (*VisibilityStore) GetWorkflowExecution added in v1.20.0

func (*VisibilityStore) ListClosedWorkflowExecutions added in v1.20.0

func (*VisibilityStore) ListClosedWorkflowExecutionsByStatus added in v1.20.0

func (*VisibilityStore) ListClosedWorkflowExecutionsByType added in v1.20.0

func (*VisibilityStore) ListClosedWorkflowExecutionsByWorkflowID added in v1.20.0

func (*VisibilityStore) ListOpenWorkflowExecutions added in v1.20.0

func (*VisibilityStore) ListOpenWorkflowExecutionsByType added in v1.20.0

func (*VisibilityStore) ListOpenWorkflowExecutionsByWorkflowID added in v1.20.0

func (*VisibilityStore) ListWorkflowExecutions added in v1.20.0

func (*VisibilityStore) RecordWorkflowExecutionClosed added in v1.20.0

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

func (*VisibilityStore) RecordWorkflowExecutionStarted added in v1.20.0

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

func (*VisibilityStore) ScanWorkflowExecutions added in v1.20.0

func (*VisibilityStore) UpsertWorkflowExecution added in v1.20.0

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

func (*VisibilityStore) ValidateCustomSearchAttributes added in v1.21.3

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL