walship

type Bucket interface {
	Put(ctx context.Context, key string, body io.ReadSeeker, contentType, contentEncoding string) error
	Get(ctx context.Context, key string) (io.ReadCloser, int64, error)
	List(ctx context.Context, prefix, token string, limit int32) (ListPage, error)
}

type DirSink struct{ Dir string }

type ListPage struct {
	Keys []string
	Next string
}

type ObjectSink struct {
	Bucket     Bucket
	Prefix     string
	Recipients []age.Recipient
	Identities []age.Identity
	// Timeout bounds each call; zero means DefaultObjectTimeout.
	Timeout time.Duration
	// TempDir holds ciphertext while uploading; empty uses the OS default.
	TempDir string
}

type Reader struct{ Sink Sink }

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

type Segment struct {
	Name       string
	Generation int
	Seq        uint32
	Offset     int64
}

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
}