persistence

Documentation

Index

• func GetDBName(parsedURI *url.URL) (db string, err error)
• func GetPath(parsedURI *url.URL) (path string, err error)
• func GetSnapshotInterval(parsedURI *url.URL) (snapshotInterval int, err error)
• type Store
• type URI

Functions

func GetDBName

func GetDBName(parsedURI *url.URL) (db string, err error)

GetDBName returns the database name from the given URI. If no database name is specified, "memory" is returned. Example: "db:bbolt:./my-db?snapshotInterval=3" returns "bbolt".

func GetPath

func GetPath(parsedURI *url.URL) (path string, err error)

func GetSnapshotInterval

func GetSnapshotInterval(parsedURI *url.URL) (snapshotInterval int, err error)

Types

type Store

type Store interface {
	GetSnapshot(actorName string) (snapshot *persistencev1.SnapshotRecord, err error)
	PersistSnapshot(actorName string, snapshot *persistencev1.SnapshotRecord)
	DeleteSnapshots(actorName string, inclusiveToIndex int)
	GetEvents(actorName string, eventIndexStart int, eventIndexEnd int, callback func(e *persistencev1.EventRecord))
	PersistEvent(actorName string, event *persistencev1.EventRecord)
	DeleteEvents(actorName string, inclusiveToIndex int)
	Restart()
	GetSnapshotInterval() int
}

Store is the interface that wraps the basic persistence operations.

type URI

type URI string