Documentation
¶
Overview ¶
Package grpc is a generated protocol buffer package.
It is generated from these files:
hyperstart.proto
It has these top-level messages:
AddContainerRequest AddProcessRequest SignalProcessRequest WaitProcessRequest WaitProcessResponse WriteStreamRequest WriteStreamResponse ReadStreamRequest ReadStreamResponse CloseStdinRequest TtyWinResizeRequest StartSandboxRequest DestroySandboxRequest IpAddress UpdateInterfaceRequest AddRouteRequest OnlineCPUMemRequest Container Mount Process User Rlimit Route
Index ¶
- func RegisterHyperstartServiceServer(s *grpc1.Server, srv HyperstartServiceServer)
- type AddContainerRequest
- type AddProcessRequest
- type AddRouteRequest
- type CloseStdinRequest
- type Container
- type DestroySandboxRequest
- type HyperstartServiceClient
- type HyperstartServiceServer
- type IpAddress
- type Mount
- type OnlineCPUMemRequest
- type Process
- func (*Process) Descriptor() ([]byte, []int)
- func (m *Process) GetArgs() []string
- func (m *Process) GetEnvs() map[string]string
- func (m *Process) GetId() string
- func (m *Process) GetRlimits() []*Rlimit
- func (m *Process) GetTerminal() bool
- func (m *Process) GetUser() *User
- func (m *Process) GetWorkdir() string
- func (*Process) ProtoMessage()
- func (m *Process) Reset()
- func (m *Process) String() string
- type ReadStreamRequest
- func (*ReadStreamRequest) Descriptor() ([]byte, []int)
- func (m *ReadStreamRequest) GetContainer() string
- func (m *ReadStreamRequest) GetLen() uint32
- func (m *ReadStreamRequest) GetProcess() string
- func (*ReadStreamRequest) ProtoMessage()
- func (m *ReadStreamRequest) Reset()
- func (m *ReadStreamRequest) String() string
- type ReadStreamResponse
- type Rlimit
- type Route
- type SignalProcessRequest
- func (*SignalProcessRequest) Descriptor() ([]byte, []int)
- func (m *SignalProcessRequest) GetContainer() string
- func (m *SignalProcessRequest) GetProcess() string
- func (m *SignalProcessRequest) GetSignal() uint32
- func (*SignalProcessRequest) ProtoMessage()
- func (m *SignalProcessRequest) Reset()
- func (m *SignalProcessRequest) String() string
- type StartSandboxRequest
- type TtyWinResizeRequest
- func (*TtyWinResizeRequest) Descriptor() ([]byte, []int)
- func (m *TtyWinResizeRequest) GetColumn() uint32
- func (m *TtyWinResizeRequest) GetContainer() string
- func (m *TtyWinResizeRequest) GetProcess() string
- func (m *TtyWinResizeRequest) GetRow() uint32
- func (*TtyWinResizeRequest) ProtoMessage()
- func (m *TtyWinResizeRequest) Reset()
- func (m *TtyWinResizeRequest) String() string
- type UpdateInterfaceRequest
- func (*UpdateInterfaceRequest) Descriptor() ([]byte, []int)
- func (m *UpdateInterfaceRequest) GetDevice() string
- func (m *UpdateInterfaceRequest) GetIpAddresses() []*IpAddress
- func (*UpdateInterfaceRequest) ProtoMessage()
- func (m *UpdateInterfaceRequest) Reset()
- func (m *UpdateInterfaceRequest) String() string
- type User
- type WaitProcessRequest
- type WaitProcessResponse
- type WriteStreamRequest
- func (*WriteStreamRequest) Descriptor() ([]byte, []int)
- func (m *WriteStreamRequest) GetContainer() string
- func (m *WriteStreamRequest) GetData() []byte
- func (m *WriteStreamRequest) GetProcess() string
- func (*WriteStreamRequest) ProtoMessage()
- func (m *WriteStreamRequest) Reset()
- func (m *WriteStreamRequest) String() string
- type WriteStreamResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterHyperstartServiceServer ¶
func RegisterHyperstartServiceServer(s *grpc1.Server, srv HyperstartServiceServer)
Types ¶
type AddContainerRequest ¶
type AddContainerRequest struct {
Container *Container `protobuf:"bytes,1,opt,name=container" json:"container,omitempty"`
Init *Process `protobuf:"bytes,2,opt,name=init" json:"init,omitempty"`
}
func (*AddContainerRequest) Descriptor ¶
func (*AddContainerRequest) Descriptor() ([]byte, []int)
func (*AddContainerRequest) GetContainer ¶
func (m *AddContainerRequest) GetContainer() *Container
func (*AddContainerRequest) GetInit ¶
func (m *AddContainerRequest) GetInit() *Process
func (*AddContainerRequest) ProtoMessage ¶
func (*AddContainerRequest) ProtoMessage()
func (*AddContainerRequest) Reset ¶
func (m *AddContainerRequest) Reset()
func (*AddContainerRequest) String ¶
func (m *AddContainerRequest) String() string
type AddProcessRequest ¶
type AddProcessRequest struct {
Container string `protobuf:"bytes,1,opt,name=container" json:"container,omitempty"`
Process *Process `protobuf:"bytes,2,opt,name=process" json:"process,omitempty"`
}
func (*AddProcessRequest) Descriptor ¶
func (*AddProcessRequest) Descriptor() ([]byte, []int)
func (*AddProcessRequest) GetContainer ¶
func (m *AddProcessRequest) GetContainer() string
func (*AddProcessRequest) GetProcess ¶
func (m *AddProcessRequest) GetProcess() *Process
func (*AddProcessRequest) ProtoMessage ¶
func (*AddProcessRequest) ProtoMessage()
func (*AddProcessRequest) Reset ¶
func (m *AddProcessRequest) Reset()
func (*AddProcessRequest) String ¶
func (m *AddProcessRequest) String() string
type AddRouteRequest ¶
type AddRouteRequest struct {
Routes []*Route `protobuf:"bytes,1,rep,name=routes" json:"routes,omitempty"`
}
func (*AddRouteRequest) Descriptor ¶
func (*AddRouteRequest) Descriptor() ([]byte, []int)
func (*AddRouteRequest) GetRoutes ¶
func (m *AddRouteRequest) GetRoutes() []*Route
func (*AddRouteRequest) ProtoMessage ¶
func (*AddRouteRequest) ProtoMessage()
func (*AddRouteRequest) Reset ¶
func (m *AddRouteRequest) Reset()
func (*AddRouteRequest) String ¶
func (m *AddRouteRequest) String() string
type CloseStdinRequest ¶
type CloseStdinRequest struct {
Container string `protobuf:"bytes,1,opt,name=container" json:"container,omitempty"`
Process string `protobuf:"bytes,2,opt,name=process" json:"process,omitempty"`
}
func (*CloseStdinRequest) Descriptor ¶
func (*CloseStdinRequest) Descriptor() ([]byte, []int)
func (*CloseStdinRequest) GetContainer ¶
func (m *CloseStdinRequest) GetContainer() string
func (*CloseStdinRequest) GetProcess ¶
func (m *CloseStdinRequest) GetProcess() string
func (*CloseStdinRequest) ProtoMessage ¶
func (*CloseStdinRequest) ProtoMessage()
func (*CloseStdinRequest) Reset ¶
func (m *CloseStdinRequest) Reset()
func (*CloseStdinRequest) String ¶
func (m *CloseStdinRequest) String() string
type Container ¶
type Container struct {
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
Mounts []*Mount `protobuf:"bytes,2,rep,name=mounts" json:"mounts,omitempty"`
Sysctl map[string]string `` /* 132-byte string literal not displayed */
}
func (*Container) Descriptor ¶
func (*Container) ProtoMessage ¶
func (*Container) ProtoMessage()
type DestroySandboxRequest ¶
type DestroySandboxRequest struct {
}
func (*DestroySandboxRequest) Descriptor ¶
func (*DestroySandboxRequest) Descriptor() ([]byte, []int)
func (*DestroySandboxRequest) ProtoMessage ¶
func (*DestroySandboxRequest) ProtoMessage()
func (*DestroySandboxRequest) Reset ¶
func (m *DestroySandboxRequest) Reset()
func (*DestroySandboxRequest) String ¶
func (m *DestroySandboxRequest) String() string
type HyperstartServiceClient ¶
type HyperstartServiceClient interface {
// execution
AddContainer(ctx context.Context, in *AddContainerRequest, opts ...grpc1.CallOption) (*google_protobuf.Empty, error)
AddProcess(ctx context.Context, in *AddProcessRequest, opts ...grpc1.CallOption) (*google_protobuf.Empty, error)
SignalProcess(ctx context.Context, in *SignalProcessRequest, opts ...grpc1.CallOption) (*google_protobuf.Empty, error)
WaitProcess(ctx context.Context, in *WaitProcessRequest, opts ...grpc1.CallOption) (*WaitProcessResponse, error)
// stdio
WriteStdin(ctx context.Context, in *WriteStreamRequest, opts ...grpc1.CallOption) (*WriteStreamResponse, error)
ReadStdout(ctx context.Context, in *ReadStreamRequest, opts ...grpc1.CallOption) (*ReadStreamResponse, error)
ReadStderr(ctx context.Context, in *ReadStreamRequest, opts ...grpc1.CallOption) (*ReadStreamResponse, error)
CloseStdin(ctx context.Context, in *CloseStdinRequest, opts ...grpc1.CallOption) (*google_protobuf.Empty, error)
TtyWinResize(ctx context.Context, in *TtyWinResizeRequest, opts ...grpc1.CallOption) (*google_protobuf.Empty, error)
// misc (TODO: some rpcs can be replaced by hyperstart-exec)
StartSandbox(ctx context.Context, in *StartSandboxRequest, opts ...grpc1.CallOption) (*google_protobuf.Empty, error)
DestroySandbox(ctx context.Context, in *DestroySandboxRequest, opts ...grpc1.CallOption) (*google_protobuf.Empty, error)
UpdateInterface(ctx context.Context, in *UpdateInterfaceRequest, opts ...grpc1.CallOption) (*google_protobuf.Empty, error)
AddRoute(ctx context.Context, in *AddRouteRequest, opts ...grpc1.CallOption) (*google_protobuf.Empty, error)
OnlineCPUMem(ctx context.Context, in *OnlineCPUMemRequest, opts ...grpc1.CallOption) (*google_protobuf.Empty, error)
}
func NewHyperstartServiceClient ¶
func NewHyperstartServiceClient(cc *grpc1.ClientConn) HyperstartServiceClient
type HyperstartServiceServer ¶
type HyperstartServiceServer interface {
// execution
AddContainer(context.Context, *AddContainerRequest) (*google_protobuf.Empty, error)
AddProcess(context.Context, *AddProcessRequest) (*google_protobuf.Empty, error)
SignalProcess(context.Context, *SignalProcessRequest) (*google_protobuf.Empty, error)
WaitProcess(context.Context, *WaitProcessRequest) (*WaitProcessResponse, error)
// stdio
WriteStdin(context.Context, *WriteStreamRequest) (*WriteStreamResponse, error)
ReadStdout(context.Context, *ReadStreamRequest) (*ReadStreamResponse, error)
ReadStderr(context.Context, *ReadStreamRequest) (*ReadStreamResponse, error)
CloseStdin(context.Context, *CloseStdinRequest) (*google_protobuf.Empty, error)
TtyWinResize(context.Context, *TtyWinResizeRequest) (*google_protobuf.Empty, error)
// misc (TODO: some rpcs can be replaced by hyperstart-exec)
StartSandbox(context.Context, *StartSandboxRequest) (*google_protobuf.Empty, error)
DestroySandbox(context.Context, *DestroySandboxRequest) (*google_protobuf.Empty, error)
UpdateInterface(context.Context, *UpdateInterfaceRequest) (*google_protobuf.Empty, error)
AddRoute(context.Context, *AddRouteRequest) (*google_protobuf.Empty, error)
OnlineCPUMem(context.Context, *OnlineCPUMemRequest) (*google_protobuf.Empty, error)
}
type IpAddress ¶
type IpAddress struct {
Address string `protobuf:"bytes,1,opt,name=address" json:"address,omitempty"`
Mask string `protobuf:"bytes,2,opt,name=mask" json:"mask,omitempty"`
}
func (*IpAddress) Descriptor ¶
func (*IpAddress) GetAddress ¶
func (*IpAddress) ProtoMessage ¶
func (*IpAddress) ProtoMessage()
type Mount ¶
type Mount struct {
Dest string `protobuf:"bytes,1,opt,name=dest" json:"dest,omitempty"`
Source string `protobuf:"bytes,2,opt,name=source" json:"source,omitempty"`
Type string `protobuf:"bytes,3,opt,name=type" json:"type,omitempty"`
Options []string `protobuf:"bytes,4,rep,name=options" json:"options,omitempty"`
}
@dest the path inside the container expect when it starts with "tmp:/" @source the path inside the container expect when it starts with "vm:/dev/" or "tmp:/"
the path which starts with "vm:/dev/" refers the guest vm's "/dev", especially, "vm:/dev/hostfs/" refers to the shared filesystem. "tmp:/" is a temporary directory which is used for temporary mounts.
message Mount (APIs about rootfs/mounts/volumes) would be changed very devastatingly
func (*Mount) Descriptor ¶
func (*Mount) GetOptions ¶
func (*Mount) ProtoMessage ¶
func (*Mount) ProtoMessage()
type OnlineCPUMemRequest ¶
type OnlineCPUMemRequest struct {
}
func (*OnlineCPUMemRequest) Descriptor ¶
func (*OnlineCPUMemRequest) Descriptor() ([]byte, []int)
func (*OnlineCPUMemRequest) ProtoMessage ¶
func (*OnlineCPUMemRequest) ProtoMessage()
func (*OnlineCPUMemRequest) Reset ¶
func (m *OnlineCPUMemRequest) Reset()
func (*OnlineCPUMemRequest) String ¶
func (m *OnlineCPUMemRequest) String() string
type Process ¶
type Process struct {
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
Args []string `protobuf:"bytes,2,rep,name=args" json:"args,omitempty"`
Envs map[string]string `` /* 128-byte string literal not displayed */
User *User `protobuf:"bytes,4,opt,name=user" json:"user,omitempty"`
Workdir string `protobuf:"bytes,5,opt,name=workdir" json:"workdir,omitempty"`
Terminal bool `protobuf:"varint,6,opt,name=terminal" json:"terminal,omitempty"`
Rlimits []*Rlimit `protobuf:"bytes,7,rep,name=rlimits" json:"rlimits,omitempty"`
}
func (*Process) Descriptor ¶
func (*Process) GetRlimits ¶
func (*Process) GetTerminal ¶
func (*Process) GetWorkdir ¶
func (*Process) ProtoMessage ¶
func (*Process) ProtoMessage()
type ReadStreamRequest ¶
type ReadStreamRequest struct {
Container string `protobuf:"bytes,1,opt,name=container" json:"container,omitempty"`
Process string `protobuf:"bytes,2,opt,name=process" json:"process,omitempty"`
Len uint32 `protobuf:"varint,3,opt,name=len" json:"len,omitempty"`
}
func (*ReadStreamRequest) Descriptor ¶
func (*ReadStreamRequest) Descriptor() ([]byte, []int)
func (*ReadStreamRequest) GetContainer ¶
func (m *ReadStreamRequest) GetContainer() string
func (*ReadStreamRequest) GetLen ¶
func (m *ReadStreamRequest) GetLen() uint32
func (*ReadStreamRequest) GetProcess ¶
func (m *ReadStreamRequest) GetProcess() string
func (*ReadStreamRequest) ProtoMessage ¶
func (*ReadStreamRequest) ProtoMessage()
func (*ReadStreamRequest) Reset ¶
func (m *ReadStreamRequest) Reset()
func (*ReadStreamRequest) String ¶
func (m *ReadStreamRequest) String() string
type ReadStreamResponse ¶
type ReadStreamResponse struct {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}
func (*ReadStreamResponse) Descriptor ¶
func (*ReadStreamResponse) Descriptor() ([]byte, []int)
func (*ReadStreamResponse) GetData ¶
func (m *ReadStreamResponse) GetData() []byte
func (*ReadStreamResponse) ProtoMessage ¶
func (*ReadStreamResponse) ProtoMessage()
func (*ReadStreamResponse) Reset ¶
func (m *ReadStreamResponse) Reset()
func (*ReadStreamResponse) String ¶
func (m *ReadStreamResponse) String() string
type Rlimit ¶
type Rlimit struct {
Type string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
Hard uint64 `protobuf:"varint,2,opt,name=hard" json:"hard,omitempty"`
Soft uint64 `protobuf:"varint,3,opt,name=soft" json:"soft,omitempty"`
}
func (*Rlimit) Descriptor ¶
func (*Rlimit) ProtoMessage ¶
func (*Rlimit) ProtoMessage()
type Route ¶
type Route struct {
Dest string `protobuf:"bytes,1,opt,name=dest" json:"dest,omitempty"`
Gateway string `protobuf:"bytes,2,opt,name=gateway" json:"gateway,omitempty"`
Device string `protobuf:"bytes,3,opt,name=device" json:"device,omitempty"`
}
func (*Route) Descriptor ¶
func (*Route) GetGateway ¶
func (*Route) ProtoMessage ¶
func (*Route) ProtoMessage()
type SignalProcessRequest ¶
type SignalProcessRequest struct {
Container string `protobuf:"bytes,1,opt,name=container" json:"container,omitempty"`
Process string `protobuf:"bytes,2,opt,name=process" json:"process,omitempty"`
Signal uint32 `protobuf:"varint,3,opt,name=signal" json:"signal,omitempty"`
}
func (*SignalProcessRequest) Descriptor ¶
func (*SignalProcessRequest) Descriptor() ([]byte, []int)
func (*SignalProcessRequest) GetContainer ¶
func (m *SignalProcessRequest) GetContainer() string
func (*SignalProcessRequest) GetProcess ¶
func (m *SignalProcessRequest) GetProcess() string
func (*SignalProcessRequest) GetSignal ¶
func (m *SignalProcessRequest) GetSignal() uint32
func (*SignalProcessRequest) ProtoMessage ¶
func (*SignalProcessRequest) ProtoMessage()
func (*SignalProcessRequest) Reset ¶
func (m *SignalProcessRequest) Reset()
func (*SignalProcessRequest) String ¶
func (m *SignalProcessRequest) String() string
type StartSandboxRequest ¶
type StartSandboxRequest struct {
Hostname string `protobuf:"bytes,1,opt,name=hostname" json:"hostname,omitempty"`
Dns []string `protobuf:"bytes,2,rep,name=dns" json:"dns,omitempty"`
}
func (*StartSandboxRequest) Descriptor ¶
func (*StartSandboxRequest) Descriptor() ([]byte, []int)
func (*StartSandboxRequest) GetDns ¶
func (m *StartSandboxRequest) GetDns() []string
func (*StartSandboxRequest) GetHostname ¶
func (m *StartSandboxRequest) GetHostname() string
func (*StartSandboxRequest) ProtoMessage ¶
func (*StartSandboxRequest) ProtoMessage()
func (*StartSandboxRequest) Reset ¶
func (m *StartSandboxRequest) Reset()
func (*StartSandboxRequest) String ¶
func (m *StartSandboxRequest) String() string
type TtyWinResizeRequest ¶
type TtyWinResizeRequest struct {
Container string `protobuf:"bytes,1,opt,name=container" json:"container,omitempty"`
Process string `protobuf:"bytes,2,opt,name=process" json:"process,omitempty"`
Row uint32 `protobuf:"varint,3,opt,name=row" json:"row,omitempty"`
Column uint32 `protobuf:"varint,4,opt,name=column" json:"column,omitempty"`
}
func (*TtyWinResizeRequest) Descriptor ¶
func (*TtyWinResizeRequest) Descriptor() ([]byte, []int)
func (*TtyWinResizeRequest) GetColumn ¶
func (m *TtyWinResizeRequest) GetColumn() uint32
func (*TtyWinResizeRequest) GetContainer ¶
func (m *TtyWinResizeRequest) GetContainer() string
func (*TtyWinResizeRequest) GetProcess ¶
func (m *TtyWinResizeRequest) GetProcess() string
func (*TtyWinResizeRequest) GetRow ¶
func (m *TtyWinResizeRequest) GetRow() uint32
func (*TtyWinResizeRequest) ProtoMessage ¶
func (*TtyWinResizeRequest) ProtoMessage()
func (*TtyWinResizeRequest) Reset ¶
func (m *TtyWinResizeRequest) Reset()
func (*TtyWinResizeRequest) String ¶
func (m *TtyWinResizeRequest) String() string
type UpdateInterfaceRequest ¶
type UpdateInterfaceRequest struct {
Device string `protobuf:"bytes,1,opt,name=device" json:"device,omitempty"`
IpAddresses []*IpAddress `protobuf:"bytes,2,rep,name=ipAddresses" json:"ipAddresses,omitempty"`
}
func (*UpdateInterfaceRequest) Descriptor ¶
func (*UpdateInterfaceRequest) Descriptor() ([]byte, []int)
func (*UpdateInterfaceRequest) GetDevice ¶
func (m *UpdateInterfaceRequest) GetDevice() string
func (*UpdateInterfaceRequest) GetIpAddresses ¶
func (m *UpdateInterfaceRequest) GetIpAddresses() []*IpAddress
func (*UpdateInterfaceRequest) ProtoMessage ¶
func (*UpdateInterfaceRequest) ProtoMessage()
func (*UpdateInterfaceRequest) Reset ¶
func (m *UpdateInterfaceRequest) Reset()
func (*UpdateInterfaceRequest) String ¶
func (m *UpdateInterfaceRequest) String() string
type User ¶
type User struct {
Uid string `protobuf:"bytes,1,opt,name=uid" json:"uid,omitempty"`
Gid string `protobuf:"bytes,2,opt,name=gid" json:"gid,omitempty"`
AdditionalGids []string `protobuf:"bytes,3,rep,name=additionalGids" json:"additionalGids,omitempty"`
}
func (*User) Descriptor ¶
func (*User) GetAdditionalGids ¶
func (*User) ProtoMessage ¶
func (*User) ProtoMessage()
type WaitProcessRequest ¶
type WaitProcessRequest struct {
Container string `protobuf:"bytes,1,opt,name=container" json:"container,omitempty"`
Process string `protobuf:"bytes,2,opt,name=process" json:"process,omitempty"`
}
func (*WaitProcessRequest) Descriptor ¶
func (*WaitProcessRequest) Descriptor() ([]byte, []int)
func (*WaitProcessRequest) GetContainer ¶
func (m *WaitProcessRequest) GetContainer() string
func (*WaitProcessRequest) GetProcess ¶
func (m *WaitProcessRequest) GetProcess() string
func (*WaitProcessRequest) ProtoMessage ¶
func (*WaitProcessRequest) ProtoMessage()
func (*WaitProcessRequest) Reset ¶
func (m *WaitProcessRequest) Reset()
func (*WaitProcessRequest) String ¶
func (m *WaitProcessRequest) String() string
type WaitProcessResponse ¶
type WaitProcessResponse struct {
Status int32 `protobuf:"varint,1,opt,name=status" json:"status,omitempty"`
}
func (*WaitProcessResponse) Descriptor ¶
func (*WaitProcessResponse) Descriptor() ([]byte, []int)
func (*WaitProcessResponse) GetStatus ¶
func (m *WaitProcessResponse) GetStatus() int32
func (*WaitProcessResponse) ProtoMessage ¶
func (*WaitProcessResponse) ProtoMessage()
func (*WaitProcessResponse) Reset ¶
func (m *WaitProcessResponse) Reset()
func (*WaitProcessResponse) String ¶
func (m *WaitProcessResponse) String() string
type WriteStreamRequest ¶
type WriteStreamRequest struct {
Container string `protobuf:"bytes,1,opt,name=container" json:"container,omitempty"`
Process string `protobuf:"bytes,2,opt,name=process" json:"process,omitempty"`
Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}
func (*WriteStreamRequest) Descriptor ¶
func (*WriteStreamRequest) Descriptor() ([]byte, []int)
func (*WriteStreamRequest) GetContainer ¶
func (m *WriteStreamRequest) GetContainer() string
func (*WriteStreamRequest) GetData ¶
func (m *WriteStreamRequest) GetData() []byte
func (*WriteStreamRequest) GetProcess ¶
func (m *WriteStreamRequest) GetProcess() string
func (*WriteStreamRequest) ProtoMessage ¶
func (*WriteStreamRequest) ProtoMessage()
func (*WriteStreamRequest) Reset ¶
func (m *WriteStreamRequest) Reset()
func (*WriteStreamRequest) String ¶
func (m *WriteStreamRequest) String() string
type WriteStreamResponse ¶
type WriteStreamResponse struct {
Len uint32 `protobuf:"varint,1,opt,name=len" json:"len,omitempty"`
}
func (*WriteStreamResponse) Descriptor ¶
func (*WriteStreamResponse) Descriptor() ([]byte, []int)
func (*WriteStreamResponse) GetLen ¶
func (m *WriteStreamResponse) GetLen() uint32
func (*WriteStreamResponse) ProtoMessage ¶
func (*WriteStreamResponse) ProtoMessage()
func (*WriteStreamResponse) Reset ¶
func (m *WriteStreamResponse) Reset()
func (*WriteStreamResponse) String ¶
func (m *WriteStreamResponse) String() string
Click to show internal directories.
Click to hide internal directories.