pbrpc

package
v0.1.8 Latest Latest
Warning

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

 Go to latest Published: Oct 27, 2018 License: Apache-2.0 Imports: 5 Imported by: 0

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

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"`
}

Container instance

func (*Container) Descriptor 

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

func (*Container) GetCommand 

func (m *Container) GetCommand() string

func (*Container) GetContainerName 

func (m *Container) GetContainerName() string

func (*Container) GetExecCMD added in v0.1.7 

func (m *Container) GetExecCMD() string

func (*Container) GetId 

func (m *Container) GetId() string

func (*Container) GetImage 

func (m *Container) GetImage() string

func (*Container) GetIps 

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

func (*Container) GetLocServer 

func (m *Container) GetLocServer() string

func (*Container) GetName 

func (m *Container) GetName() string

func (*Container) GetNamespace 

func (m *Container) GetNamespace() string

func (*Container) GetPodName 

func (m *Container) GetPodName() string

func (*Container) GetRunningNode 

func (m *Container) GetRunningNode() string

func (*Container) GetShell 

func (m *Container) GetShell() string

func (*Container) GetState 

func (m *Container) GetState() string

func (*Container) GetStatus 

func (m *Container) GetStatus() string

func (*Container) ProtoMessage 

func (*Container) ProtoMessage()

func (*Container) Reset 

func (m *Container) Reset()

func (*Container) String 

func (m *Container) String() string

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 added in v0.1.7 

type ContainerServer_LogsClient interface {
	Recv() (*Io, error)
	grpc.ClientStream
}

type ContainerServer_LogsServer added in v0.1.7 

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

func (*Empty) GetAuth 

func (m *Empty) GetAuth() string

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

type Err 

type Err struct {
	Err string `protobuf:"bytes,1,opt,name=err" json:"err,omitempty"`
}

func (*Err) Descriptor 

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

func (*Err) GetErr 

func (m *Err) GetErr() string

func (*Err) ProtoMessage 

func (*Err) ProtoMessage()

func (*Err) Reset 

func (m *Err) Reset()

func (*Err) String 

func (m *Err) String() string

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

func (*Io) GetIn 

func (m *Io) GetIn() []byte

func (*Io) GetOut 

func (m *Io) GetOut() []byte

func (*Io) ProtoMessage 

func (*Io) ProtoMessage()

func (*Io) Reset 

func (m *Io) Reset()

func (*Io) String 

func (m *Io) String() string

type LogOpts added in v0.1.7 

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 added in v0.1.7 

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

func (*LogOpts) GetC added in v0.1.7 

func (m *LogOpts) GetC() *ContainerID

func (*LogOpts) GetFollow added in v0.1.7 

func (m *LogOpts) GetFollow() bool

func (*LogOpts) GetTail added in v0.1.7 

func (m *LogOpts) GetTail() string

func (*LogOpts) ProtoMessage added in v0.1.7 

func (*LogOpts) ProtoMessage()

func (*LogOpts) Reset added in v0.1.7 

func (m *LogOpts) Reset()

func (*LogOpts) String added in v0.1.7 

func (m *LogOpts) String() string

type Pong 

type Pong struct {
	Msg string `protobuf:"bytes,1,opt,name=msg" json:"msg,omitempty"`
}

func (*Pong) Descriptor 

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

func (*Pong) GetMsg 

func (m *Pong) GetMsg() string

func (*Pong) ProtoMessage 

func (*Pong) ProtoMessage()

func (*Pong) Reset 

func (m *Pong) Reset()

func (*Pong) String 

func (m *Pong) String() string

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.