snapshot

package

v0.6.0 Latest Latest Go to latest Published: Oct 18, 2022 License: MIT Imports: 12 Imported by: 0

Details

View Source

const FileName = "snapshot.db"

View Source

const HashHeaderKey = "marmot-snapshot-tag"

View Source

const TempDirPattern = "marmot-snapshot-*"

View Source

var ErrInvalidSnapshot = errors.New("invalid snapshot")

View Source

var ErrPendingSnapshot = errors.New("system busy capturing snapshot")

This section is empty.

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

func NewNatsDBSnapshot(d *db.SqliteStreamDB) *NatsDBSnapshot

func (n *NatsDBSnapshot) RestoreSnapshot(conn *nats.Conn) error

func (n *NatsDBSnapshot) SaveSnapshot(conn *nats.Conn) error

type NatsSnapshot interface {
	SaveSnapshot(nats *nats.Conn) error
	RestoreSnapshot(nats *nats.Conn) error
}