Documentation
¶
Index ¶
- Constants
- Variables
- func NewStore(system *actor.ActorSystem, uri *url.URL) (persistence2.Store, error)
- type Store
- func (s *Store) Close() error
- func (s *Store) DeleteEvents(_ string, _ int)
- func (s *Store) DeleteSnapshots(_ string, _ int)
- func (s *Store) GetEvents(actorName string, eventIndexStart int, eventIndexEnd int, ...)
- func (s *Store) GetSnapshot(actorName string) (record *persistencev1.SnapshotRecord, err error)
- func (s *Store) GetSnapshotInterval() int
- func (s *Store) PersistEvent(actorName string, record *persistencev1.EventRecord)
- func (s *Store) PersistSnapshot(actorName string, record *persistencev1.SnapshotRecord)
- func (s *Store) Restart()
- func (s *Store) Subscribe(pid *actor.PID, last *string, predicate stream.EventPredicate) stream.SubscriptionID
- func (s *Store) Unsubscribe(_ stream.SubscriptionID)
Constants ¶
View Source
const DBName = "bbolt"
Variables ¶
View Source
var ErrNotFound = fmt.Errorf("not found")
Functions ¶
func NewStore ¶
func NewStore(system *actor.ActorSystem, uri *url.URL) (persistence2.Store, error)
Types ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
func (*Store) DeleteEvents ¶
func (*Store) DeleteSnapshots ¶
func (*Store) GetEvents ¶
func (s *Store) GetEvents(actorName string, eventIndexStart int, eventIndexEnd int, callback func(e *persistencev1.EventRecord))
func (*Store) GetSnapshot ¶
func (s *Store) GetSnapshot(actorName string) (record *persistencev1.SnapshotRecord, err error)
func (*Store) GetSnapshotInterval ¶
func (*Store) PersistEvent ¶
func (s *Store) PersistEvent(actorName string, record *persistencev1.EventRecord)
func (*Store) PersistSnapshot ¶
func (s *Store) PersistSnapshot(actorName string, record *persistencev1.SnapshotRecord)
func (*Store) Subscribe ¶
func (s *Store) Subscribe(pid *actor.PID, last *string, predicate stream.EventPredicate) stream.SubscriptionID
func (*Store) Unsubscribe ¶
func (s *Store) Unsubscribe(_ stream.SubscriptionID)
Source Files
Click to show internal directories.
Click to hide internal directories.