Documentation ¶
Index ¶
- type Boltdb
- func (provider *Boltdb) DeleteEvents(actorName string, inclusiveToIndex int)
- func (db *Boltdb) DeleteSnapshots(actorName string, inclusiveToIndex int)
- func (provider *Boltdb) GetEvents(actorName string, eventIndexStart, eventIndexEnd int, ...)
- func (provider *Boltdb) GetSnapshot(actorName string) (interface{}, int, bool)
- func (provider *Boltdb) GetSnapshotInterval() int
- func (provider *Boltdb) PersistEvent(actorName string, eventIndex int, event proto.Message)
- func (provider *Boltdb) PersistSnapshot(actorName string, eventIndex int, snapshot proto.Message)
- func (provider *Boltdb) Restart()
- type ParseMessage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Boltdb ¶
type Boltdb struct {
// contains filtered or unexported fields
}
Boltdb struct provider
func NewBoltdbProvider ¶
func NewBoltdbProvider(path string, snapshotInterval int, eventFunc ParseMessage, snapFunc ParseMessage) (*Boltdb, error)
NewBoltdbProvider create a provider for multiples actors. Only one instance is support in runtime
func (*Boltdb) DeleteEvents ¶
func (*Boltdb) DeleteSnapshots ¶
func (*Boltdb) GetEvents ¶
func (provider *Boltdb) GetEvents(actorName string, eventIndexStart, eventIndexEnd int, callback func(e interface{}))
GetEvents get events for actor from eventIndexStart
func (*Boltdb) GetSnapshot ¶
GetSnapshot get last snapshot in provider for actor
func (*Boltdb) GetSnapshotInterval ¶
GetSnapshotInterval get snapshot interval in provider
func (*Boltdb) PersistEvent ¶
PersistEvent persiste event
func (*Boltdb) PersistSnapshot ¶
PersistSnapshot save snapshot, the snapshot is overwrite
type ParseMessage ¶
Click to show internal directories.
Click to hide internal directories.