persistentcache

package

Go to main page

Versions in this module

v2

v2.2.1-rc.2

Feb 26, 2025

v2.2.1-rc.1

Feb 18, 2025

v2.2.1-rc.0

Feb 11, 2025

v2.2.0

Dec 31, 2024

v2.1.67

Dec 23, 2024

v2.1.66

Dec 17, 2024

v2.1.65

Nov 29, 2024

v2.1.64

Nov 22, 2024

Changes in this version

+ const GCHostID

type Disk

+ ReadBandwidth uint64

+ WriteBandwidth uint64

type HostManager

+ RunGC func() error

+ type HostOption func(h *Host)

+ func WithConcurrentUploadLimit(limit int32) HostOption

type MockHostManager

+ func (m *MockHostManager) RunGC() error

type MockHostManagerMockRecorder

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

type MockPeerManager

+ func (m *MockPeerManager) DeleteAllByHostID(arg0 context.Context, arg1 string) error

+ func (m *MockPeerManager) LoadAllByHostID(arg0 context.Context, arg1 string) ([]*Peer, error)

type MockPeerManagerMockRecorder

+ func (mr *MockPeerManagerMockRecorder) DeleteAllByHostID(arg0, arg1 any) *gomock.Call

+ func (mr *MockPeerManagerMockRecorder) LoadAllByHostID(arg0, arg1 any) *gomock.Call

type MockTaskManager

+ func (m *MockTaskManager) LoadCorrentReplicaCount(arg0 context.Context, arg1 string) (int64, error)

+ func (m *MockTaskManager) LoadCurrentPersistentReplicaCount(arg0 context.Context, arg1 string) (int64, error)

type MockTaskManagerMockRecorder

+ func (mr *MockTaskManagerMockRecorder) LoadCorrentReplicaCount(arg0, arg1 any) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) LoadCurrentPersistentReplicaCount(arg0, arg1 any) *gomock.Call

type PeerManager

+ DeleteAllByHostID func(context.Context, string) error

+ LoadAllByHostID func(context.Context, string) ([]*Peer, error)

v2.1.63

Nov 11, 2024

Changes in this version

+ const PeerEventFailed

+ const PeerEventSucceeded

+ const PeerEventUpload

+ const PeerStateUploading

+ const TaskEventFailed

+ const TaskEventSucceeded

type MockPeerManager

+ func (m *MockPeerManager) DeleteAllByTaskID(arg0 context.Context, arg1 string) error

+ func (m *MockPeerManager) LoadAllByTaskID(arg0 context.Context, arg1 string) ([]*Peer, error)

type MockPeerManagerMockRecorder

+ func (mr *MockPeerManagerMockRecorder) DeleteAllByTaskID(arg0, arg1 any) *gomock.Call

+ func (mr *MockPeerManagerMockRecorder) LoadAllByTaskID(arg0, arg1 any) *gomock.Call

type PeerManager

+ DeleteAllByTaskID func(context.Context, string) error

+ LoadAllByTaskID func(context.Context, string) ([]*Peer, error)

type TaskManager

+ LoadCorrentReplicaCount func(context.Context, string) (int64, error)

+ LoadCurrentPersistentReplicaCount func(context.Context, string) (int64, error)

v2.1.62

Oct 28, 2024

Changes in this version

type Build

+ RustVersion string

+ type MockPeerManager struct

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

+ func (m *MockPeerManager) Delete(arg0 context.Context, arg1 string) error

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

+ func (m *MockPeerManager) Load(arg0 context.Context, arg1 string) (*Peer, bool)

+ func (m *MockPeerManager) LoadAll(arg0 context.Context) ([]*Peer, error)

+ func (m *MockPeerManager) Store(arg0 context.Context, arg1 *Peer) error

+ type MockPeerManagerMockRecorder struct

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

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

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

+ func (mr *MockPeerManagerMockRecorder) Store(arg0, arg1 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) TaskManager() TaskManager

+ type MockResourceMockRecorder struct

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

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

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

type Peer

+ Persistent bool

+ type PeerManager interface

+ Delete func(context.Context, string) error

+ Load func(context.Context, string) (*Peer, bool)

+ LoadAll func(context.Context) ([]*Peer, error)

+ Store func(context.Context, *Peer) error

+ type Resource interface

+ HostManager func() HostManager

+ PeerManager func() PeerManager

+ TaskManager func() TaskManager

+ func New(cfg *config.Config, rdb redis.UniversalClient) Resource

v2.1.61

Oct 17, 2024

Changes in this version

+ const PeerEventDownload

+ const PeerEventDownloadFailed

+ const PeerEventDownloadSucceeded

+ const PeerEventRegister

+ const PeerStateFailed

+ const PeerStatePending

+ const PeerStateReceived

+ const PeerStateRunning

+ const PeerStateSucceeded

+ type Peer struct

+ BlockParents []string

+ Cost time.Duration

+ CreatedAt time.Time

+ FSM *fsm.FSM

+ FinishedPieces *bitset.BitSet

+ Host *Host

+ ID string

+ Log *logger.SugaredLoggerOnWith

+ Task *Task

+ UpdatedAt time.Time

+ func NewPeer(id, state string, finishedPieces *bitset.BitSet, blockParents []string, ...) *Peer

v2.1.60

Oct 9, 2024

Changes in this version

+ const TaskEventUpload

+ const TaskEventUploadFailed

+ const TaskEventUploadSucceeded

+ const TaskStateFailed

+ const TaskStatePending

+ const TaskStateSucceeded

+ const TaskStateUploading

+ 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 int32

+ ConcurrentUploadLimit int32

+ CreatedAt time.Time

+ DisableShared bool

+ Disk Disk

+ DownloadPort int32

+ Hostname string

+ ID string

+ IP string

+ KernelVersion string

+ Log *logger.SugaredLoggerOnWith

+ Memory Memory

+ Network Network

+ OS string

+ Platform string

+ PlatformFamily string

+ PlatformVersion string

+ Port int32

+ Type types.HostType

+ UpdatedAt time.Time

+ UploadCount int64

+ UploadFailedCount int64

+ func NewHost(...) *Host

+ type HostManager interface

+ Delete func(context.Context, string)

+ Load func(context.Context, string) (*Host, bool)

+ LoadAll func(context.Context) ([]*Host, error)

+ Store func(context.Context, *Host)

+ 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 context.Context, arg1 string)

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

+ func (m *MockHostManager) Load(arg0 context.Context, arg1 string) (*Host, bool)

+ func (m *MockHostManager) LoadAll(arg0 context.Context) ([]*Host, error)

+ func (m *MockHostManager) Store(arg0 context.Context, arg1 *Host)

+ type MockHostManagerMockRecorder struct

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

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

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

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

+ type MockTaskManager struct

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

+ func (m *MockTaskManager) Delete(arg0 context.Context, arg1 string)

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

+ func (m *MockTaskManager) Load(arg0 context.Context, arg1 string) (*Task, bool)

+ func (m *MockTaskManager) LoadAll(arg0 context.Context) ([]*Task, error)

+ func (m *MockTaskManager) Store(arg0 context.Context, arg1 *Task) error

+ type MockTaskManagerMockRecorder struct

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

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

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

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

+ type Network struct

+ DownloadRate uint64

+ DownloadRateLimit uint64

+ IDC string

+ Location string

+ TCPConnectionCount uint32

+ UploadRate uint64

+ UploadRateLimit uint64

+ UploadTCPConnectionCount uint32

+ type Task struct

+ Application string

+ ContentLength int64

+ CreatedAt time.Time

+ Digest *digest.Digest

+ FSM *fsm.FSM

+ ID string

+ Log *logger.SugaredLoggerOnWith

+ PersistentReplicaCount uint64

+ PieceLength int32

+ ReplicaCount uint64

+ TTL time.Duration

+ Tag string

+ TotalPieceCount int32

+ UpdatedAt time.Time

+ func NewTask(id, tag, application, state string, persistentReplicaCount uint64, ...) *Task

+ type TaskManager interface

+ Delete func(context.Context, string)

+ Load func(context.Context, string) (*Task, bool)

+ LoadAll func(context.Context) ([]*Task, error)

+ Store func(context.Context, *Task) error

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