rest

Documentation

Index

• func DecodeData(data string) ([]byte, error)
• func DecodeID(id string) (string, error)
• func EncodeData(data []byte) string
• func EncodeID(id string) string
• func HandleError(s *client.Schemas, t func(http.ResponseWriter, *http.Request) error) http.Handler
• func New() types.Frontend
• func NewRouter(s *Server) *mux.Router
• func NewSchema() *client.Schemas
• type Device
  • func (d *Device) Endpoint() string
  • func (d *Device) Expand(size int64) error
  • func (d *Device) FrontendName() string
  • func (d *Device) Init(name string, size, sectorSize int64) error
  • func (d *Device) Shutdown() error
  • func (d *Device) Startup(rwu types.ReaderWriterUnmapperAt) error
  • func (d *Device) State() types.State
  • func (d *Device) Upgrade(name string, size, sectorSize int64, rwu types.ReaderWriterUnmapperAt) error
• type ReadInput
• type ReadOutput
• type Server
  • func NewServer(d *Device) *Server
  • func (s *Server) GetVolume(rw http.ResponseWriter, req *http.Request) error
  • func (s *Server) ListVolumes(rw http.ResponseWriter, req *http.Request) error
  • func (s *Server) ReadAt(rw http.ResponseWriter, req *http.Request) error
  • func (s *Server) WriteAt(rw http.ResponseWriter, req *http.Request) error
• type Volume
  • func NewVolume(context *api.ApiContext, name string) *Volume
• type WriteInput
• type WriteOutput

Functions

func DecodeData

func DecodeData(data string) ([]byte, error)

func DecodeID

func DecodeID(id string) (string, error)

func EncodeData

func EncodeData(data []byte) string

func EncodeID

func EncodeID(id string) string

func HandleError

func HandleError(s *client.Schemas, t func(http.ResponseWriter, *http.Request) error) http.Handler

func New

func New() types.Frontend

func NewRouter

func NewRouter(s *Server) *mux.Router

func NewSchema

func NewSchema() *client.Schemas

Types

type Device

type Device struct {
	Name       string
	Size       int64
	SectorSize int64
	// contains filtered or unexported fields
}

func (*Device) Endpoint

func (d *Device) Endpoint() string

func (*Device) Expand

func (d *Device) Expand(size int64) error

func (*Device) FrontendName

func (d *Device) FrontendName() string

func (*Device) Init

func (d *Device) Init(name string, size, sectorSize int64) error

func (*Device) Shutdown

func (d *Device) Shutdown() error

func (*Device) Startup

func (d *Device) Startup(rwu types.ReaderWriterUnmapperAt) error

func (*Device) State

func (d *Device) State() types.State

func (*Device) Upgrade

func (d *Device) Upgrade(name string, size, sectorSize int64, rwu types.ReaderWriterUnmapperAt) error

type ReadInput

type ReadInput struct {
	client.Resource
	Offset int64 `json:"offset,string"`
	Length int64 `json:"length,string"`
}

type ReadOutput

type ReadOutput struct {
	client.Resource
	Data string `json:"data"`
}

type Server

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

func NewServer

func NewServer(d *Device) *Server

func (*Server) GetVolume

func (s *Server) GetVolume(rw http.ResponseWriter, req *http.Request) error

func (*Server) ListVolumes

func (s *Server) ListVolumes(rw http.ResponseWriter, req *http.Request) error

func (*Server) ReadAt

func (s *Server) ReadAt(rw http.ResponseWriter, req *http.Request) error

func (*Server) WriteAt

func (s *Server) WriteAt(rw http.ResponseWriter, req *http.Request) error

type Volume

type Volume struct {
	client.Resource
	Name string `json:"name"`
}

func NewVolume

func NewVolume(context *api.ApiContext, name string) *Volume

type WriteInput

type WriteInput struct {
	client.Resource
	Offset int64  `json:"offset"`
	Length int    `json:"length"`
	Data   string `json:"data"`
}

type WriteOutput

type WriteOutput struct {
	client.Resource
}