Documentation
¶
Overview ¶
Package message is a generated protocol buffer package.
It is generated from these files:
message.proto
It has these top-level messages:
AppnameRequest AppnameReply AppInfo AppsReply AppsRequest ContainerForBackupctl PodInfoForBackupctl BackupctlReply BackupctlRequest ConfigRequest ConfigReply Info ContainersReply ContainersRequest Container Dependency PodInfo CoreInfo CoreinfoReply CoreinfoRequest ContainerInfo DependsItem DependsAppMap DependsNodeMap DependsReply DependsRequest LocalspecReply LocalspecRequest NodeInfo NodesReply NodesRequest Pod PodGroup PodgroupReply PodgroupRequest ContainerForProxy ProcInfo ProxyReply ProxyRequest PodInfoForRebellion CoreInfoForRebellion RebellionLocalprocsReply RebellionLocalprocsRequest StreamrouterPortsRequest StreamrouterPortsReply StreamUpstream StreamService StreamProc StreamProcList Port Annotation StreamrouterStreamprocsReply StreamrouterStreamprocsRequest ContainerForWebrouter PodInfoForWebrouter CoreInfoForWebrouter WebrouterWebprocsReply WebrouterWebprocsRequest EmptyRequest VersionReply WatcherStatus StatusReply
Index ¶
- Variables
- func RegisterAppnameServer(s *grpc.Server, srv AppnameServer)
- func RegisterAppsServer(s *grpc.Server, srv AppsServer)
- func RegisterBackupctlServer(s *grpc.Server, srv BackupctlServer)
- func RegisterConfigServer(s *grpc.Server, srv ConfigServer)
- func RegisterContainersServer(s *grpc.Server, srv ContainersServer)
- func RegisterCoreinfoServer(s *grpc.Server, srv CoreinfoServer)
- func RegisterDependsServer(s *grpc.Server, srv DependsServer)
- func RegisterLainletServer(s *grpc.Server, srv LainletServer)
- func RegisterLocalspecServer(s *grpc.Server, srv LocalspecServer)
- func RegisterNodesServer(s *grpc.Server, srv NodesServer)
- func RegisterPodgroupServer(s *grpc.Server, srv PodgroupServer)
- func RegisterProxyServer(s *grpc.Server, srv ProxyServer)
- func RegisterRebellionLocalprocsServer(s *grpc.Server, srv RebellionLocalprocsServer)
- func RegisterStreamrouterPortsServer(s *grpc.Server, srv StreamrouterPortsServer)
- func RegisterStreamrouterStreamprocsServer(s *grpc.Server, srv StreamrouterStreamprocsServer)
- func RegisterWebrouterWebprocsServer(s *grpc.Server, srv WebrouterWebprocsServer)
- type Annotation
- type AppInfo
- type AppnameClient
- type AppnameReply
- type AppnameRequest
- type AppnameServer
- type AppsClient
- type AppsReply
- type AppsRequest
- type AppsServer
- type Apps_WatchClient
- type Apps_WatchServer
- type BackupctlClient
- type BackupctlReply
- type BackupctlReply_PodInfoList
- type BackupctlRequest
- type BackupctlServer
- type Backupctl_WatchClient
- type Backupctl_WatchServer
- type ConfigClient
- type ConfigReply
- type ConfigRequest
- type ConfigServer
- type Config_WatchClient
- type Config_WatchServer
- type Container
- func (*Container) Descriptor() ([]byte, []int)
- func (m *Container) GetCommand() []string
- func (m *Container) GetCpu() int32
- func (m *Container) GetEnv() []string
- func (m *Container) GetExpose() int32
- func (m *Container) GetId() string
- func (m *Container) GetImage() string
- func (m *Container) GetIp() string
- func (m *Container) GetMemory() int64
- func (m *Container) GetNodeIp() string
- func (m *Container) GetNodeName() string
- func (m *Container) GetVolumes() []string
- func (*Container) ProtoMessage()
- func (m *Container) Reset()
- func (m *Container) String() string
- type ContainerForBackupctl
- func (*ContainerForBackupctl) Descriptor() ([]byte, []int)
- func (m *ContainerForBackupctl) GetId() string
- func (m *ContainerForBackupctl) GetIp() string
- func (m *ContainerForBackupctl) GetNodeIp() string
- func (m *ContainerForBackupctl) GetNodeName() string
- func (*ContainerForBackupctl) ProtoMessage()
- func (m *ContainerForBackupctl) Reset()
- func (m *ContainerForBackupctl) String() string
- type ContainerForProxy
- type ContainerForWebrouter
- type ContainerInfo
- func (*ContainerInfo) Descriptor() ([]byte, []int)
- func (m *ContainerInfo) GetContainerID() string
- func (m *ContainerInfo) GetIP() string
- func (m *ContainerInfo) GetNodeIP() string
- func (m *ContainerInfo) GetPort() int32
- func (*ContainerInfo) ProtoMessage()
- func (m *ContainerInfo) Reset()
- func (m *ContainerInfo) String() string
- type ContainersClient
- type ContainersReply
- type ContainersRequest
- type ContainersServer
- type Containers_WatchClient
- type Containers_WatchServer
- type CoreInfo
- type CoreInfoForRebellion
- type CoreInfoForWebrouter
- type CoreinfoClient
- type CoreinfoReply
- type CoreinfoRequest
- type CoreinfoServer
- type Coreinfo_WatchClient
- type Coreinfo_WatchServer
- type Dependency
- type DependsAppMap
- type DependsClient
- type DependsItem
- type DependsNodeMap
- type DependsReply
- type DependsRequest
- type DependsServer
- type Depends_WatchClient
- type Depends_WatchServer
- type EmptyRequest
- type Info
- func (*Info) Descriptor() ([]byte, []int)
- func (m *Info) GetAppName() string
- func (m *Info) GetAppVersion() string
- func (m *Info) GetIP() string
- func (m *Info) GetInstanceNo() int32
- func (m *Info) GetNodeIP() string
- func (m *Info) GetNodeName() string
- func (m *Info) GetPort() int32
- func (m *Info) GetProcName() string
- func (*Info) ProtoMessage()
- func (m *Info) Reset()
- func (m *Info) String() string
- type LainletClient
- type LainletServer
- type LocalspecClient
- type LocalspecReply
- type LocalspecRequest
- type LocalspecServer
- type NodeInfo
- type NodeInfo_Value
- func (*NodeInfo_Value) Descriptor() ([]byte, []int)
- func (m *NodeInfo_Value) GetMval() map[string]string
- func (m *NodeInfo_Value) GetSval() string
- func (m *NodeInfo_Value) GetVtype() NodeInfo_Value_Type
- func (*NodeInfo_Value) ProtoMessage()
- func (m *NodeInfo_Value) Reset()
- func (m *NodeInfo_Value) String() string
- type NodeInfo_Value_Type
- type NodesClient
- type NodesReply
- type NodesRequest
- type NodesServer
- type Nodes_WatchClient
- type Nodes_WatchServer
- type Pod
- type PodGroup
- type PodInfo
- func (*PodInfo) Descriptor() ([]byte, []int)
- func (m *PodInfo) GetAnnotation() string
- func (m *PodInfo) GetContainers() []*Container
- func (m *PodInfo) GetDependencies() []*Dependency
- func (m *PodInfo) GetInstanceNo() int32
- func (*PodInfo) ProtoMessage()
- func (m *PodInfo) Reset()
- func (m *PodInfo) String() string
- type PodInfoForBackupctl
- func (*PodInfoForBackupctl) Descriptor() ([]byte, []int)
- func (m *PodInfoForBackupctl) GetAnnotation() string
- func (m *PodInfoForBackupctl) GetContainers() []*ContainerForBackupctl
- func (m *PodInfoForBackupctl) GetInstanceNo() int32
- func (*PodInfoForBackupctl) ProtoMessage()
- func (m *PodInfoForBackupctl) Reset()
- func (m *PodInfoForBackupctl) String() string
- type PodInfoForRebellion
- func (*PodInfoForRebellion) Descriptor() ([]byte, []int)
- func (m *PodInfoForRebellion) GetAnnotation() string
- func (m *PodInfoForRebellion) GetAppVersion() string
- func (m *PodInfoForRebellion) GetInstanceNo() int32
- func (*PodInfoForRebellion) ProtoMessage()
- func (m *PodInfoForRebellion) Reset()
- func (m *PodInfoForRebellion) String() string
- type PodInfoForWebrouter
- func (*PodInfoForWebrouter) Descriptor() ([]byte, []int)
- func (m *PodInfoForWebrouter) GetAnnotation() string
- func (m *PodInfoForWebrouter) GetContainers() []*ContainerForWebrouter
- func (*PodInfoForWebrouter) ProtoMessage()
- func (m *PodInfoForWebrouter) Reset()
- func (m *PodInfoForWebrouter) String() string
- type PodgroupClient
- type PodgroupReply
- type PodgroupRequest
- type PodgroupServer
- type Podgroup_WatchClient
- type Podgroup_WatchServer
- type Port
- type ProcInfo
- type ProxyClient
- type ProxyReply
- type ProxyRequest
- type ProxyServer
- type Proxy_WatchClient
- type Proxy_WatchServer
- type RebellionLocalprocsClient
- type RebellionLocalprocsReply
- type RebellionLocalprocsRequest
- type RebellionLocalprocsServer
- type RebellionLocalprocs_WatchClient
- type RebellionLocalprocs_WatchServer
- type StatusReply
- type StreamProc
- type StreamProcList
- type StreamService
- func (*StreamService) Descriptor() ([]byte, []int)
- func (m *StreamService) GetExpect() string
- func (m *StreamService) GetListenPort() int32
- func (m *StreamService) GetSend() string
- func (m *StreamService) GetUpstreamPort() int32
- func (*StreamService) ProtoMessage()
- func (m *StreamService) Reset()
- func (m *StreamService) String() string
- type StreamUpstream
- type StreamrouterPortsClient
- type StreamrouterPortsReply
- type StreamrouterPortsRequest
- type StreamrouterPortsServer
- type StreamrouterPorts_WatchClient
- type StreamrouterPorts_WatchServer
- type StreamrouterStreamprocsClient
- type StreamrouterStreamprocsReply
- type StreamrouterStreamprocsRequest
- type StreamrouterStreamprocsServer
- type StreamrouterStreamprocs_WatchClient
- type StreamrouterStreamprocs_WatchServer
- type VersionReply
- type WatcherStatus
- func (*WatcherStatus) Descriptor() ([]byte, []int)
- func (m *WatcherStatus) GetLastEvent() []byte
- func (m *WatcherStatus) GetNumReceivers() int32
- func (m *WatcherStatus) GetTotalKeys() int32
- func (m *WatcherStatus) GetUpdateTime() int64
- func (*WatcherStatus) ProtoMessage()
- func (m *WatcherStatus) Reset()
- func (m *WatcherStatus) String() string
- type WebrouterWebprocsClient
- type WebrouterWebprocsReply
- type WebrouterWebprocsRequest
- type WebrouterWebprocsServer
- type WebrouterWebprocs_WatchClient
- type WebrouterWebprocs_WatchServer
Constants ¶
This section is empty.
Variables ¶
View Source
var NodeInfo_Value_Type_name = map[int32]string{
0: "STRING",
1: "MAP",
}
View Source
var NodeInfo_Value_Type_value = map[string]int32{
"STRING": 0,
"MAP": 1,
}
Functions ¶
func RegisterAppnameServer ¶
func RegisterAppnameServer(s *grpc.Server, srv AppnameServer)
func RegisterAppsServer ¶
func RegisterAppsServer(s *grpc.Server, srv AppsServer)
func RegisterBackupctlServer ¶
func RegisterBackupctlServer(s *grpc.Server, srv BackupctlServer)
func RegisterConfigServer ¶
func RegisterConfigServer(s *grpc.Server, srv ConfigServer)
func RegisterContainersServer ¶
func RegisterContainersServer(s *grpc.Server, srv ContainersServer)
func RegisterCoreinfoServer ¶
func RegisterCoreinfoServer(s *grpc.Server, srv CoreinfoServer)
func RegisterDependsServer ¶
func RegisterDependsServer(s *grpc.Server, srv DependsServer)
func RegisterLainletServer ¶
func RegisterLainletServer(s *grpc.Server, srv LainletServer)
func RegisterLocalspecServer ¶
func RegisterLocalspecServer(s *grpc.Server, srv LocalspecServer)
func RegisterNodesServer ¶
func RegisterNodesServer(s *grpc.Server, srv NodesServer)
func RegisterPodgroupServer ¶
func RegisterPodgroupServer(s *grpc.Server, srv PodgroupServer)
func RegisterProxyServer ¶
func RegisterProxyServer(s *grpc.Server, srv ProxyServer)
func RegisterRebellionLocalprocsServer ¶
func RegisterRebellionLocalprocsServer(s *grpc.Server, srv RebellionLocalprocsServer)
func RegisterStreamrouterPortsServer ¶
func RegisterStreamrouterPortsServer(s *grpc.Server, srv StreamrouterPortsServer)
func RegisterStreamrouterStreamprocsServer ¶
func RegisterStreamrouterStreamprocsServer(s *grpc.Server, srv StreamrouterStreamprocsServer)
func RegisterWebrouterWebprocsServer ¶
func RegisterWebrouterWebprocsServer(s *grpc.Server, srv WebrouterWebprocsServer)
Types ¶
type Annotation ¶
type Annotation struct {
Ports []*Port `protobuf:"bytes,1,rep,name=Ports" json:"Ports,omitempty"`
}
func (*Annotation) Descriptor ¶
func (*Annotation) Descriptor() ([]byte, []int)
func (*Annotation) GetPorts ¶
func (m *Annotation) GetPorts() []*Port
func (*Annotation) ProtoMessage ¶
func (*Annotation) ProtoMessage()
func (*Annotation) Reset ¶
func (m *Annotation) Reset()
func (*Annotation) String ¶
func (m *Annotation) String() string
type AppInfo ¶
type AppInfo struct {
Appname string `protobuf:"bytes,1,opt,name=Appname" json:"Appname,omitempty"`
}
func (*AppInfo) Descriptor ¶
func (*AppInfo) GetAppname ¶
func (*AppInfo) ProtoMessage ¶
func (*AppInfo) ProtoMessage()
type AppnameClient ¶
type AppnameClient interface {
Get(ctx context.Context, in *AppnameRequest, opts ...grpc.CallOption) (*AppnameReply, error)
}
func NewAppnameClient ¶
func NewAppnameClient(cc *grpc.ClientConn) AppnameClient
type AppnameReply ¶
func (*AppnameReply) Descriptor ¶
func (*AppnameReply) Descriptor() ([]byte, []int)
func (*AppnameReply) GetData ¶
func (m *AppnameReply) GetData() map[string]string
func (*AppnameReply) ProtoMessage ¶
func (*AppnameReply) ProtoMessage()
func (*AppnameReply) Reset ¶
func (m *AppnameReply) Reset()
func (*AppnameReply) String ¶
func (m *AppnameReply) String() string
type AppnameRequest ¶
type AppnameRequest struct {
Ip string `protobuf:"bytes,1,opt,name=ip" json:"ip,omitempty"`
}
func (*AppnameRequest) Descriptor ¶
func (*AppnameRequest) Descriptor() ([]byte, []int)
func (*AppnameRequest) GetIp ¶
func (m *AppnameRequest) GetIp() string
func (*AppnameRequest) ProtoMessage ¶
func (*AppnameRequest) ProtoMessage()
func (*AppnameRequest) Reset ¶
func (m *AppnameRequest) Reset()
func (*AppnameRequest) String ¶
func (m *AppnameRequest) String() string
type AppnameServer ¶
type AppnameServer interface {
Get(context.Context, *AppnameRequest) (*AppnameReply, error)
}
type AppsClient ¶
type AppsClient interface {
Get(ctx context.Context, in *AppsRequest, opts ...grpc.CallOption) (*AppsReply, error)
Watch(ctx context.Context, in *AppsRequest, opts ...grpc.CallOption) (Apps_WatchClient, error)
}
func NewAppsClient ¶
func NewAppsClient(cc *grpc.ClientConn) AppsClient
type AppsReply ¶
func (*AppsReply) Descriptor ¶
func (*AppsReply) ProtoMessage ¶
func (*AppsReply) ProtoMessage()
type AppsRequest ¶
type AppsRequest struct {
}
func (*AppsRequest) Descriptor ¶
func (*AppsRequest) Descriptor() ([]byte, []int)
func (*AppsRequest) ProtoMessage ¶
func (*AppsRequest) ProtoMessage()
func (*AppsRequest) Reset ¶
func (m *AppsRequest) Reset()
func (*AppsRequest) String ¶
func (m *AppsRequest) String() string
type AppsServer ¶
type AppsServer interface {
Get(context.Context, *AppsRequest) (*AppsReply, error)
Watch(*AppsRequest, Apps_WatchServer) error
}
type Apps_WatchClient ¶
type Apps_WatchClient interface {
Recv() (*AppsReply, error)
grpc.ClientStream
}
type Apps_WatchServer ¶
type Apps_WatchServer interface {
Send(*AppsReply) error
grpc.ServerStream
}
type BackupctlClient ¶
type BackupctlClient interface {
Get(ctx context.Context, in *BackupctlRequest, opts ...grpc.CallOption) (*BackupctlReply, error)
Watch(ctx context.Context, in *BackupctlRequest, opts ...grpc.CallOption) (Backupctl_WatchClient, error)
}
func NewBackupctlClient ¶
func NewBackupctlClient(cc *grpc.ClientConn) BackupctlClient
type BackupctlReply ¶
type BackupctlReply struct {
Data map[string]*BackupctlReply_PodInfoList `` /* 128-byte string literal not displayed */
}
func (*BackupctlReply) Descriptor ¶
func (*BackupctlReply) Descriptor() ([]byte, []int)
func (*BackupctlReply) GetData ¶
func (m *BackupctlReply) GetData() map[string]*BackupctlReply_PodInfoList
func (*BackupctlReply) ProtoMessage ¶
func (*BackupctlReply) ProtoMessage()
func (*BackupctlReply) Reset ¶
func (m *BackupctlReply) Reset()
func (*BackupctlReply) String ¶
func (m *BackupctlReply) String() string
type BackupctlReply_PodInfoList ¶
type BackupctlReply_PodInfoList struct {
Pods []*PodInfoForBackupctl `protobuf:"bytes,1,rep,name=pods" json:"pods,omitempty"`
}
func (*BackupctlReply_PodInfoList) Descriptor ¶
func (*BackupctlReply_PodInfoList) Descriptor() ([]byte, []int)
func (*BackupctlReply_PodInfoList) GetPods ¶
func (m *BackupctlReply_PodInfoList) GetPods() []*PodInfoForBackupctl
func (*BackupctlReply_PodInfoList) ProtoMessage ¶
func (*BackupctlReply_PodInfoList) ProtoMessage()
func (*BackupctlReply_PodInfoList) Reset ¶
func (m *BackupctlReply_PodInfoList) Reset()
func (*BackupctlReply_PodInfoList) String ¶
func (m *BackupctlReply_PodInfoList) String() string
type BackupctlRequest ¶
type BackupctlRequest struct {
Appname string `protobuf:"bytes,1,opt,name=Appname" json:"Appname,omitempty"`
}
func (*BackupctlRequest) Descriptor ¶
func (*BackupctlRequest) Descriptor() ([]byte, []int)
func (*BackupctlRequest) GetAppname ¶
func (m *BackupctlRequest) GetAppname() string
func (*BackupctlRequest) ProtoMessage ¶
func (*BackupctlRequest) ProtoMessage()
func (*BackupctlRequest) Reset ¶
func (m *BackupctlRequest) Reset()
func (*BackupctlRequest) String ¶
func (m *BackupctlRequest) String() string
type BackupctlServer ¶
type BackupctlServer interface {
Get(context.Context, *BackupctlRequest) (*BackupctlReply, error)
Watch(*BackupctlRequest, Backupctl_WatchServer) error
}
type Backupctl_WatchClient ¶
type Backupctl_WatchClient interface {
Recv() (*BackupctlReply, error)
grpc.ClientStream
}
type Backupctl_WatchServer ¶
type Backupctl_WatchServer interface {
Send(*BackupctlReply) error
grpc.ServerStream
}
type ConfigClient ¶
type ConfigClient interface {
Get(ctx context.Context, in *ConfigRequest, opts ...grpc.CallOption) (*ConfigReply, error)
Watch(ctx context.Context, in *ConfigRequest, opts ...grpc.CallOption) (Config_WatchClient, error)
}
func NewConfigClient ¶
func NewConfigClient(cc *grpc.ClientConn) ConfigClient
type ConfigReply ¶
func (*ConfigReply) Descriptor ¶
func (*ConfigReply) Descriptor() ([]byte, []int)
func (*ConfigReply) GetData ¶
func (m *ConfigReply) GetData() map[string]string
func (*ConfigReply) ProtoMessage ¶
func (*ConfigReply) ProtoMessage()
func (*ConfigReply) Reset ¶
func (m *ConfigReply) Reset()
func (*ConfigReply) String ¶
func (m *ConfigReply) String() string
type ConfigRequest ¶
type ConfigRequest struct {
Target string `protobuf:"bytes,1,opt,name=Target" json:"Target,omitempty"`
}
func (*ConfigRequest) Descriptor ¶
func (*ConfigRequest) Descriptor() ([]byte, []int)
func (*ConfigRequest) GetTarget ¶
func (m *ConfigRequest) GetTarget() string
func (*ConfigRequest) ProtoMessage ¶
func (*ConfigRequest) ProtoMessage()
func (*ConfigRequest) Reset ¶
func (m *ConfigRequest) Reset()
func (*ConfigRequest) String ¶
func (m *ConfigRequest) String() string
type ConfigServer ¶
type ConfigServer interface {
Get(context.Context, *ConfigRequest) (*ConfigReply, error)
Watch(*ConfigRequest, Config_WatchServer) error
}
type Config_WatchClient ¶
type Config_WatchClient interface {
Recv() (*ConfigReply, error)
grpc.ClientStream
}
type Config_WatchServer ¶
type Config_WatchServer interface {
Send(*ConfigReply) error
grpc.ServerStream
}
type Container ¶
type Container struct {
Command []string `protobuf:"bytes,1,rep,name=Command" json:"Command,omitempty"`
Id string `protobuf:"bytes,2,opt,name=Id" json:"Id,omitempty"`
Ip string `protobuf:"bytes,3,opt,name=Ip" json:"Ip,omitempty"`
Cpu int32 `protobuf:"varint,4,opt,name=Cpu" json:"Cpu,omitempty"`
Env []string `protobuf:"bytes,5,rep,name=Env" json:"Env,omitempty"`
Expose int32 `protobuf:"varint,6,opt,name=Expose" json:"Expose,omitempty"`
Image string `protobuf:"bytes,7,opt,name=Image" json:"Image,omitempty"`
Memory int64 `protobuf:"varint,8,opt,name=Memory" json:"Memory,omitempty"`
NodeIp string `protobuf:"bytes,9,opt,name=NodeIp" json:"NodeIp,omitempty"`
NodeName string `protobuf:"bytes,10,opt,name=NodeName" json:"NodeName,omitempty"`
Volumes []string `protobuf:"bytes,11,rep,name=Volumes" json:"Volumes,omitempty"`
}
func (*Container) Descriptor ¶
func (*Container) GetCommand ¶
func (*Container) GetNodeName ¶
func (*Container) GetVolumes ¶
func (*Container) ProtoMessage ¶
func (*Container) ProtoMessage()
type ContainerForBackupctl ¶
type ContainerForBackupctl struct {
Id string `protobuf:"bytes,1,opt,name=Id" json:"Id,omitempty"`
Ip string `protobuf:"bytes,2,opt,name=Ip" json:"Ip,omitempty"`
NodeIp string `protobuf:"bytes,3,opt,name=NodeIp" json:"NodeIp,omitempty"`
NodeName string `protobuf:"bytes,4,opt,name=NodeName" json:"NodeName,omitempty"`
}
func (*ContainerForBackupctl) Descriptor ¶
func (*ContainerForBackupctl) Descriptor() ([]byte, []int)
func (*ContainerForBackupctl) GetId ¶
func (m *ContainerForBackupctl) GetId() string
func (*ContainerForBackupctl) GetIp ¶
func (m *ContainerForBackupctl) GetIp() string
func (*ContainerForBackupctl) GetNodeIp ¶
func (m *ContainerForBackupctl) GetNodeIp() string
func (*ContainerForBackupctl) GetNodeName ¶
func (m *ContainerForBackupctl) GetNodeName() string
func (*ContainerForBackupctl) ProtoMessage ¶
func (*ContainerForBackupctl) ProtoMessage()
func (*ContainerForBackupctl) Reset ¶
func (m *ContainerForBackupctl) Reset()
func (*ContainerForBackupctl) String ¶
func (m *ContainerForBackupctl) String() string
type ContainerForProxy ¶
type ContainerForProxy struct {
ContainerIp string `protobuf:"bytes,1,opt,name=ContainerIp" json:"ContainerIp,omitempty"`
ContainerPort int32 `protobuf:"varint,2,opt,name=ContainerPort" json:"ContainerPort,omitempty"`
}
func (*ContainerForProxy) Descriptor ¶
func (*ContainerForProxy) Descriptor() ([]byte, []int)
func (*ContainerForProxy) GetContainerIp ¶
func (m *ContainerForProxy) GetContainerIp() string
func (*ContainerForProxy) GetContainerPort ¶
func (m *ContainerForProxy) GetContainerPort() int32
func (*ContainerForProxy) ProtoMessage ¶
func (*ContainerForProxy) ProtoMessage()
func (*ContainerForProxy) Reset ¶
func (m *ContainerForProxy) Reset()
func (*ContainerForProxy) String ¶
func (m *ContainerForProxy) String() string
type ContainerForWebrouter ¶
type ContainerForWebrouter struct {
IP string `protobuf:"bytes,1,opt,name=IP" json:"IP,omitempty"`
Expose int32 `protobuf:"varint,2,opt,name=Expose" json:"Expose,omitempty"`
}
func (*ContainerForWebrouter) Descriptor ¶
func (*ContainerForWebrouter) Descriptor() ([]byte, []int)
func (*ContainerForWebrouter) GetExpose ¶
func (m *ContainerForWebrouter) GetExpose() int32
func (*ContainerForWebrouter) GetIP ¶
func (m *ContainerForWebrouter) GetIP() string
func (*ContainerForWebrouter) ProtoMessage ¶
func (*ContainerForWebrouter) ProtoMessage()
func (*ContainerForWebrouter) Reset ¶
func (m *ContainerForWebrouter) Reset()
func (*ContainerForWebrouter) String ¶
func (m *ContainerForWebrouter) String() string
type ContainerInfo ¶
type ContainerInfo struct {
ContainerID string `protobuf:"bytes,1,opt,name=ContainerID" json:"ContainerID,omitempty"`
NodeIP string `protobuf:"bytes,2,opt,name=NodeIP" json:"NodeIP,omitempty"`
IP string `protobuf:"bytes,3,opt,name=IP" json:"IP,omitempty"`
Port int32 `protobuf:"varint,4,opt,name=Port" json:"Port,omitempty"`
}
func (*ContainerInfo) Descriptor ¶
func (*ContainerInfo) Descriptor() ([]byte, []int)
func (*ContainerInfo) GetContainerID ¶
func (m *ContainerInfo) GetContainerID() string
func (*ContainerInfo) GetIP ¶
func (m *ContainerInfo) GetIP() string
func (*ContainerInfo) GetNodeIP ¶
func (m *ContainerInfo) GetNodeIP() string
func (*ContainerInfo) GetPort ¶
func (m *ContainerInfo) GetPort() int32
func (*ContainerInfo) ProtoMessage ¶
func (*ContainerInfo) ProtoMessage()
func (*ContainerInfo) Reset ¶
func (m *ContainerInfo) Reset()
func (*ContainerInfo) String ¶
func (m *ContainerInfo) String() string
type ContainersClient ¶
type ContainersClient interface {
Get(ctx context.Context, in *ContainersRequest, opts ...grpc.CallOption) (*ContainersReply, error)
Watch(ctx context.Context, in *ContainersRequest, opts ...grpc.CallOption) (Containers_WatchClient, error)
}
func NewContainersClient ¶
func NewContainersClient(cc *grpc.ClientConn) ContainersClient
type ContainersReply ¶
type ContainersReply struct {
Data map[string]*Info `` /* 128-byte string literal not displayed */
}
func (*ContainersReply) Descriptor ¶
func (*ContainersReply) Descriptor() ([]byte, []int)
func (*ContainersReply) GetData ¶
func (m *ContainersReply) GetData() map[string]*Info
func (*ContainersReply) ProtoMessage ¶
func (*ContainersReply) ProtoMessage()
func (*ContainersReply) Reset ¶
func (m *ContainersReply) Reset()
func (*ContainersReply) String ¶
func (m *ContainersReply) String() string
type ContainersRequest ¶
type ContainersRequest struct {
Nodename string `protobuf:"bytes,1,opt,name=Nodename" json:"Nodename,omitempty"`
}
func (*ContainersRequest) Descriptor ¶
func (*ContainersRequest) Descriptor() ([]byte, []int)
func (*ContainersRequest) GetNodename ¶
func (m *ContainersRequest) GetNodename() string
func (*ContainersRequest) ProtoMessage ¶
func (*ContainersRequest) ProtoMessage()
func (*ContainersRequest) Reset ¶
func (m *ContainersRequest) Reset()
func (*ContainersRequest) String ¶
func (m *ContainersRequest) String() string
type ContainersServer ¶
type ContainersServer interface {
Get(context.Context, *ContainersRequest) (*ContainersReply, error)
Watch(*ContainersRequest, Containers_WatchServer) error
}
type Containers_WatchClient ¶
type Containers_WatchClient interface {
Recv() (*ContainersReply, error)
grpc.ClientStream
}
type Containers_WatchServer ¶
type Containers_WatchServer interface {
Send(*ContainersReply) error
grpc.ServerStream
}
type CoreInfo ¶
type CoreInfo struct {
PodInfos []*PodInfo `protobuf:"bytes,1,rep,name=PodInfos" json:"PodInfos,omitempty"`
}
func (*CoreInfo) Descriptor ¶
func (*CoreInfo) GetPodInfos ¶
func (*CoreInfo) ProtoMessage ¶
func (*CoreInfo) ProtoMessage()
type CoreInfoForRebellion ¶
type CoreInfoForRebellion struct {
PodInfos []*PodInfoForRebellion `protobuf:"bytes,1,rep,name=PodInfos" json:"PodInfos,omitempty"`
}
func (*CoreInfoForRebellion) Descriptor ¶
func (*CoreInfoForRebellion) Descriptor() ([]byte, []int)
func (*CoreInfoForRebellion) GetPodInfos ¶
func (m *CoreInfoForRebellion) GetPodInfos() []*PodInfoForRebellion
func (*CoreInfoForRebellion) ProtoMessage ¶
func (*CoreInfoForRebellion) ProtoMessage()
func (*CoreInfoForRebellion) Reset ¶
func (m *CoreInfoForRebellion) Reset()
func (*CoreInfoForRebellion) String ¶
func (m *CoreInfoForRebellion) String() string
type CoreInfoForWebrouter ¶
type CoreInfoForWebrouter struct {
PodInfos []*PodInfoForWebrouter `protobuf:"bytes,1,rep,name=PodInfos" json:"PodInfos,omitempty"`
}
func (*CoreInfoForWebrouter) Descriptor ¶
func (*CoreInfoForWebrouter) Descriptor() ([]byte, []int)
func (*CoreInfoForWebrouter) GetPodInfos ¶
func (m *CoreInfoForWebrouter) GetPodInfos() []*PodInfoForWebrouter
func (*CoreInfoForWebrouter) ProtoMessage ¶
func (*CoreInfoForWebrouter) ProtoMessage()
func (*CoreInfoForWebrouter) Reset ¶
func (m *CoreInfoForWebrouter) Reset()
func (*CoreInfoForWebrouter) String ¶
func (m *CoreInfoForWebrouter) String() string
type CoreinfoClient ¶
type CoreinfoClient interface {
Get(ctx context.Context, in *CoreinfoRequest, opts ...grpc.CallOption) (*CoreinfoReply, error)
Watch(ctx context.Context, in *CoreinfoRequest, opts ...grpc.CallOption) (Coreinfo_WatchClient, error)
}
func NewCoreinfoClient ¶
func NewCoreinfoClient(cc *grpc.ClientConn) CoreinfoClient
type CoreinfoReply ¶
type CoreinfoReply struct {
Data map[string]*CoreInfo `` /* 128-byte string literal not displayed */
}
func (*CoreinfoReply) Descriptor ¶
func (*CoreinfoReply) Descriptor() ([]byte, []int)
func (*CoreinfoReply) GetData ¶
func (m *CoreinfoReply) GetData() map[string]*CoreInfo
func (*CoreinfoReply) ProtoMessage ¶
func (*CoreinfoReply) ProtoMessage()
func (*CoreinfoReply) Reset ¶
func (m *CoreinfoReply) Reset()
func (*CoreinfoReply) String ¶
func (m *CoreinfoReply) String() string
type CoreinfoRequest ¶
type CoreinfoRequest struct {
Appname string `protobuf:"bytes,1,opt,name=Appname" json:"Appname,omitempty"`
}
func (*CoreinfoRequest) Descriptor ¶
func (*CoreinfoRequest) Descriptor() ([]byte, []int)
func (*CoreinfoRequest) GetAppname ¶
func (m *CoreinfoRequest) GetAppname() string
func (*CoreinfoRequest) ProtoMessage ¶
func (*CoreinfoRequest) ProtoMessage()
func (*CoreinfoRequest) Reset ¶
func (m *CoreinfoRequest) Reset()
func (*CoreinfoRequest) String ¶
func (m *CoreinfoRequest) String() string
type CoreinfoServer ¶
type CoreinfoServer interface {
Get(context.Context, *CoreinfoRequest) (*CoreinfoReply, error)
Watch(*CoreinfoRequest, Coreinfo_WatchServer) error
}
type Coreinfo_WatchClient ¶
type Coreinfo_WatchClient interface {
Recv() (*CoreinfoReply, error)
grpc.ClientStream
}
type Coreinfo_WatchServer ¶
type Coreinfo_WatchServer interface {
Send(*CoreinfoReply) error
grpc.ServerStream
}
type Dependency ¶
type Dependency struct {
PodName string `protobuf:"bytes,1,opt,name=PodName" json:"PodName,omitempty"`
Policy int32 `protobuf:"varint,2,opt,name=Policy" json:"Policy,omitempty"`
}
func (*Dependency) Descriptor ¶
func (*Dependency) Descriptor() ([]byte, []int)
func (*Dependency) GetPodName ¶
func (m *Dependency) GetPodName() string
func (*Dependency) GetPolicy ¶
func (m *Dependency) GetPolicy() int32
func (*Dependency) ProtoMessage ¶
func (*Dependency) ProtoMessage()
func (*Dependency) Reset ¶
func (m *Dependency) Reset()
func (*Dependency) String ¶
func (m *Dependency) String() string
type DependsAppMap ¶
type DependsAppMap struct {
Apps map[string]*DependsItem `` /* 128-byte string literal not displayed */
}
func (*DependsAppMap) Descriptor ¶
func (*DependsAppMap) Descriptor() ([]byte, []int)
func (*DependsAppMap) GetApps ¶
func (m *DependsAppMap) GetApps() map[string]*DependsItem
func (*DependsAppMap) ProtoMessage ¶
func (*DependsAppMap) ProtoMessage()
func (*DependsAppMap) Reset ¶
func (m *DependsAppMap) Reset()
func (*DependsAppMap) String ¶
func (m *DependsAppMap) String() string
type DependsClient ¶
type DependsClient interface {
Get(ctx context.Context, in *DependsRequest, opts ...grpc.CallOption) (*DependsReply, error)
Watch(ctx context.Context, in *DependsRequest, opts ...grpc.CallOption) (Depends_WatchClient, error)
}
func NewDependsClient ¶
func NewDependsClient(cc *grpc.ClientConn) DependsClient
type DependsItem ¶
type DependsItem struct {
Annotation string `protobuf:"bytes,1,opt,name=Annotation" json:"Annotation,omitempty"`
Containers []*ContainerInfo `protobuf:"bytes,2,rep,name=Containers" json:"Containers,omitempty"`
}
func (*DependsItem) Descriptor ¶
func (*DependsItem) Descriptor() ([]byte, []int)
func (*DependsItem) GetAnnotation ¶
func (m *DependsItem) GetAnnotation() string
func (*DependsItem) GetContainers ¶
func (m *DependsItem) GetContainers() []*ContainerInfo
func (*DependsItem) ProtoMessage ¶
func (*DependsItem) ProtoMessage()
func (*DependsItem) Reset ¶
func (m *DependsItem) Reset()
func (*DependsItem) String ¶
func (m *DependsItem) String() string
type DependsNodeMap ¶
type DependsNodeMap struct {
Nodes map[string]*DependsAppMap `` /* 130-byte string literal not displayed */
}
func (*DependsNodeMap) Descriptor ¶
func (*DependsNodeMap) Descriptor() ([]byte, []int)
func (*DependsNodeMap) GetNodes ¶
func (m *DependsNodeMap) GetNodes() map[string]*DependsAppMap
func (*DependsNodeMap) ProtoMessage ¶
func (*DependsNodeMap) ProtoMessage()
func (*DependsNodeMap) Reset ¶
func (m *DependsNodeMap) Reset()
func (*DependsNodeMap) String ¶
func (m *DependsNodeMap) String() string
type DependsReply ¶
type DependsReply struct {
Data map[string]*DependsNodeMap `` /* 128-byte string literal not displayed */
}
func (*DependsReply) Descriptor ¶
func (*DependsReply) Descriptor() ([]byte, []int)
func (*DependsReply) GetData ¶
func (m *DependsReply) GetData() map[string]*DependsNodeMap
func (*DependsReply) ProtoMessage ¶
func (*DependsReply) ProtoMessage()
func (*DependsReply) Reset ¶
func (m *DependsReply) Reset()
func (*DependsReply) String ¶
func (m *DependsReply) String() string
type DependsRequest ¶
type DependsRequest struct {
Target string `protobuf:"bytes,1,opt,name=Target" json:"Target,omitempty"`
}
func (*DependsRequest) Descriptor ¶
func (*DependsRequest) Descriptor() ([]byte, []int)
func (*DependsRequest) GetTarget ¶
func (m *DependsRequest) GetTarget() string
func (*DependsRequest) ProtoMessage ¶
func (*DependsRequest) ProtoMessage()
func (*DependsRequest) Reset ¶
func (m *DependsRequest) Reset()
func (*DependsRequest) String ¶
func (m *DependsRequest) String() string
type DependsServer ¶
type DependsServer interface {
Get(context.Context, *DependsRequest) (*DependsReply, error)
Watch(*DependsRequest, Depends_WatchServer) error
}
type Depends_WatchClient ¶
type Depends_WatchClient interface {
Recv() (*DependsReply, error)
grpc.ClientStream
}
type Depends_WatchServer ¶
type Depends_WatchServer interface {
Send(*DependsReply) error
grpc.ServerStream
}
type EmptyRequest ¶
type EmptyRequest struct {
}
func (*EmptyRequest) Descriptor ¶
func (*EmptyRequest) Descriptor() ([]byte, []int)
func (*EmptyRequest) ProtoMessage ¶
func (*EmptyRequest) ProtoMessage()
func (*EmptyRequest) Reset ¶
func (m *EmptyRequest) Reset()
func (*EmptyRequest) String ¶
func (m *EmptyRequest) String() string
type Info ¶
type Info struct {
AppName string `protobuf:"bytes,1,opt,name=AppName" json:"AppName,omitempty"`
AppVersion string `protobuf:"bytes,2,opt,name=AppVersion" json:"AppVersion,omitempty"`
ProcName string `protobuf:"bytes,3,opt,name=ProcName" json:"ProcName,omitempty"`
NodeName string `protobuf:"bytes,4,opt,name=NodeName" json:"NodeName,omitempty"`
NodeIP string `protobuf:"bytes,5,opt,name=NodeIP" json:"NodeIP,omitempty"`
IP string `protobuf:"bytes,6,opt,name=IP" json:"IP,omitempty"`
Port int32 `protobuf:"varint,7,opt,name=Port" json:"Port,omitempty"`
InstanceNo int32 `protobuf:"varint,8,opt,name=InstanceNo" json:"InstanceNo,omitempty"`
}
func (*Info) Descriptor ¶
func (*Info) GetAppName ¶
func (*Info) GetAppVersion ¶
func (*Info) GetInstanceNo ¶
func (*Info) GetNodeName ¶
func (*Info) GetProcName ¶
func (*Info) ProtoMessage ¶
func (*Info) ProtoMessage()
type LainletClient ¶
type LainletClient interface {
Version(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*VersionReply, error)
Status(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*StatusReply, error)
}
func NewLainletClient ¶
func NewLainletClient(cc *grpc.ClientConn) LainletClient
type LainletServer ¶
type LainletServer interface {
Version(context.Context, *EmptyRequest) (*VersionReply, error)
Status(context.Context, *EmptyRequest) (*StatusReply, error)
}
type LocalspecClient ¶
type LocalspecClient interface {
Get(ctx context.Context, in *LocalspecRequest, opts ...grpc.CallOption) (*LocalspecReply, error)
}
func NewLocalspecClient ¶
func NewLocalspecClient(cc *grpc.ClientConn) LocalspecClient
type LocalspecReply ¶
type LocalspecReply struct {
Data []string `protobuf:"bytes,1,rep,name=Data" json:"Data,omitempty"`
LocalIP string `protobuf:"bytes,2,opt,name=LocalIP" json:"LocalIP,omitempty"`
Ip string `protobuf:"bytes,3,opt,name=ip" json:"ip,omitempty"`
}
func (*LocalspecReply) Descriptor ¶
func (*LocalspecReply) Descriptor() ([]byte, []int)
func (*LocalspecReply) GetData ¶
func (m *LocalspecReply) GetData() []string
func (*LocalspecReply) GetIp ¶
func (m *LocalspecReply) GetIp() string
func (*LocalspecReply) GetLocalIP ¶
func (m *LocalspecReply) GetLocalIP() string
func (*LocalspecReply) ProtoMessage ¶
func (*LocalspecReply) ProtoMessage()
func (*LocalspecReply) Reset ¶
func (m *LocalspecReply) Reset()
func (*LocalspecReply) String ¶
func (m *LocalspecReply) String() string
type LocalspecRequest ¶
type LocalspecRequest struct {
Nodeip string `protobuf:"bytes,1,opt,name=Nodeip" json:"Nodeip,omitempty"`
}
func (*LocalspecRequest) Descriptor ¶
func (*LocalspecRequest) Descriptor() ([]byte, []int)
func (*LocalspecRequest) GetNodeip ¶
func (m *LocalspecRequest) GetNodeip() string
func (*LocalspecRequest) ProtoMessage ¶
func (*LocalspecRequest) ProtoMessage()
func (*LocalspecRequest) Reset ¶
func (m *LocalspecRequest) Reset()
func (*LocalspecRequest) String ¶
func (m *LocalspecRequest) String() string
type LocalspecServer ¶
type LocalspecServer interface {
Get(context.Context, *LocalspecRequest) (*LocalspecReply, error)
}
type NodeInfo ¶
type NodeInfo struct {
V map[string]*NodeInfo_Value `protobuf:"bytes,1,rep,name=v" json:"v,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
}
func (*NodeInfo) Descriptor ¶
func (*NodeInfo) GetV ¶
func (m *NodeInfo) GetV() map[string]*NodeInfo_Value
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
type NodeInfo_Value ¶
type NodeInfo_Value struct {
Vtype NodeInfo_Value_Type `protobuf:"varint,1,opt,name=Vtype,enum=message.NodeInfo_Value_Type" json:"Vtype,omitempty"`
Sval string `protobuf:"bytes,2,opt,name=sval" json:"sval,omitempty"`
Mval map[string]string `` /* 128-byte string literal not displayed */
}
Value can be a string or a map of type map[string]string
func (*NodeInfo_Value) Descriptor ¶
func (*NodeInfo_Value) Descriptor() ([]byte, []int)
func (*NodeInfo_Value) GetMval ¶
func (m *NodeInfo_Value) GetMval() map[string]string
func (*NodeInfo_Value) GetSval ¶
func (m *NodeInfo_Value) GetSval() string
func (*NodeInfo_Value) GetVtype ¶
func (m *NodeInfo_Value) GetVtype() NodeInfo_Value_Type
func (*NodeInfo_Value) ProtoMessage ¶
func (*NodeInfo_Value) ProtoMessage()
func (*NodeInfo_Value) Reset ¶
func (m *NodeInfo_Value) Reset()
func (*NodeInfo_Value) String ¶
func (m *NodeInfo_Value) String() string
type NodeInfo_Value_Type ¶
type NodeInfo_Value_Type int32
const ( NodeInfo_Value_STRING NodeInfo_Value_Type = 0 NodeInfo_Value_MAP NodeInfo_Value_Type = 1 )
func (NodeInfo_Value_Type) EnumDescriptor ¶
func (NodeInfo_Value_Type) EnumDescriptor() ([]byte, []int)
func (NodeInfo_Value_Type) String ¶
func (x NodeInfo_Value_Type) String() string
type NodesClient ¶
type NodesClient interface {
Get(ctx context.Context, in *NodesRequest, opts ...grpc.CallOption) (*NodesReply, error)
Watch(ctx context.Context, in *NodesRequest, opts ...grpc.CallOption) (Nodes_WatchClient, error)
}
func NewNodesClient ¶
func NewNodesClient(cc *grpc.ClientConn) NodesClient
type NodesReply ¶
func (*NodesReply) Descriptor ¶
func (*NodesReply) Descriptor() ([]byte, []int)
func (*NodesReply) GetData ¶
func (m *NodesReply) GetData() map[string]*NodeInfo
func (*NodesReply) ProtoMessage ¶
func (*NodesReply) ProtoMessage()
func (*NodesReply) Reset ¶
func (m *NodesReply) Reset()
func (*NodesReply) String ¶
func (m *NodesReply) String() string
type NodesRequest ¶
type NodesRequest struct {
Name string `protobuf:"bytes,1,opt,name=Name" json:"Name,omitempty"`
}
func (*NodesRequest) Descriptor ¶
func (*NodesRequest) Descriptor() ([]byte, []int)
func (*NodesRequest) GetName ¶
func (m *NodesRequest) GetName() string
func (*NodesRequest) ProtoMessage ¶
func (*NodesRequest) ProtoMessage()
func (*NodesRequest) Reset ¶
func (m *NodesRequest) Reset()
func (*NodesRequest) String ¶
func (m *NodesRequest) String() string
type NodesServer ¶
type NodesServer interface {
Get(context.Context, *NodesRequest) (*NodesReply, error)
Watch(*NodesRequest, Nodes_WatchServer) error
}
type Nodes_WatchClient ¶
type Nodes_WatchClient interface {
Recv() (*NodesReply, error)
grpc.ClientStream
}
type Nodes_WatchServer ¶
type Nodes_WatchServer interface {
Send(*NodesReply) error
grpc.ServerStream
}
type Pod ¶
type Pod struct {
InstanceNo int32 `protobuf:"varint,1,opt,name=InstanceNo" json:"InstanceNo,omitempty"`
IP string `protobuf:"bytes,2,opt,name=IP" json:"IP,omitempty"`
Port int32 `protobuf:"varint,3,opt,name=Port" json:"Port,omitempty"`
ProcName string `protobuf:"bytes,4,opt,name=ProcName" json:"ProcName,omitempty"`
}
func (*Pod) Descriptor ¶
func (*Pod) GetInstanceNo ¶
func (*Pod) GetProcName ¶
func (*Pod) ProtoMessage ¶
func (*Pod) ProtoMessage()
type PodGroup ¶
type PodGroup struct {
Pods []*Pod `protobuf:"bytes,1,rep,name=Pods" json:"Pods,omitempty"`
}
func (*PodGroup) Descriptor ¶
func (*PodGroup) ProtoMessage ¶
func (*PodGroup) ProtoMessage()
type PodInfo ¶
type PodInfo struct {
Annotation string `protobuf:"bytes,1,opt,name=Annotation" json:"Annotation,omitempty"`
Containers []*Container `protobuf:"bytes,2,rep,name=Containers" json:"Containers,omitempty"`
Dependencies []*Dependency `protobuf:"bytes,3,rep,name=Dependencies" json:"Dependencies,omitempty"`
InstanceNo int32 `protobuf:"varint,4,opt,name=InstanceNo" json:"InstanceNo,omitempty"`
}
func (*PodInfo) Descriptor ¶
func (*PodInfo) GetAnnotation ¶
func (*PodInfo) GetContainers ¶
func (*PodInfo) GetDependencies ¶
func (m *PodInfo) GetDependencies() []*Dependency
func (*PodInfo) GetInstanceNo ¶
func (*PodInfo) ProtoMessage ¶
func (*PodInfo) ProtoMessage()
type PodInfoForBackupctl ¶
type PodInfoForBackupctl struct {
Annotation string `protobuf:"bytes,1,opt,name=Annotation" json:"Annotation,omitempty"`
Containers []*ContainerForBackupctl `protobuf:"bytes,2,rep,name=Containers" json:"Containers,omitempty"`
InstanceNo int32 `protobuf:"varint,3,opt,name=InstanceNo" json:"InstanceNo,omitempty"`
}
func (*PodInfoForBackupctl) Descriptor ¶
func (*PodInfoForBackupctl) Descriptor() ([]byte, []int)
func (*PodInfoForBackupctl) GetAnnotation ¶
func (m *PodInfoForBackupctl) GetAnnotation() string
func (*PodInfoForBackupctl) GetContainers ¶
func (m *PodInfoForBackupctl) GetContainers() []*ContainerForBackupctl
func (*PodInfoForBackupctl) GetInstanceNo ¶
func (m *PodInfoForBackupctl) GetInstanceNo() int32
func (*PodInfoForBackupctl) ProtoMessage ¶
func (*PodInfoForBackupctl) ProtoMessage()
func (*PodInfoForBackupctl) Reset ¶
func (m *PodInfoForBackupctl) Reset()
func (*PodInfoForBackupctl) String ¶
func (m *PodInfoForBackupctl) String() string
type PodInfoForRebellion ¶
type PodInfoForRebellion struct {
Annotation string `protobuf:"bytes,1,opt,name=Annotation" json:"Annotation,omitempty"`
AppVersion string `protobuf:"bytes,2,opt,name=AppVersion" json:"AppVersion,omitempty"`
InstanceNo int32 `protobuf:"varint,3,opt,name=InstanceNo" json:"InstanceNo,omitempty"`
}
func (*PodInfoForRebellion) Descriptor ¶
func (*PodInfoForRebellion) Descriptor() ([]byte, []int)
func (*PodInfoForRebellion) GetAnnotation ¶
func (m *PodInfoForRebellion) GetAnnotation() string
func (*PodInfoForRebellion) GetAppVersion ¶
func (m *PodInfoForRebellion) GetAppVersion() string
func (*PodInfoForRebellion) GetInstanceNo ¶
func (m *PodInfoForRebellion) GetInstanceNo() int32
func (*PodInfoForRebellion) ProtoMessage ¶
func (*PodInfoForRebellion) ProtoMessage()
func (*PodInfoForRebellion) Reset ¶
func (m *PodInfoForRebellion) Reset()
func (*PodInfoForRebellion) String ¶
func (m *PodInfoForRebellion) String() string
type PodInfoForWebrouter ¶
type PodInfoForWebrouter struct {
Annotation string `protobuf:"bytes,1,opt,name=Annotation" json:"Annotation,omitempty"`
Containers []*ContainerForWebrouter `protobuf:"bytes,2,rep,name=Containers" json:"Containers,omitempty"`
}
func (*PodInfoForWebrouter) Descriptor ¶
func (*PodInfoForWebrouter) Descriptor() ([]byte, []int)
func (*PodInfoForWebrouter) GetAnnotation ¶
func (m *PodInfoForWebrouter) GetAnnotation() string
func (*PodInfoForWebrouter) GetContainers ¶
func (m *PodInfoForWebrouter) GetContainers() []*ContainerForWebrouter
func (*PodInfoForWebrouter) ProtoMessage ¶
func (*PodInfoForWebrouter) ProtoMessage()
func (*PodInfoForWebrouter) Reset ¶
func (m *PodInfoForWebrouter) Reset()
func (*PodInfoForWebrouter) String ¶
func (m *PodInfoForWebrouter) String() string
type PodgroupClient ¶
type PodgroupClient interface {
Get(ctx context.Context, in *PodgroupRequest, opts ...grpc.CallOption) (*PodgroupReply, error)
Watch(ctx context.Context, in *PodgroupRequest, opts ...grpc.CallOption) (Podgroup_WatchClient, error)
}
func NewPodgroupClient ¶
func NewPodgroupClient(cc *grpc.ClientConn) PodgroupClient
type PodgroupReply ¶
type PodgroupReply struct {
Data []*PodGroup `protobuf:"bytes,1,rep,name=Data" json:"Data,omitempty"`
}
func (*PodgroupReply) Descriptor ¶
func (*PodgroupReply) Descriptor() ([]byte, []int)
func (*PodgroupReply) GetData ¶
func (m *PodgroupReply) GetData() []*PodGroup
func (*PodgroupReply) ProtoMessage ¶
func (*PodgroupReply) ProtoMessage()
func (*PodgroupReply) Reset ¶
func (m *PodgroupReply) Reset()
func (*PodgroupReply) String ¶
func (m *PodgroupReply) String() string
type PodgroupRequest ¶
type PodgroupRequest struct {
Appname string `protobuf:"bytes,1,opt,name=Appname" json:"Appname,omitempty"`
}
func (*PodgroupRequest) Descriptor ¶
func (*PodgroupRequest) Descriptor() ([]byte, []int)
func (*PodgroupRequest) GetAppname ¶
func (m *PodgroupRequest) GetAppname() string
func (*PodgroupRequest) ProtoMessage ¶
func (*PodgroupRequest) ProtoMessage()
func (*PodgroupRequest) Reset ¶
func (m *PodgroupRequest) Reset()
func (*PodgroupRequest) String ¶
func (m *PodgroupRequest) String() string
type PodgroupServer ¶
type PodgroupServer interface {
Get(context.Context, *PodgroupRequest) (*PodgroupReply, error)
Watch(*PodgroupRequest, Podgroup_WatchServer) error
}
type Podgroup_WatchClient ¶
type Podgroup_WatchClient interface {
Recv() (*PodgroupReply, error)
grpc.ClientStream
}
type Podgroup_WatchServer ¶
type Podgroup_WatchServer interface {
Send(*PodgroupReply) error
grpc.ServerStream
}
type Port ¶
type Port struct {
Srcport int32 `protobuf:"varint,1,opt,name=Srcport" json:"Srcport,omitempty"`
Dstport int32 `protobuf:"varint,2,opt,name=Dstport" json:"Dstport,omitempty"`
Proto string `protobuf:"bytes,3,opt,name=Proto" json:"Proto,omitempty"`
}
func (*Port) Descriptor ¶
func (*Port) GetDstport ¶
func (*Port) GetSrcport ¶
func (*Port) ProtoMessage ¶
func (*Port) ProtoMessage()
type ProcInfo ¶
type ProcInfo struct {
Containers []*ContainerForProxy `protobuf:"bytes,1,rep,name=Containers" json:"Containers,omitempty"`
}
func (*ProcInfo) Descriptor ¶
func (*ProcInfo) GetContainers ¶
func (m *ProcInfo) GetContainers() []*ContainerForProxy
func (*ProcInfo) ProtoMessage ¶
func (*ProcInfo) ProtoMessage()
type ProxyClient ¶
type ProxyClient interface {
Get(ctx context.Context, in *ProxyRequest, opts ...grpc.CallOption) (*ProxyReply, error)
Watch(ctx context.Context, in *ProxyRequest, opts ...grpc.CallOption) (Proxy_WatchClient, error)
}
func NewProxyClient ¶
func NewProxyClient(cc *grpc.ClientConn) ProxyClient
type ProxyReply ¶
func (*ProxyReply) Descriptor ¶
func (*ProxyReply) Descriptor() ([]byte, []int)
func (*ProxyReply) GetData ¶
func (m *ProxyReply) GetData() map[string]*ProcInfo
func (*ProxyReply) ProtoMessage ¶
func (*ProxyReply) ProtoMessage()
func (*ProxyReply) Reset ¶
func (m *ProxyReply) Reset()
func (*ProxyReply) String ¶
func (m *ProxyReply) String() string
type ProxyRequest ¶
type ProxyRequest struct {
Appname string `protobuf:"bytes,1,opt,name=Appname" json:"Appname,omitempty"`
}
func (*ProxyRequest) Descriptor ¶
func (*ProxyRequest) Descriptor() ([]byte, []int)
func (*ProxyRequest) GetAppname ¶
func (m *ProxyRequest) GetAppname() string
func (*ProxyRequest) ProtoMessage ¶
func (*ProxyRequest) ProtoMessage()
func (*ProxyRequest) Reset ¶
func (m *ProxyRequest) Reset()
func (*ProxyRequest) String ¶
func (m *ProxyRequest) String() string
type ProxyServer ¶
type ProxyServer interface {
Get(context.Context, *ProxyRequest) (*ProxyReply, error)
Watch(*ProxyRequest, Proxy_WatchServer) error
}
type Proxy_WatchClient ¶
type Proxy_WatchClient interface {
Recv() (*ProxyReply, error)
grpc.ClientStream
}
type Proxy_WatchServer ¶
type Proxy_WatchServer interface {
Send(*ProxyReply) error
grpc.ServerStream
}
type RebellionLocalprocsClient ¶
type RebellionLocalprocsClient interface {
Get(ctx context.Context, in *RebellionLocalprocsRequest, opts ...grpc.CallOption) (*RebellionLocalprocsReply, error)
Watch(ctx context.Context, in *RebellionLocalprocsRequest, opts ...grpc.CallOption) (RebellionLocalprocs_WatchClient, error)
}
func NewRebellionLocalprocsClient ¶
func NewRebellionLocalprocsClient(cc *grpc.ClientConn) RebellionLocalprocsClient
type RebellionLocalprocsReply ¶
type RebellionLocalprocsReply struct {
Data map[string]*CoreInfoForRebellion `` /* 128-byte string literal not displayed */
}
func (*RebellionLocalprocsReply) Descriptor ¶
func (*RebellionLocalprocsReply) Descriptor() ([]byte, []int)
func (*RebellionLocalprocsReply) GetData ¶
func (m *RebellionLocalprocsReply) GetData() map[string]*CoreInfoForRebellion
func (*RebellionLocalprocsReply) ProtoMessage ¶
func (*RebellionLocalprocsReply) ProtoMessage()
func (*RebellionLocalprocsReply) Reset ¶
func (m *RebellionLocalprocsReply) Reset()
func (*RebellionLocalprocsReply) String ¶
func (m *RebellionLocalprocsReply) String() string
type RebellionLocalprocsRequest ¶
type RebellionLocalprocsRequest struct {
Appname string `protobuf:"bytes,1,opt,name=Appname" json:"Appname,omitempty"`
}
func (*RebellionLocalprocsRequest) Descriptor ¶
func (*RebellionLocalprocsRequest) Descriptor() ([]byte, []int)
func (*RebellionLocalprocsRequest) GetAppname ¶
func (m *RebellionLocalprocsRequest) GetAppname() string
func (*RebellionLocalprocsRequest) ProtoMessage ¶
func (*RebellionLocalprocsRequest) ProtoMessage()
func (*RebellionLocalprocsRequest) Reset ¶
func (m *RebellionLocalprocsRequest) Reset()
func (*RebellionLocalprocsRequest) String ¶
func (m *RebellionLocalprocsRequest) String() string
type RebellionLocalprocsServer ¶
type RebellionLocalprocsServer interface {
Get(context.Context, *RebellionLocalprocsRequest) (*RebellionLocalprocsReply, error)
Watch(*RebellionLocalprocsRequest, RebellionLocalprocs_WatchServer) error
}
type RebellionLocalprocs_WatchClient ¶
type RebellionLocalprocs_WatchClient interface {
Recv() (*RebellionLocalprocsReply, error)
grpc.ClientStream
}
type RebellionLocalprocs_WatchServer ¶
type RebellionLocalprocs_WatchServer interface {
Send(*RebellionLocalprocsReply) error
grpc.ServerStream
}
type StatusReply ¶
type StatusReply struct {
Goroutines int32 `protobuf:"varint,1,opt,name=Goroutines" json:"Goroutines,omitempty"`
Status map[string]*WatcherStatus `` /* 132-byte string literal not displayed */
}
func (*StatusReply) Descriptor ¶
func (*StatusReply) Descriptor() ([]byte, []int)
func (*StatusReply) GetGoroutines ¶
func (m *StatusReply) GetGoroutines() int32
func (*StatusReply) GetStatus ¶
func (m *StatusReply) GetStatus() map[string]*WatcherStatus
func (*StatusReply) ProtoMessage ¶
func (*StatusReply) ProtoMessage()
func (*StatusReply) Reset ¶
func (m *StatusReply) Reset()
func (*StatusReply) String ¶
func (m *StatusReply) String() string
type StreamProc ¶
type StreamProc struct {
Name string `protobuf:"bytes,1,opt,name=Name" json:"Name,omitempty"`
Upstreams []*StreamUpstream `protobuf:"bytes,2,rep,name=Upstreams" json:"Upstreams,omitempty"`
Services []*StreamService `protobuf:"bytes,3,rep,name=Services" json:"Services,omitempty"`
}
func (*StreamProc) Descriptor ¶
func (*StreamProc) Descriptor() ([]byte, []int)
func (*StreamProc) GetName ¶
func (m *StreamProc) GetName() string
func (*StreamProc) GetServices ¶
func (m *StreamProc) GetServices() []*StreamService
func (*StreamProc) GetUpstreams ¶
func (m *StreamProc) GetUpstreams() []*StreamUpstream
func (*StreamProc) ProtoMessage ¶
func (*StreamProc) ProtoMessage()
func (*StreamProc) Reset ¶
func (m *StreamProc) Reset()
func (*StreamProc) String ¶
func (m *StreamProc) String() string
type StreamProcList ¶
type StreamProcList struct {
Procs []*StreamProc `protobuf:"bytes,1,rep,name=procs" json:"procs,omitempty"`
}
func (*StreamProcList) Descriptor ¶
func (*StreamProcList) Descriptor() ([]byte, []int)
func (*StreamProcList) GetProcs ¶
func (m *StreamProcList) GetProcs() []*StreamProc
func (*StreamProcList) ProtoMessage ¶
func (*StreamProcList) ProtoMessage()
func (*StreamProcList) Reset ¶
func (m *StreamProcList) Reset()
func (*StreamProcList) String ¶
func (m *StreamProcList) String() string
type StreamService ¶
type StreamService struct {
UpstreamPort int32 `protobuf:"varint,1,opt,name=UpstreamPort" json:"UpstreamPort,omitempty"`
ListenPort int32 `protobuf:"varint,2,opt,name=ListenPort" json:"ListenPort,omitempty"`
Send string `protobuf:"bytes,3,opt,name=Send" json:"Send,omitempty"`
Expect string `protobuf:"bytes,4,opt,name=Expect" json:"Expect,omitempty"`
}
func (*StreamService) Descriptor ¶
func (*StreamService) Descriptor() ([]byte, []int)
func (*StreamService) GetExpect ¶
func (m *StreamService) GetExpect() string
func (*StreamService) GetListenPort ¶
func (m *StreamService) GetListenPort() int32
func (*StreamService) GetSend ¶
func (m *StreamService) GetSend() string
func (*StreamService) GetUpstreamPort ¶
func (m *StreamService) GetUpstreamPort() int32
func (*StreamService) ProtoMessage ¶
func (*StreamService) ProtoMessage()
func (*StreamService) Reset ¶
func (m *StreamService) Reset()
func (*StreamService) String ¶
func (m *StreamService) String() string
type StreamUpstream ¶
type StreamUpstream struct {
Host string `protobuf:"bytes,1,opt,name=Host" json:"Host,omitempty"`
InstanceNo int32 `protobuf:"varint,2,opt,name=InstanceNo" json:"InstanceNo,omitempty"`
}
func (*StreamUpstream) Descriptor ¶
func (*StreamUpstream) Descriptor() ([]byte, []int)
func (*StreamUpstream) GetHost ¶
func (m *StreamUpstream) GetHost() string
func (*StreamUpstream) GetInstanceNo ¶
func (m *StreamUpstream) GetInstanceNo() int32
func (*StreamUpstream) ProtoMessage ¶
func (*StreamUpstream) ProtoMessage()
func (*StreamUpstream) Reset ¶
func (m *StreamUpstream) Reset()
func (*StreamUpstream) String ¶
func (m *StreamUpstream) String() string
type StreamrouterPortsClient ¶
type StreamrouterPortsClient interface {
Get(ctx context.Context, in *StreamrouterPortsRequest, opts ...grpc.CallOption) (*StreamrouterPortsReply, error)
Watch(ctx context.Context, in *StreamrouterPortsRequest, opts ...grpc.CallOption) (StreamrouterPorts_WatchClient, error)
}
func NewStreamrouterPortsClient ¶
func NewStreamrouterPortsClient(cc *grpc.ClientConn) StreamrouterPortsClient
type StreamrouterPortsReply ¶
type StreamrouterPortsReply struct {
Data []int32 `protobuf:"varint,1,rep,packed,name=Data" json:"Data,omitempty"`
}
func (*StreamrouterPortsReply) Descriptor ¶
func (*StreamrouterPortsReply) Descriptor() ([]byte, []int)
func (*StreamrouterPortsReply) GetData ¶
func (m *StreamrouterPortsReply) GetData() []int32
func (*StreamrouterPortsReply) ProtoMessage ¶
func (*StreamrouterPortsReply) ProtoMessage()
func (*StreamrouterPortsReply) Reset ¶
func (m *StreamrouterPortsReply) Reset()
func (*StreamrouterPortsReply) String ¶
func (m *StreamrouterPortsReply) String() string
type StreamrouterPortsRequest ¶
type StreamrouterPortsRequest struct {
Appname string `protobuf:"bytes,1,opt,name=Appname" json:"Appname,omitempty"`
}
func (*StreamrouterPortsRequest) Descriptor ¶
func (*StreamrouterPortsRequest) Descriptor() ([]byte, []int)
func (*StreamrouterPortsRequest) GetAppname ¶
func (m *StreamrouterPortsRequest) GetAppname() string
func (*StreamrouterPortsRequest) ProtoMessage ¶
func (*StreamrouterPortsRequest) ProtoMessage()
func (*StreamrouterPortsRequest) Reset ¶
func (m *StreamrouterPortsRequest) Reset()
func (*StreamrouterPortsRequest) String ¶
func (m *StreamrouterPortsRequest) String() string
type StreamrouterPortsServer ¶
type StreamrouterPortsServer interface {
Get(context.Context, *StreamrouterPortsRequest) (*StreamrouterPortsReply, error)
Watch(*StreamrouterPortsRequest, StreamrouterPorts_WatchServer) error
}
type StreamrouterPorts_WatchClient ¶
type StreamrouterPorts_WatchClient interface {
Recv() (*StreamrouterPortsReply, error)
grpc.ClientStream
}
type StreamrouterPorts_WatchServer ¶
type StreamrouterPorts_WatchServer interface {
Send(*StreamrouterPortsReply) error
grpc.ServerStream
}
type StreamrouterStreamprocsClient ¶
type StreamrouterStreamprocsClient interface {
Get(ctx context.Context, in *StreamrouterStreamprocsRequest, opts ...grpc.CallOption) (*StreamrouterStreamprocsReply, error)
Watch(ctx context.Context, in *StreamrouterStreamprocsRequest, opts ...grpc.CallOption) (StreamrouterStreamprocs_WatchClient, error)
}
func NewStreamrouterStreamprocsClient ¶
func NewStreamrouterStreamprocsClient(cc *grpc.ClientConn) StreamrouterStreamprocsClient
type StreamrouterStreamprocsReply ¶
type StreamrouterStreamprocsReply struct {
Data map[string]*StreamProcList `` /* 128-byte string literal not displayed */
}
func (*StreamrouterStreamprocsReply) Descriptor ¶
func (*StreamrouterStreamprocsReply) Descriptor() ([]byte, []int)
func (*StreamrouterStreamprocsReply) GetData ¶
func (m *StreamrouterStreamprocsReply) GetData() map[string]*StreamProcList
func (*StreamrouterStreamprocsReply) ProtoMessage ¶
func (*StreamrouterStreamprocsReply) ProtoMessage()
func (*StreamrouterStreamprocsReply) Reset ¶
func (m *StreamrouterStreamprocsReply) Reset()
func (*StreamrouterStreamprocsReply) String ¶
func (m *StreamrouterStreamprocsReply) String() string
type StreamrouterStreamprocsRequest ¶
type StreamrouterStreamprocsRequest struct {
Appname string `protobuf:"bytes,1,opt,name=Appname" json:"Appname,omitempty"`
}
func (*StreamrouterStreamprocsRequest) Descriptor ¶
func (*StreamrouterStreamprocsRequest) Descriptor() ([]byte, []int)
func (*StreamrouterStreamprocsRequest) GetAppname ¶
func (m *StreamrouterStreamprocsRequest) GetAppname() string
func (*StreamrouterStreamprocsRequest) ProtoMessage ¶
func (*StreamrouterStreamprocsRequest) ProtoMessage()
func (*StreamrouterStreamprocsRequest) Reset ¶
func (m *StreamrouterStreamprocsRequest) Reset()
func (*StreamrouterStreamprocsRequest) String ¶
func (m *StreamrouterStreamprocsRequest) String() string
type StreamrouterStreamprocsServer ¶
type StreamrouterStreamprocsServer interface {
Get(context.Context, *StreamrouterStreamprocsRequest) (*StreamrouterStreamprocsReply, error)
Watch(*StreamrouterStreamprocsRequest, StreamrouterStreamprocs_WatchServer) error
}
type StreamrouterStreamprocs_WatchClient ¶
type StreamrouterStreamprocs_WatchClient interface {
Recv() (*StreamrouterStreamprocsReply, error)
grpc.ClientStream
}
type StreamrouterStreamprocs_WatchServer ¶
type StreamrouterStreamprocs_WatchServer interface {
Send(*StreamrouterStreamprocsReply) error
grpc.ServerStream
}
type VersionReply ¶
type VersionReply struct {
Version string `protobuf:"bytes,1,opt,name=Version" json:"Version,omitempty"`
APIVersion string `protobuf:"bytes,2,opt,name=APIVersion" json:"APIVersion,omitempty"`
}
func (*VersionReply) Descriptor ¶
func (*VersionReply) Descriptor() ([]byte, []int)
func (*VersionReply) GetAPIVersion ¶
func (m *VersionReply) GetAPIVersion() string
func (*VersionReply) GetVersion ¶
func (m *VersionReply) GetVersion() string
func (*VersionReply) ProtoMessage ¶
func (*VersionReply) ProtoMessage()
func (*VersionReply) Reset ¶
func (m *VersionReply) Reset()
func (*VersionReply) String ¶
func (m *VersionReply) String() string
type WatcherStatus ¶
type WatcherStatus struct {
NumReceivers int32 `protobuf:"varint,1,opt,name=NumReceivers" json:"NumReceivers,omitempty"`
UpdateTime int64 `protobuf:"varint,2,opt,name=UpdateTime" json:"UpdateTime,omitempty"`
LastEvent []byte `protobuf:"bytes,3,opt,name=LastEvent,proto3" json:"LastEvent,omitempty"`
TotalKeys int32 `protobuf:"varint,4,opt,name=TotalKeys" json:"TotalKeys,omitempty"`
}
func (*WatcherStatus) Descriptor ¶
func (*WatcherStatus) Descriptor() ([]byte, []int)
func (*WatcherStatus) GetLastEvent ¶
func (m *WatcherStatus) GetLastEvent() []byte
func (*WatcherStatus) GetNumReceivers ¶
func (m *WatcherStatus) GetNumReceivers() int32
func (*WatcherStatus) GetTotalKeys ¶
func (m *WatcherStatus) GetTotalKeys() int32
func (*WatcherStatus) GetUpdateTime ¶
func (m *WatcherStatus) GetUpdateTime() int64
func (*WatcherStatus) ProtoMessage ¶
func (*WatcherStatus) ProtoMessage()
func (*WatcherStatus) Reset ¶
func (m *WatcherStatus) Reset()
func (*WatcherStatus) String ¶
func (m *WatcherStatus) String() string
type WebrouterWebprocsClient ¶
type WebrouterWebprocsClient interface {
Get(ctx context.Context, in *WebrouterWebprocsRequest, opts ...grpc.CallOption) (*WebrouterWebprocsReply, error)
Watch(ctx context.Context, in *WebrouterWebprocsRequest, opts ...grpc.CallOption) (WebrouterWebprocs_WatchClient, error)
}
func NewWebrouterWebprocsClient ¶
func NewWebrouterWebprocsClient(cc *grpc.ClientConn) WebrouterWebprocsClient
type WebrouterWebprocsReply ¶
type WebrouterWebprocsReply struct {
Data map[string]*CoreInfoForWebrouter `` /* 128-byte string literal not displayed */
}
func (*WebrouterWebprocsReply) Descriptor ¶
func (*WebrouterWebprocsReply) Descriptor() ([]byte, []int)
func (*WebrouterWebprocsReply) GetData ¶
func (m *WebrouterWebprocsReply) GetData() map[string]*CoreInfoForWebrouter
func (*WebrouterWebprocsReply) ProtoMessage ¶
func (*WebrouterWebprocsReply) ProtoMessage()
func (*WebrouterWebprocsReply) Reset ¶
func (m *WebrouterWebprocsReply) Reset()
func (*WebrouterWebprocsReply) String ¶
func (m *WebrouterWebprocsReply) String() string
type WebrouterWebprocsRequest ¶
type WebrouterWebprocsRequest struct {
Appname string `protobuf:"bytes,1,opt,name=Appname" json:"Appname,omitempty"`
}
func (*WebrouterWebprocsRequest) Descriptor ¶
func (*WebrouterWebprocsRequest) Descriptor() ([]byte, []int)
func (*WebrouterWebprocsRequest) GetAppname ¶
func (m *WebrouterWebprocsRequest) GetAppname() string
func (*WebrouterWebprocsRequest) ProtoMessage ¶
func (*WebrouterWebprocsRequest) ProtoMessage()
func (*WebrouterWebprocsRequest) Reset ¶
func (m *WebrouterWebprocsRequest) Reset()
func (*WebrouterWebprocsRequest) String ¶
func (m *WebrouterWebprocsRequest) String() string
type WebrouterWebprocsServer ¶
type WebrouterWebprocsServer interface {
Get(context.Context, *WebrouterWebprocsRequest) (*WebrouterWebprocsReply, error)
Watch(*WebrouterWebprocsRequest, WebrouterWebprocs_WatchServer) error
}
type WebrouterWebprocs_WatchClient ¶
type WebrouterWebprocs_WatchClient interface {
Recv() (*WebrouterWebprocsReply, error)
grpc.ClientStream
}
type WebrouterWebprocs_WatchServer ¶
type WebrouterWebprocs_WatchServer interface {
Send(*WebrouterWebprocsReply) error
grpc.ServerStream
}
Click to show internal directories.
Click to hide internal directories.