Documentation ¶
Overview ¶
Package grpc is a generated protocol buffer package.
It is generated from these files:
rpc.proto
It has these top-level messages:
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterBenchHubCentralServer ¶
func RegisterBenchHubCentralServer(s *grpc1.Server, srv BenchHubCentralServer)
Types ¶
type BenchHubCentralClient ¶
type BenchHubCentralClient interface { Ping(ctx context.Context, in *bh.Ping, opts ...grpc1.CallOption) (*bh.Pong, error) NodeInfo(ctx context.Context, in *bh.NodeInfoReq, opts ...grpc1.CallOption) (*bh.NodeInfoRes, error) RegisterAgent(ctx context.Context, in *bh.RegisterAgentReq, opts ...grpc1.CallOption) (*bh.RegisterAgentRes, error) AgentHeartbeat(ctx context.Context, in *bh.AgentHeartbeatReq, opts ...grpc1.CallOption) (*bh.AgentHeartbeatRes, error) ListAgent(ctx context.Context, in *bh.ListAgentReq, opts ...grpc1.CallOption) (*bh.ListAgentRes, error) SubmitJob(ctx context.Context, in *bh.SubmitJobReq, opts ...grpc1.CallOption) (*bh.SubmitJobRes, error) }
func NewBenchHubCentralClient ¶
func NewBenchHubCentralClient(cc *grpc1.ClientConn) BenchHubCentralClient
func NewClient ¶
func NewClient(con *grpc.ClientConn) BenchHubCentralClient
type BenchHubCentralServer ¶
type BenchHubCentralServer interface { Ping(context.Context, *bh.Ping) (*bh.Pong, error) NodeInfo(context.Context, *bh.NodeInfoReq) (*bh.NodeInfoRes, error) RegisterAgent(context.Context, *bh.RegisterAgentReq) (*bh.RegisterAgentRes, error) AgentHeartbeat(context.Context, *bh.AgentHeartbeatReq) (*bh.AgentHeartbeatRes, error) ListAgent(context.Context, *bh.ListAgentReq) (*bh.ListAgentRes, error) SubmitJob(context.Context, *bh.SubmitJobReq) (*bh.SubmitJobRes, error) }
Click to show internal directories.
Click to hide internal directories.