rest

Documentation

Index

• func DencodeID(id string) (string, error)
• func EncodeID(id string) string
• func NewRouter(s *Server) *mux.Router
• func NewSchema() *client.Schemas
• type JournalInput
• type Replica
  • func NewReplica(address string, mode types.Mode) *Replica
• type ReplicaCollection
• type RevertInput
• type Server
  • func NewServer(c *controller.Controller) *Server
  • func (s *Server) CreateReplica(rw http.ResponseWriter, req *http.Request) error
  • func (s *Server) DeleteReplica(rw http.ResponseWriter, req *http.Request) error
  • func (s *Server) GetReplica(rw http.ResponseWriter, req *http.Request) error
  • func (s *Server) GetVolume(rw http.ResponseWriter, req *http.Request) error
  • func (s *Server) ListJournal(rw http.ResponseWriter, req *http.Request) error
  • func (s *Server) ListReplicas(rw http.ResponseWriter, req *http.Request) error
  • func (s *Server) ListVolumes(rw http.ResponseWriter, req *http.Request) error
  • func (s *Server) RevertVolume(rw http.ResponseWriter, req *http.Request) error
  • func (s *Server) ShutdownVolume(rw http.ResponseWriter, req *http.Request) error
  • func (s *Server) SnapshotVolume(rw http.ResponseWriter, req *http.Request) error
  • func (s *Server) StartVolume(rw http.ResponseWriter, req *http.Request) error
  • func (s *Server) UpdateReplica(rw http.ResponseWriter, req *http.Request) error
• type SnapshotInput
• type SnapshotOutput
• type StartInput
• type Volume
  • func NewVolume(context *api.ApiContext, name string, replicas int) *Volume
• type VolumeCollection

Functions

func DencodeID

func DencodeID(id string) (string, error)

func EncodeID

func EncodeID(id string) string

func NewRouter

func NewRouter(s *Server) *mux.Router

func NewSchema

func NewSchema() *client.Schemas

Types

type JournalInput

type JournalInput struct {
	client.Resource
	Limit int `json:"limit"`
}

type Replica

type Replica struct {
	client.Resource
	Address string `json:"address"`
	Mode    string `json:"mode"`
}

func NewReplica

func NewReplica(address string, mode types.Mode) *Replica

type ReplicaCollection

type ReplicaCollection struct {
	client.Collection
	Data []Replica `json:"data"`
}

type RevertInput

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

type Server

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

func NewServer

func NewServer(c *controller.Controller) *Server

func (*Server) CreateReplica

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

func (*Server) DeleteReplica

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

func (*Server) GetReplica

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

func (*Server) GetVolume

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

func (*Server) ListJournal

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

ListJournal flushes operation journal (replica read/write, ping, etc.) accumulated since previous flush

func (*Server) ListReplicas

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

func (*Server) ListVolumes

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

func (*Server) RevertVolume

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

func (*Server) ShutdownVolume

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

func (*Server) SnapshotVolume

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

func (*Server) StartVolume

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

func (*Server) UpdateReplica

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

type SnapshotInput

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

type SnapshotOutput

type SnapshotOutput struct {
	client.Resource
}

type StartInput

type StartInput struct {
	client.Resource
	Replicas []string `json:"replicas"`
}

type Volume

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

func NewVolume

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

type VolumeCollection

type VolumeCollection struct {
	client.Collection
	Data []Volume `json:"data"`
}