sql

package
v1.22.2 Latest Latest
Warning

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

 Go to latest Published: Nov 13, 2023 License: MIT Imports: 26 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 (s *VisibilityStore) CountWorkflowExecutions(
	ctx context.Context,
	request *manager.CountWorkflowExecutionsRequest,
) (*manager.CountWorkflowExecutionsResponse, error)

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 (s *VisibilityStore) GetWorkflowExecution(
	ctx context.Context,
	request *manager.GetWorkflowExecutionRequest,
) (*store.InternalGetWorkflowExecutionResponse, error)

func (*VisibilityStore) ListClosedWorkflowExecutions added in v1.20.0 

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

func (*VisibilityStore) ListClosedWorkflowExecutionsByStatus added in v1.20.0 

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

func (*VisibilityStore) ListClosedWorkflowExecutionsByType added in v1.20.0 

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

func (*VisibilityStore) ListClosedWorkflowExecutionsByWorkflowID added in v1.20.0 

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

func (*VisibilityStore) ListOpenWorkflowExecutions added in v1.20.0 

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

func (*VisibilityStore) ListOpenWorkflowExecutionsByType added in v1.20.0 

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

func (*VisibilityStore) ListOpenWorkflowExecutionsByWorkflowID added in v1.20.0 

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

func (*VisibilityStore) ListWorkflowExecutions added in v1.20.0 

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

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 (s *VisibilityStore) ScanWorkflowExecutions(
	ctx context.Context,
	request *manager.ListWorkflowExecutionsRequestV2,
) (*store.InternalListWorkflowExecutionsResponse, error)

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)

Source Files

View all Source files

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.