bundler

Documentation

Index

• Variables
• type Bundler
  • func NewBundler(snapshotDriver SnapshotDriver, storePath string) *Bundler
  • func (b *Bundler) BundleIDs(logger lager.Logger) ([]string, error)
  • func (b *Bundler) Create(logger lager.Logger, spec groot.BundleSpec) (groot.Bundle, error)
  • func (b *Bundler) Destroy(logger lager.Logger, id string) error
  • func (b *Bundler) Exists(id string) (bool, error)
  • func (b *Bundler) Metrics(logger lager.Logger, id string) (groot.VolumeMetrics, error)
• type SnapshotDriver

Variables

var OF = os.OpenFile

Types

type Bundler

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

func NewBundler

func NewBundler(snapshotDriver SnapshotDriver, storePath string) *Bundler

func (*Bundler) BundleIDs

func (b *Bundler) BundleIDs(logger lager.Logger) ([]string, error)

func (*Bundler) Create

func (b *Bundler) Create(logger lager.Logger, spec groot.BundleSpec) (groot.Bundle, error)

func (*Bundler) Destroy

func (b *Bundler) Destroy(logger lager.Logger, id string) error

func (*Bundler) Exists

func (b *Bundler) Exists(id string) (bool, error)

func (*Bundler) Metrics

func (b *Bundler) Metrics(logger lager.Logger, id string) (groot.VolumeMetrics, error)

type SnapshotDriver

type SnapshotDriver interface {
	Snapshot(logger lager.Logger, fromPath, toPath string) error
	ApplyDiskLimit(logger lager.Logger, path string, diskLimit int64, exclusive bool) error
	FetchMetrics(logger lager.Logger, path string) (groot.VolumeMetrics, error)
	Destroy(logger lager.Logger, path string) error
}