database

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

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)
}

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)
}

type Engine string

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

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

type Option func(*Pagination)

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

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

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

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

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