utils

Documentation

Index

• Constants
• func AttributesFilterQueryForSelectBuilder(sl squirrel.SelectBuilder, filter *base.AttributeFilter) squirrel.SelectBuilder
• func AttributesFilterQueryForUpdateBuilder(sl squirrel.UpdateBuilder, filter *base.AttributeFilter) squirrel.UpdateBuilder
• func BulkEntityFilterQuery(tenantID, entityType string, snap uint64) string
• func GenerateGCQuery(table string, value uint64) squirrel.DeleteBuilder
• func HandleError(span trace.Span, err error, errorCode base.ErrorCode) error
• func NewContinuousToken(value string) database.ContinuousToken
• func SnapshotQuery(sl squirrel.SelectBuilder, value uint64) squirrel.SelectBuilder
• func TuplesFilterQueryForSelectBuilder(sl squirrel.SelectBuilder, filter *base.TupleFilter) squirrel.SelectBuilder
• func TuplesFilterQueryForUpdateBuilder(sl squirrel.UpdateBuilder, filter *base.TupleFilter) squirrel.UpdateBuilder
• type ContinuousToken
  • func (t ContinuousToken) Encode() database.EncodedContinuousToken
• type EncodedContinuousToken
  • func (t EncodedContinuousToken) Decode() (database.ContinuousToken, error)
  • func (t EncodedContinuousToken) String() string

Constants

const (
	BulkEntityFilterTemplate = `` /* 503-byte string literal not displayed */

)

Functions

func AttributesFilterQueryForSelectBuilder

func AttributesFilterQueryForSelectBuilder(sl squirrel.SelectBuilder, filter *base.AttributeFilter) squirrel.SelectBuilder

AttributesFilterQueryForSelectBuilder -

func AttributesFilterQueryForUpdateBuilder

func AttributesFilterQueryForUpdateBuilder(sl squirrel.UpdateBuilder, filter *base.AttributeFilter) squirrel.UpdateBuilder

AttributesFilterQueryForUpdateBuilder -

func BulkEntityFilterQuery

func BulkEntityFilterQuery(tenantID, entityType string, snap uint64) string

BulkEntityFilterQuery -

func GenerateGCQuery

func GenerateGCQuery(table string, value uint64) squirrel.DeleteBuilder

GenerateGCQuery generates a Squirrel DELETE query builder for garbage collection. It constructs a query to delete expired records from the specified table based on the provided value, which represents a transaction ID.

func HandleError

func HandleError(span trace.Span, err error, errorCode base.ErrorCode) error

HandleError records an error in the given span, logs the error, and returns a standardized error. This function is used for consistent error handling across different parts of the application.

func NewContinuousToken

func NewContinuousToken(value string) database.ContinuousToken

NewContinuousToken - Creates a new continuous token

func SnapshotQuery

func SnapshotQuery(sl squirrel.SelectBuilder, value uint64) squirrel.SelectBuilder

SnapshotQuery adds conditions to a SELECT query for checking transaction visibility based on created and expired transaction IDs. The query checks if transactions are visible in a snapshot associated with the provided value.

func TuplesFilterQueryForSelectBuilder

func TuplesFilterQueryForSelectBuilder(sl squirrel.SelectBuilder, filter *base.TupleFilter) squirrel.SelectBuilder

TuplesFilterQueryForSelectBuilder -

func TuplesFilterQueryForUpdateBuilder

func TuplesFilterQueryForUpdateBuilder(sl squirrel.UpdateBuilder, filter *base.TupleFilter) squirrel.UpdateBuilder

TuplesFilterQueryForUpdateBuilder -

Types

type ContinuousToken

type ContinuousToken struct {
	Value string
}

ContinuousToken - Structure for continuous token

func (ContinuousToken) Encode

func (t ContinuousToken) Encode() database.EncodedContinuousToken

Encode - Encodes the token to a string

type EncodedContinuousToken

type EncodedContinuousToken struct {
	Value string
}

EncodedContinuousToken - Structure for encoded continuous token

func (EncodedContinuousToken) Decode

func (t EncodedContinuousToken) Decode() (database.ContinuousToken, error)

Decode decodes the token from a string

func (EncodedContinuousToken) String

func (t EncodedContinuousToken) String() string

Decode decodes the token from a string