walship

type DirSink struct{ Dir string }

type RestoreResult struct {
	Generation int
	Epochs     int
	FrameBytes int64
	// Truncated is true when a missing segment stopped replay early.
	Truncated bool
}

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

type Sink interface {
	Put(name string, r io.Reader) error
	Get(name string) (io.ReadCloser, error)
	List(prefix string) ([]string, error)
}

type Stats struct {
	Generations   int
	Segments      int
	SnapshotBytes int64
	SegmentBytes  int64
	FrameBytes    int64
	Checkpoints   int
}