|
|
@ -25,26 +25,35 @@ import ( |
|
|
|
"github.com/minio/minio/pkg/probe" |
|
|
|
"github.com/minio/minio/pkg/probe" |
|
|
|
) |
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// MinioServer - container for minio server data
|
|
|
|
type MinioServer struct { |
|
|
|
type MinioServer struct { |
|
|
|
Name string `json:"name"` |
|
|
|
Name string `json:"name"` |
|
|
|
IP string `json:"ip"` |
|
|
|
IP string `json:"ip"` |
|
|
|
ID string `json:"id"` |
|
|
|
ID string `json:"id"` |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// ServerArg - server arg
|
|
|
|
type ServerArg struct { |
|
|
|
type ServerArg struct { |
|
|
|
MinioServer |
|
|
|
MinioServer |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
type DummyReply struct{} |
|
|
|
// ServerAddReply - server add reply
|
|
|
|
|
|
|
|
type ServerAddReply struct { |
|
|
|
|
|
|
|
Server MinioServer `json:"server"` |
|
|
|
|
|
|
|
Status string `json:"status"` |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// MemStatsReply memory statistics
|
|
|
|
type MemStatsReply struct { |
|
|
|
type MemStatsReply struct { |
|
|
|
runtime.MemStats `json:"memstats"` |
|
|
|
runtime.MemStats `json:"memstats"` |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// DiskStatsReply disk statistics
|
|
|
|
type DiskStatsReply struct { |
|
|
|
type DiskStatsReply struct { |
|
|
|
DiskStats syscall.Statfs_t `json:"diskstats"` |
|
|
|
DiskStats syscall.Statfs_t `json:"diskstats"` |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// SysInfoReply system info
|
|
|
|
type SysInfoReply struct { |
|
|
|
type SysInfoReply struct { |
|
|
|
Hostname string `json:"hostname"` |
|
|
|
Hostname string `json:"hostname"` |
|
|
|
SysARCH string `json:"sys.arch"` |
|
|
|
SysARCH string `json:"sys.arch"` |
|
|
@ -54,30 +63,38 @@ type SysInfoReply struct { |
|
|
|
GOVersion string `json:"goversion"` |
|
|
|
GOVersion string `json:"goversion"` |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
type ListReply struct { |
|
|
|
// ServerListReply list of minio servers
|
|
|
|
List []MinioServer `json:"list"` |
|
|
|
type ServerListReply struct { |
|
|
|
|
|
|
|
ServerList []MinioServer `json:"servers"` |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// ServerService server json rpc service
|
|
|
|
type ServerService struct { |
|
|
|
type ServerService struct { |
|
|
|
list []MinioServer |
|
|
|
serverList []MinioServer |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
func (this *ServerService) Add(r *http.Request, arg *ServerArg, reply *DummyReply) error { |
|
|
|
// Add - add new server
|
|
|
|
this.list = append(this.list, MinioServer{arg.Name, arg.IP, arg.ID}) |
|
|
|
func (s *ServerService) Add(r *http.Request, arg *ServerArg, reply *ServerAddReply) error { |
|
|
|
|
|
|
|
reply.Server = MinioServer{arg.Name, arg.IP, arg.ID} |
|
|
|
|
|
|
|
reply.Status = "connected" |
|
|
|
|
|
|
|
s.serverList = append(s.serverList, reply.Server) |
|
|
|
return nil |
|
|
|
return nil |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
func (this *ServerService) MemStats(r *http.Request, arg *ServerArg, reply *MemStatsReply) error { |
|
|
|
// MemStats - memory statistics on the server
|
|
|
|
|
|
|
|
func (s *ServerService) MemStats(r *http.Request, arg *ServerArg, reply *MemStatsReply) error { |
|
|
|
runtime.ReadMemStats(&reply.MemStats) |
|
|
|
runtime.ReadMemStats(&reply.MemStats) |
|
|
|
return nil |
|
|
|
return nil |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
func (this *ServerService) DiskStats(r *http.Request, arg *ServerArg, reply *DiskStatsReply) error { |
|
|
|
// DiskStats - disk statistics on the server
|
|
|
|
|
|
|
|
func (s *ServerService) DiskStats(r *http.Request, arg *ServerArg, reply *DiskStatsReply) error { |
|
|
|
syscall.Statfs("/", &reply.DiskStats) |
|
|
|
syscall.Statfs("/", &reply.DiskStats) |
|
|
|
return nil |
|
|
|
return nil |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
func (this *ServerService) SysInfo(r *http.Request, arg *ServerArg, reply *SysInfoReply) error { |
|
|
|
// SysInfo - system info for the server
|
|
|
|
|
|
|
|
func (s *ServerService) SysInfo(r *http.Request, arg *ServerArg, reply *SysInfoReply) error { |
|
|
|
reply.SysARCH = runtime.GOARCH |
|
|
|
reply.SysARCH = runtime.GOARCH |
|
|
|
reply.SysOS = runtime.GOOS |
|
|
|
reply.SysOS = runtime.GOOS |
|
|
|
reply.SysCPUS = runtime.NumCPU() |
|
|
|
reply.SysCPUS = runtime.NumCPU() |
|
|
@ -91,17 +108,12 @@ func (this *ServerService) SysInfo(r *http.Request, arg *ServerArg, reply *SysIn |
|
|
|
return nil |
|
|
|
return nil |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
func (this *ServerService) List(r *http.Request, arg *ServerArg, reply *ListReply) error { |
|
|
|
// List of servers in the cluster
|
|
|
|
reply.List = this.list |
|
|
|
func (s *ServerService) List(r *http.Request, arg *ServerArg, reply *ServerListReply) error { |
|
|
|
return nil |
|
|
|
reply.ServerList = []MinioServer{ |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func NewServerService() *ServerService { |
|
|
|
|
|
|
|
s := &ServerService{} |
|
|
|
|
|
|
|
s.list = []MinioServer{ |
|
|
|
|
|
|
|
{"server.one", "192.168.1.1", "192.168.1.1"}, |
|
|
|
{"server.one", "192.168.1.1", "192.168.1.1"}, |
|
|
|
{"server.two", "192.168.1.2", "192.168.1.2"}, |
|
|
|
{"server.two", "192.168.1.2", "192.168.1.2"}, |
|
|
|
{"server.three", "192.168.1.3", "192.168.1.3"}, |
|
|
|
{"server.three", "192.168.1.3", "192.168.1.3"}, |
|
|
|
} |
|
|
|
} |
|
|
|
return s |
|
|
|
return nil |
|
|
|
} |
|
|
|
} |
|
|
|