Documentation
¶
Index ¶
- func RegisterPilotServiceForFrontgateServer(s *grpc.Server, srv PilotServiceForFrontgateServer)
- func RegisterPilotServiceServer(s *grpc.Server, srv PilotServiceServer)
- type PilotServiceClient
- type PilotServiceForFrontgateClient
- type PilotServiceForFrontgateServer
- type PilotServiceForFrontgate_FrontgateChannelClient
- type PilotServiceForFrontgate_FrontgateChannelServer
- type PilotServiceServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterPilotServiceForFrontgateServer ¶ added in v0.2.0
func RegisterPilotServiceForFrontgateServer(s *grpc.Server, srv PilotServiceForFrontgateServer)
func RegisterPilotServiceServer ¶
func RegisterPilotServiceServer(s *grpc.Server, srv PilotServiceServer)
Types ¶
type PilotServiceClient ¶
type PilotServiceClient interface {
GetPilotConfig(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.PilotConfig, error)
GetPilotClientTLSConfig(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.PilotClientTLSConfig, error)
GetFrontgateList(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.FrontgateIdList, error)
GetFrontgateConfig(ctx context.Context, in *types.FrontgateId, opts ...grpc.CallOption) (*types.FrontgateConfig, error)
SetFrontgateConfig(ctx context.Context, in *types.FrontgateConfig, opts ...grpc.CallOption) (*types.Empty, error)
GetDroneConfig(ctx context.Context, in *types.DroneEndpoint, opts ...grpc.CallOption) (*types.DroneConfig, error)
SetDroneConfig(ctx context.Context, in *types.SetDroneConfigRequest, opts ...grpc.CallOption) (*types.Empty, error)
GetConfdConfig(ctx context.Context, in *types.ConfdEndpoint, opts ...grpc.CallOption) (*types.ConfdConfig, error)
IsConfdRunning(ctx context.Context, in *types.DroneEndpoint, opts ...grpc.CallOption) (*types.Bool, error)
StartConfd(ctx context.Context, in *types.DroneEndpoint, opts ...grpc.CallOption) (*types.Empty, error)
StopConfd(ctx context.Context, in *types.DroneEndpoint, opts ...grpc.CallOption) (*types.Empty, error)
RegisterMetadata(ctx context.Context, in *types.SubTask_RegisterMetadata, opts ...grpc.CallOption) (*types.Empty, error)
DeregisterMetadata(ctx context.Context, in *types.SubTask_DeregisterMetadata, opts ...grpc.CallOption) (*types.Empty, error)
RegisterCmd(ctx context.Context, in *types.SubTask_RegisterCmd, opts ...grpc.CallOption) (*types.Empty, error)
DeregisterCmd(ctx context.Context, in *types.SubTask_DeregisterCmd, opts ...grpc.CallOption) (*types.Empty, error)
GetSubtaskStatus(ctx context.Context, in *types.SubTaskId, opts ...grpc.CallOption) (*types.SubTaskStatus, error)
HandleSubtask(ctx context.Context, in *types.SubTaskMessage, opts ...grpc.CallOption) (*types.Empty, error)
PingPilot(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.Empty, error)
PingFrontgate(ctx context.Context, in *types.FrontgateId, opts ...grpc.CallOption) (*types.Empty, error)
PingFrontgateNode(ctx context.Context, in *types.FrontgateNodeId, opts ...grpc.CallOption) (*types.Empty, error)
PingDrone(ctx context.Context, in *types.DroneEndpoint, opts ...grpc.CallOption) (*types.Empty, error)
RunCommandOnFrontgateNode(ctx context.Context, in *types.RunCommandOnFrontgateRequest, opts ...grpc.CallOption) (*types.String, error)
RunCommandOnDrone(ctx context.Context, in *types.RunCommandOnDroneRequest, opts ...grpc.CallOption) (*types.String, error)
}
PilotServiceClient is the client API for PilotService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewPilotServiceClient ¶
func NewPilotServiceClient(cc *grpc.ClientConn) PilotServiceClient
type PilotServiceForFrontgateClient ¶ added in v0.2.0
type PilotServiceForFrontgateClient interface {
PingPilot(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.Empty, error)
GetPilotConfig(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.PilotConfig, error)
ReportSubTaskStatus(ctx context.Context, in *types.SubTaskStatus, opts ...grpc.CallOption) (*types.Empty, error)
FrontgateChannel(ctx context.Context, opts ...grpc.CallOption) (PilotServiceForFrontgate_FrontgateChannelClient, error)
}
PilotServiceForFrontgateClient is the client API for PilotServiceForFrontgate service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewPilotServiceForFrontgateClient ¶ added in v0.2.0
func NewPilotServiceForFrontgateClient(cc *grpc.ClientConn) PilotServiceForFrontgateClient
type PilotServiceForFrontgateServer ¶ added in v0.2.0
type PilotServiceForFrontgateServer interface {
PingPilot(context.Context, *types.Empty) (*types.Empty, error)
GetPilotConfig(context.Context, *types.Empty) (*types.PilotConfig, error)
ReportSubTaskStatus(context.Context, *types.SubTaskStatus) (*types.Empty, error)
FrontgateChannel(PilotServiceForFrontgate_FrontgateChannelServer) error
}
PilotServiceForFrontgateServer is the server API for PilotServiceForFrontgate service.
type PilotServiceForFrontgate_FrontgateChannelClient ¶ added in v0.2.0
type PilotServiceForFrontgate_FrontgateChannelServer ¶ added in v0.2.0
type PilotServiceServer ¶
type PilotServiceServer interface {
GetPilotConfig(context.Context, *types.Empty) (*types.PilotConfig, error)
GetPilotClientTLSConfig(context.Context, *types.Empty) (*types.PilotClientTLSConfig, error)
GetFrontgateList(context.Context, *types.Empty) (*types.FrontgateIdList, error)
GetFrontgateConfig(context.Context, *types.FrontgateId) (*types.FrontgateConfig, error)
SetFrontgateConfig(context.Context, *types.FrontgateConfig) (*types.Empty, error)
GetDroneConfig(context.Context, *types.DroneEndpoint) (*types.DroneConfig, error)
SetDroneConfig(context.Context, *types.SetDroneConfigRequest) (*types.Empty, error)
GetConfdConfig(context.Context, *types.ConfdEndpoint) (*types.ConfdConfig, error)
IsConfdRunning(context.Context, *types.DroneEndpoint) (*types.Bool, error)
StartConfd(context.Context, *types.DroneEndpoint) (*types.Empty, error)
StopConfd(context.Context, *types.DroneEndpoint) (*types.Empty, error)
RegisterMetadata(context.Context, *types.SubTask_RegisterMetadata) (*types.Empty, error)
DeregisterMetadata(context.Context, *types.SubTask_DeregisterMetadata) (*types.Empty, error)
RegisterCmd(context.Context, *types.SubTask_RegisterCmd) (*types.Empty, error)
DeregisterCmd(context.Context, *types.SubTask_DeregisterCmd) (*types.Empty, error)
GetSubtaskStatus(context.Context, *types.SubTaskId) (*types.SubTaskStatus, error)
HandleSubtask(context.Context, *types.SubTaskMessage) (*types.Empty, error)
PingPilot(context.Context, *types.Empty) (*types.Empty, error)
PingFrontgate(context.Context, *types.FrontgateId) (*types.Empty, error)
PingFrontgateNode(context.Context, *types.FrontgateNodeId) (*types.Empty, error)
PingDrone(context.Context, *types.DroneEndpoint) (*types.Empty, error)
RunCommandOnFrontgateNode(context.Context, *types.RunCommandOnFrontgateRequest) (*types.String, error)
RunCommandOnDrone(context.Context, *types.RunCommandOnDroneRequest) (*types.String, error)
}
PilotServiceServer is the server API for PilotService service.
Click to show internal directories.
Click to hide internal directories.