Versions in this module Expand all Collapse all v0 v0.1.1 Oct 2, 2018 v0.1.0 Sep 25, 2018 Changes in this version + func CheckCompute(requestCpus, totalCpus uint32, requestMemory, totalMemory uint64, ...) error + func CheckStorage(request, total uint64, reserved map[string]*pbudget.Storage) error + func GetIpmiAddress() string + func GetSerial() string + func GetTotalCPUMilliCores() uint32 + func GetTotalMemory() (uint64, error) + func RegisterNodeToAPI(name, advertiseAddress, api string) error + type NodeAPI struct + func CreateNodeAPI(ds datastore.Datastore) (*NodeAPI, error) + func (a NodeAPI) ApplyNode(ctx context.Context, req *ppool.ApplyNodeRequest) (*ppool.Node, error) + func (a NodeAPI) DeleteNode(ctx context.Context, req *ppool.DeleteNodeRequest) (*empty.Empty, error) + func (a NodeAPI) GetNode(ctx context.Context, req *ppool.GetNodeRequest) (*ppool.Node, error) + func (a NodeAPI) ListNodes(ctx context.Context, req *ppool.ListNodesRequest) (*ppool.ListNodesResponse, error) + func (a NodeAPI) ReleaseCompute(ctx context.Context, req *ppool.ReleaseComputeRequest) (*empty.Empty, error) + func (a NodeAPI) ReleaseStorage(ctx context.Context, req *ppool.ReleaseStorageRequest) (*empty.Empty, error) + func (a NodeAPI) ReserveCompute(ctx context.Context, req *ppool.ReserveComputeRequest) (*ppool.ReserveComputeResponse, error) + func (a NodeAPI) ReserveStorage(ctx context.Context, req *ppool.ReserveStorageRequest) (*ppool.ReserveStorageResponse, error) + func (a NodeAPI) ScheduleCompute(ctx context.Context, req *ppool.ScheduleComputeRequest) (*ppool.ReserveComputeResponse, error) + func (a NodeAPI) ScheduleStorage(ctx context.Context, req *ppool.ScheduleStorageRequest) (*ppool.ReserveStorageResponse, error) + type NodeAPIEventDelegate struct + func (a NodeAPIEventDelegate) NotifyJoin(n *memberlist.Node) + func (a NodeAPIEventDelegate) NotifyLeave(n *memberlist.Node) + func (a NodeAPIEventDelegate) NotifyUpdate(n *memberlist.Node) + type NodeConnections struct + NodeAPI ppool.NodeServiceClient + func NewNodeConnections(api string) (*NodeConnections, error) + func (nc NodeConnections) GetConnection(nodeName string) (*grpc.ClientConn, error) + func (nc NodeConnections) IsExisting(nodeName string) (bool, error)
Go to main page