cephbroker

Documentation

Index

• Constants
• Variables
• func New(logger lager.Logger, controller Controller, ...) *broker
• type BindResponse
• type Client
  • func NewCephClient(mds string, localMountPoint string, keyringFile string, remoteMountPath string) Client
  • func NewCephClientWithInvokerAndSystemUtil(mds string, useInvoker invoker.Invoker, os osshim.Os, ioutil ioutilshim.Ioutil, ...) Client
• type Controller
  • func NewController(cephClient Client) Controller

Constants

const (
	PermissionVolumeMount = brokerapi.RequiredPermission("volume_mount")
	DefaultContainerPath  = "/var/vcap/data"
)

const CellBasePath string = "/var/vcap/data/volumes/ceph/"

Variables

var (
	ShareNotFound   error = errors.New("share not found, internal error")
	KeyringNotFound error = errors.New("unable to open cephfs keyring")
)

Functions

func New

func New(
	logger lager.Logger, controller Controller,
	serviceName, serviceId, planName, planId, planDesc, dataDir string,
	ioutil ioutilshim.Ioutil,
) *broker

Types

type BindResponse

type BindResponse struct {
	voldriver.ErrorResponse
	SharedDevice brokerapi.SharedDevice
}

type Client

type Client interface {
	IsFilesystemMounted(voldriver.Env) bool
	MountFileSystem(voldriver.Env, string) (string, error)
	CreateShare(voldriver.Env, string) (string, error)
	DeleteShare(voldriver.Env, string) error
	GetPathsForShare(voldriver.Env, string) (string, string, error)
	GetConfigDetails(voldriver.Env) (string, string, error)
}

func NewCephClient

func NewCephClient(mds string, localMountPoint string, keyringFile string, remoteMountPath string) Client

func NewCephClientWithInvokerAndSystemUtil

func NewCephClientWithInvokerAndSystemUtil(mds string, useInvoker invoker.Invoker, os osshim.Os, ioutil ioutilshim.Ioutil, localMountPoint string, keyringFile string) Client

type Controller

type Controller interface {
	voldriver.Provisioner
	Bind(env voldriver.Env, instanceID string) BindResponse
}

func NewController

func NewController(cephClient Client) Controller