container

package
v0.0.0-...-51115e0 Latest Latest
Warning

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

 Go to latest Published: Feb 25, 2022 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

This section is empty.

Variables

View Source 
var ContainerSvc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ContainerSvc",
	HandlerType: (*ContainerSvcServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CopyToPod",
			Handler:    _ContainerSvc_CopyToPod_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Exec",
			Handler:       _ContainerSvc_Exec_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamCopyToPod",
			Handler:       _ContainerSvc_StreamCopyToPod_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "container/container.proto",
}

ContainerSvc_ServiceDesc is the grpc.ServiceDesc for ContainerSvc 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 RegisterContainerSvcHandler 

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

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

func RegisterContainerSvcHandlerClient 

func RegisterContainerSvcHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ContainerSvcClient) error

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

func RegisterContainerSvcHandlerFromEndpoint 

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

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

func RegisterContainerSvcHandlerServer 

func RegisterContainerSvcHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ContainerSvcServer) error

RegisterContainerSvcHandlerServer registers the http handlers for service ContainerSvc to "mux". UnaryRPC :call ContainerSvcServer 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 RegisterContainerSvcHandlerFromEndpoint instead.

func RegisterContainerSvcServer 

func RegisterContainerSvcServer(s grpc.ServiceRegistrar, srv ContainerSvcServer)

Types

type ContainerSvcClient 

type ContainerSvcClient 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) (ContainerSvc_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)
	//		_, err := bf.Read(bts)
	//		if err != nil {
	//			if err == io.EOF {
	//				cp.Send(&container.StreamCopyToPodRequest{
	//					FileName:  filename,
	//					Data:      bts,
	//					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,
	//			Namespace: namespace,
	//			Pod:       pod,
	//			Container: containerName,
	//		 })
	//	}
	StreamCopyToPod(ctx context.Context, opts ...grpc.CallOption) (ContainerSvc_StreamCopyToPodClient, error)
}

ContainerSvcClient is the client API for ContainerSvc service.

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

func NewContainerSvcClient 

func NewContainerSvcClient(cc grpc.ClientConnInterface) ContainerSvcClient

type ContainerSvcServer 

type ContainerSvcServer interface {
	// CopyToPod (web): 页面上传文件到 pod 内部
	CopyToPod(context.Context, *CopyToPodRequest) (*CopyToPodResponse, error)
	// Exec grpc 执行 pod 命令
	Exec(*ExecRequest, ContainerSvc_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)
	//		_, err := bf.Read(bts)
	//		if err != nil {
	//			if err == io.EOF {
	//				cp.Send(&container.StreamCopyToPodRequest{
	//					FileName:  filename,
	//					Data:      bts,
	//					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,
	//			Namespace: namespace,
	//			Pod:       pod,
	//			Container: containerName,
	//		 })
	//	}
	StreamCopyToPod(ContainerSvc_StreamCopyToPodServer) error
	// contains filtered or unexported methods
}

ContainerSvcServer is the server API for ContainerSvc service. All implementations must embed UnimplementedContainerSvcServer for forward compatibility

type ContainerSvc_ExecClient 

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

type ContainerSvc_ExecServer 

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

type ContainerSvc_StreamCopyToPodClient 

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

type ContainerSvc_StreamCopyToPodServer 

type ContainerSvc_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=podFilePath,proto3" json:"podFilePath,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 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 {
	Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecResponse) Descriptor deprecated 

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

Deprecated: Use ExecResponse.ProtoReflect.Descriptor instead.

func (*ExecResponse) GetData 

func (x *ExecResponse) GetData() 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 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=podFilePath,proto3" json:"podFilePath,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 UnimplementedContainerSvcServer 

type UnimplementedContainerSvcServer struct {
}

UnimplementedContainerSvcServer must be embedded to have forward compatible implementations.

func (UnimplementedContainerSvcServer) CopyToPod 

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

func (UnimplementedContainerSvcServer) Exec 

func (UnimplementedContainerSvcServer) Exec(*ExecRequest, ContainerSvc_ExecServer) error

func (UnimplementedContainerSvcServer) StreamCopyToPod 

func (UnimplementedContainerSvcServer) StreamCopyToPod(ContainerSvc_StreamCopyToPodServer) error

type UnsafeContainerSvcServer 

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

UnsafeContainerSvcServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ContainerSvcServer 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.