Versions in this module Expand all Collapse all v0 v0.0.1 Oct 25, 2020 Changes in this version + func Using(provider Provider) func(next actor.ReceiverFunc) actor.ReceiverFunc + type InMemoryProvider struct + func NewInMemoryProvider(snapshotInterval int) *InMemoryProvider + func (provider *InMemoryProvider) GetEvents(actorName string, eventIndexStart int, callback func(e interface{})) + func (provider *InMemoryProvider) GetSnapshot(actorName string) (snapshot interface{}, eventIndex int, ok bool) + func (provider *InMemoryProvider) GetSnapshotInterval() int + func (provider *InMemoryProvider) PersistEvent(actorName string, eventIndex int, event proto.Message) + func (provider *InMemoryProvider) PersistSnapshot(actorName string, eventIndex int, snapshot proto.Message) + func (provider *InMemoryProvider) Restart() + type Mixin struct + func (mixin *Mixin) Name() string + func (mixin *Mixin) PersistReceive(message proto.Message) + func (mixin *Mixin) PersistSnapshot(snapshot proto.Message) + func (mixin *Mixin) Recovering() bool + type OfferSnapshot struct + Snapshot interface{} + type Provider interface + GetState func() ProviderState + type ProviderState interface + GetEvents func(actorName string, eventIndexStart int, callback func(e interface{})) + GetSnapshot func(actorName string) (snapshot interface{}, eventIndex int, ok bool) + GetSnapshotInterval func() int + PersistEvent func(actorName string, eventIndex int, event proto.Message) + PersistSnapshot func(actorName string, eventIndex int, snapshot proto.Message) + Restart func() + type Replay struct + type ReplayComplete struct + type RequestSnapshot struct
Go to main page