container

package
v4.25.2 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2024 License: AGPL-3.0 Imports: 29 Imported by: 0

Documentation

Overview

Package container is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	Container_CopyToPod_FullMethodName          = "/container.Container/CopyToPod"
	Container_Exec_FullMethodName               = "/container.Container/Exec"
	Container_StreamCopyToPod_FullMethodName    = "/container.Container/StreamCopyToPod"
	Container_IsPodRunning_FullMethodName       = "/container.Container/IsPodRunning"
	Container_IsPodExists_FullMethodName        = "/container.Container/IsPodExists"
	Container_ContainerLog_FullMethodName       = "/container.Container/ContainerLog"
	Container_StreamContainerLog_FullMethodName = "/container.Container/StreamContainerLog"
)

Variables

View Source 
var Container_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "container.Container",
	HandlerType: (*ContainerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CopyToPod",
			Handler:    _Container_CopyToPod_Handler,
		},
		{
			MethodName: "IsPodRunning",
			Handler:    _Container_IsPodRunning_Handler,
		},
		{
			MethodName: "IsPodExists",
			Handler:    _Container_IsPodExists_Handler,
		},
		{
			MethodName: "ContainerLog",
			Handler:    _Container_ContainerLog_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Exec",
			Handler:       _Container_Exec_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamCopyToPod",
			Handler:       _Container_StreamCopyToPod_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "StreamContainerLog",
			Handler:       _Container_StreamContainerLog_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "container/container.proto",
}

Container_ServiceDesc is the grpc.ServiceDesc for Container service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_container_container_proto protoreflect.FileDescriptor

Functions

func RegisterContainerHandler 

func RegisterContainerHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterContainerHandler registers the http handlers for service Container to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterContainerHandlerClient 

func RegisterContainerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ContainerClient) error

RegisterContainerHandlerClient registers the http handlers for service Container to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ContainerClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ContainerClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ContainerClient" to call the correct interceptors.

func RegisterContainerHandlerFromEndpoint 

func RegisterContainerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterContainerHandlerFromEndpoint is same as RegisterContainerHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterContainerHandlerServer 

func RegisterContainerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ContainerServer) error

RegisterContainerHandlerServer registers the http handlers for service Container to "mux". UnaryRPC :call ContainerServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterContainerHandlerFromEndpoint instead.

func RegisterContainerServer 

func RegisterContainerServer(s grpc.ServiceRegistrar, srv ContainerServer)

Types

type ContainerClient 

type ContainerClient interface {
	// CopyToPod (web): 页面上传文件到 pod 内部
	CopyToPod(ctx context.Context, in *CopyToPodRequest, opts ...grpc.CallOption) (*CopyToPodResponse, error)
	// Exec grpc 执行 pod 命令
	Exec(ctx context.Context, in *ExecRequest, opts ...grpc.CallOption) (Container_ExecClient, error)
	// StreamCopyToPod grpc 上传文件到 pod
	//
	//	 demo:
	//	 cp, _ := c.Container().StreamCopyToPod(context.TODO())
	//		open, _ := os.Open("/xxxxxx/helm-v3.8.0-rc.1-linux-arm64.tar.gz")
	//		defer open.Close()
	//		bf := bufio.NewReaderSize(open, 1024*1024*5)
	//		var (
	//			filename =  open.Name()
	//			pod = "mars-demo-549f789f7d-sxvqm"
	//			containerName = "demo"
	//			namespace = "devops-a"
	//		)
	//		for {
	//			bts := make([]byte, 1024*1024)
	//			n, err := bf.Read(bts)
	//			if err != nil {
	//				if err == io.EOF {
	//					cp.Send(&container.StreamCopyToPodRequest{
	//						FileName:  filename,
	//						Data:      bts[0:n],
	//						Namespace: namespace,
	//						Pod:       pod,
	//						Container: containerName,
	//					})
	//					recv, err := cp.CloseAndRecv()
	//					if err != nil {
	//						log.Fatal(err)
	//					}
	//					log.Println(recv)
	//				}
	//				return
	//			}
	//			 cp.Send(&container.StreamCopyToPodRequest{
	//				FileName:  filename,
	//				Data:      bts[0:n],
	//				Namespace: namespace,
	//				Pod:       pod,
	//				Container: containerName,
	//			 })
	//		}
	StreamCopyToPod(ctx context.Context, opts ...grpc.CallOption) (Container_StreamCopyToPodClient, error)
	// IsPodRunning pod 是否正常在跑
	IsPodRunning(ctx context.Context, in *IsPodRunningRequest, opts ...grpc.CallOption) (*IsPodRunningResponse, error)
	// IsPodExists pod 是否存在
	IsPodExists(ctx context.Context, in *IsPodExistsRequest, opts ...grpc.CallOption) (*IsPodExistsResponse, error)
	// ContainerLog 查看 pod 日志
	ContainerLog(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (*LogResponse, error)
	// StreamContainerLog stream 方式查看 pod 日志
	StreamContainerLog(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (Container_StreamContainerLogClient, error)
}

ContainerClient is the client API for Container service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewContainerClient 

func NewContainerClient(cc grpc.ClientConnInterface) ContainerClient

type ContainerServer 

type ContainerServer interface {
	// CopyToPod (web): 页面上传文件到 pod 内部
	CopyToPod(context.Context, *CopyToPodRequest) (*CopyToPodResponse, error)
	// Exec grpc 执行 pod 命令
	Exec(*ExecRequest, Container_ExecServer) error
	// StreamCopyToPod grpc 上传文件到 pod
	//
	//	 demo:
	//	 cp, _ := c.Container().StreamCopyToPod(context.TODO())
	//		open, _ := os.Open("/xxxxxx/helm-v3.8.0-rc.1-linux-arm64.tar.gz")
	//		defer open.Close()
	//		bf := bufio.NewReaderSize(open, 1024*1024*5)
	//		var (
	//			filename =  open.Name()
	//			pod = "mars-demo-549f789f7d-sxvqm"
	//			containerName = "demo"
	//			namespace = "devops-a"
	//		)
	//		for {
	//			bts := make([]byte, 1024*1024)
	//			n, err := bf.Read(bts)
	//			if err != nil {
	//				if err == io.EOF {
	//					cp.Send(&container.StreamCopyToPodRequest{
	//						FileName:  filename,
	//						Data:      bts[0:n],
	//						Namespace: namespace,
	//						Pod:       pod,
	//						Container: containerName,
	//					})
	//					recv, err := cp.CloseAndRecv()
	//					if err != nil {
	//						log.Fatal(err)
	//					}
	//					log.Println(recv)
	//				}
	//				return
	//			}
	//			 cp.Send(&container.StreamCopyToPodRequest{
	//				FileName:  filename,
	//				Data:      bts[0:n],
	//				Namespace: namespace,
	//				Pod:       pod,
	//				Container: containerName,
	//			 })
	//		}
	StreamCopyToPod(Container_StreamCopyToPodServer) error
	// IsPodRunning pod 是否正常在跑
	IsPodRunning(context.Context, *IsPodRunningRequest) (*IsPodRunningResponse, error)
	// IsPodExists pod 是否存在
	IsPodExists(context.Context, *IsPodExistsRequest) (*IsPodExistsResponse, error)
	// ContainerLog 查看 pod 日志
	ContainerLog(context.Context, *LogRequest) (*LogResponse, error)
	// StreamContainerLog stream 方式查看 pod 日志
	StreamContainerLog(*LogRequest, Container_StreamContainerLogServer) error
	// contains filtered or unexported methods
}

ContainerServer is the server API for Container service. All implementations must embed UnimplementedContainerServer for forward compatibility

type Container_ExecClient 

type Container_ExecClient interface {
	Recv() (*ExecResponse, error)
	grpc.ClientStream
}

type Container_ExecServer 

type Container_ExecServer interface {
	Send(*ExecResponse) error
	grpc.ServerStream
}

type Container_StreamContainerLogClient 

type Container_StreamContainerLogClient interface {
	Recv() (*LogResponse, error)
	grpc.ClientStream
}

type Container_StreamContainerLogServer 

type Container_StreamContainerLogServer interface {
	Send(*LogResponse) error
	grpc.ServerStream
}

type Container_StreamCopyToPodClient 

type Container_StreamCopyToPodClient interface {
	Send(*StreamCopyToPodRequest) error
	CloseAndRecv() (*StreamCopyToPodResponse, error)
	grpc.ClientStream
}

type Container_StreamCopyToPodServer 

type Container_StreamCopyToPodServer interface {
	SendAndClose(*StreamCopyToPodResponse) error
	Recv() (*StreamCopyToPodRequest, error)
	grpc.ServerStream
}

type CopyToPodRequest 

type CopyToPodRequest struct {
	FileId    int64  `protobuf:"varint,1,opt,name=file_id,json=fileId,proto3" json:"file_id,omitempty"`
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Pod       string `protobuf:"bytes,3,opt,name=pod,proto3" json:"pod,omitempty"`
	Container string `protobuf:"bytes,4,opt,name=container,proto3" json:"container,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyToPodRequest) Descriptor deprecated 

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

Deprecated: Use CopyToPodRequest.ProtoReflect.Descriptor instead.

func (*CopyToPodRequest) GetContainer 

func (x *CopyToPodRequest) GetContainer() string

func (*CopyToPodRequest) GetFileId 

func (x *CopyToPodRequest) GetFileId() int64

func (*CopyToPodRequest) GetNamespace 

func (x *CopyToPodRequest) GetNamespace() string

func (*CopyToPodRequest) GetPod 

func (x *CopyToPodRequest) GetPod() string

func (*CopyToPodRequest) ProtoMessage 

func (*CopyToPodRequest) ProtoMessage()

func (*CopyToPodRequest) ProtoReflect 

func (x *CopyToPodRequest) ProtoReflect() protoreflect.Message

func (*CopyToPodRequest) Reset 

func (x *CopyToPodRequest) Reset()

func (*CopyToPodRequest) String 

func (x *CopyToPodRequest) String() string

func (*CopyToPodRequest) Validate 

func (m *CopyToPodRequest) Validate() error

Validate checks the field values on CopyToPodRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CopyToPodRequest) ValidateAll 

func (m *CopyToPodRequest) ValidateAll() error

ValidateAll checks the field values on CopyToPodRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CopyToPodRequestMultiError, or nil if none found.

type CopyToPodRequestMultiError 

type CopyToPodRequestMultiError []error

CopyToPodRequestMultiError is an error wrapping multiple validation errors returned by CopyToPodRequest.ValidateAll() if the designated constraints aren't met.

func (CopyToPodRequestMultiError) AllErrors 

func (m CopyToPodRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CopyToPodRequestMultiError) Error 

func (m CopyToPodRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CopyToPodRequestValidationError 

type CopyToPodRequestValidationError struct {
	// contains filtered or unexported fields
}

CopyToPodRequestValidationError is the validation error returned by CopyToPodRequest.Validate if the designated constraints aren't met.

func (CopyToPodRequestValidationError) Cause 

func (e CopyToPodRequestValidationError) Cause() error

Cause function returns cause value.

func (CopyToPodRequestValidationError) Error 

func (e CopyToPodRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CopyToPodRequestValidationError) ErrorName 

func (e CopyToPodRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CopyToPodRequestValidationError) Field 

func (e CopyToPodRequestValidationError) Field() string

Field function returns field value.

func (CopyToPodRequestValidationError) Key 

func (e CopyToPodRequestValidationError) Key() bool

Key function returns key value.

func (CopyToPodRequestValidationError) Reason 

func (e CopyToPodRequestValidationError) Reason() string

Reason function returns reason value.

type CopyToPodResponse 

type CopyToPodResponse struct {
	PodFilePath string `protobuf:"bytes,1,opt,name=pod_file_path,json=podFilePath,proto3" json:"pod_file_path,omitempty"`
	Output      string `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
	FileName    string `protobuf:"bytes,3,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyToPodResponse) Descriptor deprecated 

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

Deprecated: Use CopyToPodResponse.ProtoReflect.Descriptor instead.

func (*CopyToPodResponse) GetFileName 

func (x *CopyToPodResponse) GetFileName() string

func (*CopyToPodResponse) GetOutput 

func (x *CopyToPodResponse) GetOutput() string

func (*CopyToPodResponse) GetPodFilePath 

func (x *CopyToPodResponse) GetPodFilePath() string

func (*CopyToPodResponse) ProtoMessage 

func (*CopyToPodResponse) ProtoMessage()

func (*CopyToPodResponse) ProtoReflect 

func (x *CopyToPodResponse) ProtoReflect() protoreflect.Message

func (*CopyToPodResponse) Reset 

func (x *CopyToPodResponse) Reset()

func (*CopyToPodResponse) String 

func (x *CopyToPodResponse) String() string

func (*CopyToPodResponse) Validate 

func (m *CopyToPodResponse) Validate() error

Validate checks the field values on CopyToPodResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CopyToPodResponse) ValidateAll 

func (m *CopyToPodResponse) ValidateAll() error

ValidateAll checks the field values on CopyToPodResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CopyToPodResponseMultiError, or nil if none found.

type CopyToPodResponseMultiError 

type CopyToPodResponseMultiError []error

CopyToPodResponseMultiError is an error wrapping multiple validation errors returned by CopyToPodResponse.ValidateAll() if the designated constraints aren't met.

func (CopyToPodResponseMultiError) AllErrors 

func (m CopyToPodResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CopyToPodResponseMultiError) Error 

func (m CopyToPodResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CopyToPodResponseValidationError 

type CopyToPodResponseValidationError struct {
	// contains filtered or unexported fields
}

CopyToPodResponseValidationError is the validation error returned by CopyToPodResponse.Validate if the designated constraints aren't met.

func (CopyToPodResponseValidationError) Cause 

func (e CopyToPodResponseValidationError) Cause() error

Cause function returns cause value.

func (CopyToPodResponseValidationError) Error 

func (e CopyToPodResponseValidationError) Error() string

Error satisfies the builtin error interface

func (CopyToPodResponseValidationError) ErrorName 

func (e CopyToPodResponseValidationError) ErrorName() string

ErrorName returns error name.

func (CopyToPodResponseValidationError) Field 

func (e CopyToPodResponseValidationError) Field() string

Field function returns field value.

func (CopyToPodResponseValidationError) Key 

func (e CopyToPodResponseValidationError) Key() bool

Key function returns key value.

func (CopyToPodResponseValidationError) Reason 

func (e CopyToPodResponseValidationError) Reason() string

Reason function returns reason value.

type ExecError 

type ExecError struct {
	Code    int64  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecError) Descriptor deprecated 

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

Deprecated: Use ExecError.ProtoReflect.Descriptor instead.

func (*ExecError) GetCode 

func (x *ExecError) GetCode() int64

func (*ExecError) GetMessage 

func (x *ExecError) GetMessage() string

func (*ExecError) ProtoMessage 

func (*ExecError) ProtoMessage()

func (*ExecError) ProtoReflect 

func (x *ExecError) ProtoReflect() protoreflect.Message

func (*ExecError) Reset 

func (x *ExecError) Reset()

func (*ExecError) String 

func (x *ExecError) String() string

func (*ExecError) Validate 

func (m *ExecError) Validate() error

Validate checks the field values on ExecError with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ExecError) ValidateAll 

func (m *ExecError) ValidateAll() error

ValidateAll checks the field values on ExecError with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ExecErrorMultiError, or nil if none found.

type ExecErrorMultiError 

type ExecErrorMultiError []error

ExecErrorMultiError is an error wrapping multiple validation errors returned by ExecError.ValidateAll() if the designated constraints aren't met.

func (ExecErrorMultiError) AllErrors 

func (m ExecErrorMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExecErrorMultiError) Error 

func (m ExecErrorMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ExecErrorValidationError 

type ExecErrorValidationError struct {
	// contains filtered or unexported fields
}

ExecErrorValidationError is the validation error returned by ExecError.Validate if the designated constraints aren't met.

func (ExecErrorValidationError) Cause 

func (e ExecErrorValidationError) Cause() error

Cause function returns cause value.

func (ExecErrorValidationError) Error 

func (e ExecErrorValidationError) Error() string

Error satisfies the builtin error interface

func (ExecErrorValidationError) ErrorName 

func (e ExecErrorValidationError) ErrorName() string

ErrorName returns error name.

func (ExecErrorValidationError) Field 

func (e ExecErrorValidationError) Field() string

Field function returns field value.

func (ExecErrorValidationError) Key 

func (e ExecErrorValidationError) Key() bool

Key function returns key value.

func (ExecErrorValidationError) Reason 

func (e ExecErrorValidationError) Reason() string

Reason function returns reason value.

type ExecRequest 

type ExecRequest struct {
	Namespace string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Pod       string   `protobuf:"bytes,2,opt,name=pod,proto3" json:"pod,omitempty"`
	Container string   `protobuf:"bytes,3,opt,name=container,proto3" json:"container,omitempty"`
	Command   []string `protobuf:"bytes,4,rep,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecRequest) Descriptor deprecated 

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

Deprecated: Use ExecRequest.ProtoReflect.Descriptor instead.

func (*ExecRequest) GetCommand 

func (x *ExecRequest) GetCommand() []string

func (*ExecRequest) GetContainer 

func (x *ExecRequest) GetContainer() string

func (*ExecRequest) GetNamespace 

func (x *ExecRequest) GetNamespace() string

func (*ExecRequest) GetPod 

func (x *ExecRequest) GetPod() string

func (*ExecRequest) ProtoMessage 

func (*ExecRequest) ProtoMessage()

func (*ExecRequest) ProtoReflect 

func (x *ExecRequest) ProtoReflect() protoreflect.Message

func (*ExecRequest) Reset 

func (x *ExecRequest) Reset()

func (*ExecRequest) String 

func (x *ExecRequest) String() string

func (*ExecRequest) Validate 

func (m *ExecRequest) Validate() error

Validate checks the field values on ExecRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ExecRequest) ValidateAll 

func (m *ExecRequest) ValidateAll() error

ValidateAll checks the field values on ExecRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ExecRequestMultiError, or nil if none found.

type ExecRequestMultiError 

type ExecRequestMultiError []error

ExecRequestMultiError is an error wrapping multiple validation errors returned by ExecRequest.ValidateAll() if the designated constraints aren't met.

func (ExecRequestMultiError) AllErrors 

func (m ExecRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExecRequestMultiError) Error 

func (m ExecRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ExecRequestValidationError 

type ExecRequestValidationError struct {
	// contains filtered or unexported fields
}

ExecRequestValidationError is the validation error returned by ExecRequest.Validate if the designated constraints aren't met.

func (ExecRequestValidationError) Cause 

func (e ExecRequestValidationError) Cause() error

Cause function returns cause value.

func (ExecRequestValidationError) Error 

func (e ExecRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ExecRequestValidationError) ErrorName 

func (e ExecRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ExecRequestValidationError) Field 

func (e ExecRequestValidationError) Field() string

Field function returns field value.

func (ExecRequestValidationError) Key 

func (e ExecRequestValidationError) Key() bool

Key function returns key value.

func (ExecRequestValidationError) Reason 

func (e ExecRequestValidationError) Reason() string

Reason function returns reason value.

type ExecResponse 

type ExecResponse struct {
	Message string     `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Error   *ExecError `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecResponse) Descriptor deprecated 

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

Deprecated: Use ExecResponse.ProtoReflect.Descriptor instead.

func (*ExecResponse) GetError 

func (x *ExecResponse) GetError() *ExecError

func (*ExecResponse) GetMessage 

func (x *ExecResponse) GetMessage() string

func (*ExecResponse) ProtoMessage 

func (*ExecResponse) ProtoMessage()

func (*ExecResponse) ProtoReflect 

func (x *ExecResponse) ProtoReflect() protoreflect.Message

func (*ExecResponse) Reset 

func (x *ExecResponse) Reset()

func (*ExecResponse) String 

func (x *ExecResponse) String() string

func (*ExecResponse) Validate 

func (m *ExecResponse) Validate() error

Validate checks the field values on ExecResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ExecResponse) ValidateAll 

func (m *ExecResponse) ValidateAll() error

ValidateAll checks the field values on ExecResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ExecResponseMultiError, or nil if none found.

type ExecResponseMultiError 

type ExecResponseMultiError []error

ExecResponseMultiError is an error wrapping multiple validation errors returned by ExecResponse.ValidateAll() if the designated constraints aren't met.

func (ExecResponseMultiError) AllErrors 

func (m ExecResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExecResponseMultiError) Error 

func (m ExecResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ExecResponseValidationError 

type ExecResponseValidationError struct {
	// contains filtered or unexported fields
}

ExecResponseValidationError is the validation error returned by ExecResponse.Validate if the designated constraints aren't met.

func (ExecResponseValidationError) Cause 

func (e ExecResponseValidationError) Cause() error

Cause function returns cause value.

func (ExecResponseValidationError) Error 

func (e ExecResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ExecResponseValidationError) ErrorName 

func (e ExecResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ExecResponseValidationError) Field 

func (e ExecResponseValidationError) Field() string

Field function returns field value.

func (ExecResponseValidationError) Key 

func (e ExecResponseValidationError) Key() bool

Key function returns key value.

func (ExecResponseValidationError) Reason 

func (e ExecResponseValidationError) Reason() string

Reason function returns reason value.

type IsPodExistsRequest 

type IsPodExistsRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Pod       string `protobuf:"bytes,2,opt,name=pod,proto3" json:"pod,omitempty"`
	// contains filtered or unexported fields
}

func (*IsPodExistsRequest) Descriptor deprecated 

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

Deprecated: Use IsPodExistsRequest.ProtoReflect.Descriptor instead.

func (*IsPodExistsRequest) GetNamespace 

func (x *IsPodExistsRequest) GetNamespace() string

func (*IsPodExistsRequest) GetPod 

func (x *IsPodExistsRequest) GetPod() string

func (*IsPodExistsRequest) ProtoMessage 

func (*IsPodExistsRequest) ProtoMessage()

func (*IsPodExistsRequest) ProtoReflect 

func (x *IsPodExistsRequest) ProtoReflect() protoreflect.Message

func (*IsPodExistsRequest) Reset 

func (x *IsPodExistsRequest) Reset()

func (*IsPodExistsRequest) String 

func (x *IsPodExistsRequest) String() string

func (*IsPodExistsRequest) Validate 

func (m *IsPodExistsRequest) Validate() error

Validate checks the field values on IsPodExistsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*IsPodExistsRequest) ValidateAll 

func (m *IsPodExistsRequest) ValidateAll() error

ValidateAll checks the field values on IsPodExistsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in IsPodExistsRequestMultiError, or nil if none found.

type IsPodExistsRequestMultiError 

type IsPodExistsRequestMultiError []error

IsPodExistsRequestMultiError is an error wrapping multiple validation errors returned by IsPodExistsRequest.ValidateAll() if the designated constraints aren't met.

func (IsPodExistsRequestMultiError) AllErrors 

func (m IsPodExistsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (IsPodExistsRequestMultiError) Error 

func (m IsPodExistsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type IsPodExistsRequestValidationError 

type IsPodExistsRequestValidationError struct {
	// contains filtered or unexported fields
}

IsPodExistsRequestValidationError is the validation error returned by IsPodExistsRequest.Validate if the designated constraints aren't met.

func (IsPodExistsRequestValidationError) Cause 

func (e IsPodExistsRequestValidationError) Cause() error

Cause function returns cause value.

func (IsPodExistsRequestValidationError) Error 

func (e IsPodExistsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (IsPodExistsRequestValidationError) ErrorName 

func (e IsPodExistsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (IsPodExistsRequestValidationError) Field 

func (e IsPodExistsRequestValidationError) Field() string

Field function returns field value.

func (IsPodExistsRequestValidationError) Key 

func (e IsPodExistsRequestValidationError) Key() bool

Key function returns key value.

func (IsPodExistsRequestValidationError) Reason 

func (e IsPodExistsRequestValidationError) Reason() string

Reason function returns reason value.

type IsPodExistsResponse 

type IsPodExistsResponse struct {
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

func (*IsPodExistsResponse) Descriptor deprecated 

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

Deprecated: Use IsPodExistsResponse.ProtoReflect.Descriptor instead.

func (*IsPodExistsResponse) GetExists 

func (x *IsPodExistsResponse) GetExists() bool

func (*IsPodExistsResponse) ProtoMessage 

func (*IsPodExistsResponse) ProtoMessage()

func (*IsPodExistsResponse) ProtoReflect 

func (x *IsPodExistsResponse) ProtoReflect() protoreflect.Message

func (*IsPodExistsResponse) Reset 

func (x *IsPodExistsResponse) Reset()

func (*IsPodExistsResponse) String 

func (x *IsPodExistsResponse) String() string

func (*IsPodExistsResponse) Validate 

func (m *IsPodExistsResponse) Validate() error

Validate checks the field values on IsPodExistsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*IsPodExistsResponse) ValidateAll 

func (m *IsPodExistsResponse) ValidateAll() error

ValidateAll checks the field values on IsPodExistsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in IsPodExistsResponseMultiError, or nil if none found.

type IsPodExistsResponseMultiError 

type IsPodExistsResponseMultiError []error

IsPodExistsResponseMultiError is an error wrapping multiple validation errors returned by IsPodExistsResponse.ValidateAll() if the designated constraints aren't met.

func (IsPodExistsResponseMultiError) AllErrors 

func (m IsPodExistsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (IsPodExistsResponseMultiError) Error 

func (m IsPodExistsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type IsPodExistsResponseValidationError 

type IsPodExistsResponseValidationError struct {
	// contains filtered or unexported fields
}

IsPodExistsResponseValidationError is the validation error returned by IsPodExistsResponse.Validate if the designated constraints aren't met.

func (IsPodExistsResponseValidationError) Cause 

func (e IsPodExistsResponseValidationError) Cause() error

Cause function returns cause value.

func (IsPodExistsResponseValidationError) Error 

func (e IsPodExistsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (IsPodExistsResponseValidationError) ErrorName 

func (e IsPodExistsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (IsPodExistsResponseValidationError) Field 

func (e IsPodExistsResponseValidationError) Field() string

Field function returns field value.

func (IsPodExistsResponseValidationError) Key 

func (e IsPodExistsResponseValidationError) Key() bool

Key function returns key value.

func (IsPodExistsResponseValidationError) Reason 

func (e IsPodExistsResponseValidationError) Reason() string

Reason function returns reason value.

type IsPodRunningRequest 

type IsPodRunningRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Pod       string `protobuf:"bytes,2,opt,name=pod,proto3" json:"pod,omitempty"`
	// contains filtered or unexported fields
}

func (*IsPodRunningRequest) Descriptor deprecated 

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

Deprecated: Use IsPodRunningRequest.ProtoReflect.Descriptor instead.

func (*IsPodRunningRequest) GetNamespace 

func (x *IsPodRunningRequest) GetNamespace() string

func (*IsPodRunningRequest) GetPod 

func (x *IsPodRunningRequest) GetPod() string

func (*IsPodRunningRequest) ProtoMessage 

func (*IsPodRunningRequest) ProtoMessage()

func (*IsPodRunningRequest) ProtoReflect 

func (x *IsPodRunningRequest) ProtoReflect() protoreflect.Message

func (*IsPodRunningRequest) Reset 

func (x *IsPodRunningRequest) Reset()

func (*IsPodRunningRequest) String 

func (x *IsPodRunningRequest) String() string

func (*IsPodRunningRequest) Validate 

func (m *IsPodRunningRequest) Validate() error

Validate checks the field values on IsPodRunningRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*IsPodRunningRequest) ValidateAll 

func (m *IsPodRunningRequest) ValidateAll() error

ValidateAll checks the field values on IsPodRunningRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in IsPodRunningRequestMultiError, or nil if none found.

type IsPodRunningRequestMultiError 

type IsPodRunningRequestMultiError []error

IsPodRunningRequestMultiError is an error wrapping multiple validation errors returned by IsPodRunningRequest.ValidateAll() if the designated constraints aren't met.

func (IsPodRunningRequestMultiError) AllErrors 

func (m IsPodRunningRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (IsPodRunningRequestMultiError) Error 

func (m IsPodRunningRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type IsPodRunningRequestValidationError 

type IsPodRunningRequestValidationError struct {
	// contains filtered or unexported fields
}

IsPodRunningRequestValidationError is the validation error returned by IsPodRunningRequest.Validate if the designated constraints aren't met.

func (IsPodRunningRequestValidationError) Cause 

func (e IsPodRunningRequestValidationError) Cause() error

Cause function returns cause value.

func (IsPodRunningRequestValidationError) Error 

func (e IsPodRunningRequestValidationError) Error() string

Error satisfies the builtin error interface

func (IsPodRunningRequestValidationError) ErrorName 

func (e IsPodRunningRequestValidationError) ErrorName() string

ErrorName returns error name.

func (IsPodRunningRequestValidationError) Field 

func (e IsPodRunningRequestValidationError) Field() string

Field function returns field value.

func (IsPodRunningRequestValidationError) Key 

func (e IsPodRunningRequestValidationError) Key() bool

Key function returns key value.

func (IsPodRunningRequestValidationError) Reason 

func (e IsPodRunningRequestValidationError) Reason() string

Reason function returns reason value.

type IsPodRunningResponse 

type IsPodRunningResponse struct {
	Running bool   `protobuf:"varint,1,opt,name=running,proto3" json:"running,omitempty"`
	Reason  string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*IsPodRunningResponse) Descriptor deprecated 

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

Deprecated: Use IsPodRunningResponse.ProtoReflect.Descriptor instead.

func (*IsPodRunningResponse) GetReason 

func (x *IsPodRunningResponse) GetReason() string

func (*IsPodRunningResponse) GetRunning 

func (x *IsPodRunningResponse) GetRunning() bool

func (*IsPodRunningResponse) ProtoMessage 

func (*IsPodRunningResponse) ProtoMessage()

func (*IsPodRunningResponse) ProtoReflect 

func (x *IsPodRunningResponse) ProtoReflect() protoreflect.Message

func (*IsPodRunningResponse) Reset 

func (x *IsPodRunningResponse) Reset()

func (*IsPodRunningResponse) String 

func (x *IsPodRunningResponse) String() string

func (*IsPodRunningResponse) Validate 

func (m *IsPodRunningResponse) Validate() error

Validate checks the field values on IsPodRunningResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*IsPodRunningResponse) ValidateAll 

func (m *IsPodRunningResponse) ValidateAll() error

ValidateAll checks the field values on IsPodRunningResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in IsPodRunningResponseMultiError, or nil if none found.

type IsPodRunningResponseMultiError 

type IsPodRunningResponseMultiError []error

IsPodRunningResponseMultiError is an error wrapping multiple validation errors returned by IsPodRunningResponse.ValidateAll() if the designated constraints aren't met.

func (IsPodRunningResponseMultiError) AllErrors 

func (m IsPodRunningResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (IsPodRunningResponseMultiError) Error 

func (m IsPodRunningResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type IsPodRunningResponseValidationError 

type IsPodRunningResponseValidationError struct {
	// contains filtered or unexported fields
}

IsPodRunningResponseValidationError is the validation error returned by IsPodRunningResponse.Validate if the designated constraints aren't met.

func (IsPodRunningResponseValidationError) Cause 

func (e IsPodRunningResponseValidationError) Cause() error

Cause function returns cause value.

func (IsPodRunningResponseValidationError) Error 

func (e IsPodRunningResponseValidationError) Error() string

Error satisfies the builtin error interface

func (IsPodRunningResponseValidationError) ErrorName 

func (e IsPodRunningResponseValidationError) ErrorName() string

ErrorName returns error name.

func (IsPodRunningResponseValidationError) Field 

func (e IsPodRunningResponseValidationError) Field() string

Field function returns field value.

func (IsPodRunningResponseValidationError) Key 

func (e IsPodRunningResponseValidationError) Key() bool

Key function returns key value.

func (IsPodRunningResponseValidationError) Reason 

func (e IsPodRunningResponseValidationError) Reason() string

Reason function returns reason value.

type LogRequest 

type LogRequest struct {
	Namespace  string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Pod        string `protobuf:"bytes,2,opt,name=pod,proto3" json:"pod,omitempty"`
	Container  string `protobuf:"bytes,3,opt,name=container,proto3" json:"container,omitempty"`
	ShowEvents bool   `protobuf:"varint,4,opt,name=show_events,json=showEvents,proto3" json:"show_events,omitempty"`
	// contains filtered or unexported fields
}

func (*LogRequest) Descriptor deprecated 

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

Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.

func (*LogRequest) GetContainer 

func (x *LogRequest) GetContainer() string

func (*LogRequest) GetNamespace 

func (x *LogRequest) GetNamespace() string

func (*LogRequest) GetPod 

func (x *LogRequest) GetPod() string

func (*LogRequest) GetShowEvents 

func (x *LogRequest) GetShowEvents() bool

func (*LogRequest) ProtoMessage 

func (*LogRequest) ProtoMessage()

func (*LogRequest) ProtoReflect 

func (x *LogRequest) ProtoReflect() protoreflect.Message

func (*LogRequest) Reset 

func (x *LogRequest) Reset()

func (*LogRequest) String 

func (x *LogRequest) String() string

func (*LogRequest) Validate 

func (m *LogRequest) Validate() error

Validate checks the field values on LogRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LogRequest) ValidateAll 

func (m *LogRequest) ValidateAll() error

ValidateAll checks the field values on LogRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LogRequestMultiError, or nil if none found.

type LogRequestMultiError 

type LogRequestMultiError []error

LogRequestMultiError is an error wrapping multiple validation errors returned by LogRequest.ValidateAll() if the designated constraints aren't met.

func (LogRequestMultiError) AllErrors 

func (m LogRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogRequestMultiError) Error 

func (m LogRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type LogRequestValidationError 

type LogRequestValidationError struct {
	// contains filtered or unexported fields
}

LogRequestValidationError is the validation error returned by LogRequest.Validate if the designated constraints aren't met.

func (LogRequestValidationError) Cause 

func (e LogRequestValidationError) Cause() error

Cause function returns cause value.

func (LogRequestValidationError) Error 

func (e LogRequestValidationError) Error() string

Error satisfies the builtin error interface

func (LogRequestValidationError) ErrorName 

func (e LogRequestValidationError) ErrorName() string

ErrorName returns error name.

func (LogRequestValidationError) Field 

func (e LogRequestValidationError) Field() string

Field function returns field value.

func (LogRequestValidationError) Key 

func (e LogRequestValidationError) Key() bool

Key function returns key value.

func (LogRequestValidationError) Reason 

func (e LogRequestValidationError) Reason() string

Reason function returns reason value.

type LogResponse 

type LogResponse struct {
	Namespace     string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	PodName       string `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	ContainerName string `protobuf:"bytes,3,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"`
	Log           string `protobuf:"bytes,4,opt,name=log,proto3" json:"log,omitempty"`
	// contains filtered or unexported fields
}

func (*LogResponse) Descriptor deprecated 

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

Deprecated: Use LogResponse.ProtoReflect.Descriptor instead.

func (*LogResponse) GetContainerName 

func (x *LogResponse) GetContainerName() string

func (*LogResponse) GetLog 

func (x *LogResponse) GetLog() string

func (*LogResponse) GetNamespace 

func (x *LogResponse) GetNamespace() string

func (*LogResponse) GetPodName 

func (x *LogResponse) GetPodName() string

func (*LogResponse) ProtoMessage 

func (*LogResponse) ProtoMessage()

func (*LogResponse) ProtoReflect 

func (x *LogResponse) ProtoReflect() protoreflect.Message

func (*LogResponse) Reset 

func (x *LogResponse) Reset()

func (*LogResponse) String 

func (x *LogResponse) String() string

func (*LogResponse) Validate 

func (m *LogResponse) Validate() error

Validate checks the field values on LogResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LogResponse) ValidateAll 

func (m *LogResponse) ValidateAll() error

ValidateAll checks the field values on LogResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LogResponseMultiError, or nil if none found.

type LogResponseMultiError 

type LogResponseMultiError []error

LogResponseMultiError is an error wrapping multiple validation errors returned by LogResponse.ValidateAll() if the designated constraints aren't met.

func (LogResponseMultiError) AllErrors 

func (m LogResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogResponseMultiError) Error 

func (m LogResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type LogResponseValidationError 

type LogResponseValidationError struct {
	// contains filtered or unexported fields
}

LogResponseValidationError is the validation error returned by LogResponse.Validate if the designated constraints aren't met.

func (LogResponseValidationError) Cause 

func (e LogResponseValidationError) Cause() error

Cause function returns cause value.

func (LogResponseValidationError) Error 

func (e LogResponseValidationError) Error() string

Error satisfies the builtin error interface

func (LogResponseValidationError) ErrorName 

func (e LogResponseValidationError) ErrorName() string

ErrorName returns error name.

func (LogResponseValidationError) Field 

func (e LogResponseValidationError) Field() string

Field function returns field value.

func (LogResponseValidationError) Key 

func (e LogResponseValidationError) Key() bool

Key function returns key value.

func (LogResponseValidationError) Reason 

func (e LogResponseValidationError) Reason() string

Reason function returns reason value.

type StreamCopyToPodRequest 

type StreamCopyToPodRequest struct {
	FileName  string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	Data      []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Pod       string `protobuf:"bytes,4,opt,name=pod,proto3" json:"pod,omitempty"`
	Container string `protobuf:"bytes,5,opt,name=container,proto3" json:"container,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCopyToPodRequest) Descriptor deprecated 

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

Deprecated: Use StreamCopyToPodRequest.ProtoReflect.Descriptor instead.

func (*StreamCopyToPodRequest) GetContainer 

func (x *StreamCopyToPodRequest) GetContainer() string

func (*StreamCopyToPodRequest) GetData 

func (x *StreamCopyToPodRequest) GetData() []byte

func (*StreamCopyToPodRequest) GetFileName 

func (x *StreamCopyToPodRequest) GetFileName() string

func (*StreamCopyToPodRequest) GetNamespace 

func (x *StreamCopyToPodRequest) GetNamespace() string

func (*StreamCopyToPodRequest) GetPod 

func (x *StreamCopyToPodRequest) GetPod() string

func (*StreamCopyToPodRequest) ProtoMessage 

func (*StreamCopyToPodRequest) ProtoMessage()

func (*StreamCopyToPodRequest) ProtoReflect 

func (x *StreamCopyToPodRequest) ProtoReflect() protoreflect.Message

func (*StreamCopyToPodRequest) Reset 

func (x *StreamCopyToPodRequest) Reset()

func (*StreamCopyToPodRequest) String 

func (x *StreamCopyToPodRequest) String() string

func (*StreamCopyToPodRequest) Validate 

func (m *StreamCopyToPodRequest) Validate() error

Validate checks the field values on StreamCopyToPodRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StreamCopyToPodRequest) ValidateAll 

func (m *StreamCopyToPodRequest) ValidateAll() error

ValidateAll checks the field values on StreamCopyToPodRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StreamCopyToPodRequestMultiError, or nil if none found.

type StreamCopyToPodRequestMultiError 

type StreamCopyToPodRequestMultiError []error

StreamCopyToPodRequestMultiError is an error wrapping multiple validation errors returned by StreamCopyToPodRequest.ValidateAll() if the designated constraints aren't met.

func (StreamCopyToPodRequestMultiError) AllErrors 

func (m StreamCopyToPodRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StreamCopyToPodRequestMultiError) Error 

func (m StreamCopyToPodRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type StreamCopyToPodRequestValidationError 

type StreamCopyToPodRequestValidationError struct {
	// contains filtered or unexported fields
}

StreamCopyToPodRequestValidationError is the validation error returned by StreamCopyToPodRequest.Validate if the designated constraints aren't met.

func (StreamCopyToPodRequestValidationError) Cause 

func (e StreamCopyToPodRequestValidationError) Cause() error

Cause function returns cause value.

func (StreamCopyToPodRequestValidationError) Error 

func (e StreamCopyToPodRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StreamCopyToPodRequestValidationError) ErrorName 

func (e StreamCopyToPodRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StreamCopyToPodRequestValidationError) Field 

func (e StreamCopyToPodRequestValidationError) Field() string

Field function returns field value.

func (StreamCopyToPodRequestValidationError) Key 

func (e StreamCopyToPodRequestValidationError) Key() bool

Key function returns key value.

func (StreamCopyToPodRequestValidationError) Reason 

func (e StreamCopyToPodRequestValidationError) Reason() string

Reason function returns reason value.

type StreamCopyToPodResponse 

type StreamCopyToPodResponse struct {
	Size        int64  `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	PodFilePath string `protobuf:"bytes,2,opt,name=pod_file_path,json=podFilePath,proto3" json:"pod_file_path,omitempty"`
	Output      string `protobuf:"bytes,3,opt,name=output,proto3" json:"output,omitempty"`
	Pod         string `protobuf:"bytes,4,opt,name=pod,proto3" json:"pod,omitempty"`
	Namespace   string `protobuf:"bytes,5,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Container   string `protobuf:"bytes,6,opt,name=container,proto3" json:"container,omitempty"`
	Filename    string `protobuf:"bytes,7,opt,name=filename,proto3" json:"filename,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCopyToPodResponse) Descriptor deprecated 

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

Deprecated: Use StreamCopyToPodResponse.ProtoReflect.Descriptor instead.

func (*StreamCopyToPodResponse) GetContainer 

func (x *StreamCopyToPodResponse) GetContainer() string

func (*StreamCopyToPodResponse) GetFilename 

func (x *StreamCopyToPodResponse) GetFilename() string

func (*StreamCopyToPodResponse) GetNamespace 

func (x *StreamCopyToPodResponse) GetNamespace() string

func (*StreamCopyToPodResponse) GetOutput 

func (x *StreamCopyToPodResponse) GetOutput() string

func (*StreamCopyToPodResponse) GetPod 

func (x *StreamCopyToPodResponse) GetPod() string

func (*StreamCopyToPodResponse) GetPodFilePath 

func (x *StreamCopyToPodResponse) GetPodFilePath() string

func (*StreamCopyToPodResponse) GetSize 

func (x *StreamCopyToPodResponse) GetSize() int64

func (*StreamCopyToPodResponse) ProtoMessage 

func (*StreamCopyToPodResponse) ProtoMessage()

func (*StreamCopyToPodResponse) ProtoReflect 

func (x *StreamCopyToPodResponse) ProtoReflect() protoreflect.Message

func (*StreamCopyToPodResponse) Reset 

func (x *StreamCopyToPodResponse) Reset()

func (*StreamCopyToPodResponse) String 

func (x *StreamCopyToPodResponse) String() string

func (*StreamCopyToPodResponse) Validate 

func (m *StreamCopyToPodResponse) Validate() error

Validate checks the field values on StreamCopyToPodResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StreamCopyToPodResponse) ValidateAll 

func (m *StreamCopyToPodResponse) ValidateAll() error

ValidateAll checks the field values on StreamCopyToPodResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StreamCopyToPodResponseMultiError, or nil if none found.

type StreamCopyToPodResponseMultiError 

type StreamCopyToPodResponseMultiError []error

StreamCopyToPodResponseMultiError is an error wrapping multiple validation errors returned by StreamCopyToPodResponse.ValidateAll() if the designated constraints aren't met.

func (StreamCopyToPodResponseMultiError) AllErrors 

func (m StreamCopyToPodResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StreamCopyToPodResponseMultiError) Error 

func (m StreamCopyToPodResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type StreamCopyToPodResponseValidationError 

type StreamCopyToPodResponseValidationError struct {
	// contains filtered or unexported fields
}

StreamCopyToPodResponseValidationError is the validation error returned by StreamCopyToPodResponse.Validate if the designated constraints aren't met.

func (StreamCopyToPodResponseValidationError) Cause 

func (e StreamCopyToPodResponseValidationError) Cause() error

Cause function returns cause value.

func (StreamCopyToPodResponseValidationError) Error 

func (e StreamCopyToPodResponseValidationError) Error() string

Error satisfies the builtin error interface

func (StreamCopyToPodResponseValidationError) ErrorName 

func (e StreamCopyToPodResponseValidationError) ErrorName() string

ErrorName returns error name.

func (StreamCopyToPodResponseValidationError) Field 

func (e StreamCopyToPodResponseValidationError) Field() string

Field function returns field value.

func (StreamCopyToPodResponseValidationError) Key 

func (e StreamCopyToPodResponseValidationError) Key() bool

Key function returns key value.

func (StreamCopyToPodResponseValidationError) Reason 

func (e StreamCopyToPodResponseValidationError) Reason() string

Reason function returns reason value.

type UnimplementedContainerServer 

type UnimplementedContainerServer struct {
}

UnimplementedContainerServer must be embedded to have forward compatible implementations.

func (UnimplementedContainerServer) ContainerLog 

func (UnimplementedContainerServer) ContainerLog(context.Context, *LogRequest) (*LogResponse, error)

func (UnimplementedContainerServer) CopyToPod 

func (UnimplementedContainerServer) CopyToPod(context.Context, *CopyToPodRequest) (*CopyToPodResponse, error)

func (UnimplementedContainerServer) Exec 

func (UnimplementedContainerServer) Exec(*ExecRequest, Container_ExecServer) error

func (UnimplementedContainerServer) IsPodExists 

func (UnimplementedContainerServer) IsPodExists(context.Context, *IsPodExistsRequest) (*IsPodExistsResponse, error)

func (UnimplementedContainerServer) IsPodRunning 

func (UnimplementedContainerServer) IsPodRunning(context.Context, *IsPodRunningRequest) (*IsPodRunningResponse, error)

func (UnimplementedContainerServer) StreamContainerLog 

func (UnimplementedContainerServer) StreamContainerLog(*LogRequest, Container_StreamContainerLogServer) error

func (UnimplementedContainerServer) StreamCopyToPod 

func (UnimplementedContainerServer) StreamCopyToPod(Container_StreamCopyToPodServer) error

type UnsafeContainerServer 

type UnsafeContainerServer interface {
	// contains filtered or unexported methods
}

UnsafeContainerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ContainerServer will result in compilation errors.

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.