docker

Documentation

Index

• type Config
• type Driver
  • func New(config Config) Driver
  • func (d Driver) Create(r volume.Request) volume.Response
  • func (d Driver) Get(r volume.Request) volume.Response
  • func (d Driver) List(r volume.Request) volume.Response
  • func (d Driver) Mount(r volume.Request) volume.Response
  • func (d Driver) Path(r volume.Request) volume.Response
  • func (d Driver) Remove(r volume.Request) volume.Response
  • func (d Driver) Stop() []error
  • func (d Driver) Unmount(r volume.Request) volume.Response
• type Server
  • func NewServer(config *api.Config, mountpoint, token, root string) (*Server, error)
  • func (s *Server) Mount() error
  • func (s *Server) Unmount() error

Types

type Config

type Config struct {
	// Root for mount
	Root string

	// Token and config for Vault
	Token string
	Vault *api.Config
}

Config configures the docker volume plugin

type Driver

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

Driver implements the interface for a Docker volume plugin

func New

func New(config Config) Driver

New instantiates a new driver and returns it

func (Driver) Create

func (d Driver) Create(r volume.Request) volume.Response

Create handles volume creation calls

func (Driver) Get

func (d Driver) Get(r volume.Request) volume.Response

Get retrieves a volume

func (Driver) List

func (d Driver) List(r volume.Request) volume.Response

List mounted volumes

func (Driver) Mount

func (d Driver) Mount(r volume.Request) volume.Response

Mount handles creating and mounting servers

func (Driver) Path

func (d Driver) Path(r volume.Request) volume.Response

Path handles calls for mountpoints

func (Driver) Remove

func (d Driver) Remove(r volume.Request) volume.Response

Remove handles volume removal calls

func (Driver) Stop

func (d Driver) Stop() []error

Stop stops all the servers

func (Driver) Unmount

func (d Driver) Unmount(r volume.Request) volume.Response

Unmount handles unmounting (but not removing) servers

type Server

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

Server wraps VaultFS and tracks connection counts

func NewServer

func NewServer(config *api.Config, mountpoint, token, root string) (*Server, error)

NewServer returns a new server with initial state

func (*Server) Mount

func (s *Server) Mount() error

Mount mounts the wrapped FS on a given mountpoint. It also starts watching for errors, which it will log.

func (*Server) Unmount

func (s *Server) Unmount() error

Unmount stops the wrapped FS. It returns the last error that it sees, but will log any others it receives.