Documentation ¶
Index ¶
- Variables
- func NewFileEndpoints() []*apipb.Endpoint
- func RegisterFileHandler(s server.Server, hdlr FileHandler, opts ...server.HandlerOption) error
- func RegisterFileServer(s *grpc.Server, srv FileServer)
- type CloseRequest
- func (*CloseRequest) Descriptor() ([]byte, []int)
- func (m *CloseRequest) Marshal() (dAtA []byte, err error)
- func (m *CloseRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseRequest) ProtoMessage()
- func (m *CloseRequest) Reset()
- func (m *CloseRequest) Size() (n int)
- func (m *CloseRequest) String() string
- func (m *CloseRequest) Unmarshal(dAtA []byte) error
- func (m *CloseRequest) XXX_DiscardUnknown()
- func (m *CloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseRequest) XXX_Merge(src proto.Message)
- func (m *CloseRequest) XXX_Size() int
- func (m *CloseRequest) XXX_Unmarshal(b []byte) error
- type CloseResponse
- func (*CloseResponse) Descriptor() ([]byte, []int)
- func (m *CloseResponse) Marshal() (dAtA []byte, err error)
- func (m *CloseResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseResponse) ProtoMessage()
- func (m *CloseResponse) Reset()
- func (m *CloseResponse) Size() (n int)
- func (m *CloseResponse) String() string
- func (m *CloseResponse) Unmarshal(dAtA []byte) error
- func (m *CloseResponse) XXX_DiscardUnknown()
- func (m *CloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseResponse) XXX_Merge(src proto.Message)
- func (m *CloseResponse) XXX_Size() int
- func (m *CloseResponse) XXX_Unmarshal(b []byte) error
- type FileClient
- type FileHandler
- type FileServer
- type FileService
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- func (m *GetRequest) Marshal() (dAtA []byte, err error)
- func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetRequest) ProtoMessage()
- func (m *GetRequest) Reset()
- func (m *GetRequest) Size() (n int)
- func (m *GetRequest) String() string
- func (m *GetRequest) Unmarshal(dAtA []byte) error
- func (m *GetRequest) XXX_DiscardUnknown()
- func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRequest) XXX_Merge(src proto.Message)
- func (m *GetRequest) XXX_Size() int
- func (m *GetRequest) XXX_Unmarshal(b []byte) error
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)
- func (m *GetResponse) Marshal() (dAtA []byte, err error)
- func (m *GetResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetResponse) ProtoMessage()
- func (m *GetResponse) Reset()
- func (m *GetResponse) Size() (n int)
- func (m *GetResponse) String() string
- func (m *GetResponse) Unmarshal(dAtA []byte) error
- func (m *GetResponse) XXX_DiscardUnknown()
- func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetResponse) XXX_Merge(src proto.Message)
- func (m *GetResponse) XXX_Size() int
- func (m *GetResponse) XXX_Unmarshal(b []byte) error
- type OpenRequest
- func (*OpenRequest) Descriptor() ([]byte, []int)
- func (m *OpenRequest) Marshal() (dAtA []byte, err error)
- func (m *OpenRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OpenRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OpenRequest) ProtoMessage()
- func (m *OpenRequest) Reset()
- func (m *OpenRequest) Size() (n int)
- func (m *OpenRequest) String() string
- func (m *OpenRequest) Unmarshal(dAtA []byte) error
- func (m *OpenRequest) XXX_DiscardUnknown()
- func (m *OpenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenRequest) XXX_Merge(src proto.Message)
- func (m *OpenRequest) XXX_Size() int
- func (m *OpenRequest) XXX_Unmarshal(b []byte) error
- type OpenResponse
- func (*OpenResponse) Descriptor() ([]byte, []int)
- func (m *OpenResponse) Marshal() (dAtA []byte, err error)
- func (m *OpenResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *OpenResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OpenResponse) ProtoMessage()
- func (m *OpenResponse) Reset()
- func (m *OpenResponse) Size() (n int)
- func (m *OpenResponse) String() string
- func (m *OpenResponse) Unmarshal(dAtA []byte) error
- func (m *OpenResponse) XXX_DiscardUnknown()
- func (m *OpenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenResponse) XXX_Merge(src proto.Message)
- func (m *OpenResponse) XXX_Size() int
- func (m *OpenResponse) XXX_Unmarshal(b []byte) error
- type ReadRequest
- func (*ReadRequest) Descriptor() ([]byte, []int)
- func (m *ReadRequest) Marshal() (dAtA []byte, err error)
- func (m *ReadRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadRequest) ProtoMessage()
- func (m *ReadRequest) Reset()
- func (m *ReadRequest) Size() (n int)
- func (m *ReadRequest) String() string
- func (m *ReadRequest) Unmarshal(dAtA []byte) error
- func (m *ReadRequest) XXX_DiscardUnknown()
- func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadRequest) XXX_Merge(src proto.Message)
- func (m *ReadRequest) XXX_Size() int
- func (m *ReadRequest) XXX_Unmarshal(b []byte) error
- type ReadResponse
- func (*ReadResponse) Descriptor() ([]byte, []int)
- func (m *ReadResponse) Marshal() (dAtA []byte, err error)
- func (m *ReadResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadResponse) ProtoMessage()
- func (m *ReadResponse) Reset()
- func (m *ReadResponse) Size() (n int)
- func (m *ReadResponse) String() string
- func (m *ReadResponse) Unmarshal(dAtA []byte) error
- func (m *ReadResponse) XXX_DiscardUnknown()
- func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadResponse) XXX_Merge(src proto.Message)
- func (m *ReadResponse) XXX_Size() int
- func (m *ReadResponse) XXX_Unmarshal(b []byte) error
- type StatRequest
- func (*StatRequest) Descriptor() ([]byte, []int)
- func (m *StatRequest) Marshal() (dAtA []byte, err error)
- func (m *StatRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StatRequest) ProtoMessage()
- func (m *StatRequest) Reset()
- func (m *StatRequest) Size() (n int)
- func (m *StatRequest) String() string
- func (m *StatRequest) Unmarshal(dAtA []byte) error
- func (m *StatRequest) XXX_DiscardUnknown()
- func (m *StatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatRequest) XXX_Merge(src proto.Message)
- func (m *StatRequest) XXX_Size() int
- func (m *StatRequest) XXX_Unmarshal(b []byte) error
- type StatResponse
- func (*StatResponse) Descriptor() ([]byte, []int)
- func (m *StatResponse) Marshal() (dAtA []byte, err error)
- func (m *StatResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *StatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StatResponse) ProtoMessage()
- func (m *StatResponse) Reset()
- func (m *StatResponse) Size() (n int)
- func (m *StatResponse) String() string
- func (m *StatResponse) Unmarshal(dAtA []byte) error
- func (m *StatResponse) XXX_DiscardUnknown()
- func (m *StatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatResponse) XXX_Merge(src proto.Message)
- func (m *StatResponse) XXX_Size() int
- func (m *StatResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedFileServer
- func (*UnimplementedFileServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)
- func (*UnimplementedFileServer) Open(ctx context.Context, req *OpenRequest) (*OpenResponse, error)
- func (*UnimplementedFileServer) Read(ctx context.Context, req *ReadRequest) (*ReadResponse, error)
- func (*UnimplementedFileServer) Stat(ctx context.Context, req *StatRequest) (*StatResponse, error)
- func (*UnimplementedFileServer) Write(ctx context.Context, req *WriteRequest) (*WriteResponse, error)
- type WriteRequest
- func (*WriteRequest) Descriptor() ([]byte, []int)
- func (m *WriteRequest) Marshal() (dAtA []byte, err error)
- func (m *WriteRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WriteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WriteRequest) ProtoMessage()
- func (m *WriteRequest) Reset()
- func (m *WriteRequest) Size() (n int)
- func (m *WriteRequest) String() string
- func (m *WriteRequest) Unmarshal(dAtA []byte) error
- func (m *WriteRequest) XXX_DiscardUnknown()
- func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WriteRequest) XXX_Merge(src proto.Message)
- func (m *WriteRequest) XXX_Size() int
- func (m *WriteRequest) XXX_Unmarshal(b []byte) error
- type WriteResponse
- func (*WriteResponse) Descriptor() ([]byte, []int)
- func (m *WriteResponse) Marshal() (dAtA []byte, err error)
- func (m *WriteResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *WriteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WriteResponse) ProtoMessage()
- func (m *WriteResponse) Reset()
- func (m *WriteResponse) Size() (n int)
- func (m *WriteResponse) String() string
- func (m *WriteResponse) Unmarshal(dAtA []byte) error
- func (m *WriteResponse) XXX_DiscardUnknown()
- func (m *WriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WriteResponse) XXX_Merge(src proto.Message)
- func (m *WriteResponse) XXX_Size() int
- func (m *WriteResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func RegisterFileHandler ¶
func RegisterFileHandler(s server.Server, hdlr FileHandler, opts ...server.HandlerOption) error
func RegisterFileServer ¶
func RegisterFileServer(s *grpc.Server, srv FileServer)
Types ¶
type CloseRequest ¶
type CloseRequest struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*CloseRequest) Descriptor ¶
func (*CloseRequest) Descriptor() ([]byte, []int)
func (*CloseRequest) Marshal ¶
func (m *CloseRequest) Marshal() (dAtA []byte, err error)
func (*CloseRequest) MarshalToSizedBuffer ¶
func (m *CloseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CloseRequest) ProtoMessage ¶
func (*CloseRequest) ProtoMessage()
func (*CloseRequest) Reset ¶
func (m *CloseRequest) Reset()
func (*CloseRequest) Size ¶
func (m *CloseRequest) Size() (n int)
func (*CloseRequest) String ¶
func (m *CloseRequest) String() string
func (*CloseRequest) Unmarshal ¶
func (m *CloseRequest) Unmarshal(dAtA []byte) error
func (*CloseRequest) XXX_DiscardUnknown ¶
func (m *CloseRequest) XXX_DiscardUnknown()
func (*CloseRequest) XXX_Marshal ¶
func (m *CloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CloseRequest) XXX_Merge ¶
func (m *CloseRequest) XXX_Merge(src proto.Message)
func (*CloseRequest) XXX_Size ¶
func (m *CloseRequest) XXX_Size() int
func (*CloseRequest) XXX_Unmarshal ¶
func (m *CloseRequest) XXX_Unmarshal(b []byte) error
type CloseResponse ¶
type CloseResponse struct { }
func (*CloseResponse) Descriptor ¶
func (*CloseResponse) Descriptor() ([]byte, []int)
func (*CloseResponse) Marshal ¶
func (m *CloseResponse) Marshal() (dAtA []byte, err error)
func (*CloseResponse) MarshalToSizedBuffer ¶
func (m *CloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CloseResponse) ProtoMessage ¶
func (*CloseResponse) ProtoMessage()
func (*CloseResponse) Reset ¶
func (m *CloseResponse) Reset()
func (*CloseResponse) Size ¶
func (m *CloseResponse) Size() (n int)
func (*CloseResponse) String ¶
func (m *CloseResponse) String() string
func (*CloseResponse) Unmarshal ¶
func (m *CloseResponse) Unmarshal(dAtA []byte) error
func (*CloseResponse) XXX_DiscardUnknown ¶
func (m *CloseResponse) XXX_DiscardUnknown()
func (*CloseResponse) XXX_Marshal ¶
func (m *CloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CloseResponse) XXX_Merge ¶
func (m *CloseResponse) XXX_Merge(src proto.Message)
func (*CloseResponse) XXX_Size ¶
func (m *CloseResponse) XXX_Size() int
func (*CloseResponse) XXX_Unmarshal ¶
func (m *CloseResponse) XXX_Unmarshal(b []byte) error
type FileClient ¶
type FileClient interface { Open(ctx context.Context, in *OpenRequest, opts ...grpc.CallOption) (*OpenResponse, error) Stat(ctx context.Context, in *StatRequest, opts ...grpc.CallOption) (*StatResponse, error) Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error) Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error) Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error) }
FileClient is the client API for File service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewFileClient ¶
func NewFileClient(cc *grpc.ClientConn) FileClient
type FileHandler ¶
type FileHandler interface { Open(context.Context, *OpenRequest, *OpenResponse) error Stat(context.Context, *StatRequest, *StatResponse) error Read(context.Context, *ReadRequest, *ReadResponse) error Write(context.Context, *WriteRequest, *WriteResponse) error Close(context.Context, *CloseRequest, *CloseResponse) error }
Server API for File service
type FileServer ¶
type FileServer interface { Open(context.Context, *OpenRequest) (*OpenResponse, error) Stat(context.Context, *StatRequest) (*StatResponse, error) Read(context.Context, *ReadRequest) (*ReadResponse, error) Write(context.Context, *WriteRequest) (*WriteResponse, error) Close(context.Context, *CloseRequest) (*CloseResponse, error) }
FileServer is the server API for File service.
type FileService ¶
type FileService interface { Open(ctx context.Context, in *OpenRequest, opts ...client.CallOption) (*OpenResponse, error) Stat(ctx context.Context, in *StatRequest, opts ...client.CallOption) (*StatResponse, error) Read(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error) Write(ctx context.Context, in *WriteRequest, opts ...client.CallOption) (*WriteResponse, error) Close(ctx context.Context, in *CloseRequest, opts ...client.CallOption) (*CloseResponse, error) }
Client API for File service
func NewFileService ¶
func NewFileService(name string, c client.Client) FileService
type GetRequest ¶
type GetRequest struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` BlockId int64 `protobuf:"varint,2,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"` }
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) Marshal ¶
func (m *GetRequest) Marshal() (dAtA []byte, err error)
func (*GetRequest) MarshalToSizedBuffer ¶
func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) Size ¶
func (m *GetRequest) Size() (n int)
func (*GetRequest) String ¶
func (m *GetRequest) String() string
func (*GetRequest) Unmarshal ¶
func (m *GetRequest) Unmarshal(dAtA []byte) error
func (*GetRequest) XXX_DiscardUnknown ¶
func (m *GetRequest) XXX_DiscardUnknown()
func (*GetRequest) XXX_Marshal ¶
func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRequest) XXX_Merge ¶
func (m *GetRequest) XXX_Merge(src proto.Message)
func (*GetRequest) XXX_Size ¶
func (m *GetRequest) XXX_Size() int
func (*GetRequest) XXX_Unmarshal ¶
func (m *GetRequest) XXX_Unmarshal(b []byte) error
type GetResponse ¶
type GetResponse struct { BlockId int64 `protobuf:"varint,1,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"` Size_ int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` }
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) Marshal ¶
func (m *GetResponse) Marshal() (dAtA []byte, err error)
func (*GetResponse) MarshalToSizedBuffer ¶
func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) Reset ¶
func (m *GetResponse) Reset()
func (*GetResponse) Size ¶
func (m *GetResponse) Size() (n int)
func (*GetResponse) String ¶
func (m *GetResponse) String() string
func (*GetResponse) Unmarshal ¶
func (m *GetResponse) Unmarshal(dAtA []byte) error
func (*GetResponse) XXX_DiscardUnknown ¶
func (m *GetResponse) XXX_DiscardUnknown()
func (*GetResponse) XXX_Marshal ¶
func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetResponse) XXX_Merge ¶
func (m *GetResponse) XXX_Merge(src proto.Message)
func (*GetResponse) XXX_Size ¶
func (m *GetResponse) XXX_Size() int
func (*GetResponse) XXX_Unmarshal ¶
func (m *GetResponse) XXX_Unmarshal(b []byte) error
type OpenRequest ¶
type OpenRequest struct { Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"` Truncate bool `protobuf:"varint,2,opt,name=truncate,proto3" json:"truncate,omitempty"` }
func (*OpenRequest) Descriptor ¶
func (*OpenRequest) Descriptor() ([]byte, []int)
func (*OpenRequest) Marshal ¶
func (m *OpenRequest) Marshal() (dAtA []byte, err error)
func (*OpenRequest) MarshalToSizedBuffer ¶
func (m *OpenRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OpenRequest) ProtoMessage ¶
func (*OpenRequest) ProtoMessage()
func (*OpenRequest) Reset ¶
func (m *OpenRequest) Reset()
func (*OpenRequest) Size ¶
func (m *OpenRequest) Size() (n int)
func (*OpenRequest) String ¶
func (m *OpenRequest) String() string
func (*OpenRequest) Unmarshal ¶
func (m *OpenRequest) Unmarshal(dAtA []byte) error
func (*OpenRequest) XXX_DiscardUnknown ¶
func (m *OpenRequest) XXX_DiscardUnknown()
func (*OpenRequest) XXX_Marshal ¶
func (m *OpenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OpenRequest) XXX_Merge ¶
func (m *OpenRequest) XXX_Merge(src proto.Message)
func (*OpenRequest) XXX_Size ¶
func (m *OpenRequest) XXX_Size() int
func (*OpenRequest) XXX_Unmarshal ¶
func (m *OpenRequest) XXX_Unmarshal(b []byte) error
type OpenResponse ¶
type OpenResponse struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Result bool `protobuf:"varint,2,opt,name=result,proto3" json:"result,omitempty"` }
func (*OpenResponse) Descriptor ¶
func (*OpenResponse) Descriptor() ([]byte, []int)
func (*OpenResponse) Marshal ¶
func (m *OpenResponse) Marshal() (dAtA []byte, err error)
func (*OpenResponse) MarshalToSizedBuffer ¶
func (m *OpenResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OpenResponse) ProtoMessage ¶
func (*OpenResponse) ProtoMessage()
func (*OpenResponse) Reset ¶
func (m *OpenResponse) Reset()
func (*OpenResponse) Size ¶
func (m *OpenResponse) Size() (n int)
func (*OpenResponse) String ¶
func (m *OpenResponse) String() string
func (*OpenResponse) Unmarshal ¶
func (m *OpenResponse) Unmarshal(dAtA []byte) error
func (*OpenResponse) XXX_DiscardUnknown ¶
func (m *OpenResponse) XXX_DiscardUnknown()
func (*OpenResponse) XXX_Marshal ¶
func (m *OpenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OpenResponse) XXX_Merge ¶
func (m *OpenResponse) XXX_Merge(src proto.Message)
func (*OpenResponse) XXX_Size ¶
func (m *OpenResponse) XXX_Size() int
func (*OpenResponse) XXX_Unmarshal ¶
func (m *OpenResponse) XXX_Unmarshal(b []byte) error
type ReadRequest ¶
type ReadRequest struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` Size_ int64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"` }
func (*ReadRequest) Descriptor ¶
func (*ReadRequest) Descriptor() ([]byte, []int)
func (*ReadRequest) Marshal ¶
func (m *ReadRequest) Marshal() (dAtA []byte, err error)
func (*ReadRequest) MarshalToSizedBuffer ¶
func (m *ReadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadRequest) ProtoMessage ¶
func (*ReadRequest) ProtoMessage()
func (*ReadRequest) Reset ¶
func (m *ReadRequest) Reset()
func (*ReadRequest) Size ¶
func (m *ReadRequest) Size() (n int)
func (*ReadRequest) String ¶
func (m *ReadRequest) String() string
func (*ReadRequest) Unmarshal ¶
func (m *ReadRequest) Unmarshal(dAtA []byte) error
func (*ReadRequest) XXX_DiscardUnknown ¶
func (m *ReadRequest) XXX_DiscardUnknown()
func (*ReadRequest) XXX_Marshal ¶
func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadRequest) XXX_Merge ¶
func (m *ReadRequest) XXX_Merge(src proto.Message)
func (*ReadRequest) XXX_Size ¶
func (m *ReadRequest) XXX_Size() int
func (*ReadRequest) XXX_Unmarshal ¶
func (m *ReadRequest) XXX_Unmarshal(b []byte) error
type ReadResponse ¶
type ReadResponse struct { Size_ int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` Eof bool `protobuf:"varint,3,opt,name=eof,proto3" json:"eof,omitempty"` }
func (*ReadResponse) Descriptor ¶
func (*ReadResponse) Descriptor() ([]byte, []int)
func (*ReadResponse) Marshal ¶
func (m *ReadResponse) Marshal() (dAtA []byte, err error)
func (*ReadResponse) MarshalToSizedBuffer ¶
func (m *ReadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadResponse) ProtoMessage ¶
func (*ReadResponse) ProtoMessage()
func (*ReadResponse) Reset ¶
func (m *ReadResponse) Reset()
func (*ReadResponse) Size ¶
func (m *ReadResponse) Size() (n int)
func (*ReadResponse) String ¶
func (m *ReadResponse) String() string
func (*ReadResponse) Unmarshal ¶
func (m *ReadResponse) Unmarshal(dAtA []byte) error
func (*ReadResponse) XXX_DiscardUnknown ¶
func (m *ReadResponse) XXX_DiscardUnknown()
func (*ReadResponse) XXX_Marshal ¶
func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadResponse) XXX_Merge ¶
func (m *ReadResponse) XXX_Merge(src proto.Message)
func (*ReadResponse) XXX_Size ¶
func (m *ReadResponse) XXX_Size() int
func (*ReadResponse) XXX_Unmarshal ¶
func (m *ReadResponse) XXX_Unmarshal(b []byte) error
type StatRequest ¶
type StatRequest struct {
Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
}
func (*StatRequest) Descriptor ¶
func (*StatRequest) Descriptor() ([]byte, []int)
func (*StatRequest) Marshal ¶
func (m *StatRequest) Marshal() (dAtA []byte, err error)
func (*StatRequest) MarshalToSizedBuffer ¶
func (m *StatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StatRequest) ProtoMessage ¶
func (*StatRequest) ProtoMessage()
func (*StatRequest) Reset ¶
func (m *StatRequest) Reset()
func (*StatRequest) Size ¶
func (m *StatRequest) Size() (n int)
func (*StatRequest) String ¶
func (m *StatRequest) String() string
func (*StatRequest) Unmarshal ¶
func (m *StatRequest) Unmarshal(dAtA []byte) error
func (*StatRequest) XXX_DiscardUnknown ¶
func (m *StatRequest) XXX_DiscardUnknown()
func (*StatRequest) XXX_Marshal ¶
func (m *StatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatRequest) XXX_Merge ¶
func (m *StatRequest) XXX_Merge(src proto.Message)
func (*StatRequest) XXX_Size ¶
func (m *StatRequest) XXX_Size() int
func (*StatRequest) XXX_Unmarshal ¶
func (m *StatRequest) XXX_Unmarshal(b []byte) error
type StatResponse ¶
type StatResponse struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Size_ int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` LastModified int64 `protobuf:"varint,3,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"` }
func (*StatResponse) Descriptor ¶
func (*StatResponse) Descriptor() ([]byte, []int)
func (*StatResponse) Marshal ¶
func (m *StatResponse) Marshal() (dAtA []byte, err error)
func (*StatResponse) MarshalToSizedBuffer ¶
func (m *StatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StatResponse) ProtoMessage ¶
func (*StatResponse) ProtoMessage()
func (*StatResponse) Reset ¶
func (m *StatResponse) Reset()
func (*StatResponse) Size ¶
func (m *StatResponse) Size() (n int)
func (*StatResponse) String ¶
func (m *StatResponse) String() string
func (*StatResponse) Unmarshal ¶
func (m *StatResponse) Unmarshal(dAtA []byte) error
func (*StatResponse) XXX_DiscardUnknown ¶
func (m *StatResponse) XXX_DiscardUnknown()
func (*StatResponse) XXX_Marshal ¶
func (m *StatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatResponse) XXX_Merge ¶
func (m *StatResponse) XXX_Merge(src proto.Message)
func (*StatResponse) XXX_Size ¶
func (m *StatResponse) XXX_Size() int
func (*StatResponse) XXX_Unmarshal ¶
func (m *StatResponse) XXX_Unmarshal(b []byte) error
type UnimplementedFileServer ¶
type UnimplementedFileServer struct { }
UnimplementedFileServer can be embedded to have forward compatible implementations.
func (*UnimplementedFileServer) Close ¶
func (*UnimplementedFileServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)
func (*UnimplementedFileServer) Open ¶
func (*UnimplementedFileServer) Open(ctx context.Context, req *OpenRequest) (*OpenResponse, error)
func (*UnimplementedFileServer) Read ¶
func (*UnimplementedFileServer) Read(ctx context.Context, req *ReadRequest) (*ReadResponse, error)
func (*UnimplementedFileServer) Stat ¶
func (*UnimplementedFileServer) Stat(ctx context.Context, req *StatRequest) (*StatResponse, error)
func (*UnimplementedFileServer) Write ¶
func (*UnimplementedFileServer) Write(ctx context.Context, req *WriteRequest) (*WriteResponse, error)
type WriteRequest ¶
type WriteRequest struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` }
func (*WriteRequest) Descriptor ¶
func (*WriteRequest) Descriptor() ([]byte, []int)
func (*WriteRequest) Marshal ¶
func (m *WriteRequest) Marshal() (dAtA []byte, err error)
func (*WriteRequest) MarshalToSizedBuffer ¶
func (m *WriteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WriteRequest) ProtoMessage ¶
func (*WriteRequest) ProtoMessage()
func (*WriteRequest) Reset ¶
func (m *WriteRequest) Reset()
func (*WriteRequest) Size ¶
func (m *WriteRequest) Size() (n int)
func (*WriteRequest) String ¶
func (m *WriteRequest) String() string
func (*WriteRequest) Unmarshal ¶
func (m *WriteRequest) Unmarshal(dAtA []byte) error
func (*WriteRequest) XXX_DiscardUnknown ¶
func (m *WriteRequest) XXX_DiscardUnknown()
func (*WriteRequest) XXX_Marshal ¶
func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WriteRequest) XXX_Merge ¶
func (m *WriteRequest) XXX_Merge(src proto.Message)
func (*WriteRequest) XXX_Size ¶
func (m *WriteRequest) XXX_Size() int
func (*WriteRequest) XXX_Unmarshal ¶
func (m *WriteRequest) XXX_Unmarshal(b []byte) error
type WriteResponse ¶
type WriteResponse struct { }
func (*WriteResponse) Descriptor ¶
func (*WriteResponse) Descriptor() ([]byte, []int)
func (*WriteResponse) Marshal ¶
func (m *WriteResponse) Marshal() (dAtA []byte, err error)
func (*WriteResponse) MarshalToSizedBuffer ¶
func (m *WriteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WriteResponse) ProtoMessage ¶
func (*WriteResponse) ProtoMessage()
func (*WriteResponse) Reset ¶
func (m *WriteResponse) Reset()
func (*WriteResponse) Size ¶
func (m *WriteResponse) Size() (n int)
func (*WriteResponse) String ¶
func (m *WriteResponse) String() string
func (*WriteResponse) Unmarshal ¶
func (m *WriteResponse) Unmarshal(dAtA []byte) error
func (*WriteResponse) XXX_DiscardUnknown ¶
func (m *WriteResponse) XXX_DiscardUnknown()
func (*WriteResponse) XXX_Marshal ¶
func (m *WriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WriteResponse) XXX_Merge ¶
func (m *WriteResponse) XXX_Merge(src proto.Message)
func (*WriteResponse) XXX_Size ¶
func (m *WriteResponse) XXX_Size() int
func (*WriteResponse) XXX_Unmarshal ¶
func (m *WriteResponse) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.