Documentation
¶
Overview ¶
Package pbrpc is a generated protocol buffer package.
It is generated from these files:
api.proto
It has these top-level messages:
Empty Pong Err ContainerID LogOpts Container Containers Io WindowSize ExecOptions
Index ¶
- func RegisterContainerServerServer(s *grpc.Server, srv ContainerServerServer)
- type Container
- func (*Container) Descriptor() ([]byte, []int)
- func (m *Container) GetCommand() string
- func (m *Container) GetContainerName() string
- func (m *Container) GetExecCmd() string
- func (m *Container) GetExecEnv() string
- func (m *Container) GetExecUser() string
- func (m *Container) GetId() string
- func (m *Container) GetImage() string
- func (m *Container) GetIps() []string
- func (m *Container) GetLocServer() string
- func (m *Container) GetName() string
- func (m *Container) GetNamespace() string
- func (m *Container) GetPodName() string
- func (m *Container) GetRunningNode() string
- func (m *Container) GetShell() string
- func (m *Container) GetState() string
- func (m *Container) GetStatus() string
- func (*Container) ProtoMessage()
- func (m *Container) Reset()
- func (m *Container) String() string
- type ContainerID
- type ContainerServerClient
- type ContainerServerServer
- type ContainerServer_ExecClient
- type ContainerServer_ExecServer
- type ContainerServer_LogsClient
- type ContainerServer_LogsServer
- type Containers
- type Empty
- type Err
- type ExecOptions
- func (*ExecOptions) Descriptor() ([]byte, []int)
- func (m *ExecOptions) GetAuth() string
- func (m *ExecOptions) GetC() *Container
- func (m *ExecOptions) GetCmd() *Io
- func (m *ExecOptions) GetErr() string
- func (m *ExecOptions) GetWs() *WindowSize
- func (*ExecOptions) ProtoMessage()
- func (m *ExecOptions) Reset()
- func (m *ExecOptions) String() string
- type Io
- type LogOpts
- type Pong
- type WindowSize
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterContainerServerServer ¶
func RegisterContainerServerServer(s *grpc.Server, srv ContainerServerServer)
Types ¶
type Container ¶
type Container struct {
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
Image string `protobuf:"bytes,3,opt,name=image" json:"image,omitempty"`
Command string `protobuf:"bytes,4,opt,name=command" json:"command,omitempty"`
State string `protobuf:"bytes,5,opt,name=state" json:"state,omitempty"`
Status string `protobuf:"bytes,6,opt,name=status" json:"status,omitempty"`
Ips []string `protobuf:"bytes,7,rep,name=ips" json:"ips,omitempty"`
Shell string `protobuf:"bytes,8,opt,name=shell" json:"shell,omitempty"`
PodName string `protobuf:"bytes,9,opt,name=pod_name,json=podName" json:"pod_name,omitempty"`
ContainerName string `protobuf:"bytes,10,opt,name=container_name,json=containerName" json:"container_name,omitempty"`
Namespace string `protobuf:"bytes,11,opt,name=namespace" json:"namespace,omitempty"`
RunningNode string `protobuf:"bytes,12,opt,name=running_node,json=runningNode" json:"running_node,omitempty"`
LocServer string `protobuf:"bytes,13,opt,name=loc_server,json=locServer" json:"loc_server,omitempty"`
ExecCmd string `protobuf:"bytes,14,opt,name=execCmd" json:"execCmd,omitempty"`
ExecUser string `protobuf:"bytes,15,opt,name=execUser" json:"execUser,omitempty"`
ExecEnv string `protobuf:"bytes,16,opt,name=execEnv" json:"execEnv,omitempty"`
}
Container instance
func (*Container) Descriptor ¶
func (*Container) GetCommand ¶
func (*Container) GetContainerName ¶
func (*Container) GetExecCmd ¶
func (*Container) GetExecEnv ¶
func (*Container) GetExecUser ¶
func (*Container) GetLocServer ¶
func (*Container) GetNamespace ¶
func (*Container) GetPodName ¶
func (*Container) GetRunningNode ¶
func (*Container) ProtoMessage ¶
func (*Container) ProtoMessage()
type ContainerID ¶
type ContainerID struct {
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
Auth string `protobuf:"bytes,2,opt,name=auth" json:"auth,omitempty"`
}
func (*ContainerID) Descriptor ¶
func (*ContainerID) Descriptor() ([]byte, []int)
func (*ContainerID) GetAuth ¶
func (m *ContainerID) GetAuth() string
func (*ContainerID) GetId ¶
func (m *ContainerID) GetId() string
func (*ContainerID) ProtoMessage ¶
func (*ContainerID) ProtoMessage()
func (*ContainerID) Reset ¶
func (m *ContainerID) Reset()
func (*ContainerID) String ¶
func (m *ContainerID) String() string
type ContainerServerClient ¶
type ContainerServerClient interface {
GetInfo(ctx context.Context, in *ContainerID, opts ...grpc.CallOption) (*Container, error)
List(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Containers, error)
Start(ctx context.Context, in *ContainerID, opts ...grpc.CallOption) (*Err, error)
Stop(ctx context.Context, in *ContainerID, opts ...grpc.CallOption) (*Err, error)
Restart(ctx context.Context, in *ContainerID, opts ...grpc.CallOption) (*Err, error)
Exec(ctx context.Context, opts ...grpc.CallOption) (ContainerServer_ExecClient, error)
Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Pong, error)
Logs(ctx context.Context, in *LogOpts, opts ...grpc.CallOption) (ContainerServer_LogsClient, error)
}
func NewContainerServerClient ¶
func NewContainerServerClient(cc *grpc.ClientConn) ContainerServerClient
type ContainerServerServer ¶
type ContainerServerServer interface {
GetInfo(context.Context, *ContainerID) (*Container, error)
List(context.Context, *Empty) (*Containers, error)
Start(context.Context, *ContainerID) (*Err, error)
Stop(context.Context, *ContainerID) (*Err, error)
Restart(context.Context, *ContainerID) (*Err, error)
Exec(ContainerServer_ExecServer) error
Ping(context.Context, *Empty) (*Pong, error)
Logs(*LogOpts, ContainerServer_LogsServer) error
}
type ContainerServer_ExecClient ¶
type ContainerServer_ExecClient interface {
Send(*ExecOptions) error
Recv() (*ExecOptions, error)
grpc.ClientStream
}
type ContainerServer_ExecServer ¶
type ContainerServer_ExecServer interface {
Send(*ExecOptions) error
Recv() (*ExecOptions, error)
grpc.ServerStream
}
type ContainerServer_LogsClient ¶
type ContainerServer_LogsClient interface {
Recv() (*Io, error)
grpc.ClientStream
}
type ContainerServer_LogsServer ¶
type ContainerServer_LogsServer interface {
Send(*Io) error
grpc.ServerStream
}
type Containers ¶
type Containers struct {
Cs []*Container `protobuf:"bytes,1,rep,name=cs" json:"cs,omitempty"`
}
func (*Containers) Descriptor ¶
func (*Containers) Descriptor() ([]byte, []int)
func (*Containers) GetCs ¶
func (m *Containers) GetCs() []*Container
func (*Containers) ProtoMessage ¶
func (*Containers) ProtoMessage()
func (*Containers) Reset ¶
func (m *Containers) Reset()
func (*Containers) String ¶
func (m *Containers) String() string
type Empty ¶
type Empty struct {
Auth string `protobuf:"bytes,1,opt,name=auth" json:"auth,omitempty"`
}
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
type Err ¶
type Err struct {
Err string `protobuf:"bytes,1,opt,name=err" json:"err,omitempty"`
}
func (*Err) Descriptor ¶
func (*Err) ProtoMessage ¶
func (*Err) ProtoMessage()
type ExecOptions ¶
type ExecOptions struct {
Cmd *Io `protobuf:"bytes,1,opt,name=cmd" json:"cmd,omitempty"`
C *Container `protobuf:"bytes,2,opt,name=c" json:"c,omitempty"`
Err string `protobuf:"bytes,3,opt,name=err" json:"err,omitempty"`
Auth string `protobuf:"bytes,4,opt,name=auth" json:"auth,omitempty"`
Ws *WindowSize `protobuf:"bytes,5,opt,name=ws" json:"ws,omitempty"`
}
func (*ExecOptions) Descriptor ¶
func (*ExecOptions) Descriptor() ([]byte, []int)
func (*ExecOptions) GetAuth ¶
func (m *ExecOptions) GetAuth() string
func (*ExecOptions) GetC ¶
func (m *ExecOptions) GetC() *Container
func (*ExecOptions) GetCmd ¶
func (m *ExecOptions) GetCmd() *Io
func (*ExecOptions) GetErr ¶
func (m *ExecOptions) GetErr() string
func (*ExecOptions) GetWs ¶
func (m *ExecOptions) GetWs() *WindowSize
func (*ExecOptions) ProtoMessage ¶
func (*ExecOptions) ProtoMessage()
func (*ExecOptions) Reset ¶
func (m *ExecOptions) Reset()
func (*ExecOptions) String ¶
func (m *ExecOptions) String() string
type Io ¶
type Io struct {
In []byte `protobuf:"bytes,1,opt,name=in,proto3" json:"in,omitempty"`
Out []byte `protobuf:"bytes,2,opt,name=out,proto3" json:"out,omitempty"`
}
func (*Io) Descriptor ¶
func (*Io) ProtoMessage ¶
func (*Io) ProtoMessage()
type LogOpts ¶
type LogOpts struct {
C *ContainerID `protobuf:"bytes,1,opt,name=c" json:"c,omitempty"`
Follow bool `protobuf:"varint,2,opt,name=follow" json:"follow,omitempty"`
Tail string `protobuf:"bytes,3,opt,name=tail" json:"tail,omitempty"`
}
func (*LogOpts) Descriptor ¶
func (*LogOpts) GetC ¶
func (m *LogOpts) GetC() *ContainerID
func (*LogOpts) ProtoMessage ¶
func (*LogOpts) ProtoMessage()
type Pong ¶
type Pong struct {
Msg string `protobuf:"bytes,1,opt,name=msg" json:"msg,omitempty"`
}
func (*Pong) Descriptor ¶
func (*Pong) ProtoMessage ¶
func (*Pong) ProtoMessage()
type WindowSize ¶
type WindowSize struct {
Height int32 `protobuf:"varint,1,opt,name=height" json:"height,omitempty"`
Width int32 `protobuf:"varint,2,opt,name=width" json:"width,omitempty"`
}
func (*WindowSize) Descriptor ¶
func (*WindowSize) Descriptor() ([]byte, []int)
func (*WindowSize) GetHeight ¶
func (m *WindowSize) GetHeight() int32
func (*WindowSize) GetWidth ¶
func (m *WindowSize) GetWidth() int32
func (*WindowSize) ProtoMessage ¶
func (*WindowSize) ProtoMessage()
func (*WindowSize) Reset ¶
func (m *WindowSize) Reset()
func (*WindowSize) String ¶
func (m *WindowSize) String() string
Click to show internal directories.
Click to hide internal directories.