Versions in this module Expand all Collapse all v1 v1.5.1 Jan 20, 2020 v1.5.0 Jan 8, 2020 Changes in this version type ExtentClient + func (client *ExtentClient) Close() error v1.4.0 Nov 13, 2019 Changes in this version type ExtentClient + func (client *ExtentClient) GetRate() string + func (client *ExtentClient) SetReadRate(val int) string + func (client *ExtentClient) SetWriteRate(val int) string v1.1.1 Jun 11, 2019 Changes in this version + const MaxMountRetryLimit + const MountRetryInterval v1.1.0 May 9, 2019 Changes in this version + var TryOtherAddrError = errors.New("TryOtherAddrError") v1.0.0 Apr 2, 2019 Changes in this version + const ExtentStatusClosed + const ExtentStatusError + const ExtentStatusOpen + const ExtentStatusRecovery + const MaxDirtyListLen + const MaxNewHandlerRetry + const MaxPacketErrorCount + const MaxSelectDataPartitionForWrite + const StreamSendMaxRetry + const StreamSendSleepInterval + const StreamerError + const StreamerNormal + var NotALeaderError = errors.New("NotALeaderError") + var StreamConnPool = util.NewConnectPool() + func GetExtentHandlerID() uint64 + type AppendExtentKeyFunc func(inode uint64, key proto.ExtentKey) error + type DirtyExtentList struct + func NewDirtyExtentList() *DirtyExtentList + func (dl *DirtyExtentList) Get() *list.Element + func (dl *DirtyExtentList) Len() int + func (dl *DirtyExtentList) Put(eh *ExtentHandler) + func (dl *DirtyExtentList) Remove(e *list.Element) + type EvictRequest struct + type ExtentCache struct + func NewExtentCache(inode uint64) *ExtentCache + func (cache *ExtentCache) Append(ek *proto.ExtentKey, sync bool) + func (cache *ExtentCache) Get(offset uint64) (ret *proto.ExtentKey) + func (cache *ExtentCache) List() []*proto.ExtentKey + func (cache *ExtentCache) Max() *proto.ExtentKey + func (cache *ExtentCache) PrepareReadRequests(offset, size int, data []byte) []*ExtentRequest + func (cache *ExtentCache) PrepareWriteRequests(offset, size int, data []byte) []*ExtentRequest + func (cache *ExtentCache) Refresh(inode uint64, getExtents GetExtentsFunc) error + func (cache *ExtentCache) SetSize(size uint64, sync bool) + func (cache *ExtentCache) Size() (size int, gen uint64) + type ExtentClient struct + func NewExtentClient(volname, master string, appendExtentKey AppendExtentKeyFunc, ...) (client *ExtentClient, err error) + func (client *ExtentClient) CloseStream(inode uint64) error + func (client *ExtentClient) EvictStream(inode uint64) error + func (client *ExtentClient) FileSize(inode uint64) (size int, gen uint64) + func (client *ExtentClient) Flush(inode uint64) error + func (client *ExtentClient) GetStreamer(inode uint64) *Streamer + func (client *ExtentClient) OpenStream(inode uint64) error + func (client *ExtentClient) Read(inode uint64, data []byte, offset int, size int) (read int, err error) + func (client *ExtentClient) RefreshExtentsCache(inode uint64) error + func (client *ExtentClient) SetFileSize(inode uint64, size int) + func (client *ExtentClient) Truncate(inode uint64, size int) error + func (client *ExtentClient) Write(inode uint64, offset int, data []byte, direct bool) (write int, err error) + type ExtentHandler struct + func NewExtentHandler(stream *Streamer, offset int, storeMode int) *ExtentHandler + func (eh *ExtentHandler) String() string + type ExtentReader struct + func NewExtentReader(inode uint64, key *proto.ExtentKey, dp *wrapper.DataPartition) *ExtentReader + func (reader *ExtentReader) Read(req *ExtentRequest) (readBytes int, err error) + func (reader *ExtentReader) String() (m string) + type ExtentRequest struct + Data []byte + ExtentKey *proto.ExtentKey + FileOffset int + Size int + func NewExtentRequest(offset, size int, data []byte, ek *proto.ExtentKey) *ExtentRequest + func (er *ExtentRequest) String() string + type FlushRequest struct + type GetExtentsFunc func(inode uint64) (uint64, uint64, []proto.ExtentKey, error) + type GetReplyFunc func(conn *net.TCPConn) (err error, again bool) + type OpenRequest struct + type Packet struct + func NewCreateExtentPacket(dp *wrapper.DataPartition, inode uint64) *Packet + func NewOverwritePacket(dp *wrapper.DataPartition, extentID uint64, extentOffset int, inode uint64, ...) *Packet + func NewReadPacket(key *proto.ExtentKey, extentOffset, size int, inode uint64, fileOffset int) *Packet + func NewReply(reqID int64, partitionID uint64, extentID uint64) *Packet + func NewWritePacket(inode uint64, fileOffset, storeMode int) *Packet + func (p *Packet) String() string + type ReleaseRequest struct + type StreamConn struct + func NewStreamConn(dp *wrapper.DataPartition) *StreamConn + func (sc *StreamConn) Send(req *Packet, getReply GetReplyFunc) (err error) + func (sc *StreamConn) String() string + type Streamer struct + func NewStreamer(client *ExtentClient, inode uint64) *Streamer + func (s *Streamer) GetExtentReader(ek *proto.ExtentKey) (*ExtentReader, error) + func (s *Streamer) GetExtents() error + func (s *Streamer) IssueEvictRequest() error + func (s *Streamer) IssueFlushRequest() error + func (s *Streamer) IssueOpenRequest() error + func (s *Streamer) IssueReleaseRequest() error + func (s *Streamer) IssueTruncRequest(size int) error + func (s *Streamer) IssueWriteRequest(offset int, data []byte, direct bool) (write int, err error) + func (s *Streamer) String() string + type TruncRequest struct + type TruncateFunc func(inode, size uint64) error + type WriteRequest struct Incompatible versions in this module v2.0.0+incompatible Apr 10, 2020 v2.0.0-rc.1+incompatible Apr 9, 2020
Go to main page