sql

package
v1.34.0 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2026 License: MIT Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type QueryConverterLegacy 

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

func NewQueryConverterLegacy 

func NewQueryConverterLegacy(
	pluginName string,
	namespaceName namespace.Name,
	namespaceID namespace.ID,
	saTypeMap searchattribute.NameTypeMap,
	saMapper searchattribute.Mapper,
	queryString string,
	chasmMapper *chasm.VisibilitySearchAttributesMapper,
	archetypeID chasm.ArchetypeID,
) *QueryConverterLegacy

func (*QueryConverterLegacy) BuildCountStmt 

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

func (*QueryConverterLegacy) BuildSelectStmt 

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

type SQLQueryConverter 

type SQLQueryConverter struct {
	sqlplugin.VisibilityQueryConverter
}

func NewSQLQueryConverter 

func NewSQLQueryConverter(pluginName string) (*SQLQueryConverter, error)

func (*SQLQueryConverter) BuildAndExpr 

func (c *SQLQueryConverter) BuildAndExpr(exprs ...sqlparser.Expr) (sqlparser.Expr, error)

func (*SQLQueryConverter) BuildNotExpr 

func (c *SQLQueryConverter) BuildNotExpr(expr sqlparser.Expr) (sqlparser.Expr, error)

func (*SQLQueryConverter) BuildOrExpr 

func (c *SQLQueryConverter) BuildOrExpr(exprs ...sqlparser.Expr) (sqlparser.Expr, error)

func (*SQLQueryConverter) BuildParenExpr 

func (c *SQLQueryConverter) BuildParenExpr(expr sqlparser.Expr) (sqlparser.Expr, error)

func (*SQLQueryConverter) ConvertComparisonExpr 

func (c *SQLQueryConverter) ConvertComparisonExpr(
	operator string,
	col *query.SAColumn,
	value any,
) (sqlparser.Expr, error)

func (*SQLQueryConverter) ConvertIsExpr 

func (c *SQLQueryConverter) ConvertIsExpr(
	operator string,
	col *query.SAColumn,
) (sqlparser.Expr, error)

func (*SQLQueryConverter) ConvertKeywordComparisonExpr 

func (c *SQLQueryConverter) ConvertKeywordComparisonExpr(
	operator string,
	col *query.SAColumn,
	value any,
) (sqlparser.Expr, error)

func (*SQLQueryConverter) ConvertKeywordListComparisonExpr 

func (c *SQLQueryConverter) ConvertKeywordListComparisonExpr(
	operator string,
	col *query.SAColumn,
	value any,
) (sqlparser.Expr, error)

func (*SQLQueryConverter) ConvertRangeExpr 

func (c *SQLQueryConverter) ConvertRangeExpr(
	operator string,
	col *query.SAColumn,
	from, to any,
) (sqlparser.Expr, error)

func (*SQLQueryConverter) ConvertTextComparisonExpr 

func (c *SQLQueryConverter) ConvertTextComparisonExpr(
	operator string,
	col *query.SAColumn,
	value any,
) (sqlparser.Expr, 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,
	chasmRegistry *chasm.Registry,
	enableUnifiedQueryConverter dynamicconfig.BoolPropertyFn,
	logger log.Logger,
	metricsHandler metrics.Handler,
	serializer serialization.Serializer,
) (*VisibilityStore, error)

NewSQLVisibilityStore creates an instance of VisibilityStore

func (*VisibilityStore) AddSearchAttributes 

func (s *VisibilityStore) AddSearchAttributes(
	ctx context.Context,
	request *manager.AddSearchAttributesRequest,
) error

func (*VisibilityStore) Close 

func (s *VisibilityStore) Close()

func (*VisibilityStore) CountChasmExecutions 

func (s *VisibilityStore) CountChasmExecutions(
	ctx context.Context,
	request *manager.CountChasmExecutionsRequest,
) (*store.InternalCountExecutionsResponse, error)

func (*VisibilityStore) CountWorkflowExecutions 

func (s *VisibilityStore) CountWorkflowExecutions(
	ctx context.Context,
	request *manager.CountWorkflowExecutionsRequest,
) (*store.InternalCountExecutionsResponse, 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) ListChasmExecutions 

func (s *VisibilityStore) ListChasmExecutions(
	ctx context.Context,
	request *manager.ListChasmExecutionsRequest,
) (*store.InternalListExecutionsResponse, error)

func (*VisibilityStore) ListWorkflowExecutions 

func (s *VisibilityStore) ListWorkflowExecutions(
	ctx context.Context,
	request *manager.ListWorkflowExecutionsRequestV2,
) (*store.InternalListExecutionsResponse, 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) 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)

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.