Versions in this module Expand all Collapse all v0 v0.0.5 Aug 7, 2023 v0.0.4 Oct 23, 2021 v0.0.3 Sep 11, 2021 v0.0.2 Jul 4, 2021 v0.0.1 Jul 4, 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