snapshot

type CocoonRunner interface {
	Export(ctx context.Context, name string) (io.ReadCloser, func() error, error)
	Import(ctx context.Context, opts ImportOptions) (io.WriteCloser, func() error, error)
}

type Downloader interface {
	GetManifest(ctx context.Context, name, tag string) ([]byte, string, error)
	GetBlob(ctx context.Context, name, digest string) (io.ReadCloser, error)
}

type ExecCocoon struct {
	Binary string
	Stderr io.Writer
}

type ImportOptions struct {
	Name        string
	Description string
}

type PullOptions struct {
	Name        string
	Tag         string
	LocalName   string // overrides cocoon-side snapshot name; empty = use Name
	Description string
	Progress    func(string)
}

type Puller struct {
	Downloader Downloader
	Cocoon     CocoonRunner
}

type PushOptions struct {
	Name      string
	Tag       string
	BaseImage string // optional cocoonstack.snapshot.baseimage annotation
	Source    string
	Revision  string
	Progress  func(string)
}

type PushResult struct {
	Name           string
	Tag            string
	ManifestDigest string // sha256:<hex>
	ManifestBytes  []byte
	TotalSize      int64
	LayerCount     int
}

type Pusher struct {
	Uploader Uploader
	Cocoon   CocoonRunner
}

type StreamOptions struct {
	Name      string
	LocalName string // empty = use Name
	Writer    io.Writer
	Progress  func(string)
}

type Uploader interface {
	BlobExists(ctx context.Context, name, digest string) (bool, error)
	PutBlob(ctx context.Context, name, digest string, body io.Reader, size int64) error
	PutManifest(ctx context.Context, name, tag string, data []byte, contentType string) error
}