database

Documentation

Index

• type ContinuousToken
  • func NewNoopContinuousToken() ContinuousToken
• type Database
• type EncodedContinuousToken
• type Engine
  • func (c Engine) String() string
• type EntityCollection
  • 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
  • func NewEntityIterator(entities []*base.Entity) *EntityIterator
  • func (u *EntityIterator) GetNext() *base.Entity
  • func (u *EntityIterator) HasNext() bool
• type NoopContinuousToken
  • func (t NoopContinuousToken) Encode() EncodedContinuousToken
• type NoopEncodedContinuousToken
  • func (t NoopEncodedContinuousToken) Decode() (ContinuousToken, error)
  • func (t NoopEncodedContinuousToken) String() string
• type Option
  • func Size(size uint32) Option
  • func Token(token string) Option
• type Pagination
  • func NewPagination(opts ...Option) Pagination
  • func (p Pagination) PageSize() uint32
  • func (p Pagination) Token() string
• type SubjectCollection
  • 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
  • func NewSubjectIterator(subjects []*base.Subject) *SubjectIterator
  • func (u *SubjectIterator) GetNext() *base.Subject
  • func (u *SubjectIterator) HasNext() bool
• type TupleCollection
  • 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
  • func NewTupleIterator(tuples ...*base.Tuple) *TupleIterator
  • func (i *TupleIterator) GetNext() *base.Tuple
  • func (i *TupleIterator) HasNext() bool
• type UniqueTupleIterator
  • func NewUniqueTupleIterator(iterator1, iterator2 *TupleIterator) *UniqueTupleIterator
  • func (i *UniqueTupleIterator) GetNext() (*base.Tuple, bool)
  • func (i *UniqueTupleIterator) HasNext() bool

Types

type ContinuousToken

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

ContinuousToken -

func NewNoopContinuousToken

func NewNoopContinuousToken() ContinuousToken

NewNoopContinuousToken - Creates a new continuous token

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

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 (Engine) String

func (c Engine) String() string

String - Convert to string

type EntityCollection

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

EntityCollection - Entity collection.

func NewEntityCollection

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

NewEntityCollection - Create new subject collection.

func (*EntityCollection) Add

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

Add - New subject to collection.

func (*EntityCollection) CreateEntityIterator

func (e *EntityCollection) CreateEntityIterator() *EntityIterator

CreateEntityIterator - Create entity iterator according to collection.

func (*EntityCollection) GetEntities

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

GetEntities - Get entities

type EntityIterator

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

EntityIterator - Structure for entity iterator

func NewEntityIterator

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

NewEntityIterator -

func (*EntityIterator) GetNext

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

GetNext - Get next entity

func (*EntityIterator) HasNext

func (u *EntityIterator) HasNext() bool

HasNext - Checks whether next entity exists

type NoopContinuousToken

type NoopContinuousToken struct {
	Value string
}

func (NoopContinuousToken) Encode

func (t NoopContinuousToken) Encode() EncodedContinuousToken

Encode - Encodes the token to a string

type NoopEncodedContinuousToken

type NoopEncodedContinuousToken struct {
	Value string
}

func (NoopEncodedContinuousToken) Decode

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

Decode decodes the token from a string

func (NoopEncodedContinuousToken) String

func (t NoopEncodedContinuousToken) String() string

Decode decodes the token from a string

type Option

type Option func(*Pagination)

Option - Option type

func Size

func Size(size uint32) Option

Size -

func Token

func Token(token string) Option

Token -

type Pagination

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

Pagination -

func NewPagination

func NewPagination(opts ...Option) Pagination

NewPagination -

func (Pagination) PageSize

func (p Pagination) PageSize() uint32

PageSize -

func (Pagination) Token

func (p Pagination) Token() string

Token -

type SubjectCollection

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

SubjectCollection - Subject collection.

func NewSubjectCollection

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

NewSubjectCollection - Create new subject collection.

func (*SubjectCollection) Add

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

Add - New subject to collection.

func (*SubjectCollection) CreateSubjectIterator

func (s *SubjectCollection) CreateSubjectIterator() *SubjectIterator

CreateSubjectIterator - Create subject iterator according to collection.

func (*SubjectCollection) GetSubjects

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

GetSubjects - Get subject collection

type SubjectIterator

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

SubjectIterator - Structure for subject iterator

func NewSubjectIterator

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

NewSubjectIterator -

func (*SubjectIterator) GetNext

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

GetNext - Get next tuple

func (*SubjectIterator) HasNext

func (u *SubjectIterator) HasNext() bool

HasNext - Checks whether next subject exists

type TupleCollection

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

TupleCollection -Tuple collection.

func NewTupleCollection

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

NewTupleCollection - Create new tuple collection.

func (*TupleCollection) Add

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

Add - New subject to collection.

func (*TupleCollection) CreateTupleIterator

func (t *TupleCollection) CreateTupleIterator() *TupleIterator

CreateTupleIterator - Create tuple iterator according to collection.

func (*TupleCollection) GetTuples

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

GetTuples - Get tuples

func (*TupleCollection) ToSubjectCollection

func (t *TupleCollection) ToSubjectCollection() *SubjectCollection

ToSubjectCollection - Converts new subject collection from given tuple collection

type TupleIterator

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

TupleIterator - Tuple iterator -

func NewTupleIterator

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

NewTupleIterator -

func (*TupleIterator) GetNext

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

GetNext - Get next tuple

func (*TupleIterator) HasNext

func (i *TupleIterator) HasNext() bool

HasNext - Checks whether next tuple exists

type UniqueTupleIterator

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

func NewUniqueTupleIterator(iterator1, iterator2 *TupleIterator) *UniqueTupleIterator

NewUniqueTupleIterator creates a new UniqueTupleIterator from two TupleIterators.

func (*UniqueTupleIterator) GetNext

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

GetNext returns the next unique Tuple from the two TupleIterators.

func (*UniqueTupleIterator) HasNext

func (i *UniqueTupleIterator) HasNext() bool

HasNext checks if there is a next Tuple in either of the two TupleIterators.