message

package
v2.4.4+incompatible Latest Latest
Warning

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

Go to latest
Published: May 11, 2018 License: MIT Imports: 5 Imported by: 1

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

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) Descriptor() ([]byte, []int)

func (*AppInfo) GetAppname

func (m *AppInfo) GetAppname() string

func (*AppInfo) ProtoMessage

func (*AppInfo) ProtoMessage()

func (*AppInfo) Reset

func (m *AppInfo) Reset()

func (*AppInfo) String

func (m *AppInfo) String() string

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

type AppnameReply struct {
	Data map[string]string `` /* 128-byte string literal not displayed */
}

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

type AppsReply struct {
	Data map[string]*AppInfo `` /* 128-byte string literal not displayed */
}

func (*AppsReply) Descriptor

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

func (*AppsReply) GetData

func (m *AppsReply) GetData() map[string]*AppInfo

func (*AppsReply) ProtoMessage

func (*AppsReply) ProtoMessage()

func (*AppsReply) Reset

func (m *AppsReply) Reset()

func (*AppsReply) String

func (m *AppsReply) String() string

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 (*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 (*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 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

type ConfigReply struct {
	Data map[string]string `` /* 128-byte string literal not displayed */
}

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) Descriptor() ([]byte, []int)

func (*Container) GetCommand

func (m *Container) GetCommand() []string

func (*Container) GetCpu

func (m *Container) GetCpu() int32

func (*Container) GetEnv

func (m *Container) GetEnv() []string

func (*Container) GetExpose

func (m *Container) GetExpose() int32

func (*Container) GetId

func (m *Container) GetId() string

func (*Container) GetImage

func (m *Container) GetImage() string

func (*Container) GetIp

func (m *Container) GetIp() string

func (*Container) GetMemory

func (m *Container) GetMemory() int64

func (*Container) GetNodeIp

func (m *Container) GetNodeIp() string

func (*Container) GetNodeName

func (m *Container) GetNodeName() string

func (*Container) GetVolumes

func (m *Container) GetVolumes() []string

func (*Container) ProtoMessage

func (*Container) ProtoMessage()

func (*Container) Reset

func (m *Container) Reset()

func (*Container) String

func (m *Container) String() string

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 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) Descriptor() ([]byte, []int)

func (*CoreInfo) GetPodInfos

func (m *CoreInfo) GetPodInfos() []*PodInfo

func (*CoreInfo) ProtoMessage

func (*CoreInfo) ProtoMessage()

func (*CoreInfo) Reset

func (m *CoreInfo) Reset()

func (*CoreInfo) String

func (m *CoreInfo) String() string

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) Descriptor() ([]byte, []int)

func (*Info) GetAppName

func (m *Info) GetAppName() string

func (*Info) GetAppVersion

func (m *Info) GetAppVersion() string

func (*Info) GetIP

func (m *Info) GetIP() string

func (*Info) GetInstanceNo

func (m *Info) GetInstanceNo() int32

func (*Info) GetNodeIP

func (m *Info) GetNodeIP() string

func (*Info) GetNodeName

func (m *Info) GetNodeName() string

func (*Info) GetPort

func (m *Info) GetPort() int32

func (*Info) GetProcName

func (m *Info) GetProcName() string

func (*Info) ProtoMessage

func (*Info) ProtoMessage()

func (*Info) Reset

func (m *Info) Reset()

func (*Info) String

func (m *Info) String() string

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) Descriptor() ([]byte, []int)

func (*NodeInfo) GetV

func (m *NodeInfo) GetV() map[string]*NodeInfo_Value

func (*NodeInfo) ProtoMessage

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset

func (m *NodeInfo) Reset()

func (*NodeInfo) String

func (m *NodeInfo) String() string

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

type NodesReply struct {
	Data map[string]*NodeInfo `` /* 128-byte string literal not displayed */
}

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) Descriptor() ([]byte, []int)

func (*Pod) GetIP

func (m *Pod) GetIP() string

func (*Pod) GetInstanceNo

func (m *Pod) GetInstanceNo() int32

func (*Pod) GetPort

func (m *Pod) GetPort() int32

func (*Pod) GetProcName

func (m *Pod) GetProcName() string

func (*Pod) ProtoMessage

func (*Pod) ProtoMessage()

func (*Pod) Reset

func (m *Pod) Reset()

func (*Pod) String

func (m *Pod) String() string

type PodGroup

type PodGroup struct {
	Pods []*Pod `protobuf:"bytes,1,rep,name=Pods" json:"Pods,omitempty"`
}

func (*PodGroup) Descriptor

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

func (*PodGroup) GetPods

func (m *PodGroup) GetPods() []*Pod

func (*PodGroup) ProtoMessage

func (*PodGroup) ProtoMessage()

func (*PodGroup) Reset

func (m *PodGroup) Reset()

func (*PodGroup) String

func (m *PodGroup) String() string

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) Descriptor() ([]byte, []int)

func (*PodInfo) GetAnnotation

func (m *PodInfo) GetAnnotation() string

func (*PodInfo) GetContainers

func (m *PodInfo) GetContainers() []*Container

func (*PodInfo) GetDependencies

func (m *PodInfo) GetDependencies() []*Dependency

func (*PodInfo) GetInstanceNo

func (m *PodInfo) GetInstanceNo() int32

func (*PodInfo) ProtoMessage

func (*PodInfo) ProtoMessage()

func (*PodInfo) Reset

func (m *PodInfo) Reset()

func (*PodInfo) String

func (m *PodInfo) String() string

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) Descriptor() ([]byte, []int)

func (*Port) GetDstport

func (m *Port) GetDstport() int32

func (*Port) GetProto

func (m *Port) GetProto() string

func (*Port) GetSrcport

func (m *Port) GetSrcport() int32

func (*Port) ProtoMessage

func (*Port) ProtoMessage()

func (*Port) Reset

func (m *Port) Reset()

func (*Port) String

func (m *Port) String() string

type ProcInfo

type ProcInfo struct {
	Containers []*ContainerForProxy `protobuf:"bytes,1,rep,name=Containers" json:"Containers,omitempty"`
}

func (*ProcInfo) Descriptor

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

func (*ProcInfo) GetContainers

func (m *ProcInfo) GetContainers() []*ContainerForProxy

func (*ProcInfo) ProtoMessage

func (*ProcInfo) ProtoMessage()

func (*ProcInfo) Reset

func (m *ProcInfo) Reset()

func (*ProcInfo) String

func (m *ProcInfo) String() string

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

type ProxyReply struct {
	Data map[string]*ProcInfo `` /* 128-byte string literal not displayed */
}

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 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 (*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 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 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 StreamrouterPorts_WatchClient

type StreamrouterPorts_WatchClient interface {
	Recv() (*StreamrouterPortsReply, error)
	grpc.ClientStream
}

type StreamrouterPorts_WatchServer

type StreamrouterPorts_WatchServer interface {
	Send(*StreamrouterPortsReply) error
	grpc.ServerStream
}

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 (*StreamrouterStreamprocsReply) ProtoMessage

func (*StreamrouterStreamprocsReply) ProtoMessage()

func (*StreamrouterStreamprocsReply) Reset

func (m *StreamrouterStreamprocsReply) Reset()

func (*StreamrouterStreamprocsReply) 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

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 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 (*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 WebrouterWebprocs_WatchClient

type WebrouterWebprocs_WatchClient interface {
	Recv() (*WebrouterWebprocsReply, error)
	grpc.ClientStream
}

type WebrouterWebprocs_WatchServer

type WebrouterWebprocs_WatchServer interface {
	Send(*WebrouterWebprocsReply) error
	grpc.ServerStream
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL