memory

Documentation

Index

• Constants
• func NewStore(system *actor.ActorSystem, uri *url.URL) (persistence2.Store, error)
• type Store
  • 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) (*persistencev1.SnapshotRecord, 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()

Constants

const DBName = "memory"

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 (s *Store) DeleteEvents(_ string, _ int)

func (*Store) DeleteSnapshots

func (s *Store) DeleteSnapshots(_ string, _ int)

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) (*persistencev1.SnapshotRecord, error)

func (*Store) GetSnapshotInterval

func (s *Store) GetSnapshotInterval() int

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) Restart

func (s *Store) Restart()