snapshot

Documentation

Index

• Variables
• type NatsDBSnapshot
  • func NewNatsDBSnapshot(d *db.SqliteStreamDB, snapshotStorage Storage) *NatsDBSnapshot
  • func (n *NatsDBSnapshot) RestoreSnapshot() error
  • func (n *NatsDBSnapshot) SaveSnapshot() error
• type NatsSnapshot
• type Storage
  • func NewSnapshotStorage() (Storage, error)

Variables

var ErrInvalidStorageType = errors.New("invalid snapshot storage type")

var ErrNoSnapshotFound = errors.New("no snapshot found")

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

var ErrRequiredParameterMissing = errors.New("required parameter missing")

Types

type NatsDBSnapshot

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

func NewNatsDBSnapshot

func NewNatsDBSnapshot(d *db.SqliteStreamDB, snapshotStorage Storage) *NatsDBSnapshot

func (*NatsDBSnapshot) RestoreSnapshot

func (n *NatsDBSnapshot) RestoreSnapshot() error

func (*NatsDBSnapshot) SaveSnapshot

func (n *NatsDBSnapshot) SaveSnapshot() error

type NatsSnapshot

type NatsSnapshot interface {
	SaveSnapshot() error
	RestoreSnapshot() error
}

type Storage

type Storage interface {
	Upload(name, filePath string) error
	Download(filePath, name string) error
}

func NewSnapshotStorage

func NewSnapshotStorage() (Storage, error)