scheduler

package
v0.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 15, 2024 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_pkg_apis_scheduler_v1_scheduler_proto protoreflect.FileDescriptor
View Source
var Scheduler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "scheduler.Scheduler",
	HandlerType: (*SchedulerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterPeerTask",
			Handler:    _Scheduler_RegisterPeerTask_Handler,
		},
		{
			MethodName: "ReportPeerResult",
			Handler:    _Scheduler_ReportPeerResult_Handler,
		},
		{
			MethodName: "AnnounceTask",
			Handler:    _Scheduler_AnnounceTask_Handler,
		},
		{
			MethodName: "StatTask",
			Handler:    _Scheduler_StatTask_Handler,
		},
		{
			MethodName: "LeaveTask",
			Handler:    _Scheduler_LeaveTask_Handler,
		},
		{
			MethodName: "AnnounceHost",
			Handler:    _Scheduler_AnnounceHost_Handler,
		},
		{
			MethodName: "LeaveHost",
			Handler:    _Scheduler_LeaveHost_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ReportPieceResult",
			Handler:       _Scheduler_ReportPieceResult_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SyncProbes",
			Handler:       _Scheduler_SyncProbes_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/apis/scheduler/v1/scheduler.proto",
}

Scheduler_ServiceDesc is the grpc.ServiceDesc for Scheduler service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterSchedulerServer

func RegisterSchedulerServer(s grpc.ServiceRegistrar, srv SchedulerServer)

Types

type AnnounceHostRequest

type AnnounceHostRequest struct {

	// Host id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Host type.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Hostname.
	Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Host ip.
	Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"`
	// Port of grpc service.
	Port int32 `protobuf:"varint,5,opt,name=port,proto3" json:"port,omitempty"`
	// Port of download server.
	DownloadPort int32 `protobuf:"varint,6,opt,name=download_port,json=downloadPort,proto3" json:"download_port,omitempty"`
	// Host OS.
	Os string `protobuf:"bytes,7,opt,name=os,proto3" json:"os,omitempty"`
	// Host platform.
	Platform string `protobuf:"bytes,8,opt,name=platform,proto3" json:"platform,omitempty"`
	// Host platform family.
	PlatformFamily string `protobuf:"bytes,9,opt,name=platform_family,json=platformFamily,proto3" json:"platform_family,omitempty"`
	// Host platform version.
	PlatformVersion string `protobuf:"bytes,10,opt,name=platform_version,json=platformVersion,proto3" json:"platform_version,omitempty"`
	// Host kernel version.
	KernelVersion string `protobuf:"bytes,11,opt,name=kernel_version,json=kernelVersion,proto3" json:"kernel_version,omitempty"`
	// CPU Stat.
	Cpu *CPU `protobuf:"bytes,12,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// Memory Stat.
	Memory *Memory `protobuf:"bytes,13,opt,name=memory,proto3" json:"memory,omitempty"`
	// Network Stat.
	Network *Network `protobuf:"bytes,14,opt,name=network,proto3" json:"network,omitempty"`
	// Disk Stat.
	Disk *Disk `protobuf:"bytes,15,opt,name=disk,proto3" json:"disk,omitempty"`
	// Build information.
	Build *Build `protobuf:"bytes,16,opt,name=build,proto3" json:"build,omitempty"`
	// contains filtered or unexported fields
}

AnnounceHostRequest represents request of AnnounceHost.

func (*AnnounceHostRequest) Descriptor deprecated

func (*AnnounceHostRequest) Descriptor() ([]byte, []int)

Deprecated: Use AnnounceHostRequest.ProtoReflect.Descriptor instead.

func (*AnnounceHostRequest) GetBuild

func (x *AnnounceHostRequest) GetBuild() *Build

func (*AnnounceHostRequest) GetCpu

func (x *AnnounceHostRequest) GetCpu() *CPU

func (*AnnounceHostRequest) GetDisk

func (x *AnnounceHostRequest) GetDisk() *Disk

func (*AnnounceHostRequest) GetDownloadPort

func (x *AnnounceHostRequest) GetDownloadPort() int32

func (*AnnounceHostRequest) GetHostname

func (x *AnnounceHostRequest) GetHostname() string

func (*AnnounceHostRequest) GetId

func (x *AnnounceHostRequest) GetId() string

func (*AnnounceHostRequest) GetIp

func (x *AnnounceHostRequest) GetIp() string

func (*AnnounceHostRequest) GetKernelVersion

func (x *AnnounceHostRequest) GetKernelVersion() string

func (*AnnounceHostRequest) GetMemory

func (x *AnnounceHostRequest) GetMemory() *Memory

func (*AnnounceHostRequest) GetNetwork

func (x *AnnounceHostRequest) GetNetwork() *Network

func (*AnnounceHostRequest) GetOs

func (x *AnnounceHostRequest) GetOs() string

func (*AnnounceHostRequest) GetPlatform

func (x *AnnounceHostRequest) GetPlatform() string

func (*AnnounceHostRequest) GetPlatformFamily

func (x *AnnounceHostRequest) GetPlatformFamily() string

func (*AnnounceHostRequest) GetPlatformVersion

func (x *AnnounceHostRequest) GetPlatformVersion() string

func (*AnnounceHostRequest) GetPort

func (x *AnnounceHostRequest) GetPort() int32

func (*AnnounceHostRequest) GetType

func (x *AnnounceHostRequest) GetType() string

func (*AnnounceHostRequest) ProtoMessage

func (*AnnounceHostRequest) ProtoMessage()

func (*AnnounceHostRequest) ProtoReflect

func (x *AnnounceHostRequest) ProtoReflect() protoreflect.Message

func (*AnnounceHostRequest) Reset

func (x *AnnounceHostRequest) Reset()

func (*AnnounceHostRequest) String

func (x *AnnounceHostRequest) String() string

func (*AnnounceHostRequest) Validate

func (m *AnnounceHostRequest) Validate() error

Validate checks the field values on AnnounceHostRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AnnounceHostRequest) ValidateAll

func (m *AnnounceHostRequest) ValidateAll() error

ValidateAll checks the field values on AnnounceHostRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AnnounceHostRequestMultiError, or nil if none found.

type AnnounceHostRequestMultiError

type AnnounceHostRequestMultiError []error

AnnounceHostRequestMultiError is an error wrapping multiple validation errors returned by AnnounceHostRequest.ValidateAll() if the designated constraints aren't met.

func (AnnounceHostRequestMultiError) AllErrors

func (m AnnounceHostRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnounceHostRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type AnnounceHostRequestValidationError

type AnnounceHostRequestValidationError struct {
	// contains filtered or unexported fields
}

AnnounceHostRequestValidationError is the validation error returned by AnnounceHostRequest.Validate if the designated constraints aren't met.

func (AnnounceHostRequestValidationError) Cause

Cause function returns cause value.

func (AnnounceHostRequestValidationError) Error

Error satisfies the builtin error interface

func (AnnounceHostRequestValidationError) ErrorName

ErrorName returns error name.

func (AnnounceHostRequestValidationError) Field

Field function returns field value.

func (AnnounceHostRequestValidationError) Key

Key function returns key value.

func (AnnounceHostRequestValidationError) Reason

Reason function returns reason value.

type AnnounceTaskRequest

type AnnounceTaskRequest struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Download url.
	Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// URL meta info.
	UrlMeta *v1.UrlMeta `protobuf:"bytes,3,opt,name=url_meta,json=urlMeta,proto3" json:"url_meta,omitempty"`
	// Peer host info.
	PeerHost *PeerHost `protobuf:"bytes,4,opt,name=peer_host,json=peerHost,proto3" json:"peer_host,omitempty"`
	// Task piece info.
	PiecePacket *v1.PiecePacket `protobuf:"bytes,5,opt,name=piece_packet,json=piecePacket,proto3" json:"piece_packet,omitempty"`
	// Task type.
	TaskType v1.TaskType `protobuf:"varint,6,opt,name=task_type,json=taskType,proto3,enum=common.TaskType" json:"task_type,omitempty"`
	// contains filtered or unexported fields
}

AnnounceTaskRequest represents request of AnnounceTask.

func (*AnnounceTaskRequest) Descriptor deprecated

func (*AnnounceTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use AnnounceTaskRequest.ProtoReflect.Descriptor instead.

func (*AnnounceTaskRequest) GetPeerHost

func (x *AnnounceTaskRequest) GetPeerHost() *PeerHost

func (*AnnounceTaskRequest) GetPiecePacket

func (x *AnnounceTaskRequest) GetPiecePacket() *v1.PiecePacket

func (*AnnounceTaskRequest) GetTaskId

func (x *AnnounceTaskRequest) GetTaskId() string

func (*AnnounceTaskRequest) GetTaskType

func (x *AnnounceTaskRequest) GetTaskType() v1.TaskType

func (*AnnounceTaskRequest) GetUrl

func (x *AnnounceTaskRequest) GetUrl() string

func (*AnnounceTaskRequest) GetUrlMeta

func (x *AnnounceTaskRequest) GetUrlMeta() *v1.UrlMeta

func (*AnnounceTaskRequest) ProtoMessage

func (*AnnounceTaskRequest) ProtoMessage()

func (*AnnounceTaskRequest) ProtoReflect

func (x *AnnounceTaskRequest) ProtoReflect() protoreflect.Message

func (*AnnounceTaskRequest) Reset

func (x *AnnounceTaskRequest) Reset()

func (*AnnounceTaskRequest) String

func (x *AnnounceTaskRequest) String() string

func (*AnnounceTaskRequest) Validate

func (m *AnnounceTaskRequest) Validate() error

Validate checks the field values on AnnounceTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AnnounceTaskRequest) ValidateAll

func (m *AnnounceTaskRequest) ValidateAll() error

ValidateAll checks the field values on AnnounceTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AnnounceTaskRequestMultiError, or nil if none found.

type AnnounceTaskRequestMultiError

type AnnounceTaskRequestMultiError []error

AnnounceTaskRequestMultiError is an error wrapping multiple validation errors returned by AnnounceTaskRequest.ValidateAll() if the designated constraints aren't met.

func (AnnounceTaskRequestMultiError) AllErrors

func (m AnnounceTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnounceTaskRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type AnnounceTaskRequestValidationError

type AnnounceTaskRequestValidationError struct {
	// contains filtered or unexported fields
}

AnnounceTaskRequestValidationError is the validation error returned by AnnounceTaskRequest.Validate if the designated constraints aren't met.

func (AnnounceTaskRequestValidationError) Cause

Cause function returns cause value.

func (AnnounceTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (AnnounceTaskRequestValidationError) ErrorName

ErrorName returns error name.

func (AnnounceTaskRequestValidationError) Field

Field function returns field value.

func (AnnounceTaskRequestValidationError) Key

Key function returns key value.

func (AnnounceTaskRequestValidationError) Reason

Reason function returns reason value.

type Build

type Build struct {

	// Git version.
	GitVersion string `protobuf:"bytes,1,opt,name=git_version,json=gitVersion,proto3" json:"git_version,omitempty"`
	// Git commit.
	GitCommit string `protobuf:"bytes,2,opt,name=git_commit,json=gitCommit,proto3" json:"git_commit,omitempty"`
	// Golang version.
	GoVersion string `protobuf:"bytes,3,opt,name=go_version,json=goVersion,proto3" json:"go_version,omitempty"`
	// Build platform.
	Platform string `protobuf:"bytes,4,opt,name=platform,proto3" json:"platform,omitempty"`
	// contains filtered or unexported fields
}

Build information.

func (*Build) Descriptor deprecated

func (*Build) Descriptor() ([]byte, []int)

Deprecated: Use Build.ProtoReflect.Descriptor instead.

func (*Build) GetGitCommit

func (x *Build) GetGitCommit() string

func (*Build) GetGitVersion

func (x *Build) GetGitVersion() string

func (*Build) GetGoVersion

func (x *Build) GetGoVersion() string

func (*Build) GetPlatform

func (x *Build) GetPlatform() string

func (*Build) ProtoMessage

func (*Build) ProtoMessage()

func (*Build) ProtoReflect

func (x *Build) ProtoReflect() protoreflect.Message

func (*Build) Reset

func (x *Build) Reset()

func (*Build) String

func (x *Build) String() string

func (*Build) Validate

func (m *Build) Validate() error

Validate checks the field values on Build with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Build) ValidateAll

func (m *Build) ValidateAll() error

ValidateAll checks the field values on Build with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in BuildMultiError, or nil if none found.

type BuildMultiError

type BuildMultiError []error

BuildMultiError is an error wrapping multiple validation errors returned by Build.ValidateAll() if the designated constraints aren't met.

func (BuildMultiError) AllErrors

func (m BuildMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (BuildMultiError) Error

func (m BuildMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type BuildValidationError

type BuildValidationError struct {
	// contains filtered or unexported fields
}

BuildValidationError is the validation error returned by Build.Validate if the designated constraints aren't met.

func (BuildValidationError) Cause

func (e BuildValidationError) Cause() error

Cause function returns cause value.

func (BuildValidationError) Error

func (e BuildValidationError) Error() string

Error satisfies the builtin error interface

func (BuildValidationError) ErrorName

func (e BuildValidationError) ErrorName() string

ErrorName returns error name.

func (BuildValidationError) Field

func (e BuildValidationError) Field() string

Field function returns field value.

func (BuildValidationError) Key

func (e BuildValidationError) Key() bool

Key function returns key value.

func (BuildValidationError) Reason

func (e BuildValidationError) Reason() string

Reason function returns reason value.

type CPU

type CPU struct {

	// Number of logical cores in the system.
	LogicalCount uint32 `protobuf:"varint,1,opt,name=logical_count,json=logicalCount,proto3" json:"logical_count,omitempty"`
	// Number of physical cores in the system
	PhysicalCount uint32 `protobuf:"varint,2,opt,name=physical_count,json=physicalCount,proto3" json:"physical_count,omitempty"`
	// Percent calculates the percentage of cpu used.
	Percent float64 `protobuf:"fixed64,3,opt,name=percent,proto3" json:"percent,omitempty"`
	// Calculates the percentage of cpu used by process.
	ProcessPercent float64 `protobuf:"fixed64,4,opt,name=process_percent,json=processPercent,proto3" json:"process_percent,omitempty"`
	// CPUTimes contains the amounts of time the CPU has spent performing different kinds of work.
	Times *CPUTimes `protobuf:"bytes,5,opt,name=times,proto3" json:"times,omitempty"`
	// contains filtered or unexported fields
}

CPU Stat.

func (*CPU) Descriptor deprecated

func (*CPU) Descriptor() ([]byte, []int)

Deprecated: Use CPU.ProtoReflect.Descriptor instead.

func (*CPU) GetLogicalCount

func (x *CPU) GetLogicalCount() uint32

func (*CPU) GetPercent

func (x *CPU) GetPercent() float64

func (*CPU) GetPhysicalCount

func (x *CPU) GetPhysicalCount() uint32

func (*CPU) GetProcessPercent

func (x *CPU) GetProcessPercent() float64

func (*CPU) GetTimes

func (x *CPU) GetTimes() *CPUTimes

func (*CPU) ProtoMessage

func (*CPU) ProtoMessage()

func (*CPU) ProtoReflect

func (x *CPU) ProtoReflect() protoreflect.Message

func (*CPU) Reset

func (x *CPU) Reset()

func (*CPU) String

func (x *CPU) String() string

func (*CPU) Validate

func (m *CPU) Validate() error

Validate checks the field values on CPU with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CPU) ValidateAll

func (m *CPU) ValidateAll() error

ValidateAll checks the field values on CPU with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CPUMultiError, or nil if none found.

type CPUMultiError

type CPUMultiError []error

CPUMultiError is an error wrapping multiple validation errors returned by CPU.ValidateAll() if the designated constraints aren't met.

func (CPUMultiError) AllErrors

func (m CPUMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CPUMultiError) Error

func (m CPUMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CPUTimes

type CPUTimes struct {

	// CPU time of user.
	User float64 `protobuf:"fixed64,1,opt,name=user,proto3" json:"user,omitempty"`
	// CPU time of system.
	System float64 `protobuf:"fixed64,2,opt,name=system,proto3" json:"system,omitempty"`
	// CPU time of idle.
	Idle float64 `protobuf:"fixed64,3,opt,name=idle,proto3" json:"idle,omitempty"`
	// CPU time of nice.
	Nice float64 `protobuf:"fixed64,4,opt,name=nice,proto3" json:"nice,omitempty"`
	// CPU time of iowait.
	Iowait float64 `protobuf:"fixed64,5,opt,name=iowait,proto3" json:"iowait,omitempty"`
	// CPU time of irq.
	Irq float64 `protobuf:"fixed64,6,opt,name=irq,proto3" json:"irq,omitempty"`
	// CPU time of softirq.
	Softirq float64 `protobuf:"fixed64,7,opt,name=softirq,proto3" json:"softirq,omitempty"`
	// CPU time of steal.
	Steal float64 `protobuf:"fixed64,8,opt,name=steal,proto3" json:"steal,omitempty"`
	// CPU time of guest.
	Guest float64 `protobuf:"fixed64,9,opt,name=guest,proto3" json:"guest,omitempty"`
	// CPU time of guest nice.
	GuestNice float64 `protobuf:"fixed64,10,opt,name=guest_nice,json=guestNice,proto3" json:"guest_nice,omitempty"`
	// contains filtered or unexported fields
}

CPUTimes contains the amounts of time the CPU has spent performing different kinds of work. Time units are in seconds.

func (*CPUTimes) Descriptor deprecated

func (*CPUTimes) Descriptor() ([]byte, []int)

Deprecated: Use CPUTimes.ProtoReflect.Descriptor instead.

func (*CPUTimes) GetGuest

func (x *CPUTimes) GetGuest() float64

func (*CPUTimes) GetGuestNice

func (x *CPUTimes) GetGuestNice() float64

func (*CPUTimes) GetIdle

func (x *CPUTimes) GetIdle() float64

func (*CPUTimes) GetIowait

func (x *CPUTimes) GetIowait() float64

func (*CPUTimes) GetIrq

func (x *CPUTimes) GetIrq() float64

func (*CPUTimes) GetNice

func (x *CPUTimes) GetNice() float64

func (*CPUTimes) GetSoftirq

func (x *CPUTimes) GetSoftirq() float64

func (*CPUTimes) GetSteal

func (x *CPUTimes) GetSteal() float64

func (*CPUTimes) GetSystem

func (x *CPUTimes) GetSystem() float64

func (*CPUTimes) GetUser

func (x *CPUTimes) GetUser() float64

func (*CPUTimes) ProtoMessage

func (*CPUTimes) ProtoMessage()

func (*CPUTimes) ProtoReflect

func (x *CPUTimes) ProtoReflect() protoreflect.Message

func (*CPUTimes) Reset

func (x *CPUTimes) Reset()

func (*CPUTimes) String

func (x *CPUTimes) String() string

func (*CPUTimes) Validate

func (m *CPUTimes) Validate() error

Validate checks the field values on CPUTimes with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CPUTimes) ValidateAll

func (m *CPUTimes) ValidateAll() error

ValidateAll checks the field values on CPUTimes with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CPUTimesMultiError, or nil if none found.

type CPUTimesMultiError

type CPUTimesMultiError []error

CPUTimesMultiError is an error wrapping multiple validation errors returned by CPUTimes.ValidateAll() if the designated constraints aren't met.

func (CPUTimesMultiError) AllErrors

func (m CPUTimesMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CPUTimesMultiError) Error

func (m CPUTimesMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CPUTimesValidationError

type CPUTimesValidationError struct {
	// contains filtered or unexported fields
}

CPUTimesValidationError is the validation error returned by CPUTimes.Validate if the designated constraints aren't met.

func (CPUTimesValidationError) Cause

func (e CPUTimesValidationError) Cause() error

Cause function returns cause value.

func (CPUTimesValidationError) Error

func (e CPUTimesValidationError) Error() string

Error satisfies the builtin error interface

func (CPUTimesValidationError) ErrorName

func (e CPUTimesValidationError) ErrorName() string

ErrorName returns error name.

func (CPUTimesValidationError) Field

func (e CPUTimesValidationError) Field() string

Field function returns field value.

func (CPUTimesValidationError) Key

func (e CPUTimesValidationError) Key() bool

Key function returns key value.

func (CPUTimesValidationError) Reason

func (e CPUTimesValidationError) Reason() string

Reason function returns reason value.

type CPUValidationError

type CPUValidationError struct {
	// contains filtered or unexported fields
}

CPUValidationError is the validation error returned by CPU.Validate if the designated constraints aren't met.

func (CPUValidationError) Cause

func (e CPUValidationError) Cause() error

Cause function returns cause value.

func (CPUValidationError) Error

func (e CPUValidationError) Error() string

Error satisfies the builtin error interface

func (CPUValidationError) ErrorName

func (e CPUValidationError) ErrorName() string

ErrorName returns error name.

func (CPUValidationError) Field

func (e CPUValidationError) Field() string

Field function returns field value.

func (CPUValidationError) Key

func (e CPUValidationError) Key() bool

Key function returns key value.

func (CPUValidationError) Reason

func (e CPUValidationError) Reason() string

Reason function returns reason value.

type Disk

type Disk struct {

	// Total amount of disk on the data path of dragonfly.
	Total uint64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	// Free amount of disk on the data path of dragonfly.
	Free uint64 `protobuf:"varint,2,opt,name=free,proto3" json:"free,omitempty"`
	// Used amount of disk on the data path of dragonfly.
	Used uint64 `protobuf:"varint,3,opt,name=used,proto3" json:"used,omitempty"`
	// Used percent of disk on the data path of dragonfly directory.
	UsedPercent float64 `protobuf:"fixed64,4,opt,name=used_percent,json=usedPercent,proto3" json:"used_percent,omitempty"`
	// Total amount of indoes on the data path of dragonfly directory.
	InodesTotal uint64 `protobuf:"varint,5,opt,name=inodes_total,json=inodesTotal,proto3" json:"inodes_total,omitempty"`
	// Used amount of indoes on the data path of dragonfly directory.
	InodesUsed uint64 `protobuf:"varint,6,opt,name=inodes_used,json=inodesUsed,proto3" json:"inodes_used,omitempty"`
	// Free amount of indoes on the data path of dragonfly directory.
	InodesFree uint64 `protobuf:"varint,7,opt,name=inodes_free,json=inodesFree,proto3" json:"inodes_free,omitempty"`
	// Used percent of indoes on the data path of dragonfly directory.
	InodesUsedPercent float64 `protobuf:"fixed64,8,opt,name=inodes_used_percent,json=inodesUsedPercent,proto3" json:"inodes_used_percent,omitempty"`
	// contains filtered or unexported fields
}

Disk Stat.

func (*Disk) Descriptor deprecated

func (*Disk) Descriptor() ([]byte, []int)

Deprecated: Use Disk.ProtoReflect.Descriptor instead.

func (*Disk) GetFree

func (x *Disk) GetFree() uint64

func (*Disk) GetInodesFree

func (x *Disk) GetInodesFree() uint64

func (*Disk) GetInodesTotal

func (x *Disk) GetInodesTotal() uint64

func (*Disk) GetInodesUsed

func (x *Disk) GetInodesUsed() uint64

func (*Disk) GetInodesUsedPercent

func (x *Disk) GetInodesUsedPercent() float64

func (*Disk) GetTotal

func (x *Disk) GetTotal() uint64

func (*Disk) GetUsed

func (x *Disk) GetUsed() uint64

func (*Disk) GetUsedPercent

func (x *Disk) GetUsedPercent() float64

func (*Disk) ProtoMessage

func (*Disk) ProtoMessage()

func (*Disk) ProtoReflect

func (x *Disk) ProtoReflect() protoreflect.Message

func (*Disk) Reset

func (x *Disk) Reset()

func (*Disk) String

func (x *Disk) String() string

func (*Disk) Validate

func (m *Disk) Validate() error

Validate checks the field values on Disk with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Disk) ValidateAll

func (m *Disk) ValidateAll() error

ValidateAll checks the field values on Disk with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DiskMultiError, or nil if none found.

type DiskMultiError

type DiskMultiError []error

DiskMultiError is an error wrapping multiple validation errors returned by Disk.ValidateAll() if the designated constraints aren't met.

func (DiskMultiError) AllErrors

func (m DiskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DiskMultiError) Error

func (m DiskMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type DiskValidationError

type DiskValidationError struct {
	// contains filtered or unexported fields
}

DiskValidationError is the validation error returned by Disk.Validate if the designated constraints aren't met.

func (DiskValidationError) Cause

func (e DiskValidationError) Cause() error

Cause function returns cause value.

func (DiskValidationError) Error

func (e DiskValidationError) Error() string

Error satisfies the builtin error interface

func (DiskValidationError) ErrorName

func (e DiskValidationError) ErrorName() string

ErrorName returns error name.

func (DiskValidationError) Field

func (e DiskValidationError) Field() string

Field function returns field value.

func (DiskValidationError) Key

func (e DiskValidationError) Key() bool

Key function returns key value.

func (DiskValidationError) Reason

func (e DiskValidationError) Reason() string

Reason function returns reason value.

type FailedProbe

type FailedProbe struct {

	// Destination host metadata.
	Host *v1.Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// The description of probing failed.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

FailedProbe information.

func (*FailedProbe) Descriptor deprecated

func (*FailedProbe) Descriptor() ([]byte, []int)

Deprecated: Use FailedProbe.ProtoReflect.Descriptor instead.

func (*FailedProbe) GetDescription

func (x *FailedProbe) GetDescription() string

func (*FailedProbe) GetHost

func (x *FailedProbe) GetHost() *v1.Host

func (*FailedProbe) ProtoMessage

func (*FailedProbe) ProtoMessage()

func (*FailedProbe) ProtoReflect

func (x *FailedProbe) ProtoReflect() protoreflect.Message

func (*FailedProbe) Reset

func (x *FailedProbe) Reset()

func (*FailedProbe) String

func (x *FailedProbe) String() string

func (*FailedProbe) Validate

func (m *FailedProbe) Validate() error

Validate checks the field values on FailedProbe with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*FailedProbe) ValidateAll

func (m *FailedProbe) ValidateAll() error

ValidateAll checks the field values on FailedProbe with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in FailedProbeMultiError, or nil if none found.

type FailedProbeMultiError

type FailedProbeMultiError []error

FailedProbeMultiError is an error wrapping multiple validation errors returned by FailedProbe.ValidateAll() if the designated constraints aren't met.

func (FailedProbeMultiError) AllErrors

func (m FailedProbeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (FailedProbeMultiError) Error

func (m FailedProbeMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type FailedProbeValidationError

type FailedProbeValidationError struct {
	// contains filtered or unexported fields
}

FailedProbeValidationError is the validation error returned by FailedProbe.Validate if the designated constraints aren't met.

func (FailedProbeValidationError) Cause

Cause function returns cause value.

func (FailedProbeValidationError) Error

Error satisfies the builtin error interface

func (FailedProbeValidationError) ErrorName

func (e FailedProbeValidationError) ErrorName() string

ErrorName returns error name.

func (FailedProbeValidationError) Field

Field function returns field value.

func (FailedProbeValidationError) Key

Key function returns key value.

func (FailedProbeValidationError) Reason

Reason function returns reason value.

type LeaveHostRequest

type LeaveHostRequest struct {

	// Host id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

LeaveHostRequest represents request of LeaveHost.

func (*LeaveHostRequest) Descriptor deprecated

func (*LeaveHostRequest) Descriptor() ([]byte, []int)

Deprecated: Use LeaveHostRequest.ProtoReflect.Descriptor instead.

func (*LeaveHostRequest) GetId

func (x *LeaveHostRequest) GetId() string

func (*LeaveHostRequest) ProtoMessage

func (*LeaveHostRequest) ProtoMessage()

func (*LeaveHostRequest) ProtoReflect

func (x *LeaveHostRequest) ProtoReflect() protoreflect.Message

func (*LeaveHostRequest) Reset

func (x *LeaveHostRequest) Reset()

func (*LeaveHostRequest) String

func (x *LeaveHostRequest) String() string

func (*LeaveHostRequest) Validate

func (m *LeaveHostRequest) Validate() error

Validate checks the field values on LeaveHostRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LeaveHostRequest) ValidateAll

func (m *LeaveHostRequest) ValidateAll() error

ValidateAll checks the field values on LeaveHostRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LeaveHostRequestMultiError, or nil if none found.

type LeaveHostRequestMultiError

type LeaveHostRequestMultiError []error

LeaveHostRequestMultiError is an error wrapping multiple validation errors returned by LeaveHostRequest.ValidateAll() if the designated constraints aren't met.

func (LeaveHostRequestMultiError) AllErrors

func (m LeaveHostRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LeaveHostRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type LeaveHostRequestValidationError

type LeaveHostRequestValidationError struct {
	// contains filtered or unexported fields
}

LeaveHostRequestValidationError is the validation error returned by LeaveHostRequest.Validate if the designated constraints aren't met.

func (LeaveHostRequestValidationError) Cause

Cause function returns cause value.

func (LeaveHostRequestValidationError) Error

Error satisfies the builtin error interface

func (LeaveHostRequestValidationError) ErrorName

ErrorName returns error name.

func (LeaveHostRequestValidationError) Field

Field function returns field value.

func (LeaveHostRequestValidationError) Key

Key function returns key value.

func (LeaveHostRequestValidationError) Reason

Reason function returns reason value.

type Memory

type Memory struct {

	// Total amount of RAM on this system.
	Total uint64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	// RAM available for programs to allocate.
	Available uint64 `protobuf:"varint,2,opt,name=available,proto3" json:"available,omitempty"`
	// RAM used by programs.
	Used uint64 `protobuf:"varint,3,opt,name=used,proto3" json:"used,omitempty"`
	// Percentage of RAM used by programs.
	UsedPercent float64 `protobuf:"fixed64,4,opt,name=used_percent,json=usedPercent,proto3" json:"used_percent,omitempty"`
	// Calculates the percentage of memory used by process.
	ProcessUsedPercent float64 `protobuf:"fixed64,5,opt,name=process_used_percent,json=processUsedPercent,proto3" json:"process_used_percent,omitempty"`
	// This is the kernel's notion of free memory.
	Free uint64 `protobuf:"varint,6,opt,name=free,proto3" json:"free,omitempty"`
	// contains filtered or unexported fields
}

Memory Stat.

func (*Memory) Descriptor deprecated

func (*Memory) Descriptor() ([]byte, []int)

Deprecated: Use Memory.ProtoReflect.Descriptor instead.

func (*Memory) GetAvailable

func (x *Memory) GetAvailable() uint64

func (*Memory) GetFree

func (x *Memory) GetFree() uint64

func (*Memory) GetProcessUsedPercent

func (x *Memory) GetProcessUsedPercent() float64

func (*Memory) GetTotal

func (x *Memory) GetTotal() uint64

func (*Memory) GetUsed

func (x *Memory) GetUsed() uint64

func (*Memory) GetUsedPercent

func (x *Memory) GetUsedPercent() float64

func (*Memory) ProtoMessage

func (*Memory) ProtoMessage()

func (*Memory) ProtoReflect

func (x *Memory) ProtoReflect() protoreflect.Message

func (*Memory) Reset

func (x *Memory) Reset()

func (*Memory) String

func (x *Memory) String() string

func (*Memory) Validate

func (m *Memory) Validate() error

Validate checks the field values on Memory with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Memory) ValidateAll

func (m *Memory) ValidateAll() error

ValidateAll checks the field values on Memory with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in MemoryMultiError, or nil if none found.

type MemoryMultiError

type MemoryMultiError []error

MemoryMultiError is an error wrapping multiple validation errors returned by Memory.ValidateAll() if the designated constraints aren't met.

func (MemoryMultiError) AllErrors

func (m MemoryMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (MemoryMultiError) Error

func (m MemoryMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type MemoryValidationError

type MemoryValidationError struct {
	// contains filtered or unexported fields
}

MemoryValidationError is the validation error returned by Memory.Validate if the designated constraints aren't met.

func (MemoryValidationError) Cause

func (e MemoryValidationError) Cause() error

Cause function returns cause value.

func (MemoryValidationError) Error

func (e MemoryValidationError) Error() string

Error satisfies the builtin error interface

func (MemoryValidationError) ErrorName

func (e MemoryValidationError) ErrorName() string

ErrorName returns error name.

func (MemoryValidationError) Field

func (e MemoryValidationError) Field() string

Field function returns field value.

func (MemoryValidationError) Key

func (e MemoryValidationError) Key() bool

Key function returns key value.

func (MemoryValidationError) Reason

func (e MemoryValidationError) Reason() string

Reason function returns reason value.

type Network

type Network struct {

	// Return count of tcp connections opened and status is ESTABLISHED.
	TcpConnectionCount uint32 `protobuf:"varint,1,opt,name=tcp_connection_count,json=tcpConnectionCount,proto3" json:"tcp_connection_count,omitempty"`
	// Return count of upload tcp connections opened and status is ESTABLISHED.
	UploadTcpConnectionCount uint32 `` /* 138-byte string literal not displayed */
	// Location path(area|country|province|city|...).
	Location string `protobuf:"bytes,4,opt,name=location,proto3" json:"location,omitempty"`
	// IDC where the peer host is located
	Idc string `protobuf:"bytes,5,opt,name=idc,proto3" json:"idc,omitempty"`
	// contains filtered or unexported fields
}

Network Stat.

func (*Network) Descriptor deprecated

func (*Network) Descriptor() ([]byte, []int)

Deprecated: Use Network.ProtoReflect.Descriptor instead.

func (*Network) GetIdc

func (x *Network) GetIdc() string

func (*Network) GetLocation

func (x *Network) GetLocation() string

func (*Network) GetTcpConnectionCount

func (x *Network) GetTcpConnectionCount() uint32

func (*Network) GetUploadTcpConnectionCount

func (x *Network) GetUploadTcpConnectionCount() uint32

func (*Network) ProtoMessage

func (*Network) ProtoMessage()

func (*Network) ProtoReflect

func (x *Network) ProtoReflect() protoreflect.Message

func (*Network) Reset

func (x *Network) Reset()

func (*Network) String

func (x *Network) String() string

func (*Network) Validate

func (m *Network) Validate() error

Validate checks the field values on Network with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Network) ValidateAll

func (m *Network) ValidateAll() error

ValidateAll checks the field values on Network with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in NetworkMultiError, or nil if none found.

type NetworkMultiError

type NetworkMultiError []error

NetworkMultiError is an error wrapping multiple validation errors returned by Network.ValidateAll() if the designated constraints aren't met.

func (NetworkMultiError) AllErrors

func (m NetworkMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NetworkMultiError) Error

func (m NetworkMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type NetworkValidationError

type NetworkValidationError struct {
	// contains filtered or unexported fields
}

NetworkValidationError is the validation error returned by Network.Validate if the designated constraints aren't met.

func (NetworkValidationError) Cause

func (e NetworkValidationError) Cause() error

Cause function returns cause value.

func (NetworkValidationError) Error

func (e NetworkValidationError) Error() string

Error satisfies the builtin error interface

func (NetworkValidationError) ErrorName

func (e NetworkValidationError) ErrorName() string

ErrorName returns error name.

func (NetworkValidationError) Field

func (e NetworkValidationError) Field() string

Field function returns field value.

func (NetworkValidationError) Key

func (e NetworkValidationError) Key() bool

Key function returns key value.

func (NetworkValidationError) Reason

func (e NetworkValidationError) Reason() string

Reason function returns reason value.

type PeerHost

type PeerHost struct {

	// Peer host id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// peer host ip
	Ip string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	// Port of grpc service.
	RpcPort int32 `protobuf:"varint,3,opt,name=rpc_port,json=rpcPort,proto3" json:"rpc_port,omitempty"`
	// Port of download server.
	DownPort int32 `protobuf:"varint,4,opt,name=down_port,json=downPort,proto3" json:"down_port,omitempty"`
	// Peer hostname.
	Hostname string `protobuf:"bytes,5,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Location path(area|country|province|city|...).
	Location string `protobuf:"bytes,7,opt,name=location,proto3" json:"location,omitempty"`
	// IDC where the peer host is located
	Idc string `protobuf:"bytes,8,opt,name=idc,proto3" json:"idc,omitempty"`
	// contains filtered or unexported fields
}

PeerHost represents information of peer host.

func (*PeerHost) Descriptor deprecated

func (*PeerHost) Descriptor() ([]byte, []int)

Deprecated: Use PeerHost.ProtoReflect.Descriptor instead.

func (*PeerHost) GetDownPort

func (x *PeerHost) GetDownPort() int32

func (*PeerHost) GetHostname

func (x *PeerHost) GetHostname() string

func (*PeerHost) GetId

func (x *PeerHost) GetId() string

func (*PeerHost) GetIdc

func (x *PeerHost) GetIdc() string

func (*PeerHost) GetIp

func (x *PeerHost) GetIp() string

func (*PeerHost) GetLocation

func (x *PeerHost) GetLocation() string

func (*PeerHost) GetRpcPort

func (x *PeerHost) GetRpcPort() int32

func (*PeerHost) ProtoMessage

func (*PeerHost) ProtoMessage()

func (*PeerHost) ProtoReflect

func (x *PeerHost) ProtoReflect() protoreflect.Message

func (*PeerHost) Reset

func (x *PeerHost) Reset()

func (*PeerHost) String

func (x *PeerHost) String() string

func (*PeerHost) Validate

func (m *PeerHost) Validate() error

Validate checks the field values on PeerHost with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PeerHost) ValidateAll

func (m *PeerHost) ValidateAll() error

ValidateAll checks the field values on PeerHost with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PeerHostMultiError, or nil if none found.

type PeerHostMultiError

type PeerHostMultiError []error

PeerHostMultiError is an error wrapping multiple validation errors returned by PeerHost.ValidateAll() if the designated constraints aren't met.

func (PeerHostMultiError) AllErrors

func (m PeerHostMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerHostMultiError) Error

func (m PeerHostMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PeerHostValidationError

type PeerHostValidationError struct {
	// contains filtered or unexported fields
}

PeerHostValidationError is the validation error returned by PeerHost.Validate if the designated constraints aren't met.

func (PeerHostValidationError) Cause

func (e PeerHostValidationError) Cause() error

Cause function returns cause value.

func (PeerHostValidationError) Error

func (e PeerHostValidationError) Error() string

Error satisfies the builtin error interface

func (PeerHostValidationError) ErrorName

func (e PeerHostValidationError) ErrorName() string

ErrorName returns error name.

func (PeerHostValidationError) Field

func (e PeerHostValidationError) Field() string

Field function returns field value.

func (PeerHostValidationError) Key

func (e PeerHostValidationError) Key() bool

Key function returns key value.

func (PeerHostValidationError) Reason

func (e PeerHostValidationError) Reason() string

Reason function returns reason value.

type PeerPacket

type PeerPacket struct {

	// Task id.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Source peer id.
	SrcPid string `protobuf:"bytes,3,opt,name=src_pid,json=srcPid,proto3" json:"src_pid,omitempty"`
	// Concurrent downloading count from main peer.
	ParallelCount int32 `protobuf:"varint,4,opt,name=parallel_count,json=parallelCount,proto3" json:"parallel_count,omitempty"`
	// Main peer.
	MainPeer *PeerPacket_DestPeer `protobuf:"bytes,5,opt,name=main_peer,json=mainPeer,proto3" json:"main_peer,omitempty"`
	// Candidate peers.
	CandidatePeers []*PeerPacket_DestPeer `protobuf:"bytes,6,rep,name=candidate_peers,json=candidatePeers,proto3" json:"candidate_peers,omitempty"`
	// Result code.
	Code v1.Code `protobuf:"varint,7,opt,name=code,proto3,enum=common.Code" json:"code,omitempty"`
	// Error detail.
	//
	// Types that are assignable to Errordetails:
	//
	//	*PeerPacket_SourceError
	Errordetails isPeerPacket_Errordetails `protobuf_oneof:"errordetails"`
	// contains filtered or unexported fields
}

PeerPacket represents response of ReportPieceResult.

func (*PeerPacket) Descriptor deprecated

func (*PeerPacket) Descriptor() ([]byte, []int)

Deprecated: Use PeerPacket.ProtoReflect.Descriptor instead.

func (*PeerPacket) GetCandidatePeers

func (x *PeerPacket) GetCandidatePeers() []*PeerPacket_DestPeer

func (*PeerPacket) GetCode

func (x *PeerPacket) GetCode() v1.Code

func (*PeerPacket) GetErrordetails

func (m *PeerPacket) GetErrordetails() isPeerPacket_Errordetails

func (*PeerPacket) GetMainPeer

func (x *PeerPacket) GetMainPeer() *PeerPacket_DestPeer

func (*PeerPacket) GetParallelCount

func (x *PeerPacket) GetParallelCount() int32

func (*PeerPacket) GetSourceError

func (x *PeerPacket) GetSourceError() *v11.SourceError

func (*PeerPacket) GetSrcPid

func (x *PeerPacket) GetSrcPid() string

func (*PeerPacket) GetTaskId

func (x *PeerPacket) GetTaskId() string

func (*PeerPacket) ProtoMessage

func (*PeerPacket) ProtoMessage()

func (*PeerPacket) ProtoReflect

func (x *PeerPacket) ProtoReflect() protoreflect.Message

func (*PeerPacket) Reset

func (x *PeerPacket) Reset()

func (*PeerPacket) String

func (x *PeerPacket) String() string

func (*PeerPacket) Validate

func (m *PeerPacket) Validate() error

Validate checks the field values on PeerPacket with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PeerPacket) ValidateAll

func (m *PeerPacket) ValidateAll() error

ValidateAll checks the field values on PeerPacket with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PeerPacketMultiError, or nil if none found.

type PeerPacketMultiError

type PeerPacketMultiError []error

PeerPacketMultiError is an error wrapping multiple validation errors returned by PeerPacket.ValidateAll() if the designated constraints aren't met.

func (PeerPacketMultiError) AllErrors

func (m PeerPacketMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerPacketMultiError) Error

func (m PeerPacketMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PeerPacketValidationError

type PeerPacketValidationError struct {
	// contains filtered or unexported fields
}

PeerPacketValidationError is the validation error returned by PeerPacket.Validate if the designated constraints aren't met.

func (PeerPacketValidationError) Cause

func (e PeerPacketValidationError) Cause() error

Cause function returns cause value.

func (PeerPacketValidationError) Error

Error satisfies the builtin error interface

func (PeerPacketValidationError) ErrorName

func (e PeerPacketValidationError) ErrorName() string

ErrorName returns error name.

func (PeerPacketValidationError) Field

Field function returns field value.

func (PeerPacketValidationError) Key

Key function returns key value.

func (PeerPacketValidationError) Reason

func (e PeerPacketValidationError) Reason() string

Reason function returns reason value.

type PeerPacket_DestPeer

type PeerPacket_DestPeer struct {

	// Destination ip.
	Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	// Port of grpc service.
	RpcPort int32 `protobuf:"varint,2,opt,name=rpc_port,json=rpcPort,proto3" json:"rpc_port,omitempty"`
	// Destination peer id.
	PeerId string `protobuf:"bytes,3,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PeerPacket_DestPeer) Descriptor deprecated

func (*PeerPacket_DestPeer) Descriptor() ([]byte, []int)

Deprecated: Use PeerPacket_DestPeer.ProtoReflect.Descriptor instead.

func (*PeerPacket_DestPeer) GetIp

func (x *PeerPacket_DestPeer) GetIp() string

func (*PeerPacket_DestPeer) GetPeerId

func (x *PeerPacket_DestPeer) GetPeerId() string

func (*PeerPacket_DestPeer) GetRpcPort

func (x *PeerPacket_DestPeer) GetRpcPort() int32

func (*PeerPacket_DestPeer) ProtoMessage

func (*PeerPacket_DestPeer) ProtoMessage()

func (*PeerPacket_DestPeer) ProtoReflect

func (x *PeerPacket_DestPeer) ProtoReflect() protoreflect.Message

func (*PeerPacket_DestPeer) Reset

func (x *PeerPacket_DestPeer) Reset()

func (*PeerPacket_DestPeer) String

func (x *PeerPacket_DestPeer) String() string

func (*PeerPacket_DestPeer) Validate

func (m *PeerPacket_DestPeer) Validate() error

Validate checks the field values on PeerPacket_DestPeer with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PeerPacket_DestPeer) ValidateAll

func (m *PeerPacket_DestPeer) ValidateAll() error

ValidateAll checks the field values on PeerPacket_DestPeer with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PeerPacket_DestPeerMultiError, or nil if none found.

type PeerPacket_DestPeerMultiError

type PeerPacket_DestPeerMultiError []error

PeerPacket_DestPeerMultiError is an error wrapping multiple validation errors returned by PeerPacket_DestPeer.ValidateAll() if the designated constraints aren't met.

func (PeerPacket_DestPeerMultiError) AllErrors

func (m PeerPacket_DestPeerMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerPacket_DestPeerMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type PeerPacket_DestPeerValidationError

type PeerPacket_DestPeerValidationError struct {
	// contains filtered or unexported fields
}

PeerPacket_DestPeerValidationError is the validation error returned by PeerPacket_DestPeer.Validate if the designated constraints aren't met.

func (PeerPacket_DestPeerValidationError) Cause

Cause function returns cause value.

func (PeerPacket_DestPeerValidationError) Error

Error satisfies the builtin error interface

func (PeerPacket_DestPeerValidationError) ErrorName

ErrorName returns error name.

func (PeerPacket_DestPeerValidationError) Field

Field function returns field value.

func (PeerPacket_DestPeerValidationError) Key

Key function returns key value.

func (PeerPacket_DestPeerValidationError) Reason

Reason function returns reason value.

type PeerPacket_SourceError

type PeerPacket_SourceError struct {
	// Source error.
	SourceError *v11.SourceError `protobuf:"bytes,8,opt,name=source_error,json=sourceError,proto3,oneof"`
}

type PeerResult

type PeerResult struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Peer id.
	PeerId string `protobuf:"bytes,2,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// Source host ip.
	SrcIp string `protobuf:"bytes,3,opt,name=src_ip,json=srcIp,proto3" json:"src_ip,omitempty"`
	// IDC where the peer host is located
	Idc string `protobuf:"bytes,5,opt,name=idc,proto3" json:"idc,omitempty"`
	// Download url.
	Url string `protobuf:"bytes,6,opt,name=url,proto3" json:"url,omitempty"`
	// Total content length.
	ContentLength int64 `protobuf:"varint,7,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// Total network traffic.
	Traffic uint64 `protobuf:"varint,8,opt,name=traffic,proto3" json:"traffic,omitempty"`
	// Total cost time.
	Cost uint32 `protobuf:"varint,9,opt,name=cost,proto3" json:"cost,omitempty"`
	// Whether peer downloading file is successfully.
	Success bool `protobuf:"varint,10,opt,name=success,proto3" json:"success,omitempty"`
	// Result code.
	Code v1.Code `protobuf:"varint,11,opt,name=code,proto3,enum=common.Code" json:"code,omitempty"`
	// Task total piece count.
	TotalPieceCount int32 `protobuf:"varint,12,opt,name=total_piece_count,json=totalPieceCount,proto3" json:"total_piece_count,omitempty"`
	// Error detail.
	//
	// Types that are assignable to Errordetails:
	//
	//	*PeerResult_SourceError
	Errordetails isPeerResult_Errordetails `protobuf_oneof:"errordetails"`
	// contains filtered or unexported fields
}

PeerResult represents response of ReportPeerResult.

func (*PeerResult) Descriptor deprecated

func (*PeerResult) Descriptor() ([]byte, []int)

Deprecated: Use PeerResult.ProtoReflect.Descriptor instead.

func (*PeerResult) GetCode

func (x *PeerResult) GetCode() v1.Code

func (*PeerResult) GetContentLength

func (x *PeerResult) GetContentLength() int64

func (*PeerResult) GetCost

func (x *PeerResult) GetCost() uint32

func (*PeerResult) GetErrordetails

func (m *PeerResult) GetErrordetails() isPeerResult_Errordetails

func (*PeerResult) GetIdc

func (x *PeerResult) GetIdc() string

func (*PeerResult) GetPeerId

func (x *PeerResult) GetPeerId() string

func (*PeerResult) GetSourceError

func (x *PeerResult) GetSourceError() *v11.SourceError

func (*PeerResult) GetSrcIp

func (x *PeerResult) GetSrcIp() string

func (*PeerResult) GetSuccess

func (x *PeerResult) GetSuccess() bool

func (*PeerResult) GetTaskId

func (x *PeerResult) GetTaskId() string

func (*PeerResult) GetTotalPieceCount

func (x *PeerResult) GetTotalPieceCount() int32

func (*PeerResult) GetTraffic

func (x *PeerResult) GetTraffic() uint64

func (*PeerResult) GetUrl

func (x *PeerResult) GetUrl() string

func (*PeerResult) ProtoMessage

func (*PeerResult) ProtoMessage()

func (*PeerResult) ProtoReflect

func (x *PeerResult) ProtoReflect() protoreflect.Message

func (*PeerResult) Reset

func (x *PeerResult) Reset()

func (*PeerResult) String

func (x *PeerResult) String() string

func (*PeerResult) Validate

func (m *PeerResult) Validate() error

Validate checks the field values on PeerResult with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PeerResult) ValidateAll

func (m *PeerResult) ValidateAll() error

ValidateAll checks the field values on PeerResult with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PeerResultMultiError, or nil if none found.

type PeerResultMultiError

type PeerResultMultiError []error

PeerResultMultiError is an error wrapping multiple validation errors returned by PeerResult.ValidateAll() if the designated constraints aren't met.

func (PeerResultMultiError) AllErrors

func (m PeerResultMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerResultMultiError) Error

func (m PeerResultMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PeerResultValidationError

type PeerResultValidationError struct {
	// contains filtered or unexported fields
}

PeerResultValidationError is the validation error returned by PeerResult.Validate if the designated constraints aren't met.

func (PeerResultValidationError) Cause

func (e PeerResultValidationError) Cause() error

Cause function returns cause value.

func (PeerResultValidationError) Error

Error satisfies the builtin error interface

func (PeerResultValidationError) ErrorName

func (e PeerResultValidationError) ErrorName() string

ErrorName returns error name.

func (PeerResultValidationError) Field

Field function returns field value.

func (PeerResultValidationError) Key

Key function returns key value.

func (PeerResultValidationError) Reason

func (e PeerResultValidationError) Reason() string

Reason function returns reason value.

type PeerResult_SourceError

type PeerResult_SourceError struct {
	// Source error.
	SourceError *v11.SourceError `protobuf:"bytes,13,opt,name=source_error,json=sourceError,proto3,oneof"`
}

type PeerTarget

type PeerTarget struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Peer id.
	PeerId string `protobuf:"bytes,2,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// contains filtered or unexported fields
}

PeerTarget represents request of LeaveTask.

func (*PeerTarget) Descriptor deprecated

func (*PeerTarget) Descriptor() ([]byte, []int)

Deprecated: Use PeerTarget.ProtoReflect.Descriptor instead.

func (*PeerTarget) GetPeerId

func (x *PeerTarget) GetPeerId() string

func (*PeerTarget) GetTaskId

func (x *PeerTarget) GetTaskId() string

func (*PeerTarget) ProtoMessage

func (*PeerTarget) ProtoMessage()

func (*PeerTarget) ProtoReflect

func (x *PeerTarget) ProtoReflect() protoreflect.Message

func (*PeerTarget) Reset

func (x *PeerTarget) Reset()

func (*PeerTarget) String

func (x *PeerTarget) String() string

func (*PeerTarget) Validate

func (m *PeerTarget) Validate() error

Validate checks the field values on PeerTarget with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PeerTarget) ValidateAll

func (m *PeerTarget) ValidateAll() error

ValidateAll checks the field values on PeerTarget with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PeerTargetMultiError, or nil if none found.

type PeerTargetMultiError

type PeerTargetMultiError []error

PeerTargetMultiError is an error wrapping multiple validation errors returned by PeerTarget.ValidateAll() if the designated constraints aren't met.

func (PeerTargetMultiError) AllErrors

func (m PeerTargetMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerTargetMultiError) Error

func (m PeerTargetMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PeerTargetValidationError

type PeerTargetValidationError struct {
	// contains filtered or unexported fields
}

PeerTargetValidationError is the validation error returned by PeerTarget.Validate if the designated constraints aren't met.

func (PeerTargetValidationError) Cause

func (e PeerTargetValidationError) Cause() error

Cause function returns cause value.

func (PeerTargetValidationError) Error

Error satisfies the builtin error interface

func (PeerTargetValidationError) ErrorName

func (e PeerTargetValidationError) ErrorName() string

ErrorName returns error name.

func (PeerTargetValidationError) Field

Field function returns field value.

func (PeerTargetValidationError) Key

Key function returns key value.

func (PeerTargetValidationError) Reason

func (e PeerTargetValidationError) Reason() string

Reason function returns reason value.

type PeerTaskRequest

type PeerTaskRequest struct {

	// Download url.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// URL meta info.
	UrlMeta *v1.UrlMeta `protobuf:"bytes,2,opt,name=url_meta,json=urlMeta,proto3" json:"url_meta,omitempty"`
	// Peer id and it must be global uniqueness.
	PeerId string `protobuf:"bytes,3,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// Peer host info.
	PeerHost *PeerHost `protobuf:"bytes,4,opt,name=peer_host,json=peerHost,proto3" json:"peer_host,omitempty"`
	// Whether this request is caused by migration.
	IsMigrating bool `protobuf:"varint,6,opt,name=is_migrating,json=isMigrating,proto3" json:"is_migrating,omitempty"`
	// Task id.
	TaskId string `protobuf:"bytes,8,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

PeerTaskRequest represents request of RegisterPeerTask.

func (*PeerTaskRequest) Descriptor deprecated

func (*PeerTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use PeerTaskRequest.ProtoReflect.Descriptor instead.

func (*PeerTaskRequest) GetIsMigrating

func (x *PeerTaskRequest) GetIsMigrating() bool

func (*PeerTaskRequest) GetPeerHost

func (x *PeerTaskRequest) GetPeerHost() *PeerHost

func (*PeerTaskRequest) GetPeerId

func (x *PeerTaskRequest) GetPeerId() string

func (*PeerTaskRequest) GetTaskId

func (x *PeerTaskRequest) GetTaskId() string

func (*PeerTaskRequest) GetUrl

func (x *PeerTaskRequest) GetUrl() string

func (*PeerTaskRequest) GetUrlMeta

func (x *PeerTaskRequest) GetUrlMeta() *v1.UrlMeta

func (*PeerTaskRequest) ProtoMessage

func (*PeerTaskRequest) ProtoMessage()

func (*PeerTaskRequest) ProtoReflect

func (x *PeerTaskRequest) ProtoReflect() protoreflect.Message

func (*PeerTaskRequest) Reset

func (x *PeerTaskRequest) Reset()

func (*PeerTaskRequest) String

func (x *PeerTaskRequest) String() string

func (*PeerTaskRequest) Validate

func (m *PeerTaskRequest) Validate() error

Validate checks the field values on PeerTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PeerTaskRequest) ValidateAll

func (m *PeerTaskRequest) ValidateAll() error

ValidateAll checks the field values on PeerTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PeerTaskRequestMultiError, or nil if none found.

type PeerTaskRequestMultiError

type PeerTaskRequestMultiError []error

PeerTaskRequestMultiError is an error wrapping multiple validation errors returned by PeerTaskRequest.ValidateAll() if the designated constraints aren't met.

func (PeerTaskRequestMultiError) AllErrors

func (m PeerTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerTaskRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type PeerTaskRequestValidationError

type PeerTaskRequestValidationError struct {
	// contains filtered or unexported fields
}

PeerTaskRequestValidationError is the validation error returned by PeerTaskRequest.Validate if the designated constraints aren't met.

func (PeerTaskRequestValidationError) Cause

Cause function returns cause value.

func (PeerTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (PeerTaskRequestValidationError) ErrorName

func (e PeerTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (PeerTaskRequestValidationError) Field

Field function returns field value.

func (PeerTaskRequestValidationError) Key

Key function returns key value.

func (PeerTaskRequestValidationError) Reason

Reason function returns reason value.

type PieceResult

type PieceResult struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Source peer id.
	SrcPid string `protobuf:"bytes,2,opt,name=src_pid,json=srcPid,proto3" json:"src_pid,omitempty"`
	// Destination peer id.
	DstPid string `protobuf:"bytes,3,opt,name=dst_pid,json=dstPid,proto3" json:"dst_pid,omitempty"`
	// Piece info.
	PieceInfo *v1.PieceInfo `protobuf:"bytes,4,opt,name=piece_info,json=pieceInfo,proto3" json:"piece_info,omitempty"`
	// Begin time of the piece downloading.
	BeginTime uint64 `protobuf:"varint,5,opt,name=begin_time,json=beginTime,proto3" json:"begin_time,omitempty"`
	// End time of the piece downloading.
	EndTime uint64 `protobuf:"varint,6,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Whether the piece downloading is successfully.
	Success bool `protobuf:"varint,7,opt,name=success,proto3" json:"success,omitempty"`
	// Result code.
	Code v1.Code `protobuf:"varint,8,opt,name=code,proto3,enum=common.Code" json:"code,omitempty"`
	// Finished count.
	FinishedCount int32 `protobuf:"varint,10,opt,name=finished_count,json=finishedCount,proto3" json:"finished_count,omitempty"`
	// Task extend attribute,
	// only first success back source piece will carry extend attribute.
	ExtendAttribute *v1.ExtendAttribute `protobuf:"bytes,11,opt,name=extend_attribute,json=extendAttribute,proto3" json:"extend_attribute,omitempty"`
	// contains filtered or unexported fields
}

PieceResult represents request of ReportPieceResult.

func (*PieceResult) Descriptor deprecated

func (*PieceResult) Descriptor() ([]byte, []int)

Deprecated: Use PieceResult.ProtoReflect.Descriptor instead.

func (*PieceResult) GetBeginTime

func (x *PieceResult) GetBeginTime() uint64

func (*PieceResult) GetCode

func (x *PieceResult) GetCode() v1.Code

func (*PieceResult) GetDstPid

func (x *PieceResult) GetDstPid() string

func (*PieceResult) GetEndTime

func (x *PieceResult) GetEndTime() uint64

func (*PieceResult) GetExtendAttribute

func (x *PieceResult) GetExtendAttribute() *v1.ExtendAttribute

func (*PieceResult) GetFinishedCount

func (x *PieceResult) GetFinishedCount() int32

func (*PieceResult) GetPieceInfo

func (x *PieceResult) GetPieceInfo() *v1.PieceInfo

func (*PieceResult) GetSrcPid

func (x *PieceResult) GetSrcPid() string

func (*PieceResult) GetSuccess

func (x *PieceResult) GetSuccess() bool

func (*PieceResult) GetTaskId

func (x *PieceResult) GetTaskId() string

func (*PieceResult) ProtoMessage

func (*PieceResult) ProtoMessage()

func (*PieceResult) ProtoReflect

func (x *PieceResult) ProtoReflect() protoreflect.Message

func (*PieceResult) Reset

func (x *PieceResult) Reset()

func (*PieceResult) String

func (x *PieceResult) String() string

func (*PieceResult) Validate

func (m *PieceResult) Validate() error

Validate checks the field values on PieceResult with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PieceResult) ValidateAll

func (m *PieceResult) ValidateAll() error

ValidateAll checks the field values on PieceResult with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PieceResultMultiError, or nil if none found.

type PieceResultMultiError

type PieceResultMultiError []error

PieceResultMultiError is an error wrapping multiple validation errors returned by PieceResult.ValidateAll() if the designated constraints aren't met.

func (PieceResultMultiError) AllErrors

func (m PieceResultMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PieceResultMultiError) Error

func (m PieceResultMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PieceResultValidationError

type PieceResultValidationError struct {
	// contains filtered or unexported fields
}

PieceResultValidationError is the validation error returned by PieceResult.Validate if the designated constraints aren't met.

func (PieceResultValidationError) Cause

Cause function returns cause value.

func (PieceResultValidationError) Error

Error satisfies the builtin error interface

func (PieceResultValidationError) ErrorName

func (e PieceResultValidationError) ErrorName() string

ErrorName returns error name.

func (PieceResultValidationError) Field

Field function returns field value.

func (PieceResultValidationError) Key

Key function returns key value.

func (PieceResultValidationError) Reason

Reason function returns reason value.

type Probe

type Probe struct {

	// Destination host metadata.
	Host *v1.Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// RTT is the round-trip time sent via this pinger.
	Rtt *durationpb.Duration `protobuf:"bytes,2,opt,name=rtt,proto3" json:"rtt,omitempty"`
	// Probe create time.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

Probe information.

func (*Probe) Descriptor deprecated

func (*Probe) Descriptor() ([]byte, []int)

Deprecated: Use Probe.ProtoReflect.Descriptor instead.

func (*Probe) GetCreatedAt

func (x *Probe) GetCreatedAt() *timestamppb.Timestamp

func (*Probe) GetHost

func (x *Probe) GetHost() *v1.Host

func (*Probe) GetRtt

func (x *Probe) GetRtt() *durationpb.Duration

func (*Probe) ProtoMessage

func (*Probe) ProtoMessage()

func (*Probe) ProtoReflect

func (x *Probe) ProtoReflect() protoreflect.Message

func (*Probe) Reset

func (x *Probe) Reset()

func (*Probe) String

func (x *Probe) String() string

func (*Probe) Validate

func (m *Probe) Validate() error

Validate checks the field values on Probe with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Probe) ValidateAll

func (m *Probe) ValidateAll() error

ValidateAll checks the field values on Probe with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ProbeMultiError, or nil if none found.

type ProbeFailedRequest

type ProbeFailedRequest struct {

	// Failed probes information.
	Probes []*FailedProbe `protobuf:"bytes,1,rep,name=probes,proto3" json:"probes,omitempty"`
	// contains filtered or unexported fields
}

ProbeFailedRequest represents failed request of SyncProbesRequest.

func (*ProbeFailedRequest) Descriptor deprecated

func (*ProbeFailedRequest) Descriptor() ([]byte, []int)

Deprecated: Use ProbeFailedRequest.ProtoReflect.Descriptor instead.

func (*ProbeFailedRequest) GetProbes

func (x *ProbeFailedRequest) GetProbes() []*FailedProbe

func (*ProbeFailedRequest) ProtoMessage

func (*ProbeFailedRequest) ProtoMessage()

func (*ProbeFailedRequest) ProtoReflect

func (x *ProbeFailedRequest) ProtoReflect() protoreflect.Message

func (*ProbeFailedRequest) Reset

func (x *ProbeFailedRequest) Reset()

func (*ProbeFailedRequest) String

func (x *ProbeFailedRequest) String() string

func (*ProbeFailedRequest) Validate

func (m *ProbeFailedRequest) Validate() error

Validate checks the field values on ProbeFailedRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ProbeFailedRequest) ValidateAll

func (m *ProbeFailedRequest) ValidateAll() error

ValidateAll checks the field values on ProbeFailedRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ProbeFailedRequestMultiError, or nil if none found.

type ProbeFailedRequestMultiError

type ProbeFailedRequestMultiError []error

ProbeFailedRequestMultiError is an error wrapping multiple validation errors returned by ProbeFailedRequest.ValidateAll() if the designated constraints aren't met.

func (ProbeFailedRequestMultiError) AllErrors

func (m ProbeFailedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ProbeFailedRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ProbeFailedRequestValidationError

type ProbeFailedRequestValidationError struct {
	// contains filtered or unexported fields
}

ProbeFailedRequestValidationError is the validation error returned by ProbeFailedRequest.Validate if the designated constraints aren't met.

func (ProbeFailedRequestValidationError) Cause

Cause function returns cause value.

func (ProbeFailedRequestValidationError) Error

Error satisfies the builtin error interface

func (ProbeFailedRequestValidationError) ErrorName

ErrorName returns error name.

func (ProbeFailedRequestValidationError) Field

Field function returns field value.

func (ProbeFailedRequestValidationError) Key

Key function returns key value.

func (ProbeFailedRequestValidationError) Reason

Reason function returns reason value.

type ProbeFinishedRequest

type ProbeFinishedRequest struct {

	// Probes information.
	Probes []*Probe `protobuf:"bytes,1,rep,name=probes,proto3" json:"probes,omitempty"`
	// contains filtered or unexported fields
}

ProbeFinishedRequest represents finished request of SyncProbesRequest.

func (*ProbeFinishedRequest) Descriptor deprecated

func (*ProbeFinishedRequest) Descriptor() ([]byte, []int)

Deprecated: Use ProbeFinishedRequest.ProtoReflect.Descriptor instead.

func (*ProbeFinishedRequest) GetProbes

func (x *ProbeFinishedRequest) GetProbes() []*Probe

func (*ProbeFinishedRequest) ProtoMessage

func (*ProbeFinishedRequest) ProtoMessage()

func (*ProbeFinishedRequest) ProtoReflect

func (x *ProbeFinishedRequest) ProtoReflect() protoreflect.Message

func (*ProbeFinishedRequest) Reset

func (x *ProbeFinishedRequest) Reset()

func (*ProbeFinishedRequest) String

func (x *ProbeFinishedRequest) String() string

func (*ProbeFinishedRequest) Validate

func (m *ProbeFinishedRequest) Validate() error

Validate checks the field values on ProbeFinishedRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ProbeFinishedRequest) ValidateAll

func (m *ProbeFinishedRequest) ValidateAll() error

ValidateAll checks the field values on ProbeFinishedRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ProbeFinishedRequestMultiError, or nil if none found.

type ProbeFinishedRequestMultiError

type ProbeFinishedRequestMultiError []error

ProbeFinishedRequestMultiError is an error wrapping multiple validation errors returned by ProbeFinishedRequest.ValidateAll() if the designated constraints aren't met.

func (ProbeFinishedRequestMultiError) AllErrors

func (m ProbeFinishedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ProbeFinishedRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ProbeFinishedRequestValidationError

type ProbeFinishedRequestValidationError struct {
	// contains filtered or unexported fields
}

ProbeFinishedRequestValidationError is the validation error returned by ProbeFinishedRequest.Validate if the designated constraints aren't met.

func (ProbeFinishedRequestValidationError) Cause

Cause function returns cause value.

func (ProbeFinishedRequestValidationError) Error

Error satisfies the builtin error interface

func (ProbeFinishedRequestValidationError) ErrorName

ErrorName returns error name.

func (ProbeFinishedRequestValidationError) Field

Field function returns field value.

func (ProbeFinishedRequestValidationError) Key

Key function returns key value.

func (ProbeFinishedRequestValidationError) Reason

Reason function returns reason value.

type ProbeMultiError

type ProbeMultiError []error

ProbeMultiError is an error wrapping multiple validation errors returned by Probe.ValidateAll() if the designated constraints aren't met.

func (ProbeMultiError) AllErrors

func (m ProbeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ProbeMultiError) Error

func (m ProbeMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ProbeStartedRequest

type ProbeStartedRequest struct {
	// contains filtered or unexported fields
}

ProbeStartedRequest represents started request of SyncProbesRequest.

func (*ProbeStartedRequest) Descriptor deprecated

func (*ProbeStartedRequest) Descriptor() ([]byte, []int)

Deprecated: Use ProbeStartedRequest.ProtoReflect.Descriptor instead.

func (*ProbeStartedRequest) ProtoMessage

func (*ProbeStartedRequest) ProtoMessage()

func (*ProbeStartedRequest) ProtoReflect

func (x *ProbeStartedRequest) ProtoReflect() protoreflect.Message

func (*ProbeStartedRequest) Reset

func (x *ProbeStartedRequest) Reset()

func (*ProbeStartedRequest) String

func (x *ProbeStartedRequest) String() string

func (*ProbeStartedRequest) Validate

func (m *ProbeStartedRequest) Validate() error

Validate checks the field values on ProbeStartedRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ProbeStartedRequest) ValidateAll

func (m *ProbeStartedRequest) ValidateAll() error

ValidateAll checks the field values on ProbeStartedRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ProbeStartedRequestMultiError, or nil if none found.

type ProbeStartedRequestMultiError

type ProbeStartedRequestMultiError []error

ProbeStartedRequestMultiError is an error wrapping multiple validation errors returned by ProbeStartedRequest.ValidateAll() if the designated constraints aren't met.

func (ProbeStartedRequestMultiError) AllErrors

func (m ProbeStartedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ProbeStartedRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ProbeStartedRequestValidationError

type ProbeStartedRequestValidationError struct {
	// contains filtered or unexported fields
}

ProbeStartedRequestValidationError is the validation error returned by ProbeStartedRequest.Validate if the designated constraints aren't met.

func (ProbeStartedRequestValidationError) Cause

Cause function returns cause value.

func (ProbeStartedRequestValidationError) Error

Error satisfies the builtin error interface

func (ProbeStartedRequestValidationError) ErrorName

ErrorName returns error name.

func (ProbeStartedRequestValidationError) Field

Field function returns field value.

func (ProbeStartedRequestValidationError) Key

Key function returns key value.

func (ProbeStartedRequestValidationError) Reason

Reason function returns reason value.

type ProbeValidationError

type ProbeValidationError struct {
	// contains filtered or unexported fields
}

ProbeValidationError is the validation error returned by Probe.Validate if the designated constraints aren't met.

func (ProbeValidationError) Cause

func (e ProbeValidationError) Cause() error

Cause function returns cause value.

func (ProbeValidationError) Error

func (e ProbeValidationError) Error() string

Error satisfies the builtin error interface

func (ProbeValidationError) ErrorName

func (e ProbeValidationError) ErrorName() string

ErrorName returns error name.

func (ProbeValidationError) Field

func (e ProbeValidationError) Field() string

Field function returns field value.

func (ProbeValidationError) Key

func (e ProbeValidationError) Key() bool

Key function returns key value.

func (ProbeValidationError) Reason

func (e ProbeValidationError) Reason() string

Reason function returns reason value.

type RegisterResult

type RegisterResult struct {

	// Task type.
	TaskType v1.TaskType `protobuf:"varint,1,opt,name=task_type,json=taskType,proto3,enum=common.TaskType" json:"task_type,omitempty"`
	// Task id
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// File size scope.
	SizeScope v1.SizeScope `protobuf:"varint,3,opt,name=size_scope,json=sizeScope,proto3,enum=common.SizeScope" json:"size_scope,omitempty"`
	// Download the only piece directly for small or tiny file.
	//
	// Types that are assignable to DirectPiece:
	//
	//	*RegisterResult_SinglePiece
	//	*RegisterResult_PieceContent
	DirectPiece isRegisterResult_DirectPiece `protobuf_oneof:"direct_piece"`
	// Task extend attribute,
	// only direct_piece will carry extend attribute.
	ExtendAttribute *v1.ExtendAttribute `protobuf:"bytes,6,opt,name=extend_attribute,json=extendAttribute,proto3" json:"extend_attribute,omitempty"`
	// contains filtered or unexported fields
}

RegisterResult represents response of RegisterPeerTask.

func (*RegisterResult) Descriptor deprecated

func (*RegisterResult) Descriptor() ([]byte, []int)

Deprecated: Use RegisterResult.ProtoReflect.Descriptor instead.

func (*RegisterResult) GetDirectPiece

func (m *RegisterResult) GetDirectPiece() isRegisterResult_DirectPiece

func (*RegisterResult) GetExtendAttribute

func (x *RegisterResult) GetExtendAttribute() *v1.ExtendAttribute

func (*RegisterResult) GetPieceContent

func (x *RegisterResult) GetPieceContent() []byte

func (*RegisterResult) GetSinglePiece

func (x *RegisterResult) GetSinglePiece() *SinglePiece

func (*RegisterResult) GetSizeScope

func (x *RegisterResult) GetSizeScope() v1.SizeScope

func (*RegisterResult) GetTaskId

func (x *RegisterResult) GetTaskId() string

func (*RegisterResult) GetTaskType

func (x *RegisterResult) GetTaskType() v1.TaskType

func (*RegisterResult) ProtoMessage

func (*RegisterResult) ProtoMessage()

func (*RegisterResult) ProtoReflect

func (x *RegisterResult) ProtoReflect() protoreflect.Message

func (*RegisterResult) Reset

func (x *RegisterResult) Reset()

func (*RegisterResult) String

func (x *RegisterResult) String() string

func (*RegisterResult) Validate

func (m *RegisterResult) Validate() error

Validate checks the field values on RegisterResult with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*RegisterResult) ValidateAll

func (m *RegisterResult) ValidateAll() error

ValidateAll checks the field values on RegisterResult with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RegisterResultMultiError, or nil if none found.

type RegisterResultMultiError

type RegisterResultMultiError []error

RegisterResultMultiError is an error wrapping multiple validation errors returned by RegisterResult.ValidateAll() if the designated constraints aren't met.

func (RegisterResultMultiError) AllErrors

func (m RegisterResultMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RegisterResultMultiError) Error

func (m RegisterResultMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RegisterResultValidationError

type RegisterResultValidationError struct {
	// contains filtered or unexported fields
}

RegisterResultValidationError is the validation error returned by RegisterResult.Validate if the designated constraints aren't met.

func (RegisterResultValidationError) Cause

Cause function returns cause value.

func (RegisterResultValidationError) Error

Error satisfies the builtin error interface

func (RegisterResultValidationError) ErrorName

func (e RegisterResultValidationError) ErrorName() string

ErrorName returns error name.

func (RegisterResultValidationError) Field

Field function returns field value.

func (RegisterResultValidationError) Key

Key function returns key value.

func (RegisterResultValidationError) Reason

Reason function returns reason value.

type RegisterResult_PieceContent

type RegisterResult_PieceContent struct {
	// Return task content when size scope is tiny.
	PieceContent []byte `protobuf:"bytes,5,opt,name=piece_content,json=pieceContent,proto3,oneof"`
}

type RegisterResult_SinglePiece

type RegisterResult_SinglePiece struct {
	// Return single piece info when size scope is small.
	SinglePiece *SinglePiece `protobuf:"bytes,4,opt,name=single_piece,json=singlePiece,proto3,oneof"`
}

type SchedulerClient

type SchedulerClient interface {
	// RegisterPeerTask registers a peer into task.
	RegisterPeerTask(ctx context.Context, in *PeerTaskRequest, opts ...grpc.CallOption) (*RegisterResult, error)
	// ReportPieceResult reports piece results and receives peer packets.
	ReportPieceResult(ctx context.Context, opts ...grpc.CallOption) (Scheduler_ReportPieceResultClient, error)
	// ReportPeerResult reports downloading result for the peer.
	ReportPeerResult(ctx context.Context, in *PeerResult, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// A peer announces that it has the announced task to other peers.
	AnnounceTask(ctx context.Context, in *AnnounceTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Checks if any peer has the given task.
	StatTask(ctx context.Context, in *StatTaskRequest, opts ...grpc.CallOption) (*Task, error)
	// LeaveTask makes the peer leaving from task.
	LeaveTask(ctx context.Context, in *PeerTarget, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// AnnounceHost announces host to scheduler.
	AnnounceHost(ctx context.Context, in *AnnounceHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// LeaveHost makes the peers leaving from host.
	LeaveHost(ctx context.Context, in *LeaveHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// SyncProbes sync probes of the host.
	SyncProbes(ctx context.Context, opts ...grpc.CallOption) (Scheduler_SyncProbesClient, error)
}

SchedulerClient is the client API for Scheduler service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSchedulerClient

func NewSchedulerClient(cc grpc.ClientConnInterface) SchedulerClient

type SchedulerServer

type SchedulerServer interface {
	// RegisterPeerTask registers a peer into task.
	RegisterPeerTask(context.Context, *PeerTaskRequest) (*RegisterResult, error)
	// ReportPieceResult reports piece results and receives peer packets.
	ReportPieceResult(Scheduler_ReportPieceResultServer) error
	// ReportPeerResult reports downloading result for the peer.
	ReportPeerResult(context.Context, *PeerResult) (*emptypb.Empty, error)
	// A peer announces that it has the announced task to other peers.
	AnnounceTask(context.Context, *AnnounceTaskRequest) (*emptypb.Empty, error)
	// Checks if any peer has the given task.
	StatTask(context.Context, *StatTaskRequest) (*Task, error)
	// LeaveTask makes the peer leaving from task.
	LeaveTask(context.Context, *PeerTarget) (*emptypb.Empty, error)
	// AnnounceHost announces host to scheduler.
	AnnounceHost(context.Context, *AnnounceHostRequest) (*emptypb.Empty, error)
	// LeaveHost makes the peers leaving from host.
	LeaveHost(context.Context, *LeaveHostRequest) (*emptypb.Empty, error)
	// SyncProbes sync probes of the host.
	SyncProbes(Scheduler_SyncProbesServer) error
}

SchedulerServer is the server API for Scheduler service. All implementations should embed UnimplementedSchedulerServer for forward compatibility

type Scheduler_ReportPieceResultClient

type Scheduler_ReportPieceResultClient interface {
	Send(*PieceResult) error
	Recv() (*PeerPacket, error)
	grpc.ClientStream
}

type Scheduler_ReportPieceResultServer

type Scheduler_ReportPieceResultServer interface {
	Send(*PeerPacket) error
	Recv() (*PieceResult, error)
	grpc.ServerStream
}

type Scheduler_SyncProbesClient

type Scheduler_SyncProbesClient interface {
	Send(*SyncProbesRequest) error
	Recv() (*SyncProbesResponse, error)
	grpc.ClientStream
}

type Scheduler_SyncProbesServer

type Scheduler_SyncProbesServer interface {
	Send(*SyncProbesResponse) error
	Recv() (*SyncProbesRequest, error)
	grpc.ServerStream
}

type SinglePiece

type SinglePiece struct {

	// Destination peer id.
	DstPid string `protobuf:"bytes,1,opt,name=dst_pid,json=dstPid,proto3" json:"dst_pid,omitempty"`
	// Destination download address.
	DstAddr string `protobuf:"bytes,2,opt,name=dst_addr,json=dstAddr,proto3" json:"dst_addr,omitempty"`
	// Piece info.
	PieceInfo *v1.PieceInfo `protobuf:"bytes,3,opt,name=piece_info,json=pieceInfo,proto3" json:"piece_info,omitempty"`
	// contains filtered or unexported fields
}

SinglePiece represents information of single piece.

func (*SinglePiece) Descriptor deprecated

func (*SinglePiece) Descriptor() ([]byte, []int)

Deprecated: Use SinglePiece.ProtoReflect.Descriptor instead.

func (*SinglePiece) GetDstAddr

func (x *SinglePiece) GetDstAddr() string

func (*SinglePiece) GetDstPid

func (x *SinglePiece) GetDstPid() string

func (*SinglePiece) GetPieceInfo

func (x *SinglePiece) GetPieceInfo() *v1.PieceInfo

func (*SinglePiece) ProtoMessage

func (*SinglePiece) ProtoMessage()

func (*SinglePiece) ProtoReflect

func (x *SinglePiece) ProtoReflect() protoreflect.Message

func (*SinglePiece) Reset

func (x *SinglePiece) Reset()

func (*SinglePiece) String

func (x *SinglePiece) String() string

func (*SinglePiece) Validate

func (m *SinglePiece) Validate() error

Validate checks the field values on SinglePiece with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SinglePiece) ValidateAll

func (m *SinglePiece) ValidateAll() error

ValidateAll checks the field values on SinglePiece with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SinglePieceMultiError, or nil if none found.

type SinglePieceMultiError

type SinglePieceMultiError []error

SinglePieceMultiError is an error wrapping multiple validation errors returned by SinglePiece.ValidateAll() if the designated constraints aren't met.

func (SinglePieceMultiError) AllErrors

func (m SinglePieceMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SinglePieceMultiError) Error

func (m SinglePieceMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type SinglePieceValidationError

type SinglePieceValidationError struct {
	// contains filtered or unexported fields
}

SinglePieceValidationError is the validation error returned by SinglePiece.Validate if the designated constraints aren't met.

func (SinglePieceValidationError) Cause

Cause function returns cause value.

func (SinglePieceValidationError) Error

Error satisfies the builtin error interface

func (SinglePieceValidationError) ErrorName

func (e SinglePieceValidationError) ErrorName() string

ErrorName returns error name.

func (SinglePieceValidationError) Field

Field function returns field value.

func (SinglePieceValidationError) Key

Key function returns key value.

func (SinglePieceValidationError) Reason

Reason function returns reason value.

type StatTaskRequest

type StatTaskRequest struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

StatTaskRequest represents request of StatTask.

func (*StatTaskRequest) Descriptor deprecated

func (*StatTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use StatTaskRequest.ProtoReflect.Descriptor instead.

func (*StatTaskRequest) GetTaskId

func (x *StatTaskRequest) GetTaskId() string

func (*StatTaskRequest) ProtoMessage

func (*StatTaskRequest) ProtoMessage()

func (*StatTaskRequest) ProtoReflect

func (x *StatTaskRequest) ProtoReflect() protoreflect.Message

func (*StatTaskRequest) Reset

func (x *StatTaskRequest) Reset()

func (*StatTaskRequest) String

func (x *StatTaskRequest) String() string

func (*StatTaskRequest) Validate

func (m *StatTaskRequest) Validate() error

Validate checks the field values on StatTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StatTaskRequest) ValidateAll

func (m *StatTaskRequest) ValidateAll() error

ValidateAll checks the field values on StatTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StatTaskRequestMultiError, or nil if none found.

type StatTaskRequestMultiError

type StatTaskRequestMultiError []error

StatTaskRequestMultiError is an error wrapping multiple validation errors returned by StatTaskRequest.ValidateAll() if the designated constraints aren't met.

func (StatTaskRequestMultiError) AllErrors

func (m StatTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatTaskRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type StatTaskRequestValidationError

type StatTaskRequestValidationError struct {
	// contains filtered or unexported fields
}

StatTaskRequestValidationError is the validation error returned by StatTaskRequest.Validate if the designated constraints aren't met.

func (StatTaskRequestValidationError) Cause

Cause function returns cause value.

func (StatTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (StatTaskRequestValidationError) ErrorName

func (e StatTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatTaskRequestValidationError) Field

Field function returns field value.

func (StatTaskRequestValidationError) Key

Key function returns key value.

func (StatTaskRequestValidationError) Reason

Reason function returns reason value.

type SyncProbesRequest

type SyncProbesRequest struct {

	// Source host metadata.
	Host *v1.Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Types that are assignable to Request:
	//
	//	*SyncProbesRequest_ProbeStartedRequest
	//	*SyncProbesRequest_ProbeFinishedRequest
	//	*SyncProbesRequest_ProbeFailedRequest
	Request isSyncProbesRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

SyncProbesRequest represents request of SyncProbes.

func (*SyncProbesRequest) Descriptor deprecated

func (*SyncProbesRequest) Descriptor() ([]byte, []int)

Deprecated: Use SyncProbesRequest.ProtoReflect.Descriptor instead.

func (*SyncProbesRequest) GetHost

func (x *SyncProbesRequest) GetHost() *v1.Host

func (*SyncProbesRequest) GetProbeFailedRequest

func (x *SyncProbesRequest) GetProbeFailedRequest() *ProbeFailedRequest

func (*SyncProbesRequest) GetProbeFinishedRequest

func (x *SyncProbesRequest) GetProbeFinishedRequest() *ProbeFinishedRequest

func (*SyncProbesRequest) GetProbeStartedRequest

func (x *SyncProbesRequest) GetProbeStartedRequest() *ProbeStartedRequest

func (*SyncProbesRequest) GetRequest

func (m *SyncProbesRequest) GetRequest() isSyncProbesRequest_Request

func (*SyncProbesRequest) ProtoMessage

func (*SyncProbesRequest) ProtoMessage()

func (*SyncProbesRequest) ProtoReflect

func (x *SyncProbesRequest) ProtoReflect() protoreflect.Message

func (*SyncProbesRequest) Reset

func (x *SyncProbesRequest) Reset()

func (*SyncProbesRequest) String

func (x *SyncProbesRequest) String() string

func (*SyncProbesRequest) Validate

func (m *SyncProbesRequest) Validate() error

Validate checks the field values on SyncProbesRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SyncProbesRequest) ValidateAll

func (m *SyncProbesRequest) ValidateAll() error

ValidateAll checks the field values on SyncProbesRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SyncProbesRequestMultiError, or nil if none found.

type SyncProbesRequestMultiError

type SyncProbesRequestMultiError []error

SyncProbesRequestMultiError is an error wrapping multiple validation errors returned by SyncProbesRequest.ValidateAll() if the designated constraints aren't met.

func (SyncProbesRequestMultiError) AllErrors

func (m SyncProbesRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncProbesRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type SyncProbesRequestValidationError

type SyncProbesRequestValidationError struct {
	// contains filtered or unexported fields
}

SyncProbesRequestValidationError is the validation error returned by SyncProbesRequest.Validate if the designated constraints aren't met.

func (SyncProbesRequestValidationError) Cause

Cause function returns cause value.

func (SyncProbesRequestValidationError) Error

Error satisfies the builtin error interface

func (SyncProbesRequestValidationError) ErrorName

ErrorName returns error name.

func (SyncProbesRequestValidationError) Field

Field function returns field value.

func (SyncProbesRequestValidationError) Key

Key function returns key value.

func (SyncProbesRequestValidationError) Reason

Reason function returns reason value.

type SyncProbesRequest_ProbeFailedRequest

type SyncProbesRequest_ProbeFailedRequest struct {
	ProbeFailedRequest *ProbeFailedRequest `protobuf:"bytes,4,opt,name=probe_failed_request,json=probeFailedRequest,proto3,oneof"`
}

type SyncProbesRequest_ProbeFinishedRequest

type SyncProbesRequest_ProbeFinishedRequest struct {
	ProbeFinishedRequest *ProbeFinishedRequest `protobuf:"bytes,3,opt,name=probe_finished_request,json=probeFinishedRequest,proto3,oneof"`
}

type SyncProbesRequest_ProbeStartedRequest

type SyncProbesRequest_ProbeStartedRequest struct {
	ProbeStartedRequest *ProbeStartedRequest `protobuf:"bytes,2,opt,name=probe_started_request,json=probeStartedRequest,proto3,oneof"`
}

type SyncProbesResponse

type SyncProbesResponse struct {

	// Hosts needs to be probed.
	Hosts []*v1.Host `protobuf:"bytes,1,rep,name=hosts,proto3" json:"hosts,omitempty"`
	// contains filtered or unexported fields
}

SyncProbesResponse represents response of SyncProbes.

func (*SyncProbesResponse) Descriptor deprecated

func (*SyncProbesResponse) Descriptor() ([]byte, []int)

Deprecated: Use SyncProbesResponse.ProtoReflect.Descriptor instead.

func (*SyncProbesResponse) GetHosts

func (x *SyncProbesResponse) GetHosts() []*v1.Host

func (*SyncProbesResponse) ProtoMessage

func (*SyncProbesResponse) ProtoMessage()

func (*SyncProbesResponse) ProtoReflect

func (x *SyncProbesResponse) ProtoReflect() protoreflect.Message

func (*SyncProbesResponse) Reset

func (x *SyncProbesResponse) Reset()

func (*SyncProbesResponse) String

func (x *SyncProbesResponse) String() string

func (*SyncProbesResponse) Validate

func (m *SyncProbesResponse) Validate() error

Validate checks the field values on SyncProbesResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SyncProbesResponse) ValidateAll

func (m *SyncProbesResponse) ValidateAll() error

ValidateAll checks the field values on SyncProbesResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SyncProbesResponseMultiError, or nil if none found.

type SyncProbesResponseMultiError

type SyncProbesResponseMultiError []error

SyncProbesResponseMultiError is an error wrapping multiple validation errors returned by SyncProbesResponse.ValidateAll() if the designated constraints aren't met.

func (SyncProbesResponseMultiError) AllErrors

func (m SyncProbesResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncProbesResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type SyncProbesResponseValidationError

type SyncProbesResponseValidationError struct {
	// contains filtered or unexported fields
}

SyncProbesResponseValidationError is the validation error returned by SyncProbesResponse.Validate if the designated constraints aren't met.

func (SyncProbesResponseValidationError) Cause

Cause function returns cause value.

func (SyncProbesResponseValidationError) Error

Error satisfies the builtin error interface

func (SyncProbesResponseValidationError) ErrorName

ErrorName returns error name.

func (SyncProbesResponseValidationError) Field

Field function returns field value.

func (SyncProbesResponseValidationError) Key

Key function returns key value.

func (SyncProbesResponseValidationError) Reason

Reason function returns reason value.

type Task

type Task struct {

	// Task id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Task type.
	Type v1.TaskType `protobuf:"varint,2,opt,name=type,proto3,enum=common.TaskType" json:"type,omitempty"`
	// Task content length.
	ContentLength int64 `protobuf:"varint,3,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// Task total piece count.
	TotalPieceCount int32 `protobuf:"varint,4,opt,name=total_piece_count,json=totalPieceCount,proto3" json:"total_piece_count,omitempty"`
	// Task state.
	State string `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	// Task peer count.
	PeerCount int32 `protobuf:"varint,6,opt,name=peer_count,json=peerCount,proto3" json:"peer_count,omitempty"`
	// Task contains available peer.
	HasAvailablePeer bool `protobuf:"varint,7,opt,name=hasAvailablePeer,proto3" json:"hasAvailablePeer,omitempty"`
	// contains filtered or unexported fields
}

Task represents download task.

func (*Task) Descriptor deprecated

func (*Task) Descriptor() ([]byte, []int)

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetContentLength

func (x *Task) GetContentLength() int64

func (*Task) GetHasAvailablePeer

func (x *Task) GetHasAvailablePeer() bool

func (*Task) GetId

func (x *Task) GetId() string

func (*Task) GetPeerCount

func (x *Task) GetPeerCount() int32

func (*Task) GetState

func (x *Task) GetState() string

func (*Task) GetTotalPieceCount

func (x *Task) GetTotalPieceCount() int32

func (*Task) GetType

func (x *Task) GetType() v1.TaskType

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) ProtoReflect

func (x *Task) ProtoReflect() protoreflect.Message

func (*Task) Reset

func (x *Task) Reset()

func (*Task) String

func (x *Task) String() string

func (*Task) Validate

func (m *Task) Validate() error

Validate checks the field values on Task with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Task) ValidateAll

func (m *Task) ValidateAll() error

ValidateAll checks the field values on Task with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskMultiError, or nil if none found.

type TaskMultiError

type TaskMultiError []error

TaskMultiError is an error wrapping multiple validation errors returned by Task.ValidateAll() if the designated constraints aren't met.

func (TaskMultiError) AllErrors

func (m TaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskMultiError) Error

func (m TaskMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskValidationError

type TaskValidationError struct {
	// contains filtered or unexported fields
}

TaskValidationError is the validation error returned by Task.Validate if the designated constraints aren't met.

func (TaskValidationError) Cause

func (e TaskValidationError) Cause() error

Cause function returns cause value.

func (TaskValidationError) Error

func (e TaskValidationError) Error() string

Error satisfies the builtin error interface

func (TaskValidationError) ErrorName

func (e TaskValidationError) ErrorName() string

ErrorName returns error name.

func (TaskValidationError) Field

func (e TaskValidationError) Field() string

Field function returns field value.

func (TaskValidationError) Key

func (e TaskValidationError) Key() bool

Key function returns key value.

func (TaskValidationError) Reason

func (e TaskValidationError) Reason() string

Reason function returns reason value.

type UnimplementedSchedulerServer

type UnimplementedSchedulerServer struct {
}

UnimplementedSchedulerServer should be embedded to have forward compatible implementations.

func (UnimplementedSchedulerServer) AnnounceHost

func (UnimplementedSchedulerServer) AnnounceTask

func (UnimplementedSchedulerServer) LeaveHost

func (UnimplementedSchedulerServer) LeaveTask

func (UnimplementedSchedulerServer) RegisterPeerTask

func (UnimplementedSchedulerServer) ReportPeerResult

func (UnimplementedSchedulerServer) ReportPieceResult

func (UnimplementedSchedulerServer) StatTask

func (UnimplementedSchedulerServer) SyncProbes

type UnsafeSchedulerServer

type UnsafeSchedulerServer interface {
	// contains filtered or unexported methods
}

UnsafeSchedulerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SchedulerServer will result in compilation errors.

Directories

Path Synopsis
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

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