database

type AttributeBundle ¶ added in v0.6.0

type AttributeBundle struct {
	// Write is an AttributeCollection intended to hold attributes that are to be created or updated.
	Write AttributeCollection

	// Delete is an AttributeCollection intended to hold attributes that are to be deleted.
	Delete AttributeCollection
}

AttributeBundle defines a structure for managing collections of attributes, with separate collections for write (create/update) and delete operations.

type AttributeCollection ¶ added in v0.5.0

type AttributeCollection struct {
	// contains filtered or unexported fields
}

AttributeCollection -Attribute collection.

func NewAttributeCollection(attributes ...*base.Attribute) *AttributeCollection

func (t *AttributeCollection) Add(attribute *base.Attribute)

func (t *AttributeCollection) CreateAttributeIterator() *AttributeIterator

func (t *AttributeCollection) GetAttributes() []*base.Attribute

type AttributeIterator ¶ added in v0.5.0

type AttributeIterator struct {
	// contains filtered or unexported fields
}

AttributeIterator - Attribute iterator -

func NewAttributeIterator(attributes ...*base.Attribute) *AttributeIterator

func (u *AttributeIterator) GetNext() *base.Attribute

func (u *AttributeIterator) HasNext() bool

type ContinuousToken ¶ added in v0.3.0

type ContinuousToken interface {
	// Encode encodes the continuous token to a string.
	Encode() EncodedContinuousToken
}

ContinuousToken -

func NewNoopContinuousToken() ContinuousToken

type Database ¶

type Database interface {
	// GetEngineType get the database type (e.g. postgres, memory, etc.).
	GetEngineType() string

	// Close the database connection.
	Close() error

	// IsReady - Check if database is ready
	IsReady(ctx context.Context) (bool, error)
}

Database - Db interface

type EncodedContinuousToken ¶ added in v0.3.0

type EncodedContinuousToken interface {
	// String returns the string representation of the continuous token.
	String() string
	// Decode decodes the continuous token from a string
	Decode() (ContinuousToken, error)
}

EncodedContinuousToken -

type Engine ¶

type Engine string

Engine - Type declaration of engine

const (
	POSTGRES Engine = "postgres"
	MEMORY   Engine = "memory"
)

func (c Engine) String() string

type EntityCollection ¶

type EntityCollection struct {
	// contains filtered or unexported fields
}

EntityCollection - Entity collection.

func NewEntityCollection(entities ...*base.Entity) *EntityCollection

func (e *EntityCollection) Add(entity *base.Entity)

func (e *EntityCollection) CreateEntityIterator() *EntityIterator

func (e *EntityCollection) GetEntities() []*base.Entity

type EntityIterator ¶

type EntityIterator struct {
	// contains filtered or unexported fields
}

EntityIterator - Structure for entity iterator

func NewEntityIterator(entities []*base.Entity) *EntityIterator

func (u *EntityIterator) GetNext() *base.Entity

func (u *EntityIterator) HasNext() bool

type NoopContinuousToken ¶ added in v0.4.4

type NoopContinuousToken struct {
	Value string
}

func (t NoopContinuousToken) Encode() EncodedContinuousToken

type NoopEncodedContinuousToken ¶ added in v0.4.4

type NoopEncodedContinuousToken struct {
	Value string
}

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

func (t NoopEncodedContinuousToken) String() string

type Option ¶ added in v0.3.0

type Option func(*Pagination)

Option - Option type

func Size(size uint32) Option

func Token(token string) Option

type Pagination ¶ added in v0.3.0

type Pagination struct {
	// contains filtered or unexported fields
}

Pagination -

func NewPagination(opts ...Option) Pagination

func (p Pagination) PageSize() uint32

func (p Pagination) Token() string

type SubjectCollection ¶

type SubjectCollection struct {
	// contains filtered or unexported fields
}

SubjectCollection - Subject collection.

func NewSubjectCollection(subjects ...*base.Subject) *SubjectCollection

func (s *SubjectCollection) Add(subject *base.Subject)

func (s *SubjectCollection) CreateSubjectIterator() *SubjectIterator

func (s *SubjectCollection) GetSubjects() []*base.Subject

type SubjectIterator ¶

type SubjectIterator struct {
	// contains filtered or unexported fields
}

SubjectIterator - Structure for subject iterator

func NewSubjectIterator(subjects []*base.Subject) *SubjectIterator

func (u *SubjectIterator) GetNext() *base.Subject

func (u *SubjectIterator) HasNext() bool

type TupleBundle ¶ added in v0.6.0

type TupleBundle struct {
	// Write is a TupleCollection intended to hold tuples that are to be created or updated.
	Write TupleCollection

	// Delete is a TupleCollection intended to hold tuples that are to be deleted.
	Delete TupleCollection
}

TupleBundle defines a structure for managing collections of tuples, with separate collections for write (create/update) and delete operations.

type TupleCollection ¶

type TupleCollection struct {
	// contains filtered or unexported fields
}

TupleCollection -Tuple collection.

func NewTupleCollection(tuples ...*base.Tuple) *TupleCollection

func (t *TupleCollection) Add(tuple *base.Tuple)

func (t *TupleCollection) CreateTupleIterator() *TupleIterator

func (t *TupleCollection) GetTuples() []*base.Tuple

func (t *TupleCollection) ToSubjectCollection() *SubjectCollection

type TupleIterator ¶

type TupleIterator struct {
	// contains filtered or unexported fields
}

TupleIterator - Tuple iterator -

func NewTupleIterator(tuples ...*base.Tuple) *TupleIterator

func (i *TupleIterator) GetNext() *base.Tuple

func (i *TupleIterator) HasNext() bool

type UniqueAttributeIterator ¶ added in v0.5.0

type UniqueAttributeIterator struct {
	// contains filtered or unexported fields
}

UniqueAttributeIterator combines two AttributeIterators and ensures that only unique Attributes are returned. Uniqueness is based on the Attribute's pointer address.

func NewUniqueAttributeIterator(iterator1, iterator2 *AttributeIterator) *UniqueAttributeIterator

func (i *UniqueAttributeIterator) GetNext() (*base.Attribute, bool)

func (i *UniqueAttributeIterator) HasNext() bool

type UniqueTupleIterator ¶ added in v0.4.5

type UniqueTupleIterator struct {
	// contains filtered or unexported fields
}

UniqueTupleIterator combines two TupleIterators and ensures that only unique Tuples are returned. Uniqueness is based on the Tuple's pointer address.

func NewUniqueTupleIterator(iterator1, iterator2 *TupleIterator) *UniqueTupleIterator

func (i *UniqueTupleIterator) GetNext() (*base.Tuple, bool)

func (i *UniqueTupleIterator) HasNext() bool