Versions in this module Expand all Collapse all v0 v0.0.4 Jan 12, 2017 Changes in this version + func ParseMountOpts(mountopts string) uintptr v0.0.3 Jan 12, 2017 Changes in this version + func CheckMounts(nodeStat []byte) (bool, []string) + func GetRBDPool(device string) (string, string) + func Run(zoo Zk, s ServerConf) + func VersionShow() + type ClusterStatus struct + Health string + Quorum []Node + Zk string + type IPs struct + V4 []string + V6 []string + func GetMyIPs() IPs + type Mount struct + Block string + Fstype string + Image string + Mountopts string + Mountpoint string + Pool string + func GetMounts() []Mount + type MountState struct + Message string + State string + type Node struct + IP IPs + Mounts []Mount + Node string + Updated int64 + func GetNodeState(fqdn string) Node + type Quorum struct + DeadlyReason Node + Health string + Leader string + Quorum []Node + type RBDDevice struct + Block string + Fstype string + Image string + Mountopts string + Mountpoint string + Node string + Pool string + func (r RBDDevice) MapDevice() ([]byte, error) + func (r RBDDevice) MountFS(device string) error + func (r RBDDevice) UnmapDevice() ([]byte, error) + func (r RBDDevice) UnmountFS() error + type Resolve struct + Node string + type ServerConf struct + Addr string + Ws string + func (s ServerConf) ServeHTTP(z ZooNode, fqdn string) + func (s ServerConf) ServeWebSockets(z ZooNode) + type Writer struct + Upgrader websocket.Upgrader + func (wr Writer) WriteStatusWs(w http.ResponseWriter, r *http.Request) + type Zk struct + Hosts []string + Path string + Tick int + func (conf Zk) InitConnection() (*zk.Conn, error) + type ZooNode struct + Conn *zk.Conn + Path string + Zoo Zk + func (z ZooNode) Answer(fqdn string, req string, stderr []byte, t string) + func (z ZooNode) CheckAndSetHealth(childrens []string) + func (z ZooNode) CompareChilds(node Node) (bool, []string) + func (z ZooNode) CreateZkTree(fqdn string) + func (z ZooNode) DestroyNode(fqdn string) ([]string, string) + func (z ZooNode) EnsureZooPath(node string) (string, error) + func (z ZooNode) FindLeader(fqdn string) + func (z ZooNode) GetLeader() string + func (z ZooNode) GetQuorumHealth() string + func (z ZooNode) GetState() []byte + func (z ZooNode) MountRequest(r RBDDevice) error + func (z ZooNode) RMR(path string) + func (z ZooNode) Reconnect() + func (z ZooNode) RequestWatch(fqdn string) + func (z ZooNode) Resolve(fqdn string) error + func (z ZooNode) ResolveRequest(r Resolve) error + func (z ZooNode) SetDeadlyReason(node Node) + func (z ZooNode) SetLeader(fqdn string) + func (z ZooNode) SetQuorumHealth(health string) + func (z ZooNode) UmountRequest(r RBDDevice) error + func (z ZooNode) UpdateQuorum(childrens []string) + func (z ZooNode) UpdateState(zkPath string, fqdn string) + func (z ZooNode) WatchAnswer(fqdn string, t string) MountState