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
• func Union(a, b []string) []string
• type AutoIncForAttributes
  • func (a *AutoIncForAttributes) ID() (id uint64)
• 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

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

func Union

func Union(a, b []string) []string

Union - Get union of two slices

Types

type AutoIncForAttributes

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

func (*AutoIncForAttributes) ID

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

ID -

type AutoIncForRelationTuples

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

var (
	RelationTuplesID AutoIncForRelationTuples
	AttributesID     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