pbfrontgate

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: 13 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AcceptFrontgateServiceClient 

func AcceptFrontgateServiceClient(lis net.Listener, x FrontgateService)

AcceptFrontgateServiceClient accepts connections on the listener and serves requests for each incoming connection. Accept blocks; the caller typically invokes it in a go statement.

func ListenAndServeFrontgateService 

func ListenAndServeFrontgateService(network, addr string, x FrontgateService) error

ListenAndServeFrontgateService listen announces on the local network address laddr and serves the given FrontgateService implementation.

func NewFrontgateServiceServer 

func NewFrontgateServiceServer(x FrontgateService) *rpc.Server

NewFrontgateServiceServer returns a new FrontgateService Server.

func RegisterFrontgateService 

func RegisterFrontgateService(srv *rpc.Server, x FrontgateService) error

RegisterFrontgateService publish the given FrontgateService implementation on the server.

func ServeFrontgateService 

func ServeFrontgateService(conn io.ReadWriteCloser, x FrontgateService)

ServeFrontgateService serves the given FrontgateService implementation.

Types

type Config 

type Config struct {
	Id                   string                   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ListenPort           int32                    `protobuf:"varint,2,opt,name=listen_port,json=listenPort,proto3" json:"listen_port,omitempty"`
	PilotHost            string                   `protobuf:"bytes,3,opt,name=pilot_host,json=pilotHost,proto3" json:"pilot_host,omitempty"`
	PilotPort            int32                    `protobuf:"varint,4,opt,name=pilot_port,json=pilotPort,proto3" json:"pilot_port,omitempty"`
	NodeList             *types.FrontgateEndpoint `protobuf:"bytes,5,opt,name=node_list,json=nodeList,proto3" json:"node_list,omitempty"`
	EtcdConfig           *types.EtcdConfig        `protobuf:"bytes,6,opt,name=etcd_config,json=etcdConfig,proto3" json:"etcd_config,omitempty"`
	ConfdConfig          *types.ConfdConfig       `protobuf:"bytes,7,opt,name=confd_config,json=confdConfig,proto3" json:"confd_config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*Config) Descriptor 

func (*Config) Descriptor() ([]byte, []int)

func (*Config) GetConfdConfig 

func (m *Config) GetConfdConfig() *types.ConfdConfig

func (*Config) GetEtcdConfig 

func (m *Config) GetEtcdConfig() *types.EtcdConfig

func (*Config) GetId 

func (m *Config) GetId() string

func (*Config) GetListenPort 

func (m *Config) GetListenPort() int32

func (*Config) GetNodeList 

func (m *Config) GetNodeList() *types.FrontgateEndpoint

func (*Config) GetPilotHost 

func (m *Config) GetPilotHost() string

func (*Config) GetPilotPort 

func (m *Config) GetPilotPort() int32

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) Reset 

func (m *Config) Reset()

func (*Config) String 

func (m *Config) String() string

func (*Config) XXX_DiscardUnknown 

func (m *Config) XXX_DiscardUnknown()

func (*Config) XXX_Marshal 

func (m *Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Config) XXX_Merge 

func (m *Config) XXX_Merge(src proto.Message)

func (*Config) XXX_Size 

func (m *Config) XXX_Size() int

func (*Config) XXX_Unmarshal 

func (m *Config) XXX_Unmarshal(b []byte) error

type FrontgateService 

type FrontgateService interface {
	GetPilotVersion(in *types.Empty, out *types.Version) error
	GetFrontgateVersion(in *types.Empty, out *types.Version) error
	GetDroneVersion(in *types.DroneEndpoint, out *types.Version) error
	GetPilotConfig(in *types.Empty, out *types.PilotConfig) error
	GetFrontgateConfig(in *types.Empty, out *types.FrontgateConfig) error
	SetFrontgateConfig(in *types.FrontgateConfig, out *types.Empty) error
	SetFrontgateNodeConfig(in *types.FrontgateConfig, out *types.Empty) error
	GetDroneList(in *types.Empty, out *types.DroneIdList) error
	GetDroneConfig(in *types.DroneEndpoint, out *types.DroneConfig) error
	SetDroneConfig(in *types.SetDroneConfigRequest, out *types.Empty) error
	GetConfdConfig(in *types.ConfdEndpoint, out *types.ConfdConfig) error
	IsConfdRunning(in *types.ConfdEndpoint, out *types.Bool) error
	StartConfd(in *types.ConfdEndpoint, out *types.Empty) error
	StopConfd(in *types.ConfdEndpoint, out *types.Empty) error
	RegisterMetadata(in *types.SubTask_RegisterMetadata, out *types.Empty) error
	DeregisterMetadata(in *types.SubTask_DeregisterMetadata, out *types.Empty) error
	RegisterMetadataMapping(in *types.SubTask_RegisterMetadata, out *types.Empty) error
	DeregisterMetadataMapping(in *types.SubTask_DeregisterMetadata, out *types.Empty) error
	RegisterCmd(in *types.SubTask_RegisterCmd, out *types.Empty) error
	DeregisterCmd(in *types.SubTask_DeregisterCmd, out *types.Empty) error
	ReportSubTaskStatus(in *types.SubTaskStatus, out *types.Empty) error
	GetEtcdValuesByPrefix(in *types.String, out *types.StringMap) error
	GetEtcdValues(in *types.StringList, out *types.StringMap) error
	SetEtcdValues(in *types.StringMap, out *types.Empty) error
	PingPilot(in *types.Empty, out *types.Empty) error
	PingFrontgate(in *types.Empty, out *types.Empty) error
	PingFrontgateNode(in *types.Empty, out *types.Empty) error
	PingDrone(in *types.DroneEndpoint, out *types.Empty) error
	PingMetadataBackend(in *types.Empty, out *types.Empty) error
	RunCommand(in *types.RunCommandOnFrontgateRequest, out *types.String) error
	RunCommandOnDrone(in *types.RunCommandOnDroneRequest, out *types.String) error
	HeartBeat(in *types.Empty, out *types.Empty) error
}

type FrontgateServiceClient 

type FrontgateServiceClient struct {
	*rpc.Client
}

func DialFrontgateService 

func DialFrontgateService(network, addr string) (*FrontgateServiceClient, error)

DialFrontgateService connects to an FrontgateService at the specified network address.

func DialFrontgateServiceHTTP 

func DialFrontgateServiceHTTP(network, address string) (*FrontgateServiceClient, error)

DialFrontgateServiceHTTP connects to an HTTP RPC server at the specified network address listening on the default HTTP RPC path.

func DialFrontgateServiceHTTPPath 

func DialFrontgateServiceHTTPPath(network, address, path string) (*FrontgateServiceClient, error)

DialFrontgateServiceHTTPPath connects to an HTTP RPC server at the specified network address and path.

func DialFrontgateServiceHTTPS 

func DialFrontgateServiceHTTPS(network, address string, tlsConfig *tls.Config) (*FrontgateServiceClient, error)

DialFrontgateServiceHTTPS connects to an HTTPS RPC server at the specified network address listening on the default HTTP RPC path.

func DialFrontgateServiceHTTPSPath 

func DialFrontgateServiceHTTPSPath(network, address, path string, tlsConfig *tls.Config) (*FrontgateServiceClient, error)

DialFrontgateServiceHTTPSPath connects to an HTTPS RPC server at the specified network address and path.

func DialFrontgateServiceTimeout 

func DialFrontgateServiceTimeout(network, addr string, timeout time.Duration) (*FrontgateServiceClient, error)

DialFrontgateServiceTimeout connects to an FrontgateService at the specified network address.

func NewFrontgateServiceClient 

func NewFrontgateServiceClient(conn io.ReadWriteCloser) *FrontgateServiceClient

NewFrontgateServiceClient returns a FrontgateService stub to handle requests to the set of FrontgateService at the other end of the connection.

func (*FrontgateServiceClient) AsyncDeregisterCmd 

func (c *FrontgateServiceClient) AsyncDeregisterCmd(in *types.SubTask_DeregisterCmd, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncDeregisterMetadata 

func (c *FrontgateServiceClient) AsyncDeregisterMetadata(in *types.SubTask_DeregisterMetadata, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncDeregisterMetadataMapping added in v0.2.3 

func (c *FrontgateServiceClient) AsyncDeregisterMetadataMapping(in *types.SubTask_DeregisterMetadata, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncGetConfdConfig 

func (c *FrontgateServiceClient) AsyncGetConfdConfig(in *types.ConfdEndpoint, out *types.ConfdConfig, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncGetDroneConfig 

func (c *FrontgateServiceClient) AsyncGetDroneConfig(in *types.DroneEndpoint, out *types.DroneConfig, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncGetDroneList 

func (c *FrontgateServiceClient) AsyncGetDroneList(in *types.Empty, out *types.DroneIdList, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncGetDroneVersion added in v0.2.1 

func (c *FrontgateServiceClient) AsyncGetDroneVersion(in *types.DroneEndpoint, out *types.Version, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncGetEtcdValues 

func (c *FrontgateServiceClient) AsyncGetEtcdValues(in *types.StringList, out *types.StringMap, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncGetEtcdValuesByPrefix 

func (c *FrontgateServiceClient) AsyncGetEtcdValuesByPrefix(in *types.String, out *types.StringMap, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncGetFrontgateConfig 

func (c *FrontgateServiceClient) AsyncGetFrontgateConfig(in *types.Empty, out *types.FrontgateConfig, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncGetFrontgateVersion added in v0.2.1 

func (c *FrontgateServiceClient) AsyncGetFrontgateVersion(in *types.Empty, out *types.Version, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncGetPilotConfig 

func (c *FrontgateServiceClient) AsyncGetPilotConfig(in *types.Empty, out *types.PilotConfig, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncGetPilotVersion added in v0.2.1 

func (c *FrontgateServiceClient) AsyncGetPilotVersion(in *types.Empty, out *types.Version, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncHeartBeat 

func (c *FrontgateServiceClient) AsyncHeartBeat(in *types.Empty, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncIsConfdRunning 

func (c *FrontgateServiceClient) AsyncIsConfdRunning(in *types.ConfdEndpoint, out *types.Bool, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncPingDrone 

func (c *FrontgateServiceClient) AsyncPingDrone(in *types.DroneEndpoint, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncPingFrontgate 

func (c *FrontgateServiceClient) AsyncPingFrontgate(in *types.Empty, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncPingFrontgateNode 

func (c *FrontgateServiceClient) AsyncPingFrontgateNode(in *types.Empty, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncPingMetadataBackend added in v0.2.1 

func (c *FrontgateServiceClient) AsyncPingMetadataBackend(in *types.Empty, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncPingPilot 

func (c *FrontgateServiceClient) AsyncPingPilot(in *types.Empty, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncRegisterCmd 

func (c *FrontgateServiceClient) AsyncRegisterCmd(in *types.SubTask_RegisterCmd, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncRegisterMetadata 

func (c *FrontgateServiceClient) AsyncRegisterMetadata(in *types.SubTask_RegisterMetadata, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncRegisterMetadataMapping added in v0.2.3 

func (c *FrontgateServiceClient) AsyncRegisterMetadataMapping(in *types.SubTask_RegisterMetadata, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncReportSubTaskStatus 

func (c *FrontgateServiceClient) AsyncReportSubTaskStatus(in *types.SubTaskStatus, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncRunCommand 

func (c *FrontgateServiceClient) AsyncRunCommand(in *types.RunCommandOnFrontgateRequest, out *types.String, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncRunCommandOnDrone 

func (c *FrontgateServiceClient) AsyncRunCommandOnDrone(in *types.RunCommandOnDroneRequest, out *types.String, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncSetDroneConfig 

func (c *FrontgateServiceClient) AsyncSetDroneConfig(in *types.SetDroneConfigRequest, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncSetEtcdValues 

func (c *FrontgateServiceClient) AsyncSetEtcdValues(in *types.StringMap, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncSetFrontgateConfig 

func (c *FrontgateServiceClient) AsyncSetFrontgateConfig(in *types.FrontgateConfig, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncSetFrontgateNodeConfig 

func (c *FrontgateServiceClient) AsyncSetFrontgateNodeConfig(in *types.FrontgateConfig, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncStartConfd 

func (c *FrontgateServiceClient) AsyncStartConfd(in *types.ConfdEndpoint, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) AsyncStopConfd 

func (c *FrontgateServiceClient) AsyncStopConfd(in *types.ConfdEndpoint, out *types.Empty, done chan *rpc.Call) *rpc.Call

func (*FrontgateServiceClient) DeregisterCmd 

func (c *FrontgateServiceClient) DeregisterCmd(in *types.SubTask_DeregisterCmd) (out *types.Empty, err error)

func (*FrontgateServiceClient) DeregisterMetadata 

func (c *FrontgateServiceClient) DeregisterMetadata(in *types.SubTask_DeregisterMetadata) (out *types.Empty, err error)

func (*FrontgateServiceClient) DeregisterMetadataMapping added in v0.2.3 

func (c *FrontgateServiceClient) DeregisterMetadataMapping(in *types.SubTask_DeregisterMetadata) (out *types.Empty, err error)

func (*FrontgateServiceClient) GetConfdConfig 

func (c *FrontgateServiceClient) GetConfdConfig(in *types.ConfdEndpoint) (out *types.ConfdConfig, err error)

func (*FrontgateServiceClient) GetDroneConfig 

func (c *FrontgateServiceClient) GetDroneConfig(in *types.DroneEndpoint) (out *types.DroneConfig, err error)

func (*FrontgateServiceClient) GetDroneList 

func (c *FrontgateServiceClient) GetDroneList(in *types.Empty) (out *types.DroneIdList, err error)

func (*FrontgateServiceClient) GetDroneVersion added in v0.2.1 

func (c *FrontgateServiceClient) GetDroneVersion(in *types.DroneEndpoint) (out *types.Version, err error)

func (*FrontgateServiceClient) GetEtcdValues 

func (c *FrontgateServiceClient) GetEtcdValues(in *types.StringList) (out *types.StringMap, err error)

func (*FrontgateServiceClient) GetEtcdValuesByPrefix 

func (c *FrontgateServiceClient) GetEtcdValuesByPrefix(in *types.String) (out *types.StringMap, err error)

func (*FrontgateServiceClient) GetFrontgateConfig 

func (c *FrontgateServiceClient) GetFrontgateConfig(in *types.Empty) (out *types.FrontgateConfig, err error)

func (*FrontgateServiceClient) GetFrontgateVersion added in v0.2.1 

func (c *FrontgateServiceClient) GetFrontgateVersion(in *types.Empty) (out *types.Version, err error)

func (*FrontgateServiceClient) GetPilotConfig 

func (c *FrontgateServiceClient) GetPilotConfig(in *types.Empty) (out *types.PilotConfig, err error)

func (*FrontgateServiceClient) GetPilotVersion added in v0.2.1 

func (c *FrontgateServiceClient) GetPilotVersion(in *types.Empty) (out *types.Version, err error)

func (*FrontgateServiceClient) HeartBeat 

func (c *FrontgateServiceClient) HeartBeat(in *types.Empty) (out *types.Empty, err error)

func (*FrontgateServiceClient) IsConfdRunning 

func (c *FrontgateServiceClient) IsConfdRunning(in *types.ConfdEndpoint) (out *types.Bool, err error)

func (*FrontgateServiceClient) PingDrone 

func (c *FrontgateServiceClient) PingDrone(in *types.DroneEndpoint) (out *types.Empty, err error)

func (*FrontgateServiceClient) PingFrontgate 

func (c *FrontgateServiceClient) PingFrontgate(in *types.Empty) (out *types.Empty, err error)

func (*FrontgateServiceClient) PingFrontgateNode 

func (c *FrontgateServiceClient) PingFrontgateNode(in *types.Empty) (out *types.Empty, err error)

func (*FrontgateServiceClient) PingMetadataBackend added in v0.2.1 

func (c *FrontgateServiceClient) PingMetadataBackend(in *types.Empty) (out *types.Empty, err error)

func (*FrontgateServiceClient) PingPilot 

func (c *FrontgateServiceClient) PingPilot(in *types.Empty) (out *types.Empty, err error)

func (*FrontgateServiceClient) RegisterCmd 

func (c *FrontgateServiceClient) RegisterCmd(in *types.SubTask_RegisterCmd) (out *types.Empty, err error)

func (*FrontgateServiceClient) RegisterMetadata 

func (c *FrontgateServiceClient) RegisterMetadata(in *types.SubTask_RegisterMetadata) (out *types.Empty, err error)

func (*FrontgateServiceClient) RegisterMetadataMapping added in v0.2.3 

func (c *FrontgateServiceClient) RegisterMetadataMapping(in *types.SubTask_RegisterMetadata) (out *types.Empty, err error)

func (*FrontgateServiceClient) ReportSubTaskStatus 

func (c *FrontgateServiceClient) ReportSubTaskStatus(in *types.SubTaskStatus) (out *types.Empty, err error)

func (*FrontgateServiceClient) RunCommand 

func (c *FrontgateServiceClient) RunCommand(in *types.RunCommandOnFrontgateRequest) (out *types.String, err error)

func (*FrontgateServiceClient) RunCommandOnDrone 

func (c *FrontgateServiceClient) RunCommandOnDrone(in *types.RunCommandOnDroneRequest) (out *types.String, err error)

func (*FrontgateServiceClient) SetDroneConfig 

func (c *FrontgateServiceClient) SetDroneConfig(in *types.SetDroneConfigRequest) (out *types.Empty, err error)

func (*FrontgateServiceClient) SetEtcdValues 

func (c *FrontgateServiceClient) SetEtcdValues(in *types.StringMap) (out *types.Empty, err error)

func (*FrontgateServiceClient) SetFrontgateConfig 

func (c *FrontgateServiceClient) SetFrontgateConfig(in *types.FrontgateConfig) (out *types.Empty, err error)

func (*FrontgateServiceClient) SetFrontgateNodeConfig 

func (c *FrontgateServiceClient) SetFrontgateNodeConfig(in *types.FrontgateConfig) (out *types.Empty, err error)

func (*FrontgateServiceClient) StartConfd 

func (c *FrontgateServiceClient) StartConfd(in *types.ConfdEndpoint) (out *types.Empty, err error)

func (*FrontgateServiceClient) StopConfd 

func (c *FrontgateServiceClient) StopConfd(in *types.ConfdEndpoint) (out *types.Empty, err 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.