snapshot

type FileRestore struct {
	Options RestoreOptions
	// contains filtered or unexported fields
}

type FileSnapshot struct {
	Options SnapshotOptions
	// contains filtered or unexported fields
}

type Restore interface {
	// Init validates the RestoreOptions and returns an error if they are invalid.
	// Init must be called before a Restore is used
	Init(opts ...RestoreOption) error
	// Start opens a channel over which records from the snapshot are retrieved.
	// The channel will be closed when the entire snapshot has been read.
	Start() (<-chan *store.Record, error)
}

type RestoreOption func(r *RestoreOptions)

type RestoreOptions struct {
	Source string
}

type Snapshot interface {
	// Init validates the Snapshot options and returns an error if they are invalid.
	// Init must be called before the Snapshot is used
	Init(opts ...SnapshotOption) error
	// Start opens a channel that receives *store.Record, adding any incoming records to a backup
	// close() the channel to commit the results.
	Start() (chan<- *store.Record, error)
	// Wait waits for any operations to be committed to underlying storage
	Wait()
}

type SnapshotOption func(s *SnapshotOptions)

type SnapshotOptions struct {
	Destination string
}