config

package

Go to main page

Versions in this module

v0

v0.3.0

Aug 19, 2016

Changes in this version

+ var PolicySchema = ...

+ var RuntimeSchema = ...

+ var VolumeSchema = ...

type Client

+ func (c *Client) CreatePolicyRevision(name string, policy string) error

+ func (c *Client) GetPolicyRevision(name, revision string) (string, error)

+ func (c *Client) IsVolumeInUse(cfg *Volume) (bool, error)

+ func (c *Client) ListPolicyRevisions(name string) ([]string, error)

+ func (c *Client) WatchForPolicyChanges(activity chan *watch.Watch)

type Policy

+ Backend string

+ func (cfg *Policy) ValidateJSON() error

type RuntimeOptions

+ func (cfg *RuntimeOptions) ValidateJSON() error

type Volume

+ func (cfg *Volume) ValidateJSON() error

+ type VolumeRequest struct

+ Name string

+ Options map[string]string

+ Policy string

+ func (v *VolumeRequest) String() string

v0.2.0

Jul 15, 2016

Changes in this version

type Global

+ func (global *Global) Canonical() *Global

+ func (global *Global) Published() *Global

+ func (global *Global) SetEmpty() *Global

v0.1.1

Jun 15, 2016

v0.1.0

Jun 11, 2016

Changes in this version

+ const DefaultGlobalTTL

+ const DefaultTimeout

+ var UseTypeMount = "mount"

+ var UseTypeSnapshot = "snapshot"

+ type BackendDrivers struct

+ CRUD string

+ Mount string

+ Snapshot string

+ type Client struct

+ func NewClient(prefix string, etcdHosts []string) (*Client, error)

+ func (c *Client) CreateVolume(rc Request) (*Volume, error)

+ func (c *Client) DeletePolicy(name string) error

+ func (c *Client) DumpTarball() (string, error)

+ func (c *Client) GetPolicy(name string) (*Policy, error)

+ func (c *Client) GetUse(ut UseLocker, vc *Volume) error

+ func (c *Client) GetVolume(policy, name string) (*Volume, error)

+ func (c *Client) GetVolumeRuntime(policy, name string) (RuntimeOptions, error)

+ func (c *Client) ListAllVolumes() ([]string, error)

+ func (c *Client) ListPolicies() ([]Policy, error)

+ func (c *Client) ListUses(typ string) ([]string, error)

+ func (c *Client) ListVolumes(policy string) (map[string]*Volume, error)

+ func (c *Client) PublishPolicy(name string, cfg *Policy) error

+ func (c *Client) PublishUse(ut UseLocker) error

+ func (c *Client) PublishUseWithTTL(ut UseLocker, ttl time.Duration, exist client.PrevExistType) error

+ func (c *Client) PublishVolume(vc *Volume) error

+ func (c *Client) PublishVolumeRuntime(vo *Volume, ro RuntimeOptions) error

+ func (c *Client) RemoveTakeSnapshot(name string) error

+ func (c *Client) RemoveUse(ut UseLocker, force bool) error

+ func (c *Client) RemoveVolume(policy, name string) error

+ func (c *Client) TakeSnapshot(name string) error

+ func (c *Client) WatchSnapshotSignal(activity chan *watch.Watch)

+ func (c *Client) WatchVolumeRuntimes(activity chan *watch.Watch)

+ func (tlc *Client) GetGlobal() (*Global, error)

+ func (tlc *Client) PublishGlobal(g *Global) error

+ func (tlc *Client) WatchGlobal(activity chan *watch.Watch)

+ type CreateOptions struct

+ FileSystem string

+ Size string

+ func (co *CreateOptions) ActualSize() (uint64, error)

+ type Global struct

+ Debug bool

+ MountPath string

+ TTL time.Duration

+ Timeout time.Duration

+ func NewGlobalConfig() *Global

+ func NewGlobalConfigFromJSON(content []byte) (*Global, error)

+ type Policy struct

+ Backends BackendDrivers

+ CreateOptions CreateOptions

+ DriverOptions map[string]string

+ FileSystems map[string]string

+ Name string

+ RuntimeOptions RuntimeOptions

+ Unlocked bool

+ func NewPolicy() *Policy

+ func (cfg *Policy) String() string

+ func (cfg *Policy) Validate() error

+ type RateLimitConfig struct

+ ReadBPS uint64

+ ReadIOPS uint

+ WriteBPS uint64

+ WriteIOPS uint

+ type Request struct

+ Options map[string]string

+ Policy string

+ Volume string

+ type RuntimeOptions struct

+ RateLimit RateLimitConfig

+ Snapshot SnapshotConfig

+ UseSnapshots bool

+ func (ro *RuntimeOptions) Validate() error

+ type SnapshotConfig struct

+ Frequency string

+ Keep uint

+ type UseLocker interface

+ GetReason func() string

+ GetVolume func() string

+ MayExist func() bool

+ Type func() string

+ type UseMount struct

+ Hostname string

+ Reason string

+ Volume string

+ func (um *UseMount) GetReason() string

+ func (um *UseMount) GetVolume() string

+ func (um *UseMount) MayExist() bool

+ func (um *UseMount) Type() string

+ type UseSnapshot struct

+ Reason string

+ Volume string

+ func (us *UseSnapshot) GetReason() string

+ func (us *UseSnapshot) GetVolume() string

+ func (us *UseSnapshot) MayExist() bool

+ func (us *UseSnapshot) Type() string

+ type Volume struct

+ Backends BackendDrivers

+ CreateOptions CreateOptions

+ DriverOptions map[string]string

+ MountSource string

+ PolicyName string

+ RuntimeOptions RuntimeOptions

+ Unlocked bool

+ VolumeName string

+ func (cfg *Volume) String() string

+ func (cfg *Volume) ToDriverOptions(timeout time.Duration) (storage.DriverOptions, error)

+ func (cfg *Volume) Validate() error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL