utils

Documentation

Index

• func FilterAttributesQuery(tenantID string, filter *base.AttributeFilter) memdb.FilterFunc
• func FilterRelationTuplesQuery(tenantID string, filter *base.TupleFilter) memdb.FilterFunc
• func GetAttributesIndexNameAndArgsByFilters(tenantID string, filter *base.AttributeFilter) (string, []any)
• func GetRelationTuplesIndexNameAndArgsByFilters(tenantID string, filter *base.TupleFilter) (string, []any)
• func NewContinuousToken(value string) database.ContinuousToken
• type ContinuousToken
  • func (t ContinuousToken) Encode() database.EncodedContinuousToken
• type EncodedContinuousToken
  • func (t EncodedContinuousToken) Decode() (database.ContinuousToken, error)
  • func (t EncodedContinuousToken) String() string

Functions

func FilterAttributesQuery

func FilterAttributesQuery(tenantID string, filter *base.AttributeFilter) memdb.FilterFunc

FilterAttributesQuery - Filter attributes according to given filter

func FilterRelationTuplesQuery

func FilterRelationTuplesQuery(tenantID string, filter *base.TupleFilter) memdb.FilterFunc

FilterRelationTuplesQuery - Filter relation tuples according to given filter

func GetAttributesIndexNameAndArgsByFilters

func GetAttributesIndexNameAndArgsByFilters(tenantID string, filter *base.AttributeFilter) (string, []any)

func GetRelationTuplesIndexNameAndArgsByFilters

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

GetRelationTuplesIndexNameAndArgsByFilters - Get index name and arguments by filters

func NewContinuousToken

func NewContinuousToken(value string) database.ContinuousToken

NewContinuousToken - Creates a new continuous token

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