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.