client

Documentation

Index

• func QmReplyToStatement(reply *pb.QmReply) (ms metering.Statement)
• type MeteringClient
  • func NewMeteringClient(host string, port string) MeteringClient
  • func (mc MeteringClient) ComputeMetering(projectID int, meteringType int, typeInfo string) (ms metering.Statement, err error)
  • func (mc MeteringClient) QueryMetering(projectID int, meteringType int, typeInfo string) (ms metering.Statement, err error)
  • func (mc MeteringClient) RegisterCronMeteringTask(meteringType int) (msg string, err error)
• type SchedulingClient
  • func NewSchedulingClient(host string, port string) SchedulingClient
  • func (sc SchedulingClient) QueryCGpuTree(projectID int, cgpuType int64, QueryType int64, treeFormat int64) (jsonTree string, selected []int64, NodesNum int64, err error)
  • func (sc SchedulingClient) QueryProjectRes(projectID int) (pr projectRes.ResInfo, err error)
  • func (sc SchedulingClient) QueryProjectResLite(projectID int) (prl projectRes.ResInfoLite, err error)
  • func (sc SchedulingClient) SchedulingCGpu(projectID int, cgpuType int, nodesAfter []int64, ctrlID int, ctrlCN string) (allocInfo project.AllocNum, err error)
  • func (sc SchedulingClient) SchedulingStorage(projectID int, storageSizeAfter int, storageAllocInfoAfter string, ctrlID int, ...) (allocInfo project.AllocNum, err error)

Functions

func QmReplyToStatement

func QmReplyToStatement(reply *pb.QmReply) (ms metering.Statement)

Types

type MeteringClient

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

func NewMeteringClient

func NewMeteringClient(host string, port string) MeteringClient

func (MeteringClient) ComputeMetering

func (mc MeteringClient) ComputeMetering(projectID int,
	meteringType int, typeInfo string) (ms metering.Statement, err error)

func (MeteringClient) QueryMetering

func (mc MeteringClient) QueryMetering(projectID int,
	meteringType int, typeInfo string) (ms metering.Statement, err error)

func (MeteringClient) RegisterCronMeteringTask

func (mc MeteringClient) RegisterCronMeteringTask(meteringType int) (msg string, err error)

type SchedulingClient

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

func NewSchedulingClient

func NewSchedulingClient(host string, port string) SchedulingClient

func (SchedulingClient) QueryCGpuTree

func (sc SchedulingClient) QueryCGpuTree(projectID int, cgpuType int64, QueryType int64, treeFormat int64) (
	jsonTree string, selected []int64, NodesNum int64, err error)

func (SchedulingClient) QueryProjectRes

func (sc SchedulingClient) QueryProjectRes(projectID int) (pr projectRes.ResInfo, err error)

func (SchedulingClient) QueryProjectResLite

func (sc SchedulingClient) QueryProjectResLite(projectID int) (prl projectRes.ResInfoLite, err error)

func (SchedulingClient) SchedulingCGpu

func (sc SchedulingClient) SchedulingCGpu(projectID int, cgpuType int, nodesAfter []int64,
	ctrlID int, ctrlCN string) (allocInfo project.AllocNum, err error)

func (SchedulingClient) SchedulingStorage

func (sc SchedulingClient) SchedulingStorage(projectID int,
	storageSizeAfter int, storageAllocInfoAfter string, ctrlID int, ctrlCN string) (allocInfo project.AllocNum, err error)