base

Jul 28, 2022

Changes in this version

type Code

+ const Code_BackToSourceAborted

type ExtendAttribute

+ Status string

+ StatusCode int32

+ func (x *ExtendAttribute) GetStatus() string

+ func (x *ExtendAttribute) GetStatusCode() int32

Jul 1, 2022

Changes in this version

+ var Pattern_name = map[int32]string

+ var Pattern_value = map[string]int32

+ var TaskType_name = map[int32]string

+ var TaskType_value = map[string]int32

+ type Pattern int32

+ const Pattern_P2P

+ const Pattern_SEED_PEER

+ const Pattern_SOURCE

+ func (Pattern) Descriptor() protoreflect.EnumDescriptor

+ func (Pattern) EnumDescriptor() ([]byte, []int)

+ func (Pattern) Type() protoreflect.EnumType

+ func (x Pattern) Enum() *Pattern

+ func (x Pattern) Number() protoreflect.EnumNumber

+ func (x Pattern) String() string

+ type TaskType int32

+ const TaskType_DfCache

+ const TaskType_DfStore

+ const TaskType_Normal

+ func (TaskType) Descriptor() protoreflect.EnumDescriptor

+ func (TaskType) EnumDescriptor() ([]byte, []int)

+ func (TaskType) Type() protoreflect.EnumType

+ func (x TaskType) Enum() *TaskType

+ func (x TaskType) Number() protoreflect.EnumNumber

+ func (x TaskType) String() string

Jun 6, 2022

Changes in this version

+ type ExtendAttribute struct

+ Header map[string]string

+ func (*ExtendAttribute) Descriptor() ([]byte, []int)

+ func (*ExtendAttribute) ProtoMessage()

+ func (m *ExtendAttribute) Validate() error

+ func (x *ExtendAttribute) GetHeader() map[string]string

+ func (x *ExtendAttribute) ProtoReflect() protoreflect.Message

+ func (x *ExtendAttribute) Reset()

+ func (x *ExtendAttribute) String() string

+ type ExtendAttributeValidationError struct

+ func (e ExtendAttributeValidationError) Cause() error

+ func (e ExtendAttributeValidationError) Error() string

+ func (e ExtendAttributeValidationError) ErrorName() string

+ func (e ExtendAttributeValidationError) Field() string

+ func (e ExtendAttributeValidationError) Key() bool

+ func (e ExtendAttributeValidationError) Reason() string

type PiecePacket

+ ExtendAttribute *ExtendAttribute

+ func (x *PiecePacket) GetExtendAttribute() *ExtendAttribute

Apr 11, 2022

Changes in this version

type Code

+ const Code_ClientBackSourceError

+ const Code_ClientConnectionError

+ const Code_ClientPieceNotFound

type PieceInfo

+ DownloadCost uint64

+ func (x *PieceInfo) GetDownloadCost() uint64

Dec 3, 2021

Changes in this version

type Code

+ const Code_BadRequest

+ const Code_CDNError

+ const Code_CDNTaskDownloadFail

+ const Code_CDNTaskNotFound

+ const Code_CDNTaskRegistryFail

+ const Code_ClientContextCanceled

+ const Code_ClientError

+ const Code_ClientPieceDownloadFail

+ const Code_ClientPieceRequestFail

+ const Code_ClientRequestLimitFail

+ const Code_ClientScheduleTimeout

+ const Code_ClientWaitPieceReady

+ const Code_InvalidResourceType

+ const Code_PeerTaskNotFound

+ const Code_RequestTimeOut

+ const Code_ResourceLacked

+ const Code_SchedError

+ const Code_SchedNeedBackSource

+ const Code_SchedPeerGone

+ const Code_SchedPeerNotFound

+ const Code_SchedPeerPieceResultReportFail

+ const Code_SchedTaskStatusError

+ const Code_ServerUnavailable

+ const Code_Success

+ const Code_UnknownError

type GrpcDfError

+ func (m *GrpcDfError) ValidateAll() error

+ type GrpcDfErrorMultiError []error

+ func (m GrpcDfErrorMultiError) AllErrors() []error

+ func (m GrpcDfErrorMultiError) Error() string

type HostLoad

+ func (m *HostLoad) ValidateAll() error

+ type HostLoadMultiError []error

+ func (m HostLoadMultiError) AllErrors() []error

+ func (m HostLoadMultiError) Error() string

type PieceInfo

+ func (m *PieceInfo) ValidateAll() error

+ type PieceInfoMultiError []error

+ func (m PieceInfoMultiError) AllErrors() []error

+ func (m PieceInfoMultiError) Error() string

type PiecePacket

+ func (m *PiecePacket) ValidateAll() error

+ type PiecePacketMultiError []error

+ func (m PiecePacketMultiError) AllErrors() []error

+ func (m PiecePacketMultiError) Error() string

type PieceTaskRequest

+ func (m *PieceTaskRequest) ValidateAll() error

+ type PieceTaskRequestMultiError []error

+ func (m PieceTaskRequestMultiError) AllErrors() []error

+ func (m PieceTaskRequestMultiError) Error() string

type UrlMeta

+ func (m *UrlMeta) ValidateAll() error

+ type UrlMetaMultiError []error

+ func (m UrlMetaMultiError) AllErrors() []error

+ func (m UrlMetaMultiError) Error() string

Sep 9, 2021

Changes in this version

+ var Code_name = map[int32]string

+ var Code_value = map[string]int32

+ var File_pkg_rpc_base_base_proto protoreflect.FileDescriptor

+ var PieceStyle_name = map[int32]string

+ var PieceStyle_value = map[string]int32

+ var SizeScope_name = map[int32]string

+ var SizeScope_value = map[string]int32

+ type Code int32

+ const Code_X_UNSPECIFIED

+ func (Code) Descriptor() protoreflect.EnumDescriptor

+ func (Code) EnumDescriptor() ([]byte, []int)

+ func (Code) Type() protoreflect.EnumType

+ func (x Code) Enum() *Code

+ func (x Code) Number() protoreflect.EnumNumber

+ func (x Code) String() string

+ type GrpcDfError struct

+ Code Code

+ Message string

+ func (*GrpcDfError) Descriptor() ([]byte, []int)

+ func (*GrpcDfError) ProtoMessage()

+ func (m *GrpcDfError) Validate() error

+ func (x *GrpcDfError) GetCode() Code

+ func (x *GrpcDfError) GetMessage() string

+ func (x *GrpcDfError) ProtoReflect() protoreflect.Message

+ func (x *GrpcDfError) Reset()

+ func (x *GrpcDfError) String() string

+ type GrpcDfErrorValidationError struct

+ func (e GrpcDfErrorValidationError) Cause() error

+ func (e GrpcDfErrorValidationError) Error() string

+ func (e GrpcDfErrorValidationError) ErrorName() string

+ func (e GrpcDfErrorValidationError) Field() string

+ func (e GrpcDfErrorValidationError) Key() bool

+ func (e GrpcDfErrorValidationError) Reason() string

+ type HostLoad struct

+ CpuRatio float32

+ DiskRatio float32

+ MemRatio float32

+ func (*HostLoad) Descriptor() ([]byte, []int)

+ func (*HostLoad) ProtoMessage()

+ func (m *HostLoad) Validate() error

+ func (x *HostLoad) GetCpuRatio() float32

+ func (x *HostLoad) GetDiskRatio() float32

+ func (x *HostLoad) GetMemRatio() float32

+ func (x *HostLoad) ProtoReflect() protoreflect.Message

+ func (x *HostLoad) Reset()

+ func (x *HostLoad) String() string

+ type HostLoadValidationError struct

+ func (e HostLoadValidationError) Cause() error

+ func (e HostLoadValidationError) Error() string

+ func (e HostLoadValidationError) ErrorName() string

+ func (e HostLoadValidationError) Field() string

+ func (e HostLoadValidationError) Key() bool

+ func (e HostLoadValidationError) Reason() string

+ type PieceInfo struct

+ PieceMd5 string

+ PieceNum int32

+ PieceOffset uint64

+ PieceStyle PieceStyle

+ RangeSize int32

+ RangeStart uint64

+ func (*PieceInfo) Descriptor() ([]byte, []int)

+ func (*PieceInfo) ProtoMessage()

+ func (m *PieceInfo) Validate() error

+ func (x *PieceInfo) GetPieceMd5() string

+ func (x *PieceInfo) GetPieceNum() int32

+ func (x *PieceInfo) GetPieceOffset() uint64

+ func (x *PieceInfo) GetPieceStyle() PieceStyle

+ func (x *PieceInfo) GetRangeSize() int32

+ func (x *PieceInfo) GetRangeStart() uint64

+ func (x *PieceInfo) ProtoReflect() protoreflect.Message

+ func (x *PieceInfo) Reset()

+ func (x *PieceInfo) String() string

+ type PieceInfoValidationError struct

+ func (e PieceInfoValidationError) Cause() error

+ func (e PieceInfoValidationError) Error() string

+ func (e PieceInfoValidationError) ErrorName() string

+ func (e PieceInfoValidationError) Field() string

+ func (e PieceInfoValidationError) Key() bool

+ func (e PieceInfoValidationError) Reason() string

+ type PiecePacket struct

+ ContentLength int64

+ DstAddr string

+ DstPid string

+ PieceInfos []*PieceInfo

+ PieceMd5Sign string

+ TaskId string

+ TotalPiece int32

+ func (*PiecePacket) Descriptor() ([]byte, []int)

+ func (*PiecePacket) ProtoMessage()

+ func (m *PiecePacket) Validate() error

+ func (x *PiecePacket) GetContentLength() int64

+ func (x *PiecePacket) GetDstAddr() string

+ func (x *PiecePacket) GetDstPid() string

+ func (x *PiecePacket) GetPieceInfos() []*PieceInfo

+ func (x *PiecePacket) GetPieceMd5Sign() string

+ func (x *PiecePacket) GetTaskId() string

+ func (x *PiecePacket) GetTotalPiece() int32

+ func (x *PiecePacket) ProtoReflect() protoreflect.Message

+ func (x *PiecePacket) Reset()

+ func (x *PiecePacket) String() string

+ type PiecePacketValidationError struct

+ func (e PiecePacketValidationError) Cause() error

+ func (e PiecePacketValidationError) Error() string

+ func (e PiecePacketValidationError) ErrorName() string

+ func (e PiecePacketValidationError) Field() string

+ func (e PiecePacketValidationError) Key() bool

+ func (e PiecePacketValidationError) Reason() string

+ type PieceStyle int32

+ const PieceStyle_PLAIN

+ func (PieceStyle) Descriptor() protoreflect.EnumDescriptor

+ func (PieceStyle) EnumDescriptor() ([]byte, []int)

+ func (PieceStyle) Type() protoreflect.EnumType

+ func (x PieceStyle) Enum() *PieceStyle

+ func (x PieceStyle) Number() protoreflect.EnumNumber

+ func (x PieceStyle) String() string

+ type PieceTaskRequest struct

+ DstPid string

+ Limit int32

+ SrcPid string

+ StartNum int32

+ TaskId string

+ func (*PieceTaskRequest) Descriptor() ([]byte, []int)

+ func (*PieceTaskRequest) ProtoMessage()

+ func (m *PieceTaskRequest) Validate() error

+ func (x *PieceTaskRequest) GetDstPid() string

+ func (x *PieceTaskRequest) GetLimit() int32

+ func (x *PieceTaskRequest) GetSrcPid() string

+ func (x *PieceTaskRequest) GetStartNum() int32

+ func (x *PieceTaskRequest) GetTaskId() string

+ func (x *PieceTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *PieceTaskRequest) Reset()

+ func (x *PieceTaskRequest) String() string

+ type PieceTaskRequestValidationError struct

+ func (e PieceTaskRequestValidationError) Cause() error

+ func (e PieceTaskRequestValidationError) Error() string

+ func (e PieceTaskRequestValidationError) ErrorName() string

+ func (e PieceTaskRequestValidationError) Field() string

+ func (e PieceTaskRequestValidationError) Key() bool

+ func (e PieceTaskRequestValidationError) Reason() string

+ type SizeScope int32

+ const SizeScope_NORMAL

+ const SizeScope_SMALL

+ const SizeScope_TINY

+ func (SizeScope) Descriptor() protoreflect.EnumDescriptor

+ func (SizeScope) EnumDescriptor() ([]byte, []int)

+ func (SizeScope) Type() protoreflect.EnumType

+ func (x SizeScope) Enum() *SizeScope

+ func (x SizeScope) Number() protoreflect.EnumNumber

+ func (x SizeScope) String() string

+ type UrlMeta struct

+ Digest string

+ Filter string

+ Header map[string]string

+ Range string

+ Tag string

+ func (*UrlMeta) Descriptor() ([]byte, []int)

+ func (*UrlMeta) ProtoMessage()

+ func (m *UrlMeta) Validate() error

+ func (x *UrlMeta) GetDigest() string

+ func (x *UrlMeta) GetFilter() string

+ func (x *UrlMeta) GetHeader() map[string]string

+ func (x *UrlMeta) GetRange() string

+ func (x *UrlMeta) GetTag() string

+ func (x *UrlMeta) ProtoReflect() protoreflect.Message

+ func (x *UrlMeta) Reset()

+ func (x *UrlMeta) String() string

+ type UrlMetaValidationError struct

+ func (e UrlMetaValidationError) Cause() error

+ func (e UrlMetaValidationError) Error() string

+ func (e UrlMetaValidationError) ErrorName() string

+ func (e UrlMetaValidationError) Field() string

+ func (e UrlMetaValidationError) Key() bool

+ func (e UrlMetaValidationError) Reason() string