aggregate

Oct 6, 2021

Changes in this version

+ var AlreadyFinalized = errors.MakeExternalError("group has already been finalized", "GROUP-STORE", nil, nil)

+ var AlreadyInitialized = errors.MakeExternalError("group has already been initialized", "GROUP-STORE", nil, nil)

+ var NotFound = errors.MakeExternalError("group not found", "GROUP-STORE", nil, nil)

+ type Function interface

+ Add func(item *kodex.Item, group Group) error

+ Finalize func(group Group) (interface{}, error)

+ Initialize func(group Group) error

+ Merge func(group []Group) (Group, error)

+ type Group interface

+ Clone func() (Group, error)

+ Expiration func() int64

+ GroupByValues func() map[string]interface{}

+ Hash func() []byte

+ Initialize func(state State) error

+ Initialized func() bool

+ Lock func()

+ State func() State

+ Unlock func()

+ type GroupStore interface

+ ExpireAllGroups func() (map[string][]Group, error)

+ ExpireGroups func(expiration int64) (map[string][]Group, error)

+ Reset func() error

+ Shard func() (Shard, error)

+ Teardown func() error

+ type Shard interface

+ Commit func() error

+ CreateGroup func(hash []byte, groupByValues map[string]interface{}, expiration int64) (Group, error)

+ ExpireAllGroups func() ([]Group, error)

+ ExpireGroups func(expiration int64) ([]Group, error)

+ GroupByHash func(hash []byte) (Group, error)

+ ID func() interface{}

+ Return func() error

+ type State interface

+ Clone func() (State, error)

+ Deserialize func([]byte) error

+ Serialize func() ([]byte, error)