Versions in this module Expand all Collapse all v3 v3.7.1 Feb 23, 2022 v3.7.0 Oct 11, 2021 v3.6.0 Aug 12, 2021 v3.5.2 Jul 6, 2021 v3.5.1 Apr 16, 2021 v3.5.0 Jan 25, 2021 v3.0.1 Jan 20, 2021 Changes in this version + func NewFileEndpoints() []*api.Endpoint + func RegisterFileHandler(s server.Server, hdlr FileHandler, opts ...server.HandlerOption) error + 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 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 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 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