utils

Documentation

Index

• func FilterQueryForSelectBuilder(sl squirrel.SelectBuilder, filter *base.TupleFilter) squirrel.SelectBuilder
• func FilterQueryForUpdateBuilder(sl squirrel.UpdateBuilder, filter *base.TupleFilter) squirrel.UpdateBuilder
• func NewContinuousToken(value string) database.ContinuousToken
• func NewNoopContinuousToken() database.ContinuousToken
• func Rollback(tx *sql.Tx, logger logger.Interface)
• func SnapshotQuery(sl squirrel.SelectBuilder, revision uint64) squirrel.SelectBuilder
• type ContinuousToken
  • func (t ContinuousToken) Encode() database.EncodedContinuousToken
• type EncodedContinuousToken
  • func (t EncodedContinuousToken) Decode() (database.ContinuousToken, error)
  • func (t EncodedContinuousToken) String() string
• type NoopContinuousToken
  • func (t NoopContinuousToken) Encode() database.EncodedContinuousToken
• type NoopEncodedContinuousToken
  • func (t NoopEncodedContinuousToken) Decode() (database.ContinuousToken, error)
  • func (t NoopEncodedContinuousToken) String() string

Functions

func FilterQueryForSelectBuilder

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

FilterQueryForSelectBuilder -

func FilterQueryForUpdateBuilder

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

FilterQueryForUpdateBuilder -

func NewContinuousToken

func NewContinuousToken(value string) database.ContinuousToken

NewContinuousToken - Creates a new continuous token

func NewNoopContinuousToken

func NewNoopContinuousToken() database.ContinuousToken

NewNoopContinuousToken - Creates a new continuous token

func Rollback

func Rollback(tx *sql.Tx, logger logger.Interface)

Rollback - Rollbacks a transaction and logs the error

func SnapshotQuery

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

SnapshotQuery -

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

type NoopContinuousToken

type NoopContinuousToken struct {
	Value string
}

func (NoopContinuousToken) Encode

func (t NoopContinuousToken) Encode() database.EncodedContinuousToken

Encode - Encodes the token to a string

type NoopEncodedContinuousToken

type NoopEncodedContinuousToken struct {
	Value string
}

func (NoopEncodedContinuousToken) Decode

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

Decode decodes the token from a string

func (NoopEncodedContinuousToken) String

func (t NoopEncodedContinuousToken) String() string

Decode decodes the token from a string