Versions in this module Expand all Collapse all v0 v0.1.3 May 15, 2024 Changes in this version + var File_pkg_apis_common_v2_common_proto protoreflect.FileDescriptor + var Priority_name = map[int32]string + var Priority_value = map[string]int32 + var SizeScope_name = map[int32]string + var SizeScope_value = map[string]int32 + var TaskType_name = map[int32]string + var TaskType_value = map[string]int32 + var TrafficType_name = map[int32]string + var TrafficType_value = map[string]int32 + type Build struct + GitCommit *string + GitVersion string + GoVersion *string + Platform *string + RustVersion *string + func (*Build) Descriptor() ([]byte, []int) + func (*Build) ProtoMessage() + func (m *Build) Validate() error + func (m *Build) ValidateAll() error + func (x *Build) GetGitCommit() string + func (x *Build) GetGitVersion() string + func (x *Build) GetGoVersion() string + func (x *Build) GetPlatform() string + func (x *Build) GetRustVersion() string + func (x *Build) ProtoReflect() protoreflect.Message + func (x *Build) Reset() + func (x *Build) String() string + type BuildMultiError []error + func (m BuildMultiError) AllErrors() []error + func (m BuildMultiError) Error() string + type BuildValidationError struct + func (e BuildValidationError) Cause() error + func (e BuildValidationError) Error() string + func (e BuildValidationError) ErrorName() string + func (e BuildValidationError) Field() string + func (e BuildValidationError) Key() bool + func (e BuildValidationError) Reason() string + type CPU struct + LogicalCount uint32 + Percent float64 + PhysicalCount uint32 + ProcessPercent float64 + Times *CPUTimes + func (*CPU) Descriptor() ([]byte, []int) + func (*CPU) ProtoMessage() + func (m *CPU) Validate() error + func (m *CPU) ValidateAll() error + func (x *CPU) GetLogicalCount() uint32 + func (x *CPU) GetPercent() float64 + func (x *CPU) GetPhysicalCount() uint32 + func (x *CPU) GetProcessPercent() float64 + func (x *CPU) GetTimes() *CPUTimes + func (x *CPU) ProtoReflect() protoreflect.Message + func (x *CPU) Reset() + func (x *CPU) String() string + type CPUMultiError []error + func (m CPUMultiError) AllErrors() []error + func (m CPUMultiError) Error() string + type CPUTimes struct + Guest float64 + GuestNice float64 + Idle float64 + Iowait float64 + Irq float64 + Nice float64 + Softirq float64 + Steal float64 + System float64 + User float64 + func (*CPUTimes) Descriptor() ([]byte, []int) + func (*CPUTimes) ProtoMessage() + func (m *CPUTimes) Validate() error + func (m *CPUTimes) ValidateAll() error + func (x *CPUTimes) GetGuest() float64 + func (x *CPUTimes) GetGuestNice() float64 + func (x *CPUTimes) GetIdle() float64 + func (x *CPUTimes) GetIowait() float64 + func (x *CPUTimes) GetIrq() float64 + func (x *CPUTimes) GetNice() float64 + func (x *CPUTimes) GetSoftirq() float64 + func (x *CPUTimes) GetSteal() float64 + func (x *CPUTimes) GetSystem() float64 + func (x *CPUTimes) GetUser() float64 + func (x *CPUTimes) ProtoReflect() protoreflect.Message + func (x *CPUTimes) Reset() + func (x *CPUTimes) String() string + type CPUTimesMultiError []error + func (m CPUTimesMultiError) AllErrors() []error + func (m CPUTimesMultiError) Error() string + type CPUTimesValidationError struct + func (e CPUTimesValidationError) Cause() error + func (e CPUTimesValidationError) Error() string + func (e CPUTimesValidationError) ErrorName() string + func (e CPUTimesValidationError) Field() string + func (e CPUTimesValidationError) Key() bool + func (e CPUTimesValidationError) Reason() string + type CPUValidationError struct + func (e CPUValidationError) Cause() error + func (e CPUValidationError) Error() string + func (e CPUValidationError) ErrorName() string + func (e CPUValidationError) Field() string + func (e CPUValidationError) Key() bool + func (e CPUValidationError) Reason() string + type Disk struct + Free uint64 + InodesFree uint64 + InodesTotal uint64 + InodesUsed uint64 + InodesUsedPercent float64 + Total uint64 + Used uint64 + UsedPercent float64 + func (*Disk) Descriptor() ([]byte, []int) + func (*Disk) ProtoMessage() + func (m *Disk) Validate() error + func (m *Disk) ValidateAll() error + func (x *Disk) GetFree() uint64 + func (x *Disk) GetInodesFree() uint64 + func (x *Disk) GetInodesTotal() uint64 + func (x *Disk) GetInodesUsed() uint64 + func (x *Disk) GetInodesUsedPercent() float64 + func (x *Disk) GetTotal() uint64 + func (x *Disk) GetUsed() uint64 + func (x *Disk) GetUsedPercent() float64 + func (x *Disk) ProtoReflect() protoreflect.Message + func (x *Disk) Reset() + func (x *Disk) String() string + type DiskMultiError []error + func (m DiskMultiError) AllErrors() []error + func (m DiskMultiError) Error() string + type DiskValidationError struct + func (e DiskValidationError) Cause() error + func (e DiskValidationError) Error() string + func (e DiskValidationError) ErrorName() string + func (e DiskValidationError) Field() string + func (e DiskValidationError) Key() bool + func (e DiskValidationError) Reason() string + type Download struct + Application string + Digest string + DownloadRateLimit float64 + Filters []string + Header map[string]string + NeedBackToSource bool + OutputPath string + PieceLength int32 + Priority Priority + Range *Range + Tag string + Timeout *durationpb.Duration + Type TaskType + Url string + func (*Download) Descriptor() ([]byte, []int) + func (*Download) ProtoMessage() + func (m *Download) Validate() error + func (m *Download) ValidateAll() error + func (x *Download) GetApplication() string + func (x *Download) GetDigest() string + func (x *Download) GetDownloadRateLimit() float64 + func (x *Download) GetFilters() []string + func (x *Download) GetHeader() map[string]string + func (x *Download) GetNeedBackToSource() bool + func (x *Download) GetOutputPath() string + func (x *Download) GetPieceLength() int32 + func (x *Download) GetPriority() Priority + func (x *Download) GetRange() *Range + func (x *Download) GetTag() string + func (x *Download) GetTimeout() *durationpb.Duration + func (x *Download) GetType() TaskType + func (x *Download) GetUrl() string + func (x *Download) ProtoReflect() protoreflect.Message + func (x *Download) Reset() + func (x *Download) String() string + type DownloadMultiError []error + func (m DownloadMultiError) AllErrors() []error + func (m DownloadMultiError) Error() string + type DownloadValidationError struct + func (e DownloadValidationError) Cause() error + func (e DownloadValidationError) Error() string + func (e DownloadValidationError) ErrorName() string + func (e DownloadValidationError) Field() string + func (e DownloadValidationError) Key() bool + func (e DownloadValidationError) Reason() string + type Host struct + Build *Build + Cpu *CPU + Disk *Disk + DownloadPort int32 + Hostname string + Id string + Ip string + KernelVersion string + Memory *Memory + Network *Network + Os string + Platform string + PlatformFamily string + PlatformVersion string + Port int32 + Type uint32 + func (*Host) Descriptor() ([]byte, []int) + func (*Host) ProtoMessage() + func (m *Host) Validate() error + func (m *Host) ValidateAll() error + func (x *Host) GetBuild() *Build + func (x *Host) GetCpu() *CPU + func (x *Host) GetDisk() *Disk + func (x *Host) GetDownloadPort() int32 + func (x *Host) GetHostname() string + func (x *Host) GetId() string + func (x *Host) GetIp() string + func (x *Host) GetKernelVersion() string + func (x *Host) GetMemory() *Memory + func (x *Host) GetNetwork() *Network + func (x *Host) GetOs() string + func (x *Host) GetPlatform() string + func (x *Host) GetPlatformFamily() string + func (x *Host) GetPlatformVersion() string + func (x *Host) GetPort() int32 + func (x *Host) GetType() uint32 + func (x *Host) ProtoReflect() protoreflect.Message + func (x *Host) Reset() + func (x *Host) String() string + type HostMultiError []error + func (m HostMultiError) AllErrors() []error + func (m HostMultiError) Error() string + type HostValidationError struct + func (e HostValidationError) Cause() error + func (e HostValidationError) Error() string + func (e HostValidationError) ErrorName() string + func (e HostValidationError) Field() string + func (e HostValidationError) Key() bool + func (e HostValidationError) Reason() string + type Memory struct + Available uint64 + Free uint64 + ProcessUsedPercent float64 + Total uint64 + Used uint64 + UsedPercent float64 + func (*Memory) Descriptor() ([]byte, []int) + func (*Memory) ProtoMessage() + func (m *Memory) Validate() error + func (m *Memory) ValidateAll() error + func (x *Memory) GetAvailable() uint64 + func (x *Memory) GetFree() uint64 + func (x *Memory) GetProcessUsedPercent() float64 + func (x *Memory) GetTotal() uint64 + func (x *Memory) GetUsed() uint64 + func (x *Memory) GetUsedPercent() float64 + func (x *Memory) ProtoReflect() protoreflect.Message + func (x *Memory) Reset() + func (x *Memory) String() string + type MemoryMultiError []error + func (m MemoryMultiError) AllErrors() []error + func (m MemoryMultiError) Error() string + type MemoryValidationError struct + func (e MemoryValidationError) Cause() error + func (e MemoryValidationError) Error() string + func (e MemoryValidationError) ErrorName() string + func (e MemoryValidationError) Field() string + func (e MemoryValidationError) Key() bool + func (e MemoryValidationError) Reason() string + type Network struct + Idc *string + Location *string + TcpConnectionCount uint32 + UploadTcpConnectionCount uint32 + func (*Network) Descriptor() ([]byte, []int) + func (*Network) ProtoMessage() + func (m *Network) Validate() error + func (m *Network) ValidateAll() error + func (x *Network) GetIdc() string + func (x *Network) GetLocation() string + func (x *Network) GetTcpConnectionCount() uint32 + func (x *Network) GetUploadTcpConnectionCount() uint32 + func (x *Network) ProtoReflect() protoreflect.Message + func (x *Network) Reset() + func (x *Network) String() string + type NetworkMultiError []error + func (m NetworkMultiError) AllErrors() []error + func (m NetworkMultiError) Error() string + type NetworkValidationError struct + func (e NetworkValidationError) Cause() error + func (e NetworkValidationError) Error() string + func (e NetworkValidationError) ErrorName() string + func (e NetworkValidationError) Field() string + func (e NetworkValidationError) Key() bool + func (e NetworkValidationError) Reason() string + type Peer struct + Cost *durationpb.Duration + CreatedAt *timestamppb.Timestamp + Host *Host + Id string + NeedBackToSource bool + Pieces []*Piece + Priority Priority + Range *Range + State string + Task *Task + UpdatedAt *timestamppb.Timestamp + func (*Peer) Descriptor() ([]byte, []int) + func (*Peer) ProtoMessage() + func (m *Peer) Validate() error + func (m *Peer) ValidateAll() error + func (x *Peer) GetCost() *durationpb.Duration + func (x *Peer) GetCreatedAt() *timestamppb.Timestamp + func (x *Peer) GetHost() *Host + func (x *Peer) GetId() string + func (x *Peer) GetNeedBackToSource() bool + func (x *Peer) GetPieces() []*Piece + func (x *Peer) GetPriority() Priority + func (x *Peer) GetRange() *Range + func (x *Peer) GetState() string + func (x *Peer) GetTask() *Task + func (x *Peer) GetUpdatedAt() *timestamppb.Timestamp + func (x *Peer) ProtoReflect() protoreflect.Message + func (x *Peer) Reset() + func (x *Peer) String() string + type PeerMultiError []error + func (m PeerMultiError) AllErrors() []error + func (m PeerMultiError) Error() string + type PeerValidationError struct + func (e PeerValidationError) Cause() error + func (e PeerValidationError) Error() string + func (e PeerValidationError) ErrorName() string + func (e PeerValidationError) Field() string + func (e PeerValidationError) Key() bool + func (e PeerValidationError) Reason() string + type Piece struct + Content []byte + Cost *durationpb.Duration + CreatedAt *timestamppb.Timestamp + Digest string + Length uint64 + Number int32 + Offset uint64 + ParentId string + TrafficType TrafficType + func (*Piece) Descriptor() ([]byte, []int) + func (*Piece) ProtoMessage() + func (m *Piece) Validate() error + func (m *Piece) ValidateAll() error + func (x *Piece) GetContent() []byte + func (x *Piece) GetCost() *durationpb.Duration + func (x *Piece) GetCreatedAt() *timestamppb.Timestamp + func (x *Piece) GetDigest() string + func (x *Piece) GetLength() uint64 + func (x *Piece) GetNumber() int32 + func (x *Piece) GetOffset() uint64 + func (x *Piece) GetParentId() string + func (x *Piece) GetTrafficType() TrafficType + func (x *Piece) ProtoReflect() protoreflect.Message + func (x *Piece) Reset() + func (x *Piece) String() string + type PieceMultiError []error + func (m PieceMultiError) AllErrors() []error + func (m PieceMultiError) Error() string + type PieceValidationError struct + func (e PieceValidationError) Cause() error + func (e PieceValidationError) Error() string + func (e PieceValidationError) ErrorName() string + func (e PieceValidationError) Field() string + func (e PieceValidationError) Key() bool + func (e PieceValidationError) Reason() string + type Priority int32 + const Priority_LEVEL0 + const Priority_LEVEL1 + const Priority_LEVEL2 + const Priority_LEVEL3 + const Priority_LEVEL4 + const Priority_LEVEL5 + const Priority_LEVEL6 + func (Priority) Descriptor() protoreflect.EnumDescriptor + func (Priority) EnumDescriptor() ([]byte, []int) + func (Priority) Type() protoreflect.EnumType + func (x Priority) Enum() *Priority + func (x Priority) Number() protoreflect.EnumNumber + func (x Priority) String() string + type Range struct + Length int64 + Start int64 + func (*Range) Descriptor() ([]byte, []int) + func (*Range) ProtoMessage() + func (m *Range) Validate() error + func (m *Range) ValidateAll() error + func (x *Range) GetLength() int64 + func (x *Range) GetStart() int64 + func (x *Range) ProtoReflect() protoreflect.Message + func (x *Range) Reset() + func (x *Range) String() string + type RangeMultiError []error + func (m RangeMultiError) AllErrors() []error + func (m RangeMultiError) Error() string + type RangeValidationError struct + func (e RangeValidationError) Cause() error + func (e RangeValidationError) Error() string + func (e RangeValidationError) ErrorName() string + func (e RangeValidationError) Field() string + func (e RangeValidationError) Key() bool + func (e RangeValidationError) Reason() string + type SizeScope int32 + const SizeScope_EMPTY + const SizeScope_NORMAL + const SizeScope_SMALL + const SizeScope_TINY + const SizeScope_UNKNOW + 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 Task struct + Application string + ContentLength int64 + CreatedAt *timestamppb.Timestamp + Digest string + Filters []string + HasAvailablePeer bool + Header map[string]string + Id string + PeerCount int32 + PieceCount int32 + PieceLength int32 + Pieces []*Piece + SizeScope SizeScope + State string + Tag string + Type TaskType + UpdatedAt *timestamppb.Timestamp + Url string + func (*Task) Descriptor() ([]byte, []int) + func (*Task) ProtoMessage() + func (m *Task) Validate() error + func (m *Task) ValidateAll() error + func (x *Task) GetApplication() string + func (x *Task) GetContentLength() int64 + func (x *Task) GetCreatedAt() *timestamppb.Timestamp + func (x *Task) GetDigest() string + func (x *Task) GetFilters() []string + func (x *Task) GetHasAvailablePeer() bool + func (x *Task) GetHeader() map[string]string + func (x *Task) GetId() string + func (x *Task) GetPeerCount() int32 + func (x *Task) GetPieceCount() int32 + func (x *Task) GetPieceLength() int32 + func (x *Task) GetPieces() []*Piece + func (x *Task) GetSizeScope() SizeScope + func (x *Task) GetState() string + func (x *Task) GetTag() string + func (x *Task) GetType() TaskType + func (x *Task) GetUpdatedAt() *timestamppb.Timestamp + func (x *Task) GetUrl() string + func (x *Task) ProtoReflect() protoreflect.Message + func (x *Task) Reset() + func (x *Task) String() string + type TaskMultiError []error + func (m TaskMultiError) AllErrors() []error + func (m TaskMultiError) Error() string + type TaskType int32 + const TaskType_DFCACHE + const TaskType_DFDAEMON + const TaskType_DFSTORE + 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 + type TaskValidationError struct + func (e TaskValidationError) Cause() error + func (e TaskValidationError) Error() string + func (e TaskValidationError) ErrorName() string + func (e TaskValidationError) Field() string + func (e TaskValidationError) Key() bool + func (e TaskValidationError) Reason() string + type TrafficType int32 + const TrafficType_BACK_TO_SOURCE + const TrafficType_LOCAL_PEER + const TrafficType_REMOTE_PEER + func (TrafficType) Descriptor() protoreflect.EnumDescriptor + func (TrafficType) EnumDescriptor() ([]byte, []int) + func (TrafficType) Type() protoreflect.EnumType + func (x TrafficType) Enum() *TrafficType + func (x TrafficType) Number() protoreflect.EnumNumber + func (x TrafficType) String() string