pbpilot

package
v0.4.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 16, 2020 License: Apache-2.0 Imports: 10 Imported by: 4

Documentation

Index

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 {
	GetPilotVersion(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.Version, error)
	GetFrontgateVersion(ctx context.Context, in *types.FrontgateId, opts ...grpc.CallOption) (*types.Version, error)
	GetDroneVersion(ctx context.Context, in *types.DroneEndpoint, opts ...grpc.CallOption) (*types.Version, error)
	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)
	RegisterMetadataMapping(ctx context.Context, in *types.SubTask_RegisterMetadata, opts ...grpc.CallOption) (*types.Empty, error)
	DeregisterMetadataMapping(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)
	PingMetadataBackend(ctx context.Context, in *types.FrontgateId, 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 {
	GetPilotVersion(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.Version, error)
	GetFrontgateVersion(ctx context.Context, in *types.FrontgateId, opts ...grpc.CallOption) (*types.Version, error)
	GetDroneVersion(ctx context.Context, in *types.DroneEndpoint, opts ...grpc.CallOption) (*types.Version, error)
	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 {
	GetPilotVersion(context.Context, *types.Empty) (*types.Version, error)
	GetFrontgateVersion(context.Context, *types.FrontgateId) (*types.Version, error)
	GetDroneVersion(context.Context, *types.DroneEndpoint) (*types.Version, error)
	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_FrontgateChannelClient interface {
	Send(*types.Bytes) error
	Recv() (*types.Bytes, error)
	grpc.ClientStream
}

type PilotServiceForFrontgate_FrontgateChannelServer added in v0.2.0 

type PilotServiceForFrontgate_FrontgateChannelServer interface {
	Send(*types.Bytes) error
	Recv() (*types.Bytes, error)
	grpc.ServerStream
}

type PilotServiceServer 

type PilotServiceServer interface {
	GetPilotVersion(context.Context, *types.Empty) (*types.Version, error)
	GetFrontgateVersion(context.Context, *types.FrontgateId) (*types.Version, error)
	GetDroneVersion(context.Context, *types.DroneEndpoint) (*types.Version, error)
	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)
	RegisterMetadataMapping(context.Context, *types.SubTask_RegisterMetadata) (*types.Empty, error)
	DeregisterMetadataMapping(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)
	PingMetadataBackend(context.Context, *types.FrontgateId) (*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.

type UnimplementedPilotServiceForFrontgateServer added in v0.4.6 

type UnimplementedPilotServiceForFrontgateServer struct {
}

UnimplementedPilotServiceForFrontgateServer can be embedded to have forward compatible implementations.

func (*UnimplementedPilotServiceForFrontgateServer) FrontgateChannel added in v0.4.6 

func (*UnimplementedPilotServiceForFrontgateServer) FrontgateChannel(srv PilotServiceForFrontgate_FrontgateChannelServer) error

func (*UnimplementedPilotServiceForFrontgateServer) GetDroneVersion added in v0.4.6 

func (*UnimplementedPilotServiceForFrontgateServer) GetDroneVersion(ctx context.Context, req *types.DroneEndpoint) (*types.Version, error)

func (*UnimplementedPilotServiceForFrontgateServer) GetFrontgateVersion added in v0.4.6 

func (*UnimplementedPilotServiceForFrontgateServer) GetFrontgateVersion(ctx context.Context, req *types.FrontgateId) (*types.Version, error)

func (*UnimplementedPilotServiceForFrontgateServer) GetPilotConfig added in v0.4.6 

func (*UnimplementedPilotServiceForFrontgateServer) GetPilotConfig(ctx context.Context, req *types.Empty) (*types.PilotConfig, error)

func (*UnimplementedPilotServiceForFrontgateServer) GetPilotVersion added in v0.4.6 

func (*UnimplementedPilotServiceForFrontgateServer) GetPilotVersion(ctx context.Context, req *types.Empty) (*types.Version, error)

func (*UnimplementedPilotServiceForFrontgateServer) PingPilot added in v0.4.6 

func (*UnimplementedPilotServiceForFrontgateServer) PingPilot(ctx context.Context, req *types.Empty) (*types.Empty, error)

func (*UnimplementedPilotServiceForFrontgateServer) ReportSubTaskStatus added in v0.4.6 

func (*UnimplementedPilotServiceForFrontgateServer) ReportSubTaskStatus(ctx context.Context, req *types.SubTaskStatus) (*types.Empty, error)

type UnimplementedPilotServiceServer added in v0.4.6 

type UnimplementedPilotServiceServer struct {
}

UnimplementedPilotServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPilotServiceServer) DeregisterCmd added in v0.4.6 

func (*UnimplementedPilotServiceServer) DeregisterCmd(ctx context.Context, req *types.SubTask_DeregisterCmd) (*types.Empty, error)

func (*UnimplementedPilotServiceServer) DeregisterMetadata added in v0.4.6 

func (*UnimplementedPilotServiceServer) DeregisterMetadata(ctx context.Context, req *types.SubTask_DeregisterMetadata) (*types.Empty, error)

func (*UnimplementedPilotServiceServer) DeregisterMetadataMapping added in v0.4.6 

func (*UnimplementedPilotServiceServer) DeregisterMetadataMapping(ctx context.Context, req *types.SubTask_DeregisterMetadata) (*types.Empty, error)

func (*UnimplementedPilotServiceServer) GetConfdConfig added in v0.4.6 

func (*UnimplementedPilotServiceServer) GetConfdConfig(ctx context.Context, req *types.ConfdEndpoint) (*types.ConfdConfig, error)

func (*UnimplementedPilotServiceServer) GetDroneConfig added in v0.4.6 

func (*UnimplementedPilotServiceServer) GetDroneConfig(ctx context.Context, req *types.DroneEndpoint) (*types.DroneConfig, error)

func (*UnimplementedPilotServiceServer) GetDroneVersion added in v0.4.6 

func (*UnimplementedPilotServiceServer) GetDroneVersion(ctx context.Context, req *types.DroneEndpoint) (*types.Version, error)

func (*UnimplementedPilotServiceServer) GetFrontgateConfig added in v0.4.6 

func (*UnimplementedPilotServiceServer) GetFrontgateConfig(ctx context.Context, req *types.FrontgateId) (*types.FrontgateConfig, error)

func (*UnimplementedPilotServiceServer) GetFrontgateList added in v0.4.6 

func (*UnimplementedPilotServiceServer) GetFrontgateList(ctx context.Context, req *types.Empty) (*types.FrontgateIdList, error)

func (*UnimplementedPilotServiceServer) GetFrontgateVersion added in v0.4.6 

func (*UnimplementedPilotServiceServer) GetFrontgateVersion(ctx context.Context, req *types.FrontgateId) (*types.Version, error)

func (*UnimplementedPilotServiceServer) GetPilotClientTLSConfig added in v0.4.6 

func (*UnimplementedPilotServiceServer) GetPilotClientTLSConfig(ctx context.Context, req *types.Empty) (*types.PilotClientTLSConfig, error)

func (*UnimplementedPilotServiceServer) GetPilotConfig added in v0.4.6 

func (*UnimplementedPilotServiceServer) GetPilotConfig(ctx context.Context, req *types.Empty) (*types.PilotConfig, error)

func (*UnimplementedPilotServiceServer) GetPilotVersion added in v0.4.6 

func (*UnimplementedPilotServiceServer) GetPilotVersion(ctx context.Context, req *types.Empty) (*types.Version, error)

func (*UnimplementedPilotServiceServer) GetSubtaskStatus added in v0.4.6 

func (*UnimplementedPilotServiceServer) GetSubtaskStatus(ctx context.Context, req *types.SubTaskId) (*types.SubTaskStatus, error)

func (*UnimplementedPilotServiceServer) HandleSubtask added in v0.4.6 

func (*UnimplementedPilotServiceServer) HandleSubtask(ctx context.Context, req *types.SubTaskMessage) (*types.Empty, error)

func (*UnimplementedPilotServiceServer) IsConfdRunning added in v0.4.6 

func (*UnimplementedPilotServiceServer) IsConfdRunning(ctx context.Context, req *types.DroneEndpoint) (*types.Bool, error)

func (*UnimplementedPilotServiceServer) PingDrone added in v0.4.6 

func (*UnimplementedPilotServiceServer) PingDrone(ctx context.Context, req *types.DroneEndpoint) (*types.Empty, error)

func (*UnimplementedPilotServiceServer) PingFrontgate added in v0.4.6 

func (*UnimplementedPilotServiceServer) PingFrontgate(ctx context.Context, req *types.FrontgateId) (*types.Empty, error)

func (*UnimplementedPilotServiceServer) PingFrontgateNode added in v0.4.6 

func (*UnimplementedPilotServiceServer) PingFrontgateNode(ctx context.Context, req *types.FrontgateNodeId) (*types.Empty, error)

func (*UnimplementedPilotServiceServer) PingMetadataBackend added in v0.4.6 

func (*UnimplementedPilotServiceServer) PingMetadataBackend(ctx context.Context, req *types.FrontgateId) (*types.Empty, error)

func (*UnimplementedPilotServiceServer) PingPilot added in v0.4.6 

func (*UnimplementedPilotServiceServer) PingPilot(ctx context.Context, req *types.Empty) (*types.Empty, error)

func (*UnimplementedPilotServiceServer) RegisterCmd added in v0.4.6 

func (*UnimplementedPilotServiceServer) RegisterCmd(ctx context.Context, req *types.SubTask_RegisterCmd) (*types.Empty, error)

func (*UnimplementedPilotServiceServer) RegisterMetadata added in v0.4.6 

func (*UnimplementedPilotServiceServer) RegisterMetadata(ctx context.Context, req *types.SubTask_RegisterMetadata) (*types.Empty, error)

func (*UnimplementedPilotServiceServer) RegisterMetadataMapping added in v0.4.6 

func (*UnimplementedPilotServiceServer) RegisterMetadataMapping(ctx context.Context, req *types.SubTask_RegisterMetadata) (*types.Empty, error)

func (*UnimplementedPilotServiceServer) RunCommandOnDrone added in v0.4.6 

func (*UnimplementedPilotServiceServer) RunCommandOnDrone(ctx context.Context, req *types.RunCommandOnDroneRequest) (*types.String, error)

func (*UnimplementedPilotServiceServer) RunCommandOnFrontgateNode added in v0.4.6 

func (*UnimplementedPilotServiceServer) RunCommandOnFrontgateNode(ctx context.Context, req *types.RunCommandOnFrontgateRequest) (*types.String, error)

func (*UnimplementedPilotServiceServer) SetDroneConfig added in v0.4.6 

func (*UnimplementedPilotServiceServer) SetDroneConfig(ctx context.Context, req *types.SetDroneConfigRequest) (*types.Empty, error)

func (*UnimplementedPilotServiceServer) SetFrontgateConfig added in v0.4.6 

func (*UnimplementedPilotServiceServer) SetFrontgateConfig(ctx context.Context, req *types.FrontgateConfig) (*types.Empty, error)

func (*UnimplementedPilotServiceServer) StartConfd added in v0.4.6 

func (*UnimplementedPilotServiceServer) StartConfd(ctx context.Context, req *types.DroneEndpoint) (*types.Empty, error)

func (*UnimplementedPilotServiceServer) StopConfd added in v0.4.6 

func (*UnimplementedPilotServiceServer) StopConfd(ctx context.Context, req *types.DroneEndpoint) (*types.Empty, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.