api

package
v1.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 5, 2021 License: Apache-2.0 Imports: 17 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrCreateVolumeFailed = errors.New("failed to create volume")
View Source
var ErrDestroyVolumeFailed = errors.New("failed to destroy volume")
View Source
var ErrGetP2pUrlFailed = errors.New("failed to get p2p url")
View Source
var ErrGetPrivilegedFailed = errors.New("failed to get privileged status of volume")
View Source
var ErrGetVolumeFailed = errors.New("failed to get volume")
View Source
var ErrListVolumesFailed = errors.New("failed to list volumes")
View Source
var ErrSetPrivilegedFailed = errors.New("failed to change privileged status of volume")
View Source
var ErrSetPropertyFailed = errors.New("failed to set property on volume")
View Source
var ErrStreamInFailed = errors.New("failed to stream in to volume")
View Source
var ErrStreamOutFailed = errors.New("failed to stream out from volume")
View Source
var ErrStreamOutNotFound = errors.New("no such file or directory")
View Source
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 added in v1.9.0

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

func NewP2pServer added in v1.9.0

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

func (*P2pServer) GetP2pUrl added in v1.9.0

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 added in v1.5.0

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 added in v1.9.0

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

Jump to

Keyboard shortcuts

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