servergrpc

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jan 3, 2017 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package servergrpc is a generated protocol buffer package.

It is generated from these files: 

github.com/appcelerator/amp/cmd/adm-server/servergrpc/cluster-server.proto

It has these top-level messages: 

ClientMes
RegisterRequest
AgentHealthRequest
ServerRet
ServerRets
GetNodesInfoRequest
NodesInfo
NodeInfo
PurgeNodesRequest
PurgeNodeAnswer
PurgeNodesAnswers
AmpRequest
AmpRet
TypedOutput
AmpMonitorAnswers
AmpStatusAnswer

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterClusterServerServiceServer 

func RegisterClusterServerServiceServer(s *grpc.Server, srv ClusterServerServiceServer)

Types

type AgentHealthRequest 

type AgentHealthRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}

func (*AgentHealthRequest) Descriptor 

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

func (*AgentHealthRequest) GetId 

func (m *AgentHealthRequest) GetId() string

func (*AgentHealthRequest) ProtoMessage 

func (*AgentHealthRequest) ProtoMessage()

func (*AgentHealthRequest) Reset 

func (m *AgentHealthRequest) Reset()

func (*AgentHealthRequest) String 

func (m *AgentHealthRequest) String() string

type AmpMonitorAnswers 

type AmpMonitorAnswers struct {
	Outputs []*TypedOutput `protobuf:"bytes,1,rep,name=outputs" json:"outputs,omitempty"`
}

func (*AmpMonitorAnswers) Descriptor 

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

func (*AmpMonitorAnswers) GetOutputs 

func (m *AmpMonitorAnswers) GetOutputs() []*TypedOutput

func (*AmpMonitorAnswers) ProtoMessage 

func (*AmpMonitorAnswers) ProtoMessage()

func (*AmpMonitorAnswers) Reset 

func (m *AmpMonitorAnswers) Reset()

func (*AmpMonitorAnswers) String 

func (m *AmpMonitorAnswers) String() string

type AmpRequest 

type AmpRequest struct {
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId" json:"client_id,omitempty"`
	Silence  bool   `protobuf:"varint,2,opt,name=silence" json:"silence,omitempty"`
	Verbose  bool   `protobuf:"varint,3,opt,name=verbose" json:"verbose,omitempty"`
	Force    bool   `protobuf:"varint,4,opt,name=force" json:"force,omitempty"`
	Local    bool   `protobuf:"varint,5,opt,name=local" json:"local,omitempty"`
	Node     string `protobuf:"bytes,6,opt,name=node" json:"node,omitempty"`
}

func (*AmpRequest) Descriptor 

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

func (*AmpRequest) GetClientId 

func (m *AmpRequest) GetClientId() string

func (*AmpRequest) GetForce 

func (m *AmpRequest) GetForce() bool

func (*AmpRequest) GetLocal 

func (m *AmpRequest) GetLocal() bool

func (*AmpRequest) GetNode 

func (m *AmpRequest) GetNode() string

func (*AmpRequest) GetSilence 

func (m *AmpRequest) GetSilence() bool

func (*AmpRequest) GetVerbose 

func (m *AmpRequest) GetVerbose() bool

func (*AmpRequest) ProtoMessage 

func (*AmpRequest) ProtoMessage()

func (*AmpRequest) Reset 

func (m *AmpRequest) Reset()

func (*AmpRequest) String 

func (m *AmpRequest) String() string

type AmpRet 

type AmpRet struct {
}

func (*AmpRet) Descriptor 

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

func (*AmpRet) ProtoMessage 

func (*AmpRet) ProtoMessage()

func (*AmpRet) Reset 

func (m *AmpRet) Reset()

func (*AmpRet) String 

func (m *AmpRet) String() string

type AmpStatusAnswer 

type AmpStatusAnswer struct {
	Status string `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
}

func (*AmpStatusAnswer) Descriptor 

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

func (*AmpStatusAnswer) GetStatus 

func (m *AmpStatusAnswer) GetStatus() string

func (*AmpStatusAnswer) ProtoMessage 

func (*AmpStatusAnswer) ProtoMessage()

func (*AmpStatusAnswer) Reset 

func (m *AmpStatusAnswer) Reset()

func (*AmpStatusAnswer) String 

func (m *AmpStatusAnswer) String() string

type ClientMes 

type ClientMes struct {
	ClientId string       `protobuf:"bytes,1,opt,name=client_id,json=clientId" json:"client_id,omitempty"`
	Function string       `protobuf:"bytes,2,opt,name=function" json:"function,omitempty"`
	Output   *TypedOutput `protobuf:"bytes,3,opt,name=output" json:"output,omitempty"`
}

func (*ClientMes) Descriptor 

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

func (*ClientMes) GetClientId 

func (m *ClientMes) GetClientId() string

func (*ClientMes) GetFunction 

func (m *ClientMes) GetFunction() string

func (*ClientMes) GetOutput 

func (m *ClientMes) GetOutput() *TypedOutput

func (*ClientMes) ProtoMessage 

func (*ClientMes) ProtoMessage()

func (*ClientMes) Reset 

func (m *ClientMes) Reset()

func (*ClientMes) String 

func (m *ClientMes) String() string

type ClusterServerServiceClient 

type ClusterServerServiceClient interface {
	GetClientStream(ctx context.Context, opts ...grpc.CallOption) (ClusterServerService_GetClientStreamClient, error)
	RegisterAgent(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*ServerRet, error)
	AgentHealth(ctx context.Context, in *AgentHealthRequest, opts ...grpc.CallOption) (*ServerRet, error)
	GetNodesInfo(ctx context.Context, in *GetNodesInfoRequest, opts ...grpc.CallOption) (*NodesInfo, error)
	PurgeNodes(ctx context.Context, in *PurgeNodesRequest, opts ...grpc.CallOption) (*PurgeNodesAnswers, error)
	AmpMonitor(ctx context.Context, in *AmpRequest, opts ...grpc.CallOption) (*AmpMonitorAnswers, error)
	AmpPull(ctx context.Context, in *AmpRequest, opts ...grpc.CallOption) (*AmpRet, error)
	GetAmpStatus(ctx context.Context, in *AmpRequest, opts ...grpc.CallOption) (*AmpStatusAnswer, error)
	AmpStart(ctx context.Context, in *AmpRequest, opts ...grpc.CallOption) (*AmpRet, error)
	AmpStop(ctx context.Context, in *AmpRequest, opts ...grpc.CallOption) (*AmpRet, error)
}

func NewClusterServerServiceClient 

func NewClusterServerServiceClient(cc *grpc.ClientConn) ClusterServerServiceClient

type ClusterServerServiceServer 

type ClusterServerServiceServer interface {
	GetClientStream(ClusterServerService_GetClientStreamServer) error
	RegisterAgent(context.Context, *RegisterRequest) (*ServerRet, error)
	AgentHealth(context.Context, *AgentHealthRequest) (*ServerRet, error)
	GetNodesInfo(context.Context, *GetNodesInfoRequest) (*NodesInfo, error)
	PurgeNodes(context.Context, *PurgeNodesRequest) (*PurgeNodesAnswers, error)
	AmpMonitor(context.Context, *AmpRequest) (*AmpMonitorAnswers, error)
	AmpPull(context.Context, *AmpRequest) (*AmpRet, error)
	GetAmpStatus(context.Context, *AmpRequest) (*AmpStatusAnswer, error)
	AmpStart(context.Context, *AmpRequest) (*AmpRet, error)
	AmpStop(context.Context, *AmpRequest) (*AmpRet, error)
}

type ClusterServerService_GetClientStreamClient 

type ClusterServerService_GetClientStreamClient interface {
	Send(*ClientMes) error
	Recv() (*ClientMes, error)
	grpc.ClientStream
}

type ClusterServerService_GetClientStreamServer 

type ClusterServerService_GetClientStreamServer interface {
	Send(*ClientMes) error
	Recv() (*ClientMes, error)
	grpc.ServerStream
}

type GetNodesInfoRequest 

type GetNodesInfoRequest struct {
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId" json:"client_id,omitempty"`
	Node     string `protobuf:"bytes,2,opt,name=node" json:"node,omitempty"`
	More     bool   `protobuf:"varint,3,opt,name=more" json:"more,omitempty"`
}

func (*GetNodesInfoRequest) Descriptor 

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

func (*GetNodesInfoRequest) GetClientId 

func (m *GetNodesInfoRequest) GetClientId() string

func (*GetNodesInfoRequest) GetMore 

func (m *GetNodesInfoRequest) GetMore() bool

func (*GetNodesInfoRequest) GetNode 

func (m *GetNodesInfoRequest) GetNode() string

func (*GetNodesInfoRequest) ProtoMessage 

func (*GetNodesInfoRequest) ProtoMessage()

func (*GetNodesInfoRequest) Reset 

func (m *GetNodesInfoRequest) Reset()

func (*GetNodesInfoRequest) String 

func (m *GetNodesInfoRequest) String() string

type NodeInfo 

type NodeInfo struct {
	Id                  string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Role                string `protobuf:"bytes,2,opt,name=role" json:"role,omitempty"`
	Availability        string `protobuf:"bytes,3,opt,name=availability" json:"availability,omitempty"`
	Hostname            string `protobuf:"bytes,4,opt,name=hostname" json:"hostname,omitempty"`
	HostArchitecture    string `protobuf:"bytes,5,opt,name=host_architecture,json=hostArchitecture" json:"host_architecture,omitempty"`
	HostOs              string `protobuf:"bytes,6,opt,name=host_os,json=hostOs" json:"host_os,omitempty"`
	Cpu                 int64  `protobuf:"varint,7,opt,name=cpu" json:"cpu,omitempty"`
	Memory              int64  `protobuf:"varint,8,opt,name=memory" json:"memory,omitempty"`
	DockerVersion       string `protobuf:"bytes,9,opt,name=docker_version,json=dockerVersion" json:"docker_version,omitempty"`
	Status              string `protobuf:"bytes,10,opt,name=status" json:"status,omitempty"`
	Leader              bool   `protobuf:"varint,11,opt,name=leader" json:"leader,omitempty"`
	Reachability        string `protobuf:"bytes,12,opt,name=reachability" json:"reachability,omitempty"`
	Address             string `protobuf:"bytes,13,opt,name=address" json:"address,omitempty"`
	NbContainers        int64  `protobuf:"varint,14,opt,name=nb_containers,json=nbContainers" json:"nb_containers,omitempty"`
	NbContainersRunning int64  `protobuf:"varint,15,opt,name=nb_containers_running,json=nbContainersRunning" json:"nb_containers_running,omitempty"`
	NbContainersPaused  int64  `protobuf:"varint,16,opt,name=nb_containers_paused,json=nbContainersPaused" json:"nb_containers_paused,omitempty"`
	NbContainersStopped int64  `protobuf:"varint,17,opt,name=nb_containers_stopped,json=nbContainersStopped" json:"nb_containers_stopped,omitempty"`
	Images              int64  `protobuf:"varint,18,opt,name=images" json:"images,omitempty"`
	Error               string `protobuf:"bytes,19,opt,name=error" json:"error,omitempty"`
	AgentId             string `protobuf:"bytes,20,opt,name=agentId" json:"agentId,omitempty"`
	NodeName            string `protobuf:"bytes,21,opt,name=nodeName" json:"nodeName,omitempty"`
}

func (*NodeInfo) Descriptor 

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

func (*NodeInfo) GetAddress 

func (m *NodeInfo) GetAddress() string

func (*NodeInfo) GetAgentId 

func (m *NodeInfo) GetAgentId() string

func (*NodeInfo) GetAvailability 

func (m *NodeInfo) GetAvailability() string

func (*NodeInfo) GetCpu 

func (m *NodeInfo) GetCpu() int64

func (*NodeInfo) GetDockerVersion 

func (m *NodeInfo) GetDockerVersion() string

func (*NodeInfo) GetError 

func (m *NodeInfo) GetError() string

func (*NodeInfo) GetHostArchitecture 

func (m *NodeInfo) GetHostArchitecture() string

func (*NodeInfo) GetHostOs 

func (m *NodeInfo) GetHostOs() string

func (*NodeInfo) GetHostname 

func (m *NodeInfo) GetHostname() string

func (*NodeInfo) GetId 

func (m *NodeInfo) GetId() string

func (*NodeInfo) GetImages 

func (m *NodeInfo) GetImages() int64

func (*NodeInfo) GetLeader 

func (m *NodeInfo) GetLeader() bool

func (*NodeInfo) GetMemory 

func (m *NodeInfo) GetMemory() int64

func (*NodeInfo) GetNbContainers 

func (m *NodeInfo) GetNbContainers() int64

func (*NodeInfo) GetNbContainersPaused 

func (m *NodeInfo) GetNbContainersPaused() int64

func (*NodeInfo) GetNbContainersRunning 

func (m *NodeInfo) GetNbContainersRunning() int64

func (*NodeInfo) GetNbContainersStopped 

func (m *NodeInfo) GetNbContainersStopped() int64

func (*NodeInfo) GetNodeName 

func (m *NodeInfo) GetNodeName() string

func (*NodeInfo) GetReachability 

func (m *NodeInfo) GetReachability() string

func (*NodeInfo) GetRole 

func (m *NodeInfo) GetRole() string

func (*NodeInfo) GetStatus 

func (m *NodeInfo) GetStatus() string

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset 

func (m *NodeInfo) Reset()

func (*NodeInfo) String 

func (m *NodeInfo) String() string

type NodesInfo 

type NodesInfo struct {
	Nodes []*NodeInfo `protobuf:"bytes,1,rep,name=nodes" json:"nodes,omitempty"`
}

func (*NodesInfo) Descriptor 

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

func (*NodesInfo) GetNodes 

func (m *NodesInfo) GetNodes() []*NodeInfo

func (*NodesInfo) ProtoMessage 

func (*NodesInfo) ProtoMessage()

func (*NodesInfo) Reset 

func (m *NodesInfo) Reset()

func (*NodesInfo) String 

func (m *NodesInfo) String() string

type PurgeNodeAnswer 

type PurgeNodeAnswer struct {
	ClientId     string `protobuf:"bytes,1,opt,name=client_id,json=clientId" json:"client_id,omitempty"`
	AgentId      string `protobuf:"bytes,2,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	NbContainers int32  `protobuf:"varint,3,opt,name=nb_containers,json=nbContainers" json:"nb_containers,omitempty"`
	NbVolumes    int32  `protobuf:"varint,4,opt,name=nb_volumes,json=nbVolumes" json:"nb_volumes,omitempty"`
	NbImages     int32  `protobuf:"varint,5,opt,name=nb_images,json=nbImages" json:"nb_images,omitempty"`
	Error        string `protobuf:"bytes,6,opt,name=error" json:"error,omitempty"`
}

func (*PurgeNodeAnswer) Descriptor 

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

func (*PurgeNodeAnswer) GetAgentId 

func (m *PurgeNodeAnswer) GetAgentId() string

func (*PurgeNodeAnswer) GetClientId 

func (m *PurgeNodeAnswer) GetClientId() string

func (*PurgeNodeAnswer) GetError 

func (m *PurgeNodeAnswer) GetError() string

func (*PurgeNodeAnswer) GetNbContainers 

func (m *PurgeNodeAnswer) GetNbContainers() int32

func (*PurgeNodeAnswer) GetNbImages 

func (m *PurgeNodeAnswer) GetNbImages() int32

func (*PurgeNodeAnswer) GetNbVolumes 

func (m *PurgeNodeAnswer) GetNbVolumes() int32

func (*PurgeNodeAnswer) ProtoMessage 

func (*PurgeNodeAnswer) ProtoMessage()

func (*PurgeNodeAnswer) Reset 

func (m *PurgeNodeAnswer) Reset()

func (*PurgeNodeAnswer) String 

func (m *PurgeNodeAnswer) String() string

type PurgeNodesAnswers 

type PurgeNodesAnswers struct {
	Agents []*PurgeNodeAnswer `protobuf:"bytes,1,rep,name=agents" json:"agents,omitempty"`
}

func (*PurgeNodesAnswers) Descriptor 

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

func (*PurgeNodesAnswers) GetAgents 

func (m *PurgeNodesAnswers) GetAgents() []*PurgeNodeAnswer

func (*PurgeNodesAnswers) ProtoMessage 

func (*PurgeNodesAnswers) ProtoMessage()

func (*PurgeNodesAnswers) Reset 

func (m *PurgeNodesAnswers) Reset()

func (*PurgeNodesAnswers) String 

func (m *PurgeNodesAnswers) String() string

type PurgeNodesRequest 

type PurgeNodesRequest struct {
	ClientId  string `protobuf:"bytes,1,opt,name=client_id,json=clientId" json:"client_id,omitempty"`
	Node      string `protobuf:"bytes,2,opt,name=node" json:"node,omitempty"`
	Container bool   `protobuf:"varint,3,opt,name=container" json:"container,omitempty"`
	Volume    bool   `protobuf:"varint,4,opt,name=volume" json:"volume,omitempty"`
	Image     bool   `protobuf:"varint,5,opt,name=image" json:"image,omitempty"`
	Force     bool   `protobuf:"varint,6,opt,name=force" json:"force,omitempty"`
}

func (*PurgeNodesRequest) Descriptor 

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

func (*PurgeNodesRequest) GetClientId 

func (m *PurgeNodesRequest) GetClientId() string

func (*PurgeNodesRequest) GetContainer 

func (m *PurgeNodesRequest) GetContainer() bool

func (*PurgeNodesRequest) GetForce 

func (m *PurgeNodesRequest) GetForce() bool

func (*PurgeNodesRequest) GetImage 

func (m *PurgeNodesRequest) GetImage() bool

func (*PurgeNodesRequest) GetNode 

func (m *PurgeNodesRequest) GetNode() string

func (*PurgeNodesRequest) GetVolume 

func (m *PurgeNodesRequest) GetVolume() bool

func (*PurgeNodesRequest) ProtoMessage 

func (*PurgeNodesRequest) ProtoMessage()

func (*PurgeNodesRequest) Reset 

func (m *PurgeNodesRequest) Reset()

func (*PurgeNodesRequest) String 

func (m *PurgeNodesRequest) String() string

type RegisterRequest 

type RegisterRequest struct {
	Id       string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	NodeId   string `protobuf:"bytes,2,opt,name=node_id,json=nodeId" json:"node_id,omitempty"`
	Hostname string `protobuf:"bytes,3,opt,name=hostname" json:"hostname,omitempty"`
	Address  string `protobuf:"bytes,4,opt,name=address" json:"address,omitempty"`
}

func (*RegisterRequest) Descriptor 

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

func (*RegisterRequest) GetAddress 

func (m *RegisterRequest) GetAddress() string

func (*RegisterRequest) GetHostname 

func (m *RegisterRequest) GetHostname() string

func (*RegisterRequest) GetId 

func (m *RegisterRequest) GetId() string

func (*RegisterRequest) GetNodeId 

func (m *RegisterRequest) GetNodeId() string

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset 

func (m *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (m *RegisterRequest) String() string

type ServerRet 

type ServerRet struct {
	AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
}

func (*ServerRet) Descriptor 

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

func (*ServerRet) GetAgentId 

func (m *ServerRet) GetAgentId() string

func (*ServerRet) GetError 

func (m *ServerRet) GetError() string

func (*ServerRet) ProtoMessage 

func (*ServerRet) ProtoMessage()

func (*ServerRet) Reset 

func (m *ServerRet) Reset()

func (*ServerRet) String 

func (m *ServerRet) String() string

type ServerRets 

type ServerRets struct {
	Rets []*ServerRet `protobuf:"bytes,1,rep,name=rets" json:"rets,omitempty"`
}

func (*ServerRets) Descriptor 

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

func (*ServerRets) GetRets 

func (m *ServerRets) GetRets() []*ServerRet

func (*ServerRets) ProtoMessage 

func (*ServerRets) ProtoMessage()

func (*ServerRets) Reset 

func (m *ServerRets) Reset()

func (*ServerRets) String 

func (m *ServerRets) String() string

type TypedOutput 

type TypedOutput struct {
	Output     string `protobuf:"bytes,1,opt,name=output" json:"output,omitempty"`
	OutputType int32  `protobuf:"varint,2,opt,name=output_type,json=outputType" json:"output_type,omitempty"`
}

func (*TypedOutput) Descriptor 

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

func (*TypedOutput) GetOutput 

func (m *TypedOutput) GetOutput() string

func (*TypedOutput) GetOutputType 

func (m *TypedOutput) GetOutputType() int32

func (*TypedOutput) ProtoMessage 

func (*TypedOutput) ProtoMessage()

func (*TypedOutput) Reset 

func (m *TypedOutput) Reset()

func (*TypedOutput) String 

func (m *TypedOutput) String() string

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.