Documentation ¶
Index ¶
- Constants
- func DencodeID(id string) (string, error)
- func EncodeID(id string) string
- func NewRouter(s *Server) *mux.Router
- func NewSchema() *client.Schemas
- type DiskCollection
- type JournalInput
- type Metrics
- type PortInput
- type PrepareRebuildOutput
- type Replica
- type ReplicaCollection
- type RevertInput
- type 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) GetVersionDetails(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) PrepareRebuildReplica(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) UpdatePort(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) UpdateReplica(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) VerifyRebuildReplica(rw http.ResponseWriter, req *http.Request) error
- type SnapshotInput
- type SnapshotOutput
- type StartInput
- type Version
- type Volume
- type VolumeCollection
Constants ¶
View Source
const ( StreamTypeVolume = "volumes" StreamTypeReplica = "replicas" StreamTypeMetrics = "metrics" )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type DiskCollection ¶ added in v0.3.0
type DiskCollection struct { client.Collection Data []string `json:"data"` }
type JournalInput ¶ added in v0.2.0
type PrepareRebuildOutput ¶ added in v0.3.0
type Replica ¶
func NewReplica ¶
type ReplicaCollection ¶
type ReplicaCollection struct { client.Collection Data []Replica `json:"data"` }
type RevertInput ¶ added in v0.2.0
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func NewServer ¶
func NewServer(c *controller.Controller) *Server
func (*Server) CreateReplica ¶
func (*Server) DeleteReplica ¶
func (*Server) GetReplica ¶
func (*Server) GetVersionDetails ¶ added in v0.3.0
func (*Server) ListJournal ¶ added in v0.2.0
ListJournal flushes operation journal (replica read/write, ping, etc.) accumulated since previous flush
func (*Server) ListReplicas ¶
func (*Server) ListVolumes ¶
func (*Server) PrepareRebuildReplica ¶ added in v0.3.0
func (*Server) RevertVolume ¶ added in v0.2.0
func (*Server) ShutdownVolume ¶
func (*Server) SnapshotVolume ¶
func (*Server) StartVolume ¶
func (*Server) UpdatePort ¶ added in v0.3.0
func (*Server) UpdateReplica ¶
func (*Server) VerifyRebuildReplica ¶ added in v0.3.0
type SnapshotInput ¶ added in v0.2.0
type SnapshotOutput ¶
type StartInput ¶
type Volume ¶
type VolumeCollection ¶
type VolumeCollection struct { client.Collection Data []Volume `json:"data"` }
Click to show internal directories.
Click to hide internal directories.