ent

package module

Go to main page

Versions in this module

v0

v0.2.11

Nov 21, 2020

Changes in this version

+ func GetFieldValue(e Ent, fieldIndex int) reflect.Value

type EntBase

+ func (e *EntBase) ClearEntFieldChanged(fieldIndex int)

+ func (e *EntBase) EntPendingFields() FieldSet

+ func (e *EntBase) IsEntFieldChanged(fieldIndex int) bool

+ func (e *EntBase) SetEntFieldChanged(fieldIndex int)

v0.2.10

Nov 21, 2020

v0.2.9

Nov 21, 2020

Changes in this version

type Storage

+ func GetStorage(e Ent) Storage

v0.2.8

Nov 19, 2020

Changes in this version

+ const Reverse

+ func DeleteAllEntsOfType(s Storage, prototype Ent) error

+ func FindIdByIndex(s Storage, entTypeName string, x *EntIndex, flags []LookupFlags, nfields int, ...) (uint64, error)

+ func FindIdByIndexKey(s Storage, entTypeName string, x *EntIndex, key []byte, flags []LookupFlags) (uint64, error)

+ func FindIdsByIndex(s Storage, entTypeName string, x *EntIndex, limit int, flags []LookupFlags, ...) ([]uint64, error)

+ func FindIdsByIndexKey(s Storage, entTypeName string, x *EntIndex, key []byte, limit int, ...) ([]uint64, error)

+ func SetEntBaseFields(e Ent, s Storage, id, version uint64, changes FieldSet)

type Ent

+ func LoadEntsByIndexKey(s Storage, e Ent, x *EntIndex, key []byte, limit int, flags []LookupFlags) ([]Ent, error)

+ type EntIterator interface

+ Err func() error

+ Next func(e Ent) bool

+ type FieldSet uint64

+ func (f FieldSet) Contains(other FieldSet) bool

+ func (f FieldSet) Has(fieldIndex int) bool

+ func (f FieldSet) Len() int

+ func (f FieldSet) Union(other FieldSet) FieldSet

+ func (f FieldSet) With(fieldIndex int) FieldSet

+ func (f FieldSet) Without(fieldIndex int) FieldSet

+ type IdIterator interface

+ Err func() error

+ Next func(id *uint64) bool

+ type LookupFlags int

type Storage

+ Create func(e Ent, fields FieldSet) (id uint64, err error)

+ Delete func(e Ent, id uint64) error

+ FindByIndex func(entType string, x *EntIndex, key []byte, limit int, fl LookupFlags) ([]uint64, error)

+ IterateEnts func(proto Ent) EntIterator

+ IterateIds func(entType string) IdIterator

+ LoadById func(e Ent, id uint64) (version uint64, err error)

+ LoadByIndex func(e Ent, x *EntIndex, key []byte, limit int, fl LookupFlags) ([]Ent, error)

+ Save func(e Ent, fields FieldSet) (version uint64, err error)

v0.2.7

Nov 16, 2020

v0.2.6

Nov 16, 2020

Changes in this version

+ var ErrUniqueConflict = errors.New("unique index conflict")

+ type IndexConflictErr struct

+ EntTypeName string

+ IndexName string

+ Underlying error

+ func (e *IndexConflictErr) Error() string

+ func (e *IndexConflictErr) Unwrap() error

v0.2.5

Nov 16, 2020

v0.2.4

Nov 16, 2020

v0.2.3

Nov 16, 2020

v0.2.2

Nov 16, 2020

v0.2.1

Nov 16, 2020

v0.2.0

Nov 16, 2020

Changes in this version

+ const ReprOmitEmpty

+ var ErrNotChanged = errors.New("ent not changed")

+ func EntString(e Ent) string

+ func FieldsWithEmptyValue(e Ent) uint64

+ func JsonDecodeEnt(e Ent, data []byte) (id, version uint64, err error)

+ func JsonDecodeEntPartial(e Ent, data []byte, fields uint64) (version uint64, err error)

+ func JsonEncodeEnt(e Ent, id, version, fieldmap uint64, indent string) ([]byte, error)

+ func Repr(e Ent, fieldmap uint64, flags ReprFlags) ([]byte, error)

type Ent

+ EntDecodePartial func(c Decoder, fields uint64) (version uint64)

+ EntFields func() Fields

type EntBase

+ func (e *EntBase) EntFields() Fields

type EntIndex

+ func (x EntIndex) IsUnique() bool

+ type Fields struct

+ Fieldmap uint64

+ Names []string

+ type IdSet []uint64

+ func ParseIdSet(data []byte) IdSet

+ func (s *IdSet) Add(id uint64)

+ func (s *IdSet) Del(id uint64)

+ func (s IdSet) Encode() []byte

+ func (s IdSet) Has(id uint64) bool

+ func (s IdSet) Sort()

type JsonEncoder

+ BareKeys bool

+ func (e *JsonEncoder) Key(k string)

+ type ReprFlags int

type StorageIndexEdit

+ func ComputeIndexEdits(indexGet IndexGetter, nextEnt, prevEnt Ent, id, changedFields uint64) ([]StorageIndexEdit, error)

v0.1.0

Nov 13, 2020

Changes in this version

+ const EntIndexUnique

+ var ErrDuplicateEnt = errors.New("duplicate ent")

+ var ErrNoStorage = errors.New("no ent storage")

+ var ErrNotFound = errors.New("ent not found")

+ var ErrVersionConflict = errors.New("version conflict")

+ var FieldNameId = "_id"

+ var FieldNameVersion = "_ver"

+ func ClearFieldChanged(e *EntBase, fieldIndex int)

+ func CreateEnt(e Ent, storage Storage) error

+ func DeleteEnt(e Ent) error

+ func FindEntIdByIndex(s Storage, entTypeName, indexName string, keyEncoder func(Encoder)) (uint64, error)

+ func FindEntIdByIndexKey(s Storage, entTypeName, indexName string, key []byte) (uint64, error)

+ func FindEntIdsByIndex(s Storage, entTypeName, indexName string, nfields int, ...) ([]uint64, error)

+ func IsFieldChanged(e *EntBase, fieldIndex int) bool

+ func JsonDecode(e Ent, data []byte) error

+ func JsonEncode(e Ent) ([]byte, error)

+ func JsonEncodeUnsaved(e Ent) ([]byte, error)

+ func LoadEntById(e Ent, storage Storage, id uint64) error

+ func LoadEntByIndex(s Storage, e Ent, indexName string, keyEncoder func(Encoder)) error

+ func LoadEntByIndexKey(s Storage, e Ent, indexName string, key []byte) error

+ func ReloadEnt(e Ent) error

+ func SaveEnt(e Ent) error

+ func SetEntBaseFieldsAfterLoad(e Ent, s Storage, id, version uint64)

+ func SetFieldChanged(e *EntBase, fieldIndex int)

+ type Buffer []byte

+ func NewBuffer(initcap int) Buffer

+ func (b *Buffer) Grow(n int) int

+ func (b *Buffer) Reserve(n int)

+ func (b *Buffer) Reset()

+ func (b *Buffer) Write(data []byte) int

+ func (b *Buffer) WriteByte(v byte)

+ func (b *Buffer) WriteString(s string)

+ func (b Buffer) Bytes() []byte

+ func (b Buffer) DenseBytes(densityThreshold float64) []byte

+ type Decoder interface

+ Blob func() []byte

+ Bool func() bool

+ DictHeader func() int

+ Discard func()

+ Err func() error

+ Float func(bitsize int) float64

+ Int func(bitsize int) int64

+ Key func() string

+ ListHeader func() int

+ More func() bool

+ Str func() string

+ Uint func(bitsize int) uint64

+ type Encoder interface

+ BeginDict func(length int)

+ BeginEnt func(version uint64)

+ BeginList func(length int)

+ Blob func(v []byte)

+ Bool func(v bool)

+ EndDict func()

+ EndEnt func()

+ EndList func()

+ Err func() error

+ Float func(v float64, bitsize int)

+ Int func(v int64, bitsize int)

+ Key func(k string)

+ Str func(v string)

+ Uint func(v uint64, bitsize int)

+ type Ent interface

+ EntDecode func(c Decoder) (id, version uint64)

+ EntDecodeIndexed func(c Decoder, fields uint64) (version uint64)

+ EntEncode func(c Encoder, fieldmap uint64)

+ EntIndexes func() []EntIndex

+ EntNew func() Ent

+ EntTypeName func() string

+ HasUnsavedChanges func() bool

+ Id func() uint64

+ Version func() uint64

+ func LoadEntsByIndex(s Storage, e Ent, indexName string, nfields int, keyEncoder func(Encoder)) ([]Ent, error)

+ type EntBase struct

+ func (e *EntBase) EntDecode(c Decoder) (id, version uint64)

+ func (e *EntBase) EntEncode(Encoder, uint64)

+ func (e *EntBase) EntIndexes() []EntIndex

+ func (e *EntBase) EntIsFieldChanged(fieldIndex int) bool

+ func (e *EntBase) EntTypeName() string

+ func (e *EntBase) HasUnsavedChanges() bool

+ func (e *EntBase) Id() uint64

+ func (e *EntBase) Version() uint64

+ type EntIndex struct

+ Fields uint64

+ Flags EntIndexFlag

+ Name string

+ type EntIndexFlag int

+ type EntType struct

+ Name string

+ Type reflect.Type

+ func EntTypeByName(typename string) *EntType

+ func Register(e Ent) *EntType

+ func TypeOf(e Ent) *EntType

+ type Id uint64

+ type IndexGetter = func(entTypeName, indexName, key string) ([]uint64, error)

+ type IndexKeyEncoder struct

+ func (c *IndexKeyEncoder) BeginDict(length int)

+ func (c *IndexKeyEncoder) BeginEnt(version uint64)

+ func (c *IndexKeyEncoder) BeginList(length int)

+ func (c *IndexKeyEncoder) Blob(v []byte)

+ func (c *IndexKeyEncoder) Bool(v bool)

+ func (c *IndexKeyEncoder) EncodeKey(e Ent, fieldmap uint64) ([]byte, error)

+ func (c *IndexKeyEncoder) EndDict()

+ func (c *IndexKeyEncoder) EndEnt()

+ func (c *IndexKeyEncoder) EndList()

+ func (c *IndexKeyEncoder) Err() error

+ func (c *IndexKeyEncoder) Float(v float64, bitsize int)

+ func (c *IndexKeyEncoder) Int(v int64, bitsize int)

+ func (c *IndexKeyEncoder) Key(k string)

+ func (c *IndexKeyEncoder) Reset(nfields int)

+ func (c *IndexKeyEncoder) Str(v string)

+ func (c *IndexKeyEncoder) Uint(v uint64, bitsize int)

+ type JsonDecoder struct

+ func NewJsonDecoder(data []byte) *JsonDecoder

+ func (c *JsonDecoder) DictHeader() int

+ func (c *JsonDecoder) ListHeader() int

+ type JsonEncoder struct

+ func (c *JsonEncoder) BeginDict(length int)

+ func (c *JsonEncoder) BeginEnt(version uint64)

+ func (c *JsonEncoder) BeginList(length int)

+ func (c *JsonEncoder) EndDict()

+ func (c *JsonEncoder) EndEnt()

+ func (c *JsonEncoder) EndList()

+ func (c *JsonEncoder) Err() error

+ type JsonError struct

+ Underlying error

+ func (e *JsonError) Error() string

+ func (e *JsonError) Unwrap() error

+ type MemoryStorage struct

+ func NewMemoryStorage() *MemoryStorage

+ func (s *MemoryStorage) CreateEnt(e Ent, fieldmap uint64) (id uint64, err error)

+ func (s *MemoryStorage) DeleteEnt(e Ent) error

+ func (s *MemoryStorage) FindEntIdsByIndex(entTypeName, indexName string, key []byte) ([]uint64, error)

+ func (s *MemoryStorage) LoadEntById(e Ent, id uint64) (version uint64, err error)

+ func (s *MemoryStorage) LoadEntsByIndex(e Ent, indexName string, key []byte) ([]Ent, error)

+ func (s *MemoryStorage) SaveEnt(e Ent, fieldmap uint64) (nextVersion uint64, err error)

+ type Storage interface

+ CreateEnt func(e Ent, fieldmap uint64) (id uint64, err error)

+ DeleteEnt func(e Ent) error

+ FindEntIdsByIndex func(entTypeName, indexName string, key []byte) (ids []uint64, err error)

+ LoadEntById func(e Ent, id uint64) (version uint64, err error)

+ LoadEntsByIndex func(e Ent, indexName string, key []byte) ([]Ent, error)

+ SaveEnt func(e Ent, fieldmap uint64) (version uint64, err error)

+ type StorageIndexEdit struct

+ Index *EntIndex

+ IsCleanup bool

+ Key string

+ Value []uint64

+ func CalcStorageIndexEdits(indexGet IndexGetter, nextEnt, prevEnt Ent, id, changedFields uint64) ([]StorageIndexEdit, error)

+ type VersionConflictErr struct

+ ActualVersion uint64

+ ExpectedVersion uint64

+ Underlying error

+ func NewVersionConflictErr(expectedVersion, actualVersion uint64) *VersionConflictErr

+ func (e *VersionConflictErr) Error() string

+ func (e *VersionConflictErr) Unwrap() error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL