proto

package

Go to main page

Versions in this module

v1

v1.5.1

Jan 20, 2020

Changes in this version

+ const ListenPort

type BadPartitionView

+ Path string

type ClusterView

+ BadMetaPartitionIDs []BadPartitionView

type MetaPartitionInfo

+ IsRecover bool

type MetaPartitionView

+ IsRecover bool

+ MaxInodeID uint64

v1.5.0

Jan 8, 2020

Changes in this version

+ const APIAccess

+ const APIRsc

+ const AdminAddCaps

+ const AdminAddRaftNode

+ const AdminCreateKey

+ const AdminCreateMetaPartition

+ const AdminDeleteCaps

+ const AdminDeleteKey

+ const AdminGetCaps

+ const AdminGetKey

+ const AdminRemoveRaftNode

+ const AuthServiceID

+ const Authenticate

+ const CertFile

+ const ClientGetTicket

+ const ClientKey

+ const ClientMessage

+ const DataNode

+ const DataServiceID

+ const EnableHTTPS

+ const ErrCodeAccessKeyNotExists

+ const ErrCodeAuthAPIAccessGenRespError

+ const ErrCodeAuthKeyStoreError

+ const ErrCodeAuthOSCapsOpGenRespError

+ const ErrCodeAuthRaftNodeGenRespError

+ const ErrCodeAuthReqRedirectError

+ const ErrCodeExpiredTicket

+ const ErrCodeInvalidTicket

+ const ErrCodeMasterAPIGenRespError

+ const ErrCodeNoCellToCreateDataPartition

+ const MasterNode

+ const MasterServiceID

+ const MetaNode

+ const MetaServiceID

+ const NoneOwnerVOLRsc

+ const OSAddCaps

+ const OSDeleteCaps

+ const OSGetCaps

+ const OpAddMultipartPart

+ const OpCreateMultipart

+ const OpGetMultipart

+ const OpListMultiparts

+ const OpMetaBatchExtentsAdd

+ const OpMetaBatchGetXAttr

+ const OpMetaDeleteInode

+ const OpMetaGetXAttr

+ const OpMetaListXAttr

+ const OpMetaRemoveXAttr

+ const OpMetaSetXAttr

+ const OpRemoveMultipart

+ const OwnerVOLRsc

+ const SkipOwnerValidation

+ const TicketHost

+ const VOLAccess

+ var ErrAccessKeyNotExists = errors.New("access key not exists")

+ var ErrAuthAPIAccessGenRespError = errors.New("auth API access response error")

+ var ErrAuthKeyStoreError = errors.New("auth keystore error")

+ var ErrAuthOSCapsOpGenRespError = errors.New("auth Object Storage Node API response error")

+ var ErrDuplicateKey = errors.New("duplicate key")

+ var ErrExpiredTicket = errors.New("expired ticket")

+ var ErrInvalidTicket = errors.New("invalid ticket")

+ var ErrKeyNotExists = errors.New("key not exists")

+ var ErrMasterAPIGenRespError = errors.New("master API generate response error")

+ var ErrNoCellToCreateDataPartition = errors.New("no cell available for creating a data partition")

+ var MsgType2ResourceMap = map[MsgType]string

+ func CheckAPIAccessCaps(ticket *cryptoutil.Ticket, rscType string, mp MsgType, action string) (err error)

+ func CheckVOLAccessCaps(ticket *cryptoutil.Ticket, volName string, action string, accessNode string) (err error)

+ func ExtractAPIAccessTicket(req *APIAccessReq, key []byte) (ticket cryptoutil.Ticket, ts int64, err error)

+ func ExtractTicket(str string, key []byte) (ticket cryptoutil.Ticket, err error)

+ func GetDataFromResp(body []byte, key []byte) (plaintext []byte, err error)

+ func IsValidClientID(id string) (err error)

+ func IsValidMsgReqType(serviceID string, msgType MsgType) (err error)

+ func IsValidServiceID(serviceID string) (err error)

+ func ParseVerifier(verifier string, key []byte) (ts int64, err error)

+ func SendBytes(client *http.Client, target string, data []byte) (res []byte, err error)

+ func SendData(client *http.Client, target string, data interface{}) (res []byte, err error)

+ func VerifyAPIAccessReqIDs(req *APIAccessReq) (err error)

+ func VerifyAPIRespComm(apiResp *APIAccessResp, msg MsgType, clientID string, serviceID string, ...) (err error)

+ func VerifyTicketRespComm(ticketResp *AuthGetTicketResp, msg MsgType, clientID string, serviceID string, ...) (err error)

+ type APIAccessReq struct

+ ClientID string

+ ServiceID string

+ Ticket string

+ Type MsgType

+ Verifier string

+ type APIAccessResp struct

+ ClientID string

+ ServiceID string

+ Type MsgType

+ Verifier int64

+ type AddMultipartPartRequest struct

+ MultipartId string

+ Part *MultipartPartInfo

+ PartitionId uint64

+ VolName string

+ type AppendExtentKeysRequest struct

+ Extents []ExtentKey

+ Inode uint64

+ PartitionId uint64

+ VolName string

+ type AuthAPIAccessReq struct

+ APIReq APIAccessReq

+ KeyInfo keystore.KeyInfo

+ type AuthAPIAccessResp struct

+ APIResp APIAccessResp

+ KeyInfo keystore.KeyInfo

+ func ParseAuthAPIAccessResp(body []byte, key []byte) (resp AuthAPIAccessResp, err error)

+ type AuthGetTicketReq struct

+ ClientID string

+ ServiceID string

+ Type MsgType

+ Verifier string

+ type AuthGetTicketResp struct

+ ClientID string

+ ServiceID string

+ SessionKey cryptoutil.CryptoKey

+ Ticket string

+ Type MsgType

+ Verifier int64

+ func ParseAuthGetTicketResp(body []byte, key []byte) (resp AuthGetTicketResp, err error)

+ type AuthOSAccessKeyReq struct

+ AKCaps keystore.AccessKeyCaps

+ APIReq APIAccessReq

+ type AuthOSAccessKeyResp struct

+ AKCaps keystore.AccessKeyCaps

+ APIResp APIAccessResp

+ func ParseAuthOSAKResp(body []byte, key []byte) (resp AuthOSAccessKeyResp, err error)

+ type AuthRaftNodeInfo struct

+ Addr string

+ ID uint64

+ type AuthRaftNodeReq struct

+ APIReq APIAccessReq

+ RaftNodeInfo AuthRaftNodeInfo

+ type AuthRaftNodeResp struct

+ APIResp APIAccessResp

+ Msg string

+ func ParseAuthRaftNodeResp(body []byte, key []byte) (resp AuthRaftNodeResp, err error)

+ type BadPartitionView struct

+ DiskPath string

+ PartitionIDs []uint64

+ type BatchGetXAttrRequest struct

+ Inodes []uint64

+ Keys []string

+ PartitionId uint64

+ VolName string

+ type BatchGetXAttrResponse struct

+ PartitionId uint64

+ VolName string

+ XAttrs []*XAttrInfo

+ type ClusterView struct

+ Applied uint64

+ BadPartitionIDs []BadPartitionView

+ DataNodeStatInfo *NodeStatInfo

+ DataNodes []NodeView

+ DisableAutoAlloc bool

+ LeaderAddr string

+ MaxDataPartitionID uint64

+ MaxMetaNodeID uint64

+ MaxMetaPartitionID uint64

+ MetaNodeStatInfo *NodeStatInfo

+ MetaNodeThreshold float32

+ MetaNodes []NodeView

+ Name string

+ VolStatInfo []*VolStatInfo

+ type CreateMultipartRequest struct

+ PartitionId uint64

+ Path string

+ VolName string

+ type CreateMultipartResponse struct

+ Info *MultipartInfo

type DataNodeHeartbeatResponse

+ CellName string

+ type DataNodeInfo struct

+ Addr string

+ AvailableSpace uint64

+ BadDisks []string

+ Carry float64

+ CellName string

+ DataPartitionCount uint32

+ DataPartitionReports []*PartitionReport

+ ID uint64

+ IsActive bool

+ NodeSetID uint64

+ PersistenceDataPartitions []uint64

+ ReportTime time.Time

+ SelectedTimes uint64

+ Total uint64

+ UsageRatio float64

+ Used uint64

+ type DataPartitionInfo struct

+ FileInCoreMap map[string]*FileInCore

+ FilesWithMissingReplica map[string]int64

+ Hosts []string

+ LastLoadedTime int64

+ MissingNodes map[string]int64

+ PartitionID uint64

+ Peers []Peer

+ ReplicaNum uint8

+ Replicas []*DataReplica

+ Status int8

+ VolID uint64

+ VolName string

+ type DataReplica struct

+ Addr string

+ DiskPath string

+ FileCount uint32

+ HasLoadResponse bool

+ IsLeader bool

+ NeedsToCompare bool

+ ReportTime int64

+ Status int8

+ Total uint64

+ Used uint64

+ type DeleteInodeRequest struct

+ Inode uint64

+ PartitionId uint64

+ VolName string

+ type FileInCore struct

+ LastModify int64

+ MetadataArray []*FileMetadata

+ Name string

+ type FileMetadata struct

+ Crc uint32

+ LocAddr string

+ Size uint32

+ type GetMultipartRequest struct

+ MultipartId string

+ PartitionId uint64

+ VolName string

+ type GetMultipartResponse struct

+ Info *MultipartInfo

+ type GetXAttrRequest struct

+ Inode uint64

+ Key string

+ PartitionId uint64

+ VolName string

+ type GetXAttrResponse struct

+ Inode uint64

+ Key string

+ PartitionId uint64

+ Value string

+ VolName string

+ type HTTPAuthReply struct

+ Code int32

+ Data interface{}

+ Msg string

+ func ParseAuthReply(body []byte) (jobj HTTPAuthReply, err error)

+ type ListMultipartRequest struct

+ Delimiter string

+ Marker string

+ Max uint64

+ MultipartIdMarker string

+ PartitionId uint64

+ Prefix string

+ VolName string

+ type ListMultipartResponse struct

+ Multiparts []*MultipartInfo

+ type ListXAttrRequest struct

+ Inode uint64

+ PartitionId uint64

+ VolName string

+ type ListXAttrResponse struct

+ Inode uint64

+ PartitionId uint64

+ VolName string

+ XAttr map[string]string

+ type MasterAPIAccessResp struct

+ APIResp APIAccessResp

+ Data []byte

type MetaNodeHeartbeatResponse

+ CellName string

+ type MetaNodeInfo struct

+ Addr string

+ Carry float64

+ CellName string

+ ID uint64

+ IsActive bool

+ MaxMemAvailWeight uint64

+ MetaPartitionCount int

+ NodeSetID uint64

+ PersistenceMetaPartitions []uint64

+ Ratio float64

+ ReportTime time.Time

+ SelectCount uint64

+ Threshold float32

+ Total uint64

+ Used uint64

+ type MetaPartitionInfo struct

+ End uint64

+ Hosts []string

+ LoadResponse []*MetaPartitionLoadResponse

+ MaxInodeID uint64

+ MissNodes map[string]int64

+ PartitionID uint64

+ Peers []Peer

+ ReplicaNum uint8

+ Replicas []*MetaReplicaInfo

+ Start uint64

+ Status int8

type MetaPartitionLoadResponse

+ DentryCount uint64

+ MaxInode uint64

+ type MetaReplicaInfo struct

+ Addr string

+ IsLeader bool

+ ReportTime int64

+ Status int8

+ type MsgType uint32

+ const MsgAuthAddCapsReq

+ const MsgAuthAddCapsResp

+ const MsgAuthAddRaftNodeReq

+ const MsgAuthAddRaftNodeResp

+ const MsgAuthBase

+ const MsgAuthCreateKeyReq

+ const MsgAuthCreateKeyResp

+ const MsgAuthDeleteCapsReq

+ const MsgAuthDeleteCapsResp

+ const MsgAuthDeleteKeyReq

+ const MsgAuthDeleteKeyResp

+ const MsgAuthGetCapsReq

+ const MsgAuthGetCapsResp

+ const MsgAuthGetKeyReq

+ const MsgAuthGetKeyResp

+ const MsgAuthOSAddCapsReq

+ const MsgAuthOSAddCapsResp

+ const MsgAuthOSDeleteCapsReq

+ const MsgAuthOSDeleteCapsResp

+ const MsgAuthOSGetCapsReq

+ const MsgAuthOSGetCapsResp

+ const MsgAuthRemoveRaftNodeReq

+ const MsgAuthRemoveRaftNodeResp

+ const MsgAuthTicketReq

+ const MsgAuthTicketResp

+ const MsgDataTicketReq

+ const MsgDataTicketResp

+ const MsgMasterAPIAccessReq

+ const MsgMasterAPIAccessResp

+ const MsgMasterFetchVolViewReq

+ const MsgMasterTicketReq

+ const MsgMasterTicketResp

+ const MsgMetaTicketReq

+ const MsgMetaTicketResp

+ type MultipartInfo struct

+ ID string

+ InitTime time.Time

+ Parts []*MultipartPartInfo

+ Path string

+ type MultipartPartInfo struct

+ ID uint16

+ Inode uint64

+ MD5 string

+ Size uint64

+ UploadTime time.Time

+ type NodeStatInfo struct

+ IncreasedGB int64

+ TotalGB uint64

+ UsedGB uint64

+ UsedRatio string

+ type NodeView struct

+ Addr string

+ ID uint64

+ IsWritable bool

+ Status bool

+ type Nonce uint64

+ type OSSSecure struct

+ AccessKey string

+ SecretKey string

+ type RemoveMultipartRequest struct

+ MultipartId string

+ PartitionId uint64

+ VolName string

+ type RemoveXAttrRequest struct

+ Inode uint64

+ Key string

+ PartitionId uint64

+ VolName string

+ type ServiceID uint32

+ type SetXAttrRequest struct

+ Inode uint64

+ Key string

+ PartitionId uint64

+ Value string

+ VolName string

type SimpleVolView

+ Authenticate bool

type VolStatInfo

+ UsedRatio string

type VolView

+ OSSSecure *OSSSecure

+ Owner string

+ func (v *VolView) SetOSSSecure(accessKey, secretKey string)

+ func (v *VolView) SetOwner(owner string)

+ type XAttrInfo struct

+ Inode uint64

+ XAttrs map[string]string

+ func (info XAttrInfo) String() string

v1.4.0

Nov 13, 2019

Changes in this version

+ const AdminAddDataReplica

+ const AdminAddMetaReplica

+ const AdminDeleteDataReplica

+ const AdminDeleteMetaReplica

+ const OpAddDataPartitionRaftMember

+ const OpAddMetaPartitionRaftMember

+ const OpDataPartitionTryToLeader

+ const OpMetaPartitionTryToLeader

+ const OpRemoveDataPartitionRaftMember

+ const OpRemoveMetaPartitionRaftMember

+ const OpStreamFollowerRead

+ const ReadRate

+ const WriteRate

+ type AddDataPartitionRaftMemberRequest struct

+ AddPeer Peer

+ PartitionId uint64

+ type AddMetaPartitionRaftMemberRequest struct

+ AddPeer Peer

+ PartitionId uint64

type AdminTask

+ PartitionID uint64

type DataNodeHeartbeatResponse

+ BadDisks []string

type DataPartitionResponse

+ Epoch uint64

type Packet

+ func (p *Packet) AddMesgLog(m string)

+ func (p *Packet) SetPacketRePrepare()

+ type RemoveDataPartitionRaftMemberRequest struct

+ PartitionId uint64

+ RemovePeer Peer

+ type RemoveMetaPartitionRaftMemberRequest struct

+ PartitionId uint64

+ RemovePeer Peer

type SimpleVolView

+ FollowerRead bool

+ NeedToLowerReplica bool

type VolView

+ FollowerRead bool

v1.3.0

Sep 11, 2019

Changes in this version

+ const AttrValid

+ const AutoInvalData

+ const ClientMetaPartitions

+ const DecommissionedCreateDataPartition

+ const EnSyncWrite

+ const IcacheTimeout

+ const KeepCache

+ const LogDir

+ const LogLevel

+ const LookupValid

+ const MasterAddr

+ const MountPoint

+ const NormalCreateDataPartition

+ const OpGetMaxExtentIDAndPartitionSize

+ const OpReadTinyDeleteRecord

+ const OpTinyExtentRepairRead

+ const Owner

+ const ProfPort

+ const Rdonly

+ const VolName

+ const WarnLogDir

+ const WriteCache

type CreateDataPartitionRequest

+ CreateType int

type LoadDataPartitionResponse

+ VolName string

type MetaPartitionReport

+ VolName string

v1.2.0

Jul 16, 2019

Changes in this version

type CreateDataPartitionRequest

+ Hosts []string

type Packet

+ HasPrepare bool

+ func (p *Packet) SetPacketHasPrepare()

v1.1.1

Jun 11, 2019

Changes in this version

type CreateInodeRequest

+ Gid uint32

+ Uid uint32

v1.1.0

May 9, 2019

Changes in this version

+ const OpTryOtherAddr

type PartitionReport

+ VolName string

v1.0.0

Apr 2, 2019

Changes in this version

+ const AddDataNode

+ const AddMetaNode

+ const AddRaftNode

+ const AddrSplit

+ const AdminClusterFreeze

+ const AdminCreateDataPartition

+ const AdminCreateMP

+ const AdminCreateVol

+ const AdminDecommissionDataPartition

+ const AdminDecommissionMetaPartition

+ const AdminDeleteVol

+ const AdminGetCluster

+ const AdminGetDataPartition

+ const AdminGetIP

+ const AdminGetVol

+ const AdminLoadDataPartition

+ const AdminLoadMetaPartition

+ const AdminSetMetaNodeThreshold

+ const AdminUpdateVol

+ const AttrGid

+ const AttrMode

+ const AttrUid

+ const ClientDataPartitions

+ const ClientMetaPartition

+ const ClientVol

+ const ClientVolStat

+ const DecommissionDataNode

+ const DecommissionDisk

+ const DecommissionMetaNode

+ const ErrCodeActiveDataNodesTooLess

+ const ErrCodeActiveMetaNodesTooLess

+ const ErrCodeCannotBeOffLine

+ const ErrCodeDataNodeNotExists

+ const ErrCodeDataPartitionNotExists

+ const ErrCodeDuplicateVol

+ const ErrCodeHasOneMissingReplica

+ const ErrCodeIllegalDataReplica

+ const ErrCodeIllegalMetaReplica

+ const ErrCodeInternalError

+ const ErrCodeInvalidCfg

+ const ErrCodeInvalidMpStart

+ const ErrCodeMarshalData

+ const ErrCodeMetaNodeNotExists

+ const ErrCodeMetaPartitionNotExists

+ const ErrCodeMissingReplica

+ const ErrCodeNoAvailDataPartition

+ const ErrCodeNoDataNodeToCreateDataPartition

+ const ErrCodeNoDataNodeToWrite

+ const ErrCodeNoEnoughReplica

+ const ErrCodeNoLeader

+ const ErrCodeNoMetaNodeToCreateMetaPartition

+ const ErrCodeNoMetaNodeToWrite

+ const ErrCodeNoNodeSetToCreateDataPartition

+ const ErrCodeNoNodeSetToCreateMetaPartition

+ const ErrCodeNoRackToCreateDataPartition

+ const ErrCodeParamError

+ const ErrCodePersistenceByRaft

+ const ErrCodeReshuffleArray

+ const ErrCodeSuccess

+ const ErrCodeUnmarshalData

+ const ErrCodeVolAuthKeyNotMatch

+ const ErrCodeVolNotExists

+ const GetAllWatermarksDeadLineTime

+ const GetDataNode

+ const GetDataNodeTaskResponse

+ const GetMetaNode

+ const GetMetaNodeTaskResponse

+ const GetTopologyView

+ const MaxSendCount

+ const NoReadDeadlineTime

+ const NormalExtentType

+ const OpAgain

+ const OpArgMismatchErr

+ const OpBroadcastMinAppliedID

+ const OpCreateDataPartition

+ const OpCreateExtent

+ const OpCreateMetaPartition

+ const OpDataNodeHeartbeat

+ const OpDecommissionDataPartition

+ const OpDecommissionMetaPartition

+ const OpDeleteDataPartition

+ const OpDeleteFile

+ const OpDeleteMetaPartition

+ const OpDiskErr

+ const OpDiskNoSpaceErr

+ const OpErr

+ const OpExistErr

+ const OpExtentRepairRead

+ const OpGetAllWatermarks

+ const OpGetAppliedId

+ const OpGetPartitionSize

+ const OpInitResultCode

+ const OpInodeFullErr

+ const OpIntraGroupNetErr

+ const OpLoadDataPartition

+ const OpLoadMetaPartition

+ const OpMarkDelete

+ const OpMetaBatchInodeGet

+ const OpMetaCreateDentry

+ const OpMetaCreateInode

+ const OpMetaDeleteDentry

+ const OpMetaEvictInode

+ const OpMetaExtentsAdd

+ const OpMetaExtentsDel

+ const OpMetaExtentsList

+ const OpMetaFreeInodesOnRaftFollower

+ const OpMetaInodeGet

+ const OpMetaLinkInode

+ const OpMetaLookup

+ const OpMetaNodeHeartbeat

+ const OpMetaOpen

+ const OpMetaReadDir

+ const OpMetaReleaseOpen

+ const OpMetaSetattr

+ const OpMetaTruncate

+ const OpMetaUnlinkInode

+ const OpMetaUpdateDentry

+ const OpNotEmtpy

+ const OpNotExistErr

+ const OpNotLeaderErr

+ const OpNotPerm

+ const OpNotifyReplicasToRepair

+ const OpOk

+ const OpPing

+ const OpRandomWrite

+ const OpRead

+ const OpReadTinyDelete

+ const OpReplicateFile

+ const OpStreamRead

+ const OpSyncRandomWrite

+ const OpSyncWrite

+ const OpUpdateMetaPartition

+ const OpWrite

+ const ProtoMagic

+ const ReadDeadlineTime

+ const ReadOnly

+ const ReadWrite

+ const RemoveRaftNode

+ const ResponseInterval

+ const ResponseTimeOut

+ const RootIno

+ const SyncSendTaskDeadlineTime

+ const TaskFailed

+ const TaskRunning

+ const TaskStart

+ const TaskSucceeds

+ const TinyExtentType

+ const Unavailable

+ const WriteDeadlineTime

+ var Buffers = buf.NewBufferPool()

+ var Err2CodeMap = map[error]int32

+ var ErrActiveDataNodesTooLess = errors.New("no enough active data node")

+ var ErrActiveMetaNodesTooLess = errors.New("no enough active meta node")

+ var ErrCannotBeOffLine = errors.New("cannot take the data replica offline")

+ var ErrDataNodeNotExists = errors.New("data partition not exists")

+ var ErrDataPartitionNotExists = errors.New("data partition not exists")

+ var ErrDuplicateVol = errors.New("duplicate vol")

+ var ErrHasOneMissingReplica = errors.New("there is a missing data replica")

+ var ErrIllegalDataReplica = errors.New("data replica is illegal")

+ var ErrIllegalMetaReplica = errors.New("illegal meta replica")

+ var ErrInternalError = errors.New("internal error")

+ var ErrInvalidCfg = errors.New("bad configuration file")

+ var ErrInvalidMpStart = errors.New("invalid meta partition start value")

+ var ErrMarshalData = errors.New("marshal data error")

+ var ErrMetaNodeNotExists = errors.New("data partition not exists")

+ var ErrMetaPartitionNotExists = errors.New("meta partition not exists")

+ var ErrMissingReplica = errors.New("a missing data replica is found")

+ var ErrNoAvailDataPartition = errors.New("no available data partition")

+ var ErrNoDataNodeToCreateDataPartition = errors.New("no enough data nodes for creating a data partition")

+ var ErrNoDataNodeToWrite = errors.New("No data node available for creating a data partition")

+ var ErrNoEnoughReplica = errors.New("no enough replicas")

+ var ErrNoLeader = errors.New("no leader")

+ var ErrNoMetaNodeToCreateMetaPartition = errors.New("no enough meta nodes for creating a meta partition")

+ var ErrNoMetaNodeToWrite = errors.New("No meta node available for creating a meta partition")

+ var ErrNoNodeSetToCreateDataPartition = errors.New("no node set available for creating a data partition")

+ var ErrNoNodeSetToCreateMetaPartition = errors.New("no node set available for creating a meta partition")

+ var ErrNoRackToCreateDataPartition = errors.New("no rack available for creating a data partition")

+ var ErrParamError = errors.New("parameter error")

+ var ErrPersistenceByRaft = errors.New("persistence by raft occurred error")

+ var ErrReshuffleArray = errors.New("the array to be reshuffled is nil")

+ var ErrSuc = errors.New("success")

+ var ErrUnmarshalData = errors.New("unmarshal data error")

+ var ErrVolAuthKeyNotMatch = errors.New("client and server auth key do not match")

+ var ErrVolNotExists = errors.New("vol not exists")

+ var ExtentLength = 40

+ var GRequestID = int64(1)

+ var InvalidKey = errors.New("invalid key error")

+ func GenerateRequestID() int64

+ func IsDir(mode uint32) bool

+ func IsRegular(mode uint32) bool

+ func IsSymlink(mode uint32) bool

+ func Mode(osMode os.FileMode) uint32

+ func OsMode(mode uint32) os.FileMode

+ func ReadFull(c net.Conn, buf *[]byte, readSize int) (err error)

+ type AdminTask struct

+ CreateTime int64

+ ID string

+ OpCode uint8

+ OperatorAddr string

+ Request interface{}

+ Response interface{}

+ SendCount uint8

+ SendTime int64

+ Status int8

+ func NewAdminTask(opCode uint8, opAddr string, request interface{}) (t *AdminTask)

+ func (t *AdminTask) CheckTaskNeedSend() (needRetry bool)

+ func (t *AdminTask) CheckTaskTimeOut() (notResponse bool)

+ func (t *AdminTask) IsHeartbeatTask() bool

+ func (t *AdminTask) IsTaskFailed() (isFail bool)

+ func (t *AdminTask) IsTaskSuccessful() (isSuccess bool)

+ func (t *AdminTask) IsUrgentTask() bool

+ func (t *AdminTask) SetStatus(status int8)

+ func (t *AdminTask) ToString() (msg string)

+ type AppendExtentKeyRequest struct

+ Extent ExtentKey

+ Inode uint64

+ PartitionID uint64

+ VolName string

+ type BatchInodeGetRequest struct

+ Inodes []uint64

+ PartitionID uint64

+ VolName string

+ type BatchInodeGetResponse struct

+ Infos []*InodeInfo

+ type ClusterInfo struct

+ Cluster string

+ Ip string

+ type CreateDataPartitionRequest struct

+ IsRandomWrite bool

+ Members []Peer

+ PartitionId uint64

+ PartitionSize int

+ PartitionType string

+ VolumeId string

+ type CreateDataPartitionResponse struct

+ PartitionId uint64

+ Result string

+ Status uint8

+ type CreateDentryRequest struct

+ Inode uint64

+ Mode uint32

+ Name string

+ ParentID uint64

+ PartitionID uint64

+ VolName string

+ type CreateInodeRequest struct

+ Mode uint32

+ PartitionID uint64

+ Target []byte

+ VolName string

+ type CreateInodeResponse struct

+ Info *InodeInfo

+ type CreateMetaPartitionRequest struct

+ End uint64

+ Members []Peer

+ MetaId string

+ PartitionID uint64

+ Start uint64

+ VolName string

+ type CreateMetaPartitionResponse struct

+ PartitionID uint64

+ Result string

+ Status uint8

+ VolName string

+ type CreateNameSpaceRequest struct

+ Name string

+ type CreateNameSpaceResponse struct

+ Result string

+ Status int

+ type DataNodeHeartbeatResponse struct

+ Available uint64

+ CreatedPartitionCnt uint32

+ MaxCapacity uint64

+ PartitionReports []*PartitionReport

+ RackName string

+ RemainingCapacity uint64

+ Result string

+ Status uint8

+ Total uint64

+ TotalPartitionSize uint64

+ Used uint64

+ type DataPartitionDecommissionRequest struct

+ AddPeer Peer

+ PartitionId uint64

+ RemovePeer Peer

+ type DataPartitionDecommissionResponse struct

+ PartitionId uint64

+ Result string

+ Status uint8

+ type DataPartitionResponse struct

+ Hosts []string

+ LeaderAddr string

+ PartitionID uint64

+ ReplicaNum uint8

+ Status int8

+ type DataPartitionsView struct

+ DataPartitions []*DataPartitionResponse

+ func NewDataPartitionsView() (dataPartitionsView *DataPartitionsView)

+ type DeleteDataPartitionRequest struct

+ DataPartitionType string

+ PartitionId uint64

+ PartitionSize int

+ type DeleteDataPartitionResponse struct

+ PartitionId uint64

+ Result string

+ Status uint8

+ type DeleteDentryRequest struct

+ Name string

+ ParentID uint64

+ PartitionID uint64

+ VolName string

+ type DeleteDentryResponse struct

+ Inode uint64

+ type DeleteFileRequest struct

+ Name string

+ VolId uint64

+ type DeleteFileResponse struct

+ Name string

+ Result string

+ Status uint8

+ VolId uint64

+ type DeleteMetaPartitionRequest struct

+ PartitionID uint64

+ type DeleteMetaPartitionResponse struct

+ PartitionID uint64

+ Result string

+ Status uint8

+ type Dentry struct

+ Inode uint64

+ Name string

+ Type uint32

+ func (d Dentry) String() string

+ type EvictInodeRequest struct

+ Inode uint64

+ PartitionID uint64

+ VolName string

+ type ExtentKey struct

+ CRC uint32

+ ExtentId uint64

+ ExtentOffset uint64

+ FileOffset uint64

+ PartitionId uint64

+ Size uint32

+ func (k *ExtentKey) Copy() btree.Item

+ func (k *ExtentKey) GetExtentKey() (m string)

+ func (k *ExtentKey) Less(than btree.Item) bool

+ func (k *ExtentKey) Marshal() (m string)

+ func (k *ExtentKey) MarshalBinary() ([]byte, error)

+ func (k *ExtentKey) UnMarshal(m string) (err error)

+ func (k *ExtentKey) UnmarshalBinary(buf *bytes.Buffer) (err error)

+ func (k ExtentKey) String() string

+ type File struct

+ Crc uint32

+ Modified int64

+ Name string

+ Size uint32

+ type GetExtentsRequest struct

+ Inode uint64

+ PartitionID uint64

+ VolName string

+ type GetExtentsResponse struct

+ Extents []ExtentKey

+ Generation uint64

+ Size uint64

+ type HTTPReply struct

+ Code int32

+ Data interface{}

+ Msg string

+ type HeartBeatRequest struct

+ CurrTime int64

+ MasterAddr string

+ type InodeGetRequest struct

+ Inode uint64

+ PartitionID uint64

+ VolName string

+ type InodeGetResponse struct

+ Info *InodeInfo

+ type InodeInfo struct

+ AccessTime time.Time

+ CreateTime time.Time

+ Generation uint64

+ Gid uint32

+ Inode uint64

+ Mode uint32

+ ModifyTime time.Time

+ Nlink uint32

+ Size uint64

+ Target []byte

+ Uid uint32

+ func (info *InodeInfo) String() string

+ type LinkInodeRequest struct

+ Inode uint64

+ PartitionID uint64

+ VolName string

+ type LinkInodeResponse struct

+ Info *InodeInfo

+ type LoadDataPartitionRequest struct

+ PartitionId uint64

+ type LoadDataPartitionResponse struct

+ PartitionId uint64

+ PartitionSnapshot []*File

+ PartitionStatus int

+ Result string

+ Status uint8

+ Used uint64

+ type LoadMetaPartitionMetricRequest struct

+ End uint64

+ PartitionID uint64

+ Start uint64

+ type LoadMetaPartitionMetricResponse struct

+ End uint64

+ MaxInode uint64

+ Result string

+ Start uint64

+ Status uint8

+ type LookupRequest struct

+ Name string

+ ParentID uint64

+ PartitionID uint64

+ VolName string

+ type LookupResponse struct

+ Inode uint64

+ Mode uint32

+ type MetaNodeHeartbeatResponse struct

+ MetaPartitionReports []*MetaPartitionReport

+ RackName string

+ Result string

+ Status uint8

+ Total uint64

+ Used uint64

+ type MetaPartitionDecommissionRequest struct

+ AddPeer Peer

+ PartitionID uint64

+ RemovePeer Peer

+ VolName string

+ type MetaPartitionDecommissionResponse struct

+ PartitionID uint64

+ Result string

+ Status uint8

+ VolName string

+ type MetaPartitionLoadRequest struct

+ PartitionID uint64

+ type MetaPartitionLoadResponse struct

+ Addr string

+ ApplyID uint64

+ DentrySign uint32

+ DoCompare bool

+ InodeSign uint32

+ PartitionID uint64

+ type MetaPartitionReport struct

+ End uint64

+ IsLeader bool

+ MaxInodeID uint64

+ PartitionID uint64

+ Start uint64

+ Status int

+ type MetaPartitionView struct

+ End uint64

+ LeaderAddr string

+ Members []string

+ PartitionID uint64

+ Start uint64

+ Status int8

+ func NewMetaPartitionView(partitionID, start, end uint64, status int8) (mpView *MetaPartitionView)

+ type Packet struct

+ Arg []byte

+ ArgLen uint32

+ CRC uint32

+ Data []byte

+ ExtentID uint64

+ ExtentOffset int64

+ ExtentType uint8

+ KernelOffset uint64

+ Magic uint8

+ Opcode uint8

+ PartitionID uint64

+ RemainingFollowers uint8

+ ReqID int64

+ ResultCode uint8

+ Size uint32

+ StartT int64

+ func NewPacket() *Packet

+ func NewPacketReqID() *Packet

+ func (p *Packet) GetOpMsg() (m string)

+ func (p *Packet) GetReqID() int64

+ func (p *Packet) GetResultMsg() (m string)

+ func (p *Packet) GetStoreType() (m string)

+ func (p *Packet) GetUniqueLogId() (m string)

+ func (p *Packet) IsForwardPkt() bool

+ func (p *Packet) LogMessage(action, remote string, start int64, err error) (m string)

+ func (p *Packet) MarshalData(v interface{}) error

+ func (p *Packet) MarshalHeader(out []byte)

+ func (p *Packet) PacketErrorWithBody(code uint8, reply []byte)

+ func (p *Packet) PacketOkReply()

+ func (p *Packet) PacketOkWithBody(reply []byte)

+ func (p *Packet) ReadFromConn(c net.Conn, timeoutSec int) (err error)

+ func (p *Packet) ShouldRetry() bool

+ func (p *Packet) String() string

+ func (p *Packet) UnmarshalData(v interface{}) error

+ func (p *Packet) UnmarshalHeader(in []byte) error

+ func (p *Packet) WriteToConn(c net.Conn) (err error)

+ func (p *Packet) WriteToNoDeadLineConn(c net.Conn) (err error)

+ type PartitionReport struct

+ DiskPath string

+ ExtentCount int

+ IsLeader bool

+ NeedCompare bool

+ PartitionID uint64

+ PartitionStatus int

+ Total uint64

+ Used uint64

+ type Peer struct

+ Addr string

+ ID uint64

+ type ReadDirRequest struct

+ ParentID uint64

+ PartitionID uint64

+ VolName string

+ type ReadDirResponse struct

+ Children []Dentry

+ type RegisterMetaNodeResp struct

+ ID uint64

+ type SetAttrRequest struct

+ Gid uint32

+ Inode uint64

+ Mode uint32

+ PartitionID uint64

+ Uid uint32

+ Valid uint32

+ VolName string

+ type SimpleVolView struct

+ Capacity uint64

+ DpCnt int

+ DpReplicaNum uint8

+ ID uint64

+ MpCnt int

+ MpReplicaNum uint8

+ Name string

+ Owner string

+ RwDpCnt int

+ Status uint8

+ type TinyExtentDeleteRecord struct

+ CRC uint32

+ ExtentId uint64

+ ExtentOffset uint64

+ FileOffset uint64

+ PartitionId uint64

+ Size uint32

+ TinyDeleteFileOffset int64

+ type TruncateRequest struct

+ Inode uint64

+ PartitionID uint64

+ Size uint64

+ VolName string

+ type UnlinkInodeRequest struct

+ Inode uint64

+ PartitionID uint64

+ VolName string

+ type UnlinkInodeResponse struct

+ Info *InodeInfo

+ type UpdateDentryRequest struct

+ Inode uint64

+ Name string

+ ParentID uint64

+ PartitionID uint64

+ VolName string

+ type UpdateDentryResponse struct

+ Inode uint64

+ type UpdateMetaPartitionRequest struct

+ End uint64

+ PartitionID uint64

+ Start uint64

+ VolName string

+ type UpdateMetaPartitionResponse struct

+ End uint64

+ PartitionID uint64

+ Result string

+ Status uint8

+ VolName string

+ type VolStatInfo struct

+ Name string

+ TotalSize uint64

+ UsedSize uint64

+ type VolView struct

+ DataPartitions []*DataPartitionResponse

+ MetaPartitions []*MetaPartitionView

+ Name string

+ Status uint8

+ func NewVolView(name string, status uint8) (view *VolView)

Incompatible versions in this module

v3.0.0-beta-rc.1+incompatible

Jan 27, 2022

v3.0.0-beta-rc.0+incompatible

Oct 19, 2021

v3.0.0-beta+incompatible

Jan 27, 2022

v2.5.2+incompatible

Jun 27, 2022

v2.5.1+incompatible

Jan 26, 2022

v2.5.1-rc.0+incompatible

Dec 15, 2021

v2.5.0+incompatible

Dec 15, 2021

v2.5.0-rc.1+incompatible

Sep 24, 2021

v2.5.0-rc.0+incompatible

Sep 24, 2021

v2.4.3+incompatible

Mar 18, 2022

v2.4.1+incompatible

Dec 31, 2021

v2.4.1-rc.1+incompatible

Oct 19, 2021

v2.4.1-rc.0+incompatible

Sep 2, 2021

v2.4.0+incompatible

May 14, 2021

v2.4.0-rc.1+incompatible

Apr 23, 2021

v2.4.0-rc.0+incompatible

Apr 14, 2021

v2.3.0+incompatible

Feb 28, 2021

v2.3.0-rc.2+incompatible

Feb 9, 2021

v2.3.0-rc.1+incompatible

Jan 28, 2021

v2.2.2+incompatible

Sep 23, 2020

v2.2.1+incompatible

Sep 7, 2020

v2.2.0+incompatible

Sep 4, 2020

v2.1.0+incompatible

Jul 10, 2020

v2.1.0-rc.1+incompatible

Jun 13, 2020

v2.0.0+incompatible

Apr 9, 2020

v2.0.0-rc.1+incompatible

Apr 9, 2020

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL