common

package
v0.0.0-...-0cd89e8 Latest Latest
Warning

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

 Go to latest Published: Oct 11, 2016 License: GPL-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Package common is a generated protocol buffer package.

It is generated from these files: 

vmserver.proto

It has these top-level messages: 

GetMetricsRequest
GetMetricsResponse
LogsRequest
LogLine
File
UploadResponse
StartProxyRequest
StartProxyResponse
RunCmdRequest
RunCmdResponse
SetIPRequest
SetIPResponse
GetIPRequest
GetIPResponse
SetSandboxConfigRequest
SetSandboxConfigResponse
GetSandboxConfigRequest
GetSandboxConfigResponse
CopyFileRequest
CopyFileResponse
MountFsRequest
MountFsResponse
UnmountFsRequest
UnmountFsResponse
SetHostnameRequest
SetHostnameResponse
AddRouteRequest
AddRouteResponse
AddMountRequest
AddMountResponse
DelMountRequest
DelMountResponse

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ExtractLabels 

func ExtractLabels(input map[string]string) (map[string]string, map[string]string)

func GenerateEnvList 

func GenerateEnvList(envs []*kubeapi.KeyValue) (result []string)

func GetContainerTimestamps 

func GetContainerTimestamps(r *dockertypes.ContainerJSON) (time.Time, time.Time, time.Time, error)

func MakeContainerName 

func MakeContainerName(s *kubeapi.PodSandboxConfig, c *kubeapi.ContainerConfig) string

func MakeLabels 

func MakeLabels(labels, annotations map[string]string) map[string]string

func NewDockerFilter 

func NewDockerFilter(args *dockerfilters.Args) *dockerFilter

func ParseContainer 

func ParseContainer(c string) (string, string, error)

func ParseContainerName 

func ParseContainerName(name string) (*kubeapi.ContainerMetadata, error)

TODO: Evaluate whether we should rely on labels completely.

func ParseDockerTimestamp 

func ParseDockerTimestamp(s string) (time.Time, error)

ParseDockerTimestamp parses the timestamp returned by DockerInterface from string to time.Time

func RegisterMetricsServer 

func RegisterMetricsServer(s *grpc.Server, srv MetricsServer)

func RegisterMountsServer 

func RegisterMountsServer(s *grpc.Server, srv MountsServer)

func RegisterVMServerServer 

func RegisterVMServerServer(s *grpc.Server, srv VMServerServer)

func ToDockerContainerStatus 

func ToDockerContainerStatus(state kubeapi.ContainerState) string

func ToRuntimeAPIContainer 

func ToRuntimeAPIContainer(podId string, name string, c *dockertypes.Container) (*kubeapi.Container, error)

func ToRuntimeAPIContainerState 

func ToRuntimeAPIContainerState(state string) kubeapi.ContainerState

func ToRuntimeAPIImage 

func ToRuntimeAPIImage(image *dockertypes.Image) (*kubeapi.Image, error)

Types

type AddMountRequest 

type AddMountRequest struct {
	Volume     string `protobuf:"bytes,1,opt,name=volume" json:"volume,omitempty"`
	MountPoint string `protobuf:"bytes,2,opt,name=mountPoint" json:"mountPoint,omitempty"`
	FsType     string `protobuf:"bytes,3,opt,name=fsType" json:"fsType,omitempty"`
	Device     string `protobuf:"bytes,4,opt,name=device" json:"device,omitempty"`
	ReadOnly   bool   `protobuf:"varint,5,opt,name=readOnly" json:"readOnly,omitempty"`
	PodUUID    string `protobuf:"bytes,6,opt,name=podUUID" json:"podUUID,omitempty"`
}

func (*AddMountRequest) Descriptor 

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

func (*AddMountRequest) GetDevice 

func (m *AddMountRequest) GetDevice() string

func (*AddMountRequest) GetFsType 

func (m *AddMountRequest) GetFsType() string

func (*AddMountRequest) GetMountPoint 

func (m *AddMountRequest) GetMountPoint() string

func (*AddMountRequest) GetPodUUID 

func (m *AddMountRequest) GetPodUUID() string

func (*AddMountRequest) GetReadOnly 

func (m *AddMountRequest) GetReadOnly() bool

func (*AddMountRequest) GetVolume 

func (m *AddMountRequest) GetVolume() string

func (*AddMountRequest) ProtoMessage 

func (*AddMountRequest) ProtoMessage()

func (*AddMountRequest) Reset 

func (m *AddMountRequest) Reset()

func (*AddMountRequest) String 

func (m *AddMountRequest) String() string

type AddMountResponse 

type AddMountResponse struct {
}

func (*AddMountResponse) Descriptor 

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

func (*AddMountResponse) ProtoMessage 

func (*AddMountResponse) ProtoMessage()

func (*AddMountResponse) Reset 

func (m *AddMountResponse) Reset()

func (*AddMountResponse) String 

func (m *AddMountResponse) String() string

type AddRouteRequest 

type AddRouteRequest struct {
	Target  string `protobuf:"bytes,1,opt,name=target" json:"target,omitempty"`
	Gateway string `protobuf:"bytes,2,opt,name=gateway" json:"gateway,omitempty"`
}

func (*AddRouteRequest) Descriptor 

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

func (*AddRouteRequest) GetGateway 

func (m *AddRouteRequest) GetGateway() string

func (*AddRouteRequest) GetTarget 

func (m *AddRouteRequest) GetTarget() string

func (*AddRouteRequest) ProtoMessage 

func (*AddRouteRequest) ProtoMessage()

func (*AddRouteRequest) Reset 

func (m *AddRouteRequest) Reset()

func (*AddRouteRequest) String 

func (m *AddRouteRequest) String() string

type AddRouteResponse 

type AddRouteResponse struct {
}

func (*AddRouteResponse) Descriptor 

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

func (*AddRouteResponse) ProtoMessage 

func (*AddRouteResponse) ProtoMessage()

func (*AddRouteResponse) Reset 

func (m *AddRouteResponse) Reset()

func (*AddRouteResponse) String 

func (m *AddRouteResponse) String() string

type CopyFileRequest 

type CopyFileRequest struct {
	File     string `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
	FileData []byte `protobuf:"bytes,2,opt,name=fileData,proto3" json:"fileData,omitempty"`
}

func (*CopyFileRequest) Descriptor 

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

func (*CopyFileRequest) GetFile 

func (m *CopyFileRequest) GetFile() string

func (*CopyFileRequest) GetFileData 

func (m *CopyFileRequest) GetFileData() []byte

func (*CopyFileRequest) ProtoMessage 

func (*CopyFileRequest) ProtoMessage()

func (*CopyFileRequest) Reset 

func (m *CopyFileRequest) Reset()

func (*CopyFileRequest) String 

func (m *CopyFileRequest) String() string

type CopyFileResponse 

type CopyFileResponse struct {
}

func (*CopyFileResponse) Descriptor 

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

func (*CopyFileResponse) ProtoMessage 

func (*CopyFileResponse) ProtoMessage()

func (*CopyFileResponse) Reset 

func (m *CopyFileResponse) Reset()

func (*CopyFileResponse) String 

func (m *CopyFileResponse) String() string

type DelMountRequest 

type DelMountRequest struct {
	MountPoint string `protobuf:"bytes,1,opt,name=mountPoint" json:"mountPoint,omitempty"`
}

func (*DelMountRequest) Descriptor 

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

func (*DelMountRequest) GetMountPoint 

func (m *DelMountRequest) GetMountPoint() string

func (*DelMountRequest) ProtoMessage 

func (*DelMountRequest) ProtoMessage()

func (*DelMountRequest) Reset 

func (m *DelMountRequest) Reset()

func (*DelMountRequest) String 

func (m *DelMountRequest) String() string

type DelMountResponse 

type DelMountResponse struct {
}

func (*DelMountResponse) Descriptor 

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

func (*DelMountResponse) ProtoMessage 

func (*DelMountResponse) ProtoMessage()

func (*DelMountResponse) Reset 

func (m *DelMountResponse) Reset()

func (*DelMountResponse) String 

func (m *DelMountResponse) String() string

type File 

type File struct {
	Size int64  `protobuf:"varint,1,opt,name=size" json:"size,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*File) Descriptor 

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

func (*File) GetData 

func (m *File) GetData() []byte

func (*File) GetSize 

func (m *File) GetSize() int64

func (*File) ProtoMessage 

func (*File) ProtoMessage()

func (*File) Reset 

func (m *File) Reset()

func (*File) String 

func (m *File) String() string

type GetIPRequest 

type GetIPRequest struct {
}

func (*GetIPRequest) Descriptor 

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

func (*GetIPRequest) ProtoMessage 

func (*GetIPRequest) ProtoMessage()

func (*GetIPRequest) Reset 

func (m *GetIPRequest) Reset()

func (*GetIPRequest) String 

func (m *GetIPRequest) String() string

type GetIPResponse 

type GetIPResponse struct {
	Ip string `protobuf:"bytes,1,opt,name=ip" json:"ip,omitempty"`
}

func (*GetIPResponse) Descriptor 

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

func (*GetIPResponse) GetIp 

func (m *GetIPResponse) GetIp() string

func (*GetIPResponse) ProtoMessage 

func (*GetIPResponse) ProtoMessage()

func (*GetIPResponse) Reset 

func (m *GetIPResponse) Reset()

func (*GetIPResponse) String 

func (m *GetIPResponse) String() string

type GetMetricsRequest 

type GetMetricsRequest struct {
	Count int32 `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
}

func (*GetMetricsRequest) Descriptor 

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

func (*GetMetricsRequest) GetCount 

func (m *GetMetricsRequest) GetCount() int32

func (*GetMetricsRequest) ProtoMessage 

func (*GetMetricsRequest) ProtoMessage()

func (*GetMetricsRequest) Reset 

func (m *GetMetricsRequest) Reset()

func (*GetMetricsRequest) String 

func (m *GetMetricsRequest) String() string

type GetMetricsResponse 

type GetMetricsResponse struct {
	JsonMetricResponses [][]byte `protobuf:"bytes,1,rep,name=jsonMetricResponses,proto3" json:"jsonMetricResponses,omitempty"`
}

func (*GetMetricsResponse) Descriptor 

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

func (*GetMetricsResponse) GetJsonMetricResponses 

func (m *GetMetricsResponse) GetJsonMetricResponses() [][]byte

func (*GetMetricsResponse) ProtoMessage 

func (*GetMetricsResponse) ProtoMessage()

func (*GetMetricsResponse) Reset 

func (m *GetMetricsResponse) Reset()

func (*GetMetricsResponse) String 

func (m *GetMetricsResponse) String() string

type GetSandboxConfigRequest 

type GetSandboxConfigRequest struct {
}

func (*GetSandboxConfigRequest) Descriptor 

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

func (*GetSandboxConfigRequest) ProtoMessage 

func (*GetSandboxConfigRequest) ProtoMessage()

func (*GetSandboxConfigRequest) Reset 

func (m *GetSandboxConfigRequest) Reset()

func (*GetSandboxConfigRequest) String 

func (m *GetSandboxConfigRequest) String() string

type GetSandboxConfigResponse 

type GetSandboxConfigResponse struct {
	Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
}

func (*GetSandboxConfigResponse) Descriptor 

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

func (*GetSandboxConfigResponse) GetConfig 

func (m *GetSandboxConfigResponse) GetConfig() []byte

func (*GetSandboxConfigResponse) ProtoMessage 

func (*GetSandboxConfigResponse) ProtoMessage()

func (*GetSandboxConfigResponse) Reset 

func (m *GetSandboxConfigResponse) Reset()

func (*GetSandboxConfigResponse) String 

func (m *GetSandboxConfigResponse) String() string

type LogLine 

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

func (*LogLine) Descriptor 

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

func (*LogLine) GetLogLine 

func (m *LogLine) GetLogLine() string

func (*LogLine) ProtoMessage 

func (*LogLine) ProtoMessage()

func (*LogLine) Reset 

func (m *LogLine) Reset()

func (*LogLine) String 

func (m *LogLine) String() string

type LogsRequest 

type LogsRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=containerID" json:"containerID,omitempty"`
}

func (*LogsRequest) Descriptor 

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

func (*LogsRequest) GetContainerID 

func (m *LogsRequest) GetContainerID() string

func (*LogsRequest) ProtoMessage 

func (*LogsRequest) ProtoMessage()

func (*LogsRequest) Reset 

func (m *LogsRequest) Reset()

func (*LogsRequest) String 

func (m *LogsRequest) String() string

type MetricsClient 

type MetricsClient interface {
	GetMetrics(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (*GetMetricsResponse, error)
}

func NewMetricsClient 

func NewMetricsClient(cc *grpc.ClientConn) MetricsClient

type MetricsServer 

type MetricsServer interface {
	GetMetrics(context.Context, *GetMetricsRequest) (*GetMetricsResponse, error)
}

type MountFsRequest 

type MountFsRequest struct {
	Source   string `protobuf:"bytes,1,opt,name=source" json:"source,omitempty"`
	Target   string `protobuf:"bytes,2,opt,name=target" json:"target,omitempty"`
	Fstype   string `protobuf:"bytes,3,opt,name=fstype" json:"fstype,omitempty"`
	ReadOnly bool   `protobuf:"varint,4,opt,name=readOnly" json:"readOnly,omitempty"`
}

func (*MountFsRequest) Descriptor 

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

func (*MountFsRequest) GetFstype 

func (m *MountFsRequest) GetFstype() string

func (*MountFsRequest) GetReadOnly 

func (m *MountFsRequest) GetReadOnly() bool

func (*MountFsRequest) GetSource 

func (m *MountFsRequest) GetSource() string

func (*MountFsRequest) GetTarget 

func (m *MountFsRequest) GetTarget() string

func (*MountFsRequest) ProtoMessage 

func (*MountFsRequest) ProtoMessage()

func (*MountFsRequest) Reset 

func (m *MountFsRequest) Reset()

func (*MountFsRequest) String 

func (m *MountFsRequest) String() string

type MountFsResponse 

type MountFsResponse struct {
}

func (*MountFsResponse) Descriptor 

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

func (*MountFsResponse) ProtoMessage 

func (*MountFsResponse) ProtoMessage()

func (*MountFsResponse) Reset 

func (m *MountFsResponse) Reset()

func (*MountFsResponse) String 

func (m *MountFsResponse) String() string

type MountsClient 

type MountsClient interface {
	AddMount(ctx context.Context, in *AddMountRequest, opts ...grpc.CallOption) (*AddMountResponse, error)
	DelMount(ctx context.Context, in *DelMountRequest, opts ...grpc.CallOption) (*DelMountResponse, error)
}

func NewMountsClient 

func NewMountsClient(cc *grpc.ClientConn) MountsClient

type MountsServer 

type MountsServer interface {
	AddMount(context.Context, *AddMountRequest) (*AddMountResponse, error)
	DelMount(context.Context, *DelMountRequest) (*DelMountResponse, error)
}

type RunCmdRequest 

type RunCmdRequest struct {
	Cmd  string   `protobuf:"bytes,1,opt,name=cmd" json:"cmd,omitempty"`
	Args []string `protobuf:"bytes,2,rep,name=args" json:"args,omitempty"`
}

func (*RunCmdRequest) Descriptor 

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

func (*RunCmdRequest) GetArgs 

func (m *RunCmdRequest) GetArgs() []string

func (*RunCmdRequest) GetCmd 

func (m *RunCmdRequest) GetCmd() string

func (*RunCmdRequest) ProtoMessage 

func (*RunCmdRequest) ProtoMessage()

func (*RunCmdRequest) Reset 

func (m *RunCmdRequest) Reset()

func (*RunCmdRequest) String 

func (m *RunCmdRequest) String() string

type RunCmdResponse 

type RunCmdResponse struct {
}

func (*RunCmdResponse) Descriptor 

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

func (*RunCmdResponse) ProtoMessage 

func (*RunCmdResponse) ProtoMessage()

func (*RunCmdResponse) Reset 

func (m *RunCmdResponse) Reset()

func (*RunCmdResponse) String 

func (m *RunCmdResponse) String() string

type SetHostnameRequest 

type SetHostnameRequest struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname" json:"hostname,omitempty"`
}

func (*SetHostnameRequest) Descriptor 

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

func (*SetHostnameRequest) GetHostname 

func (m *SetHostnameRequest) GetHostname() string

func (*SetHostnameRequest) ProtoMessage 

func (*SetHostnameRequest) ProtoMessage()

func (*SetHostnameRequest) Reset 

func (m *SetHostnameRequest) Reset()

func (*SetHostnameRequest) String 

func (m *SetHostnameRequest) String() string

type SetHostnameResponse 

type SetHostnameResponse struct {
}

func (*SetHostnameResponse) Descriptor 

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

func (*SetHostnameResponse) ProtoMessage 

func (*SetHostnameResponse) ProtoMessage()

func (*SetHostnameResponse) Reset 

func (m *SetHostnameResponse) Reset()

func (*SetHostnameResponse) String 

func (m *SetHostnameResponse) String() string

type SetIPRequest 

type SetIPRequest struct {
	Ip string `protobuf:"bytes,1,opt,name=ip" json:"ip,omitempty"`
}

func (*SetIPRequest) Descriptor 

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

func (*SetIPRequest) GetIp 

func (m *SetIPRequest) GetIp() string

func (*SetIPRequest) ProtoMessage 

func (*SetIPRequest) ProtoMessage()

func (*SetIPRequest) Reset 

func (m *SetIPRequest) Reset()

func (*SetIPRequest) String 

func (m *SetIPRequest) String() string

type SetIPResponse 

type SetIPResponse struct {
}

func (*SetIPResponse) Descriptor 

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

func (*SetIPResponse) ProtoMessage 

func (*SetIPResponse) ProtoMessage()

func (*SetIPResponse) Reset 

func (m *SetIPResponse) Reset()

func (*SetIPResponse) String 

func (m *SetIPResponse) String() string

type SetSandboxConfigRequest 

type SetSandboxConfigRequest struct {
	Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
}

func (*SetSandboxConfigRequest) Descriptor 

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

func (*SetSandboxConfigRequest) GetConfig 

func (m *SetSandboxConfigRequest) GetConfig() []byte

func (*SetSandboxConfigRequest) ProtoMessage 

func (*SetSandboxConfigRequest) ProtoMessage()

func (*SetSandboxConfigRequest) Reset 

func (m *SetSandboxConfigRequest) Reset()

func (*SetSandboxConfigRequest) String 

func (m *SetSandboxConfigRequest) String() string

type SetSandboxConfigResponse 

type SetSandboxConfigResponse struct {
}

func (*SetSandboxConfigResponse) Descriptor 

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

func (*SetSandboxConfigResponse) ProtoMessage 

func (*SetSandboxConfigResponse) ProtoMessage()

func (*SetSandboxConfigResponse) Reset 

func (m *SetSandboxConfigResponse) Reset()

func (*SetSandboxConfigResponse) String 

func (m *SetSandboxConfigResponse) String() string

type StartProxyRequest 

type StartProxyRequest struct {
	Ip          string `protobuf:"bytes,1,opt,name=ip" json:"ip,omitempty"`
	ClusterCidr string `protobuf:"bytes,2,opt,name=clusterCidr" json:"clusterCidr,omitempty"`
	Kubeconfig  []byte `protobuf:"bytes,3,opt,name=kubeconfig,proto3" json:"kubeconfig,omitempty"`
}

func (*StartProxyRequest) Descriptor 

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

func (*StartProxyRequest) GetClusterCidr 

func (m *StartProxyRequest) GetClusterCidr() string

func (*StartProxyRequest) GetIp 

func (m *StartProxyRequest) GetIp() string

func (*StartProxyRequest) GetKubeconfig 

func (m *StartProxyRequest) GetKubeconfig() []byte

func (*StartProxyRequest) ProtoMessage 

func (*StartProxyRequest) ProtoMessage()

func (*StartProxyRequest) Reset 

func (m *StartProxyRequest) Reset()

func (*StartProxyRequest) String 

func (m *StartProxyRequest) String() string

type StartProxyResponse 

type StartProxyResponse struct {
}

func (*StartProxyResponse) Descriptor 

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

func (*StartProxyResponse) ProtoMessage 

func (*StartProxyResponse) ProtoMessage()

func (*StartProxyResponse) Reset 

func (m *StartProxyResponse) Reset()

func (*StartProxyResponse) String 

func (m *StartProxyResponse) String() string

type UnmountFsRequest 

type UnmountFsRequest struct {
	Target string `protobuf:"bytes,1,opt,name=target" json:"target,omitempty"`
}

func (*UnmountFsRequest) Descriptor 

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

func (*UnmountFsRequest) GetTarget 

func (m *UnmountFsRequest) GetTarget() string

func (*UnmountFsRequest) ProtoMessage 

func (*UnmountFsRequest) ProtoMessage()

func (*UnmountFsRequest) Reset 

func (m *UnmountFsRequest) Reset()

func (*UnmountFsRequest) String 

func (m *UnmountFsRequest) String() string

type UnmountFsResponse 

type UnmountFsResponse struct {
}

func (*UnmountFsResponse) Descriptor 

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

func (*UnmountFsResponse) ProtoMessage 

func (*UnmountFsResponse) ProtoMessage()

func (*UnmountFsResponse) Reset 

func (m *UnmountFsResponse) Reset()

func (*UnmountFsResponse) String 

func (m *UnmountFsResponse) String() string

type UploadResponse 

type UploadResponse struct {
}

func (*UploadResponse) Descriptor 

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

func (*UploadResponse) ProtoMessage 

func (*UploadResponse) ProtoMessage()

func (*UploadResponse) Reset 

func (m *UploadResponse) Reset()

func (*UploadResponse) String 

func (m *UploadResponse) String() string

type VMServerClient 

type VMServerClient interface {
	// rpc UploadFiles(File) returns (UploadResponse) {}
	StartProxy(ctx context.Context, in *StartProxyRequest, opts ...grpc.CallOption) (*StartProxyResponse, error)
	RunCmd(ctx context.Context, in *RunCmdRequest, opts ...grpc.CallOption) (*RunCmdResponse, error)
	SetPodIP(ctx context.Context, in *SetIPRequest, opts ...grpc.CallOption) (*SetIPResponse, error)
	GetPodIP(ctx context.Context, in *GetIPRequest, opts ...grpc.CallOption) (*GetIPResponse, error)
	SetSandboxConfig(ctx context.Context, in *SetSandboxConfigRequest, opts ...grpc.CallOption) (*SetSandboxConfigResponse, error)
	GetSandboxConfig(ctx context.Context, in *GetSandboxConfigRequest, opts ...grpc.CallOption) (*GetSandboxConfigResponse, error)
	CopyFile(ctx context.Context, in *CopyFileRequest, opts ...grpc.CallOption) (*CopyFileResponse, error)
	MountFs(ctx context.Context, in *MountFsRequest, opts ...grpc.CallOption) (*MountFsResponse, error)
	UnmountFs(ctx context.Context, in *UnmountFsRequest, opts ...grpc.CallOption) (*UnmountFsResponse, error)
	SetHostname(ctx context.Context, in *SetHostnameRequest, opts ...grpc.CallOption) (*SetHostnameResponse, error)
	Logs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (VMServer_LogsClient, error)
	GetMetrics(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (*GetMetricsResponse, error)
	AddRoute(ctx context.Context, in *AddRouteRequest, opts ...grpc.CallOption) (*AddRouteResponse, error)
}

func NewVMServerClient 

func NewVMServerClient(cc *grpc.ClientConn) VMServerClient

type VMServerServer 

type VMServerServer interface {
	// rpc UploadFiles(File) returns (UploadResponse) {}
	StartProxy(context.Context, *StartProxyRequest) (*StartProxyResponse, error)
	RunCmd(context.Context, *RunCmdRequest) (*RunCmdResponse, error)
	SetPodIP(context.Context, *SetIPRequest) (*SetIPResponse, error)
	GetPodIP(context.Context, *GetIPRequest) (*GetIPResponse, error)
	SetSandboxConfig(context.Context, *SetSandboxConfigRequest) (*SetSandboxConfigResponse, error)
	GetSandboxConfig(context.Context, *GetSandboxConfigRequest) (*GetSandboxConfigResponse, error)
	CopyFile(context.Context, *CopyFileRequest) (*CopyFileResponse, error)
	MountFs(context.Context, *MountFsRequest) (*MountFsResponse, error)
	UnmountFs(context.Context, *UnmountFsRequest) (*UnmountFsResponse, error)
	SetHostname(context.Context, *SetHostnameRequest) (*SetHostnameResponse, error)
	Logs(*LogsRequest, VMServer_LogsServer) error
	GetMetrics(context.Context, *GetMetricsRequest) (*GetMetricsResponse, error)
	AddRoute(context.Context, *AddRouteRequest) (*AddRouteResponse, error)
}

type VMServer_LogsClient 

type VMServer_LogsClient interface {
	Recv() (*LogLine, error)
	grpc.ClientStream
}

type VMServer_LogsServer 

type VMServer_LogsServer interface {
	Send(*LogLine) error
	grpc.ServerStream
}

Source Files

View all Source files

Directories

Path Synopsis

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.