Documentation ¶
Index ¶
- Variables
- func RegisterPluginServer(s *grpc.Server, srv PluginServer)
- type CreateContainerRequest
- func (*CreateContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateContainerRequest) GetConfig() *v1alpha5.Backdrop
- func (x *CreateContainerRequest) GetStdio() bool
- func (x *CreateContainerRequest) GetTty() bool
- func (*CreateContainerRequest) ProtoMessage()
- func (x *CreateContainerRequest) ProtoReflect() protoreflect.Message
- func (x *CreateContainerRequest) Reset()
- func (x *CreateContainerRequest) String() string
- type CreateContainerResponse
- func (*CreateContainerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateContainerResponse) GetContainerId() string
- func (*CreateContainerResponse) ProtoMessage()
- func (x *CreateContainerResponse) ProtoReflect() protoreflect.Message
- func (x *CreateContainerResponse) Reset()
- func (x *CreateContainerResponse) String() string
- type DeleteContainerRequest
- func (*DeleteContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteContainerRequest) GetContainerId() string
- func (*DeleteContainerRequest) ProtoMessage()
- func (x *DeleteContainerRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteContainerRequest) Reset()
- func (x *DeleteContainerRequest) String() string
- type GetImageRequest
- type GetImageResponse
- type KillContainerRequest
- func (*KillContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *KillContainerRequest) GetContainerId() string
- func (x *KillContainerRequest) GetSignal() string
- func (*KillContainerRequest) ProtoMessage()
- func (x *KillContainerRequest) ProtoReflect() protoreflect.Message
- func (x *KillContainerRequest) Reset()
- func (x *KillContainerRequest) String() string
- type PluginClient
- type PluginServer
- type Plugin_StreamInputClient
- type Plugin_StreamInputServer
- type Plugin_StreamOutputClient
- type Plugin_StreamOutputServer
- type ResizeContainerRequest
- func (*ResizeContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResizeContainerRequest) GetContainerId() string
- func (x *ResizeContainerRequest) GetHeight() uint32
- func (x *ResizeContainerRequest) GetWidth() uint32
- func (*ResizeContainerRequest) ProtoMessage()
- func (x *ResizeContainerRequest) ProtoReflect() protoreflect.Message
- func (x *ResizeContainerRequest) Reset()
- func (x *ResizeContainerRequest) String() string
- type StartContainerRequest
- func (*StartContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartContainerRequest) GetContainerId() string
- func (*StartContainerRequest) ProtoMessage()
- func (x *StartContainerRequest) ProtoReflect() protoreflect.Message
- func (x *StartContainerRequest) Reset()
- func (x *StartContainerRequest) String() string
- type StreamContainerRequest
- func (*StreamContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamContainerRequest) GetContainerId() string
- func (x *StreamContainerRequest) GetHeight() uint32
- func (x *StreamContainerRequest) GetWidth() uint32
- func (*StreamContainerRequest) ProtoMessage()
- func (x *StreamContainerRequest) ProtoReflect() protoreflect.Message
- func (x *StreamContainerRequest) Reset()
- func (x *StreamContainerRequest) String() string
- type StreamContainerResponse
- func (*StreamContainerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamContainerResponse) GetExitCode() int64
- func (x *StreamContainerResponse) GetMessage() string
- func (*StreamContainerResponse) ProtoMessage()
- func (x *StreamContainerResponse) ProtoReflect() protoreflect.Message
- func (x *StreamContainerResponse) Reset()
- func (x *StreamContainerResponse) String() string
- type UnimplementedPluginServer
- func (*UnimplementedPluginServer) CreateContainer(context.Context, *CreateContainerRequest) (*CreateContainerResponse, error)
- func (*UnimplementedPluginServer) DeleteContainer(context.Context, *DeleteContainerRequest) (*empty.Empty, error)
- func (*UnimplementedPluginServer) GetImage(context.Context, *GetImageRequest) (*GetImageResponse, error)
- func (*UnimplementedPluginServer) GetPluginInfo(context.Context, *empty.Empty) (*v1alpha5.PluginInfo, error)
- func (*UnimplementedPluginServer) InitPlugin(context.Context, *empty.Empty) (*v1alpha5.InitPluginResponse, error)
- func (*UnimplementedPluginServer) KillContainer(context.Context, *KillContainerRequest) (*empty.Empty, error)
- func (*UnimplementedPluginServer) ResetPlugin(context.Context, *empty.Empty) (*empty.Empty, error)
- func (*UnimplementedPluginServer) ResizeContainer(context.Context, *ResizeContainerRequest) (*empty.Empty, error)
- func (*UnimplementedPluginServer) StartContainer(context.Context, *StartContainerRequest) (*empty.Empty, error)
- func (*UnimplementedPluginServer) StreamContainer(context.Context, *StreamContainerRequest) (*StreamContainerResponse, error)
- func (*UnimplementedPluginServer) StreamInput(Plugin_StreamInputServer) error
- func (*UnimplementedPluginServer) StreamOutput(*v1alpha5.StreamOutputRequest, Plugin_StreamOutputServer) error
Constants ¶
This section is empty.
Variables ¶
var File_runtime_v1alpha1_runtime_proto protoreflect.FileDescriptor
Functions ¶
func RegisterPluginServer ¶
func RegisterPluginServer(s *grpc.Server, srv PluginServer)
Types ¶
type CreateContainerRequest ¶
type CreateContainerRequest struct { Config *v1alpha5.Backdrop `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` Tty bool `protobuf:"varint,2,opt,name=tty,proto3" json:"tty,omitempty"` Stdio bool `protobuf:"varint,3,opt,name=stdio,proto3" json:"stdio,omitempty"` // contains filtered or unexported fields }
func (*CreateContainerRequest) Descriptor
deprecated
func (*CreateContainerRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateContainerRequest.ProtoReflect.Descriptor instead.
func (*CreateContainerRequest) GetConfig ¶
func (x *CreateContainerRequest) GetConfig() *v1alpha5.Backdrop
func (*CreateContainerRequest) GetStdio ¶
func (x *CreateContainerRequest) GetStdio() bool
func (*CreateContainerRequest) GetTty ¶
func (x *CreateContainerRequest) GetTty() bool
func (*CreateContainerRequest) ProtoMessage ¶
func (*CreateContainerRequest) ProtoMessage()
func (*CreateContainerRequest) ProtoReflect ¶
func (x *CreateContainerRequest) ProtoReflect() protoreflect.Message
func (*CreateContainerRequest) Reset ¶
func (x *CreateContainerRequest) Reset()
func (*CreateContainerRequest) String ¶
func (x *CreateContainerRequest) String() string
type CreateContainerResponse ¶
type CreateContainerResponse struct { ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` // contains filtered or unexported fields }
func (*CreateContainerResponse) Descriptor
deprecated
func (*CreateContainerResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateContainerResponse.ProtoReflect.Descriptor instead.
func (*CreateContainerResponse) GetContainerId ¶
func (x *CreateContainerResponse) GetContainerId() string
func (*CreateContainerResponse) ProtoMessage ¶
func (*CreateContainerResponse) ProtoMessage()
func (*CreateContainerResponse) ProtoReflect ¶
func (x *CreateContainerResponse) ProtoReflect() protoreflect.Message
func (*CreateContainerResponse) Reset ¶
func (x *CreateContainerResponse) Reset()
func (*CreateContainerResponse) String ¶
func (x *CreateContainerResponse) String() string
type DeleteContainerRequest ¶
type DeleteContainerRequest struct { ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` // contains filtered or unexported fields }
func (*DeleteContainerRequest) Descriptor
deprecated
func (*DeleteContainerRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteContainerRequest.ProtoReflect.Descriptor instead.
func (*DeleteContainerRequest) GetContainerId ¶
func (x *DeleteContainerRequest) GetContainerId() string
func (*DeleteContainerRequest) ProtoMessage ¶
func (*DeleteContainerRequest) ProtoMessage()
func (*DeleteContainerRequest) ProtoReflect ¶
func (x *DeleteContainerRequest) ProtoReflect() protoreflect.Message
func (*DeleteContainerRequest) Reset ¶
func (x *DeleteContainerRequest) Reset()
func (*DeleteContainerRequest) String ¶
func (x *DeleteContainerRequest) String() string
type GetImageRequest ¶
type GetImageRequest struct { ImageSpec string `protobuf:"bytes,1,opt,name=image_spec,json=imageSpec,proto3" json:"image_spec,omitempty"` // contains filtered or unexported fields }
func (*GetImageRequest) Descriptor
deprecated
func (*GetImageRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetImageRequest.ProtoReflect.Descriptor instead.
func (*GetImageRequest) GetImageSpec ¶
func (x *GetImageRequest) GetImageSpec() string
func (*GetImageRequest) ProtoMessage ¶
func (*GetImageRequest) ProtoMessage()
func (*GetImageRequest) ProtoReflect ¶
func (x *GetImageRequest) ProtoReflect() protoreflect.Message
func (*GetImageRequest) Reset ¶
func (x *GetImageRequest) Reset()
func (*GetImageRequest) String ¶
func (x *GetImageRequest) String() string
type GetImageResponse ¶
type GetImageResponse struct { ImageId string `protobuf:"bytes,1,opt,name=image_id,json=imageId,proto3" json:"image_id,omitempty"` // contains filtered or unexported fields }
func (*GetImageResponse) Descriptor
deprecated
func (*GetImageResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetImageResponse.ProtoReflect.Descriptor instead.
func (*GetImageResponse) GetImageId ¶
func (x *GetImageResponse) GetImageId() string
func (*GetImageResponse) ProtoMessage ¶
func (*GetImageResponse) ProtoMessage()
func (*GetImageResponse) ProtoReflect ¶
func (x *GetImageResponse) ProtoReflect() protoreflect.Message
func (*GetImageResponse) Reset ¶
func (x *GetImageResponse) Reset()
func (*GetImageResponse) String ¶
func (x *GetImageResponse) String() string
type KillContainerRequest ¶
type KillContainerRequest struct { ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` Signal string `protobuf:"bytes,2,opt,name=signal,proto3" json:"signal,omitempty"` // contains filtered or unexported fields }
func (*KillContainerRequest) Descriptor
deprecated
func (*KillContainerRequest) Descriptor() ([]byte, []int)
Deprecated: Use KillContainerRequest.ProtoReflect.Descriptor instead.
func (*KillContainerRequest) GetContainerId ¶
func (x *KillContainerRequest) GetContainerId() string
func (*KillContainerRequest) GetSignal ¶
func (x *KillContainerRequest) GetSignal() string
func (*KillContainerRequest) ProtoMessage ¶
func (*KillContainerRequest) ProtoMessage()
func (*KillContainerRequest) ProtoReflect ¶
func (x *KillContainerRequest) ProtoReflect() protoreflect.Message
func (*KillContainerRequest) Reset ¶
func (x *KillContainerRequest) Reset()
func (*KillContainerRequest) String ¶
func (x *KillContainerRequest) String() string
type PluginClient ¶
type PluginClient interface { GetPluginInfo(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1alpha5.PluginInfo, error) InitPlugin(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1alpha5.InitPluginResponse, error) ResetPlugin(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error) StreamInput(ctx context.Context, opts ...grpc.CallOption) (Plugin_StreamInputClient, error) StreamOutput(ctx context.Context, in *v1alpha5.StreamOutputRequest, opts ...grpc.CallOption) (Plugin_StreamOutputClient, error) CreateContainer(ctx context.Context, in *CreateContainerRequest, opts ...grpc.CallOption) (*CreateContainerResponse, error) DeleteContainer(ctx context.Context, in *DeleteContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error) StartContainer(ctx context.Context, in *StartContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error) StreamContainer(ctx context.Context, in *StreamContainerRequest, opts ...grpc.CallOption) (*StreamContainerResponse, error) ResizeContainer(ctx context.Context, in *ResizeContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error) KillContainer(ctx context.Context, in *KillContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error) GetImage(ctx context.Context, in *GetImageRequest, opts ...grpc.CallOption) (*GetImageResponse, error) }
PluginClient is the client API for Plugin service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewPluginClient ¶
func NewPluginClient(cc grpc.ClientConnInterface) PluginClient
type PluginServer ¶
type PluginServer interface { GetPluginInfo(context.Context, *empty.Empty) (*v1alpha5.PluginInfo, error) InitPlugin(context.Context, *empty.Empty) (*v1alpha5.InitPluginResponse, error) ResetPlugin(context.Context, *empty.Empty) (*empty.Empty, error) StreamInput(Plugin_StreamInputServer) error StreamOutput(*v1alpha5.StreamOutputRequest, Plugin_StreamOutputServer) error CreateContainer(context.Context, *CreateContainerRequest) (*CreateContainerResponse, error) DeleteContainer(context.Context, *DeleteContainerRequest) (*empty.Empty, error) StartContainer(context.Context, *StartContainerRequest) (*empty.Empty, error) StreamContainer(context.Context, *StreamContainerRequest) (*StreamContainerResponse, error) ResizeContainer(context.Context, *ResizeContainerRequest) (*empty.Empty, error) KillContainer(context.Context, *KillContainerRequest) (*empty.Empty, error) GetImage(context.Context, *GetImageRequest) (*GetImageResponse, error) }
PluginServer is the server API for Plugin service.
type Plugin_StreamInputClient ¶
type Plugin_StreamInputClient interface { Send(*v1alpha5.StreamInputRequest) error CloseAndRecv() (*empty.Empty, error) grpc.ClientStream }
type Plugin_StreamInputServer ¶
type Plugin_StreamInputServer interface { SendAndClose(*empty.Empty) error Recv() (*v1alpha5.StreamInputRequest, error) grpc.ServerStream }
type Plugin_StreamOutputClient ¶
type Plugin_StreamOutputClient interface { Recv() (*v1alpha5.OutputData, error) grpc.ClientStream }
type Plugin_StreamOutputServer ¶
type Plugin_StreamOutputServer interface { Send(*v1alpha5.OutputData) error grpc.ServerStream }
type ResizeContainerRequest ¶
type ResizeContainerRequest struct { ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` Height uint32 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"` Width uint32 `protobuf:"varint,3,opt,name=width,proto3" json:"width,omitempty"` // contains filtered or unexported fields }
func (*ResizeContainerRequest) Descriptor
deprecated
func (*ResizeContainerRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResizeContainerRequest.ProtoReflect.Descriptor instead.
func (*ResizeContainerRequest) GetContainerId ¶
func (x *ResizeContainerRequest) GetContainerId() string
func (*ResizeContainerRequest) GetHeight ¶
func (x *ResizeContainerRequest) GetHeight() uint32
func (*ResizeContainerRequest) GetWidth ¶
func (x *ResizeContainerRequest) GetWidth() uint32
func (*ResizeContainerRequest) ProtoMessage ¶
func (*ResizeContainerRequest) ProtoMessage()
func (*ResizeContainerRequest) ProtoReflect ¶
func (x *ResizeContainerRequest) ProtoReflect() protoreflect.Message
func (*ResizeContainerRequest) Reset ¶
func (x *ResizeContainerRequest) Reset()
func (*ResizeContainerRequest) String ¶
func (x *ResizeContainerRequest) String() string
type StartContainerRequest ¶
type StartContainerRequest struct { ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` // contains filtered or unexported fields }
func (*StartContainerRequest) Descriptor
deprecated
func (*StartContainerRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartContainerRequest.ProtoReflect.Descriptor instead.
func (*StartContainerRequest) GetContainerId ¶
func (x *StartContainerRequest) GetContainerId() string
func (*StartContainerRequest) ProtoMessage ¶
func (*StartContainerRequest) ProtoMessage()
func (*StartContainerRequest) ProtoReflect ¶
func (x *StartContainerRequest) ProtoReflect() protoreflect.Message
func (*StartContainerRequest) Reset ¶
func (x *StartContainerRequest) Reset()
func (*StartContainerRequest) String ¶
func (x *StartContainerRequest) String() string
type StreamContainerRequest ¶
type StreamContainerRequest struct { ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` Height uint32 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"` Width uint32 `protobuf:"varint,3,opt,name=width,proto3" json:"width,omitempty"` // contains filtered or unexported fields }
func (*StreamContainerRequest) Descriptor
deprecated
func (*StreamContainerRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamContainerRequest.ProtoReflect.Descriptor instead.
func (*StreamContainerRequest) GetContainerId ¶
func (x *StreamContainerRequest) GetContainerId() string
func (*StreamContainerRequest) GetHeight ¶
func (x *StreamContainerRequest) GetHeight() uint32
func (*StreamContainerRequest) GetWidth ¶
func (x *StreamContainerRequest) GetWidth() uint32
func (*StreamContainerRequest) ProtoMessage ¶
func (*StreamContainerRequest) ProtoMessage()
func (*StreamContainerRequest) ProtoReflect ¶
func (x *StreamContainerRequest) ProtoReflect() protoreflect.Message
func (*StreamContainerRequest) Reset ¶
func (x *StreamContainerRequest) Reset()
func (*StreamContainerRequest) String ¶
func (x *StreamContainerRequest) String() string
type StreamContainerResponse ¶
type StreamContainerResponse struct { ExitCode int64 `protobuf:"varint,1,opt,name=exitCode,proto3" json:"exitCode,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*StreamContainerResponse) Descriptor
deprecated
func (*StreamContainerResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamContainerResponse.ProtoReflect.Descriptor instead.
func (*StreamContainerResponse) GetExitCode ¶
func (x *StreamContainerResponse) GetExitCode() int64
func (*StreamContainerResponse) GetMessage ¶
func (x *StreamContainerResponse) GetMessage() string
func (*StreamContainerResponse) ProtoMessage ¶
func (*StreamContainerResponse) ProtoMessage()
func (*StreamContainerResponse) ProtoReflect ¶
func (x *StreamContainerResponse) ProtoReflect() protoreflect.Message
func (*StreamContainerResponse) Reset ¶
func (x *StreamContainerResponse) Reset()
func (*StreamContainerResponse) String ¶
func (x *StreamContainerResponse) String() string
type UnimplementedPluginServer ¶
type UnimplementedPluginServer struct { }
UnimplementedPluginServer can be embedded to have forward compatible implementations.
func (*UnimplementedPluginServer) CreateContainer ¶
func (*UnimplementedPluginServer) CreateContainer(context.Context, *CreateContainerRequest) (*CreateContainerResponse, error)
func (*UnimplementedPluginServer) DeleteContainer ¶
func (*UnimplementedPluginServer) DeleteContainer(context.Context, *DeleteContainerRequest) (*empty.Empty, error)
func (*UnimplementedPluginServer) GetImage ¶
func (*UnimplementedPluginServer) GetImage(context.Context, *GetImageRequest) (*GetImageResponse, error)
func (*UnimplementedPluginServer) GetPluginInfo ¶
func (*UnimplementedPluginServer) GetPluginInfo(context.Context, *empty.Empty) (*v1alpha5.PluginInfo, error)
func (*UnimplementedPluginServer) InitPlugin ¶
func (*UnimplementedPluginServer) InitPlugin(context.Context, *empty.Empty) (*v1alpha5.InitPluginResponse, error)
func (*UnimplementedPluginServer) KillContainer ¶
func (*UnimplementedPluginServer) KillContainer(context.Context, *KillContainerRequest) (*empty.Empty, error)
func (*UnimplementedPluginServer) ResetPlugin ¶
func (*UnimplementedPluginServer) ResizeContainer ¶
func (*UnimplementedPluginServer) ResizeContainer(context.Context, *ResizeContainerRequest) (*empty.Empty, error)
func (*UnimplementedPluginServer) StartContainer ¶
func (*UnimplementedPluginServer) StartContainer(context.Context, *StartContainerRequest) (*empty.Empty, error)
func (*UnimplementedPluginServer) StreamContainer ¶
func (*UnimplementedPluginServer) StreamContainer(context.Context, *StreamContainerRequest) (*StreamContainerResponse, error)
func (*UnimplementedPluginServer) StreamInput ¶
func (*UnimplementedPluginServer) StreamInput(Plugin_StreamInputServer) error
func (*UnimplementedPluginServer) StreamOutput ¶
func (*UnimplementedPluginServer) StreamOutput(*v1alpha5.StreamOutputRequest, Plugin_StreamOutputServer) error