utils

Documentation

Index

• func FilterQuery(filter *base.TupleFilter) memdb.FilterFunc
• func GetIndexNameAndArgsByFilters(tenantID string, filter *base.TupleFilter) (string, []any)
• func NewContinuousToken(value string) database.ContinuousToken
• func NewNoopContinuousToken() database.ContinuousToken
• type AutoIncForRelationTuples
  • func (a *AutoIncForRelationTuples) ID() (id uint64)
• 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 FilterQuery

func FilterQuery(filter *base.TupleFilter) memdb.FilterFunc

FilterQuery - Filter relation tuples according to given filter

func GetIndexNameAndArgsByFilters

func GetIndexNameAndArgsByFilters(tenantID string, filter *base.TupleFilter) (string, []any)

GetIndexNameAndArgsByFilters - Get index name and arguments by filters

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

Types

type AutoIncForRelationTuples

type AutoIncForRelationTuples struct {
	sync.Mutex
	// contains filtered or unexported fields
}

var RelationTuplesID AutoIncForRelationTuples

func (*AutoIncForRelationTuples) ID

func (a *AutoIncForRelationTuples) ID() (id uint64)

ID -

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