Versions in this module Expand all Collapse all v2 v2.9.3 Mar 2, 2021 v2.9.2 Mar 2, 2021 Changes in this version + func NewFileEndpoints() []*api.Endpoint + func RegisterFileHandler(s server.Server, hdlr FileHandler, opts ...server.HandlerOption) error + func RegisterFileServer(s *grpc.Server, srv FileServer) + type CloseRequest struct + Id int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CloseRequest) Descriptor() ([]byte, []int) + func (*CloseRequest) ProtoMessage() + func (m *CloseRequest) GetId() int64 + func (m *CloseRequest) Reset() + func (m *CloseRequest) String() string + 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 struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CloseResponse) Descriptor() ([]byte, []int) + func (*CloseResponse) ProtoMessage() + func (m *CloseResponse) Reset() + func (m *CloseResponse) String() string + 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 interface + Close func(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error) + Open func(ctx context.Context, in *OpenRequest, opts ...grpc.CallOption) (*OpenResponse, error) + Read func(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error) + Stat func(ctx context.Context, in *StatRequest, opts ...grpc.CallOption) (*StatResponse, error) + Write func(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error) + func NewFileClient(cc *grpc.ClientConn) FileClient + type FileHandler interface + Close func(context.Context, *CloseRequest, *CloseResponse) error + Open func(context.Context, *OpenRequest, *OpenResponse) error + Read func(context.Context, *ReadRequest, *ReadResponse) error + Stat func(context.Context, *StatRequest, *StatResponse) error + Write func(context.Context, *WriteRequest, *WriteResponse) error + type FileServer interface + Close func(context.Context, *CloseRequest) (*CloseResponse, error) + Open func(context.Context, *OpenRequest) (*OpenResponse, error) + Read func(context.Context, *ReadRequest) (*ReadResponse, error) + Stat func(context.Context, *StatRequest) (*StatResponse, error) + Write func(context.Context, *WriteRequest) (*WriteResponse, error) + type FileService interface + Close func(ctx context.Context, in *CloseRequest, opts ...client.CallOption) (*CloseResponse, error) + Open func(ctx context.Context, in *OpenRequest, opts ...client.CallOption) (*OpenResponse, error) + Read func(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error) + Stat func(ctx context.Context, in *StatRequest, opts ...client.CallOption) (*StatResponse, error) + Write func(ctx context.Context, in *WriteRequest, opts ...client.CallOption) (*WriteResponse, error) + func NewFileService(name string, c client.Client) FileService + type GetRequest struct + BlockId int64 + Id int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (m *GetRequest) GetBlockId() int64 + func (m *GetRequest) GetId() int64 + func (m *GetRequest) Reset() + func (m *GetRequest) String() string + 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 struct + BlockId int64 + Data []byte + Size int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (m *GetResponse) GetBlockId() int64 + func (m *GetResponse) GetData() []byte + func (m *GetResponse) GetSize() int64 + func (m *GetResponse) Reset() + func (m *GetResponse) String() string + 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 struct + Filename string + Truncate bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OpenRequest) Descriptor() ([]byte, []int) + func (*OpenRequest) ProtoMessage() + func (m *OpenRequest) GetFilename() string + func (m *OpenRequest) GetTruncate() bool + func (m *OpenRequest) Reset() + func (m *OpenRequest) String() string + 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 struct + Id int64 + Result bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OpenResponse) Descriptor() ([]byte, []int) + func (*OpenResponse) ProtoMessage() + func (m *OpenResponse) GetId() int64 + func (m *OpenResponse) GetResult() bool + func (m *OpenResponse) Reset() + func (m *OpenResponse) String() string + 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 struct + Id int64 + Offset int64 + Size int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadRequest) Descriptor() ([]byte, []int) + func (*ReadRequest) ProtoMessage() + func (m *ReadRequest) GetId() int64 + func (m *ReadRequest) GetOffset() int64 + func (m *ReadRequest) GetSize() int64 + func (m *ReadRequest) Reset() + func (m *ReadRequest) String() string + 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 struct + Data []byte + Eof bool + Size int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadResponse) Descriptor() ([]byte, []int) + func (*ReadResponse) ProtoMessage() + func (m *ReadResponse) GetData() []byte + func (m *ReadResponse) GetEof() bool + func (m *ReadResponse) GetSize() int64 + func (m *ReadResponse) Reset() + func (m *ReadResponse) String() string + 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 struct + Filename string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StatRequest) Descriptor() ([]byte, []int) + func (*StatRequest) ProtoMessage() + func (m *StatRequest) GetFilename() string + func (m *StatRequest) Reset() + func (m *StatRequest) String() string + 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 struct + LastModified int64 + Size int64 + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StatResponse) Descriptor() ([]byte, []int) + func (*StatResponse) ProtoMessage() + func (m *StatResponse) GetLastModified() int64 + func (m *StatResponse) GetSize() int64 + func (m *StatResponse) GetType() string + func (m *StatResponse) Reset() + func (m *StatResponse) String() string + 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 struct + 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 struct + Data []byte + Id int64 + Offset int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteRequest) Descriptor() ([]byte, []int) + func (*WriteRequest) ProtoMessage() + func (m *WriteRequest) GetData() []byte + func (m *WriteRequest) GetId() int64 + func (m *WriteRequest) GetOffset() int64 + func (m *WriteRequest) Reset() + func (m *WriteRequest) String() string + 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 struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteResponse) Descriptor() ([]byte, []int) + func (*WriteResponse) ProtoMessage() + func (m *WriteResponse) Reset() + func (m *WriteResponse) String() string + 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