store

Documentation

Index

• Constants
• Variables
• type Bundle
  • func NewBundle(path string) *Bundle
  • func (bdl *Bundle) Path() string
  • func (bdl *Bundle) RootFSPath() string
• type Bundler
  • func NewBundler(snapshotDriver SnapshotDriver, storePath string) *Bundler
  • func (b *Bundler) Create(logger lager.Logger, id string, 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 Configurer
  • func NewConfigurer() *Configurer
  • func (c *Configurer) Ensure(logger lager.Logger, storePath string) error
• type SnapshotDriver

Constants

const BUNDLES_DIR_NAME = "bundles"

const CACHE_DIR_NAME = "cache"

const LOCKS_DIR_NAME = "locks"

const VOLUMES_DIR_NAME = "volumes"

Variables

var OF = os.OpenFile

Types

type Bundle

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

func NewBundle

func NewBundle(path string) *Bundle

func (*Bundle) Path

func (bdl *Bundle) Path() string

func (*Bundle) RootFSPath

func (bdl *Bundle) RootFSPath() string

type Bundler

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

func NewBundler

func NewBundler(snapshotDriver SnapshotDriver, storePath string) *Bundler

func (*Bundler) Create

func (b *Bundler) Create(logger lager.Logger, id string, 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 Configurer

type Configurer struct {
}

func NewConfigurer

func NewConfigurer() *Configurer

func (*Configurer) Ensure

func (c *Configurer) Ensure(logger lager.Logger, storePath string) 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
}