api

Documentation

Index

• Variables
• func ConvertQueryToProperties(values url.Values) (volume.Properties, error)
• func NewHandler(logger lager.Logger, strategerizer volume.Strategerizer, ...) (http.Handler, error)
• func RespondWithError(w http.ResponseWriter, err error, statusCode ...int)
• type ErrorResponse
• type P2pServer
  • func NewP2pServer(logger lager.Logger, p2pInterfacePattern *regexp.Regexp, ...) *P2pServer
  • func (server *P2pServer) GetP2pUrl(w http.ResponseWriter, req *http.Request)
• type VolumeServer
  • func NewVolumeServer(logger lager.Logger, strategerizer volume.Strategerizer, ...) *VolumeServer
  • func (vs *VolumeServer) CreateVolume(w http.ResponseWriter, req *http.Request)
  • func (vs *VolumeServer) CreateVolumeAsync(w http.ResponseWriter, req *http.Request)
  • func (vs *VolumeServer) CreateVolumeAsyncCancel(w http.ResponseWriter, req *http.Request)
  • func (vs *VolumeServer) CreateVolumeAsyncCheck(w http.ResponseWriter, req *http.Request)
  • func (vs *VolumeServer) DestroyVolume(w http.ResponseWriter, req *http.Request)
  • func (vs *VolumeServer) DestroyVolumes(w http.ResponseWriter, req *http.Request)
  • func (vs *VolumeServer) GetPrivileged(w http.ResponseWriter, req *http.Request)
  • func (vs *VolumeServer) GetVolume(w http.ResponseWriter, req *http.Request)
  • func (vs *VolumeServer) ListVolumes(w http.ResponseWriter, req *http.Request)
  • func (vs *VolumeServer) SetPrivileged(w http.ResponseWriter, req *http.Request)
  • func (vs *VolumeServer) SetProperty(w http.ResponseWriter, req *http.Request)
  • func (vs *VolumeServer) StreamIn(w http.ResponseWriter, req *http.Request)
  • func (vs *VolumeServer) StreamOut(w http.ResponseWriter, req *http.Request)
  • func (vs *VolumeServer) StreamP2pOut(w http.ResponseWriter, req *http.Request)

Variables

var ErrCreateVolumeFailed = errors.New("failed to create volume")

var ErrDestroyVolumeFailed = errors.New("failed to destroy volume")

var ErrGetP2pUrlFailed = errors.New("failed to get p2p url")

var ErrGetPrivilegedFailed = errors.New("failed to get privileged status of volume")

var ErrGetVolumeFailed = errors.New("failed to get volume")

var ErrListVolumesFailed = errors.New("failed to list volumes")

var ErrSetPrivilegedFailed = errors.New("failed to change privileged status of volume")

var ErrSetPropertyFailed = errors.New("failed to set property on volume")

var ErrStreamInFailed = errors.New("failed to stream in to volume")

var ErrStreamOutFailed = errors.New("failed to stream out from volume")

var ErrStreamOutNotFound = errors.New("no such file or directory")

var ErrStreamP2pOutFailed = errors.New("failed to stream p2p out from volume")

Functions

func ConvertQueryToProperties

func ConvertQueryToProperties(values url.Values) (volume.Properties, error)

func NewHandler

func NewHandler(
	logger lager.Logger,
	strategerizer volume.Strategerizer,
	volumeRepo volume.Repository,
	p2pInterfacePattern *regexp.Regexp,
	p2pInterfaceFamily int,
	p2pStreamPort uint16,
) (http.Handler, error)

func RespondWithError

func RespondWithError(w http.ResponseWriter, err error, statusCode ...int)

Types

type ErrorResponse

type ErrorResponse struct {
	Message string `json:"error"`
}

type P2pServer

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

func NewP2pServer

func NewP2pServer(
	logger lager.Logger,
	p2pInterfacePattern *regexp.Regexp,
	p2pInterfaceFamily int,
	p2pStreamPort uint16,
) *P2pServer

func (*P2pServer) GetP2pUrl

func (server *P2pServer) GetP2pUrl(w http.ResponseWriter, req *http.Request)

type VolumeServer

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

func NewVolumeServer

func NewVolumeServer(
	logger lager.Logger,
	strategerizer volume.Strategerizer,
	volumeRepo volume.Repository,
) *VolumeServer

func (*VolumeServer) CreateVolume

func (vs *VolumeServer) CreateVolume(w http.ResponseWriter, req *http.Request)

func (*VolumeServer) CreateVolumeAsync

func (vs *VolumeServer) CreateVolumeAsync(w http.ResponseWriter, req *http.Request)

func (*VolumeServer) CreateVolumeAsyncCancel

func (vs *VolumeServer) CreateVolumeAsyncCancel(w http.ResponseWriter, req *http.Request)

func (*VolumeServer) CreateVolumeAsyncCheck

func (vs *VolumeServer) CreateVolumeAsyncCheck(w http.ResponseWriter, req *http.Request)

func (*VolumeServer) DestroyVolume

func (vs *VolumeServer) DestroyVolume(w http.ResponseWriter, req *http.Request)

func (*VolumeServer) DestroyVolumes

func (vs *VolumeServer) DestroyVolumes(w http.ResponseWriter, req *http.Request)

func (*VolumeServer) GetPrivileged

func (vs *VolumeServer) GetPrivileged(w http.ResponseWriter, req *http.Request)

func (*VolumeServer) GetVolume

func (vs *VolumeServer) GetVolume(w http.ResponseWriter, req *http.Request)

func (*VolumeServer) ListVolumes

func (vs *VolumeServer) ListVolumes(w http.ResponseWriter, req *http.Request)

func (*VolumeServer) SetPrivileged

func (vs *VolumeServer) SetPrivileged(w http.ResponseWriter, req *http.Request)

func (*VolumeServer) SetProperty

func (vs *VolumeServer) SetProperty(w http.ResponseWriter, req *http.Request)

func (*VolumeServer) StreamIn

func (vs *VolumeServer) StreamIn(w http.ResponseWriter, req *http.Request)

func (*VolumeServer) StreamOut

func (vs *VolumeServer) StreamOut(w http.ResponseWriter, req *http.Request)

func (*VolumeServer) StreamP2pOut

func (vs *VolumeServer) StreamP2pOut(w http.ResponseWriter, req *http.Request)