persistence

type EventStore interface {
	GetEvents(actorName string, eventIndexStart int, eventIndexEnd int, callback func(e interface{}))
	PersistEvent(actorName string, eventIndex int, event proto.Message)
	DeleteEvents(actorName string, inclusiveToIndex int)
}

type InMemoryProvider struct {
	// contains filtered or unexported fields
}

type Mixin struct {
	// contains filtered or unexported fields
}

type OfferSnapshot struct {
	Snapshot interface{}
}

type Provider interface {
	GetState() ProviderState
}

type ProviderState interface {
	SnapshotStore
	EventStore

	Restart()
	GetSnapshotInterval() int
}

type Replay struct{}

type ReplayComplete struct{}

type RequestSnapshot struct{}

type SnapshotStore interface {
	GetSnapshot(actorName string) (snapshot interface{}, eventIndex int, ok bool)
	PersistSnapshot(actorName string, snapshotIndex int, snapshot proto.Message)
	DeleteSnapshots(actorName string, inclusiveToIndex int)
}