command

Apr 25, 2023

Changes in this version

type Command

+ GetChangeContext func() *change.Context

type CreateEntityCommand

+ Context *change.Context

+ func (self *CreateEntityCommand[T]) GetChangeContext() *change.Context

type DeleteEntityCommand

+ Context *change.Context

+ func (self *DeleteEntityCommand) GetChangeContext() *change.Context

type SyncSnapshotCommand

+ func (self *SyncSnapshotCommand) GetChangeContext() *change.Context

type UpdateEntityCommand

+ Context *change.Context

+ func (self *UpdateEntityCommand[T]) GetChangeContext() *change.Context

Feb 20, 2023

Changes in this version

type Dispatcher

+ GetPeers func() map[string]channel.Channel

type LocalDispatcher

+ func (self *LocalDispatcher) GetPeers() map[string]channel.Channel

Jan 4, 2023

Changes in this version

type Dispatcher

+ IsLeaderOrLeaderless func() bool

type LocalDispatcher

+ func (self *LocalDispatcher) IsLeaderOrLeaderless() bool

Aug 22, 2022

Changes in this version

+ type SyncSnapshotCommand struct

+ Snapshot []byte

+ SnapshotId string

+ SnapshotSink func(cmd *SyncSnapshotCommand) error

+ func (self *SyncSnapshotCommand) Apply() error

+ func (self *SyncSnapshotCommand) Encode() ([]byte, error)

Aug 15, 2022

Changes in this version

type LocalDispatcher

+ EncodeDecodeCommands bool

Jul 29, 2022

Changes in this version

type CreateEntityCommand

+ Flags uint32

type UpdateEntityCommand

+ Flags uint32

Jun 3, 2022

Changes in this version

+ type Command interface

+ Apply func() error

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

+ type CreateEntityCommand struct

+ Creator EntityCreator[T]

+ Entity T

+ PostCreateHook func(tx *bbolt.Tx, entity T) error

+ func (self *CreateEntityCommand[T]) Apply() error

+ func (self *CreateEntityCommand[T]) Encode() ([]byte, error)

+ type Decoder interface

+ Decode func(commandType int32, data []byte) (Command, error)

+ type DecoderF func(commandType int32, data []byte) (Command, error)

+ func (self DecoderF) Decode(commandType int32, data []byte) (Command, error)

+ type Decoders interface

+ Clear func()

+ Decode func(data []byte) (Command, error)

+ GetDecoder func(id int32) Decoder

+ Register func(id int32, decoder Decoder)

+ RegisterF func(id int32, decoder DecoderF)

+ func GetDefaultDecoders() Decoders

+ func NewDecoders() Decoders

+ type DeleteEntityCommand struct

+ Deleter EntityDeleter

+ Id string

+ func (self *DeleteEntityCommand) Apply() error

+ func (self *DeleteEntityCommand) Encode() ([]byte, error)

+ type Dispatcher interface

+ Dispatch func(command Command) error

+ type EntityCreator interface

+ ApplyCreate func(cmd *CreateEntityCommand[T]) error

+ type EntityDeleter interface

+ ApplyDelete func(cmd *DeleteEntityCommand) error

+ GetEntityTypeId func() string

+ type EntityManager interface

+ type EntityMarshaller interface

+ GetEntityTypeId func() string

+ Marshall func(entity T) ([]byte, error)

+ Unmarshall func(bytes []byte) (T, error)

+ type EntityUpdater interface

+ ApplyUpdate func(cmd *UpdateEntityCommand[T]) error

+ type LocalDispatcher struct

+ func (LocalDispatcher) Dispatch(command Command) error

+ type UpdateEntityCommand struct

+ Entity T

+ UpdatedFields boltz.UpdatedFields

+ Updater EntityUpdater[T]

+ func (self *UpdateEntityCommand[T]) Apply() error

+ func (self *UpdateEntityCommand[T]) Encode() ([]byte, error)

+ type Validatable interface

+ Validate func() error