standard

package

Go to main page

Versions in this module

v2

v2.2.0

Dec 31, 2024

v2.1.67

Dec 23, 2024

v2.1.66

Dec 17, 2024

Changes in this version

type MockSeedPeerClient

+ func (m *MockSeedPeerClient) SeedPeers() []*manager.SeedPeer

type MockSeedPeerClientMockRecorder

+ func (mr *MockSeedPeerClientMockRecorder) SeedPeers() *gomock.Call

type SeedPeerClient

+ SeedPeers func() []*managerv2.SeedPeer

v2.1.65

Nov 29, 2024

v2.1.64

Nov 22, 2024

Changes in this version

type Disk

+ ReadBandwidth uint64

+ WriteBandwidth uint64

v2.1.63

Nov 11, 2024

v2.1.62

Oct 28, 2024

Changes in this version

type Host

+ func (h *Host) IsSeedPeer() bool

v2.1.61

Oct 17, 2024

v2.1.60

Oct 9, 2024

Changes in this version

+ const EmptyFileSize

+ const FailedPeerCountLimit

+ const GCHostID

+ const GCPeerID

+ const GCTaskID

+ const PeerCountLimitForTask

+ const PeerEventDownload

+ const PeerEventDownloadBackToSource

+ const PeerEventDownloadFailed

+ const PeerEventDownloadSucceeded

+ const PeerEventLeave

+ const PeerEventRegisterEmpty

+ const PeerEventRegisterNormal

+ const PeerEventRegisterSmall

+ const PeerEventRegisterTiny

+ const PeerStateBackToSource

+ const PeerStateFailed

+ const PeerStateLeave

+ const PeerStatePending

+ const PeerStateReceivedEmpty

+ const PeerStateReceivedNormal

+ const PeerStateReceivedSmall

+ const PeerStateReceivedTiny

+ const PeerStateRunning

+ const PeerStateSucceeded

+ const SeedPeerFailedTimeout

+ const TaskEventDownload

+ const TaskEventDownloadFailed

+ const TaskEventDownloadSucceeded

+ const TaskEventLeave

+ const TaskStateFailed

+ const TaskStateLeave

+ const TaskStatePending

+ const TaskStateRunning

+ const TaskStateSucceeded

+ const TinyFileSize

+ func IsPieceBackToSource(parentID string) bool

+ type Build struct

+ GitCommit string

+ GitVersion string

+ GoVersion string

+ Platform string

+ type CPU struct

+ LogicalCount uint32

+ Percent float64

+ PhysicalCount uint32

+ ProcessPercent float64

+ Times CPUTimes

+ type CPUTimes struct

+ Guest float64

+ GuestNice float64

+ Idle float64

+ Iowait float64

+ Irq float64

+ Nice float64

+ Softirq float64

+ Steal float64

+ System float64

+ User float64

+ type Disk struct

+ Free uint64

+ InodesFree uint64

+ InodesTotal uint64

+ InodesUsed uint64

+ InodesUsedPercent float64

+ Total uint64

+ Used uint64

+ UsedPercent float64

+ type Host struct

+ AnnounceInterval time.Duration

+ Build Build

+ CPU CPU

+ ConcurrentUploadCount *atomic.Int32

+ ConcurrentUploadLimit *atomic.Int32

+ CreatedAt *atomic.Time

+ DisableShared bool

+ Disk Disk

+ DownloadPort int32

+ Hostname string

+ ID string

+ IP string

+ KernelVersion string

+ Log *logger.SugaredLoggerOnWith

+ Memory Memory

+ Network Network

+ OS string

+ ObjectStoragePort int32

+ PeerCount *atomic.Int32

+ Peers *sync.Map

+ Platform string

+ PlatformFamily string

+ PlatformVersion string

+ Port int32

+ SchedulerClusterID uint64

+ Type types.HostType

+ UpdatedAt *atomic.Time

+ UploadCount *atomic.Int64

+ UploadFailedCount *atomic.Int64

+ func NewHost(id, ip, hostname string, port, downloadPort int32, typ types.HostType, ...) *Host

+ func (h *Host) DeletePeer(key string)

+ func (h *Host) FreeUploadCount() int32

+ func (h *Host) LeavePeers()

+ func (h *Host) LoadPeer(key string) (*Peer, bool)

+ func (h *Host) StorePeer(peer *Peer)

+ type HostManager interface

+ Delete func(string)

+ Load func(string) (*Host, bool)

+ LoadAll func() []*Host

+ LoadOrStore func(*Host) (*Host, bool)

+ LoadRandom func(int, set.SafeSet[string]) []*Host

+ Range func(f func(any, any) bool)

+ RunGC func() error

+ Store func(*Host)

+ type HostOption func(h *Host)

+ func WithAnnounceInterval(announceInterval time.Duration) HostOption

+ func WithBuild(build Build) HostOption

+ func WithCPU(cpu CPU) HostOption

+ func WithConcurrentUploadLimit(limit int32) HostOption

+ func WithDisableShared(disableShared bool) HostOption

+ func WithDisk(disk Disk) HostOption

+ func WithKernelVersion(kernelVersion string) HostOption

+ func WithMemory(memory Memory) HostOption

+ func WithNetwork(network Network) HostOption

+ func WithOS(os string) HostOption

+ func WithObjectStoragePort(port int32) HostOption

+ func WithPlatform(platform string) HostOption

+ func WithPlatformFamily(platformFamily string) HostOption

+ func WithPlatformVersion(platformVersion string) HostOption

+ func WithSchedulerClusterID(id uint64) HostOption

+ type Memory struct

+ Available uint64

+ Free uint64

+ ProcessUsedPercent float64

+ Total uint64

+ Used uint64

+ UsedPercent float64

+ type MockHostManager struct

+ func NewMockHostManager(ctrl *gomock.Controller) *MockHostManager

+ func (m *MockHostManager) Delete(arg0 string)

+ func (m *MockHostManager) EXPECT() *MockHostManagerMockRecorder

+ func (m *MockHostManager) Load(arg0 string) (*Host, bool)

+ func (m *MockHostManager) LoadAll() []*Host

+ func (m *MockHostManager) LoadOrStore(arg0 *Host) (*Host, bool)

+ func (m *MockHostManager) LoadRandom(arg0 int, arg1 set.SafeSet[string]) []*Host

+ func (m *MockHostManager) Range(f func(any, any) bool)

+ func (m *MockHostManager) RunGC() error

+ func (m *MockHostManager) Store(arg0 *Host)

+ type MockHostManagerMockRecorder struct

+ func (mr *MockHostManagerMockRecorder) Delete(arg0 any) *gomock.Call

+ func (mr *MockHostManagerMockRecorder) Load(arg0 any) *gomock.Call

+ func (mr *MockHostManagerMockRecorder) LoadAll() *gomock.Call

+ func (mr *MockHostManagerMockRecorder) LoadOrStore(arg0 any) *gomock.Call

+ func (mr *MockHostManagerMockRecorder) LoadRandom(arg0, arg1 any) *gomock.Call

+ func (mr *MockHostManagerMockRecorder) Range(f any) *gomock.Call

+ func (mr *MockHostManagerMockRecorder) RunGC() *gomock.Call

+ func (mr *MockHostManagerMockRecorder) Store(arg0 any) *gomock.Call

+ type MockPeerManager struct

+ func NewMockPeerManager(ctrl *gomock.Controller) *MockPeerManager

+ func (m *MockPeerManager) Delete(arg0 string)

+ func (m *MockPeerManager) EXPECT() *MockPeerManagerMockRecorder

+ func (m *MockPeerManager) Load(arg0 string) (*Peer, bool)

+ func (m *MockPeerManager) LoadOrStore(arg0 *Peer) (*Peer, bool)

+ func (m *MockPeerManager) Range(f func(any, any) bool)

+ func (m *MockPeerManager) RunGC() error

+ func (m *MockPeerManager) Store(arg0 *Peer)

+ type MockPeerManagerMockRecorder struct

+ func (mr *MockPeerManagerMockRecorder) Delete(arg0 any) *gomock.Call

+ func (mr *MockPeerManagerMockRecorder) Load(arg0 any) *gomock.Call

+ func (mr *MockPeerManagerMockRecorder) LoadOrStore(arg0 any) *gomock.Call

+ func (mr *MockPeerManagerMockRecorder) Range(f any) *gomock.Call

+ func (mr *MockPeerManagerMockRecorder) RunGC() *gomock.Call

+ func (mr *MockPeerManagerMockRecorder) Store(arg0 any) *gomock.Call

+ type MockResource struct

+ func NewMockResource(ctrl *gomock.Controller) *MockResource

+ func (m *MockResource) EXPECT() *MockResourceMockRecorder

+ func (m *MockResource) HostManager() HostManager

+ func (m *MockResource) PeerManager() PeerManager

+ func (m *MockResource) SeedPeer() SeedPeer

+ func (m *MockResource) Stop() error

+ func (m *MockResource) TaskManager() TaskManager

+ type MockResourceMockRecorder struct

+ func (mr *MockResourceMockRecorder) HostManager() *gomock.Call

+ func (mr *MockResourceMockRecorder) PeerManager() *gomock.Call

+ func (mr *MockResourceMockRecorder) SeedPeer() *gomock.Call

+ func (mr *MockResourceMockRecorder) Stop() *gomock.Call

+ func (mr *MockResourceMockRecorder) TaskManager() *gomock.Call

+ type MockSeedPeer struct

+ func NewMockSeedPeer(ctrl *gomock.Controller) *MockSeedPeer

+ func (m *MockSeedPeer) Client() SeedPeerClient

+ func (m *MockSeedPeer) EXPECT() *MockSeedPeerMockRecorder

+ func (m *MockSeedPeer) Stop() error

+ func (m *MockSeedPeer) TriggerDownloadTask(arg0 context.Context, arg1 string, arg2 *dfdaemon.DownloadTaskRequest) error

+ func (m *MockSeedPeer) TriggerTask(arg0 context.Context, arg1 *http.Range, arg2 *Task) (*Peer, *scheduler.PeerResult, error)

+ type MockSeedPeerClient struct

+ func NewMockSeedPeerClient(ctrl *gomock.Controller) *MockSeedPeerClient

+ func (m *MockSeedPeerClient) Addrs() []string

+ func (m *MockSeedPeerClient) Close() error

+ func (m *MockSeedPeerClient) DeletePersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.DeletePersistentCacheTaskRequest, ...) error

+ func (m *MockSeedPeerClient) DeleteTask(arg0 context.Context, arg1 *dfdaemon.DeleteTaskRequest, ...) error

+ func (m *MockSeedPeerClient) DownloadPersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.DownloadPersistentCacheTaskRequest, ...) (dfdaemon.DfdaemonUpload_DownloadPersistentCacheTaskClient, error)

+ func (m *MockSeedPeerClient) DownloadPiece(arg0 context.Context, arg1 *dfdaemon.DownloadPieceRequest, ...) (*dfdaemon.DownloadPieceResponse, error)

+ func (m *MockSeedPeerClient) DownloadTask(arg0 context.Context, arg1 string, arg2 *dfdaemon.DownloadTaskRequest, ...) (dfdaemon.DfdaemonUpload_DownloadTaskClient, error)

+ func (m *MockSeedPeerClient) EXPECT() *MockSeedPeerClientMockRecorder

+ func (m *MockSeedPeerClient) GetPieceTasks(arg0 context.Context, arg1 *common.PieceTaskRequest, arg2 ...grpc.CallOption) (*common.PiecePacket, error)

+ func (m *MockSeedPeerClient) ObtainSeeds(arg0 context.Context, arg1 *cdnsystem.SeedRequest, arg2 ...grpc.CallOption) (cdnsystem.Seeder_ObtainSeedsClient, error)

+ func (m *MockSeedPeerClient) OnNotify(arg0 *config.DynconfigData)

+ func (m *MockSeedPeerClient) StatPersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.StatPersistentCacheTaskRequest, ...) (*common0.PersistentCacheTask, error)

+ func (m *MockSeedPeerClient) StatTask(arg0 context.Context, arg1 *dfdaemon.StatTaskRequest, arg2 ...grpc.CallOption) (*common0.Task, error)

+ func (m *MockSeedPeerClient) SyncPieceTasks(arg0 context.Context, arg1 *common.PieceTaskRequest, arg2 ...grpc.CallOption) (cdnsystem.Seeder_SyncPieceTasksClient, error)

+ func (m *MockSeedPeerClient) SyncPieces(arg0 context.Context, arg1 *dfdaemon.SyncPiecesRequest, ...) (dfdaemon.DfdaemonUpload_SyncPiecesClient, error)

+ type MockSeedPeerClientMockRecorder struct

+ func (mr *MockSeedPeerClientMockRecorder) Addrs() *gomock.Call

+ func (mr *MockSeedPeerClientMockRecorder) Close() *gomock.Call

+ func (mr *MockSeedPeerClientMockRecorder) DeletePersistentCacheTask(arg0, arg1 any, arg2 ...any) *gomock.Call

+ func (mr *MockSeedPeerClientMockRecorder) DeleteTask(arg0, arg1 any, arg2 ...any) *gomock.Call

+ func (mr *MockSeedPeerClientMockRecorder) DownloadPersistentCacheTask(arg0, arg1 any, arg2 ...any) *gomock.Call

+ func (mr *MockSeedPeerClientMockRecorder) DownloadPiece(arg0, arg1 any, arg2 ...any) *gomock.Call

+ func (mr *MockSeedPeerClientMockRecorder) DownloadTask(arg0, arg1, arg2 any, arg3 ...any) *gomock.Call

+ func (mr *MockSeedPeerClientMockRecorder) GetPieceTasks(arg0, arg1 any, arg2 ...any) *gomock.Call

+ func (mr *MockSeedPeerClientMockRecorder) ObtainSeeds(arg0, arg1 any, arg2 ...any) *gomock.Call

+ func (mr *MockSeedPeerClientMockRecorder) OnNotify(arg0 any) *gomock.Call

+ func (mr *MockSeedPeerClientMockRecorder) StatPersistentCacheTask(arg0, arg1 any, arg2 ...any) *gomock.Call

+ func (mr *MockSeedPeerClientMockRecorder) StatTask(arg0, arg1 any, arg2 ...any) *gomock.Call

+ func (mr *MockSeedPeerClientMockRecorder) SyncPieceTasks(arg0, arg1 any, arg2 ...any) *gomock.Call

+ func (mr *MockSeedPeerClientMockRecorder) SyncPieces(arg0, arg1 any, arg2 ...any) *gomock.Call

+ type MockSeedPeerMockRecorder struct

+ func (mr *MockSeedPeerMockRecorder) Client() *gomock.Call

+ func (mr *MockSeedPeerMockRecorder) Stop() *gomock.Call

+ func (mr *MockSeedPeerMockRecorder) TriggerDownloadTask(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockSeedPeerMockRecorder) TriggerTask(arg0, arg1, arg2 any) *gomock.Call

+ type MockTaskManager struct

+ func NewMockTaskManager(ctrl *gomock.Controller) *MockTaskManager

+ func (m *MockTaskManager) Delete(arg0 string)

+ func (m *MockTaskManager) EXPECT() *MockTaskManagerMockRecorder

+ func (m *MockTaskManager) Load(arg0 string) (*Task, bool)

+ func (m *MockTaskManager) LoadOrStore(arg0 *Task) (*Task, bool)

+ func (m *MockTaskManager) Range(f func(any, any) bool)

+ func (m *MockTaskManager) RunGC() error

+ func (m *MockTaskManager) Store(arg0 *Task)

+ type MockTaskManagerMockRecorder struct

+ func (mr *MockTaskManagerMockRecorder) Delete(arg0 any) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) Load(arg0 any) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) LoadOrStore(arg0 any) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) Range(f any) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) RunGC() *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) Store(arg0 any) *gomock.Call

+ type Network struct

+ DownloadRate uint64

+ DownloadRateLimit uint64

+ IDC string

+ Location string

+ TCPConnectionCount uint32

+ UploadRate uint64

+ UploadRateLimit uint64

+ UploadTCPConnectionCount uint32

+ type Option func(r *resource)

+ func WithTransportCredentials(creds credentials.TransportCredentials) Option

+ type Peer struct

+ AnnouncePeerStream *atomic.Value

+ BlockParents set.SafeSet[string]

+ Config *config.ResourceConfig

+ Cost *atomic.Duration

+ CreatedAt *atomic.Time

+ FSM *fsm.FSM

+ FinishedPieces *bitset.BitSet

+ Host *Host

+ ID string

+ Log *logger.SugaredLoggerOnWith

+ NeedBackToSource *atomic.Bool

+ PieceUpdatedAt *atomic.Time

+ Pieces *sync.Map

+ Priority commonv2.Priority

+ Range *nethttp.Range

+ ReportPieceResultStream *atomic.Value

+ Task *Task

+ UpdatedAt *atomic.Time

+ func NewPeer(id string, cfg *config.ResourceConfig, task *Task, host *Host, ...) *Peer

+ func (p *Peer) AppendPieceCost(duration time.Duration)

+ func (p *Peer) CalculatePriority(dynconfig config.DynconfigInterface) commonv2.Priority

+ func (p *Peer) Children() []*Peer

+ func (p *Peer) DeleteAnnouncePeerStream()

+ func (p *Peer) DeletePiece(key int32)

+ func (p *Peer) DeleteReportPieceResultStream()

+ func (p *Peer) DownloadTinyFile() ([]byte, error)

+ func (p *Peer) LoadAnnouncePeerStream() (schedulerv2.Scheduler_AnnouncePeerServer, bool)

+ func (p *Peer) LoadPiece(key int32) (*Piece, bool)

+ func (p *Peer) LoadReportPieceResultStream() (schedulerv1.Scheduler_ReportPieceResultServer, bool)

+ func (p *Peer) Parents() []*Peer

+ func (p *Peer) PieceCosts() []time.Duration

+ func (p *Peer) StoreAnnouncePeerStream(stream schedulerv2.Scheduler_AnnouncePeerServer)

+ func (p *Peer) StorePiece(piece *Piece)

+ func (p *Peer) StoreReportPieceResultStream(stream schedulerv1.Scheduler_ReportPieceResultServer)

+ type PeerManager interface

+ Delete func(string)

+ Load func(string) (*Peer, bool)

+ LoadOrStore func(*Peer) (*Peer, bool)

+ Range func(f func(any, any) bool)

+ RunGC func() error

+ Store func(*Peer)

+ type PeerOption func(peer *Peer)

+ func WithAnnouncePeerStream(stream schedulerv2.Scheduler_AnnouncePeerServer) PeerOption

+ func WithPriority(priority commonv2.Priority) PeerOption

+ func WithRange(rg nethttp.Range) PeerOption

+ type Piece struct

+ Cost time.Duration

+ CreatedAt time.Time

+ Digest *digest.Digest

+ Length uint64

+ Number int32

+ Offset uint64

+ ParentID string

+ TrafficType commonv2.TrafficType

+ type Resource interface

+ HostManager func() HostManager

+ PeerManager func() PeerManager

+ SeedPeer func() SeedPeer

+ Stop func() error

+ TaskManager func() TaskManager

+ func New(cfg *config.Config, gc gc.GC, dynconfig config.DynconfigInterface, ...) (Resource, error)

+ type SeedPeer interface

+ Client func() SeedPeerClient

+ Stop func() error

+ TriggerDownloadTask func(context.Context, string, *dfdaemonv2.DownloadTaskRequest) error

+ TriggerTask func(context.Context, *http.Range, *Task) (*Peer, *schedulerv1.PeerResult, error)

+ type SeedPeerClient interface

+ Addrs func() []string

+ type Task struct

+ Application string

+ BackToSourceLimit *atomic.Int32

+ BackToSourcePeers set.SafeSet[string]

+ ContentLength *atomic.Int64

+ CreatedAt *atomic.Time

+ DAG dag.DAG[*Peer]

+ Digest *digest.Digest

+ DirectPiece []byte

+ FSM *fsm.FSM

+ FilteredQueryParams []string

+ Header map[string]string

+ ID string

+ Log *logger.SugaredLoggerOnWith

+ PeerFailedCount *atomic.Int32

+ PieceLength int32

+ Pieces *sync.Map

+ Tag string

+ TotalPieceCount *atomic.Int32

+ Type commonv2.TaskType

+ URL string

+ UpdatedAt *atomic.Time

+ func NewTask(id, url, tag, application string, typ commonv2.TaskType, ...) *Task

+ func (t *Task) AddPeerEdge(fromPeer *Peer, toPeer *Peer) error

+ func (t *Task) CanAddPeerEdge(fromPeerKey, toPeerKey string) bool

+ func (t *Task) CanBackToSource() bool

+ func (t *Task) CanReuseDirectPiece() bool

+ func (t *Task) DeletePeer(key string)

+ func (t *Task) DeletePeerInEdges(key string) error

+ func (t *Task) DeletePeerOutEdges(key string) error

+ func (t *Task) DeletePiece(key int32)

+ func (t *Task) HasAvailablePeer(blocklist set.SafeSet[string]) bool

+ func (t *Task) IsSeedPeerFailed() bool

+ func (t *Task) LoadFinishedPeers() []*Peer

+ func (t *Task) LoadPeer(key string) (*Peer, bool)

+ func (t *Task) LoadPeers() []*Peer

+ func (t *Task) LoadPiece(key int32) (*Piece, bool)

+ func (t *Task) LoadRandomPeers(n uint) []*Peer

+ func (t *Task) LoadSeedPeer() (*Peer, bool)

+ func (t *Task) PeerCount() int

+ func (t *Task) PeerDegree(key string) (int, error)

+ func (t *Task) PeerInDegree(key string) (int, error)

+ func (t *Task) PeerOutDegree(key string) (int, error)

+ func (t *Task) ReportPieceResultToPeers(peerPacket *schedulerv1.PeerPacket, event string)

+ func (t *Task) SizeScope() commonv2.SizeScope

+ func (t *Task) StorePeer(peer *Peer)

+ func (t *Task) StorePiece(piece *Piece)

+ type TaskManager interface

+ Delete func(string)

+ Load func(string) (*Task, bool)

+ LoadOrStore func(*Task) (*Task, bool)

+ Range func(f func(any, any) bool)

+ RunGC func() error

+ Store func(*Task)

+ type TaskOption func(task *Task)

+ func WithDigest(d *digest.Digest) TaskOption

+ func WithPieceLength(pieceLength int32) TaskOption

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