v2

package
v1.3.2 Latest Latest
Warning

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

 Go to latest Published: Dec 6, 2022 License: Apache-2.0 Imports: 25 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_apis_scheduler_v2_scheduler_proto protoreflect.FileDescriptor

Functions

func RegisterSchedulerServer 

func RegisterSchedulerServer(s *grpc.Server, srv SchedulerServer)

Types

type AnnounceHostRequest added in v1.2.5 

type AnnounceHostRequest struct {

	// Host id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Host type.
	Type uint32 `protobuf:"varint,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 added in v1.2.5 

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

Deprecated: Use AnnounceHostRequest.ProtoReflect.Descriptor instead.

func (*AnnounceHostRequest) GetBuild added in v1.2.5 

func (x *AnnounceHostRequest) GetBuild() *Build

func (*AnnounceHostRequest) GetCpu added in v1.2.5 

func (x *AnnounceHostRequest) GetCpu() *CPU

func (*AnnounceHostRequest) GetDisk added in v1.2.5 

func (x *AnnounceHostRequest) GetDisk() *Disk

func (*AnnounceHostRequest) GetDownloadPort added in v1.2.5 

func (x *AnnounceHostRequest) GetDownloadPort() int32

func (*AnnounceHostRequest) GetHostname added in v1.2.5 

func (x *AnnounceHostRequest) GetHostname() string

func (*AnnounceHostRequest) GetId added in v1.2.5 

func (x *AnnounceHostRequest) GetId() string

func (*AnnounceHostRequest) GetIp added in v1.2.5 

func (x *AnnounceHostRequest) GetIp() string

func (*AnnounceHostRequest) GetKernelVersion added in v1.2.5 

func (x *AnnounceHostRequest) GetKernelVersion() string

func (*AnnounceHostRequest) GetMemory added in v1.2.5 

func (x *AnnounceHostRequest) GetMemory() *Memory

func (*AnnounceHostRequest) GetNetwork added in v1.2.5 

func (x *AnnounceHostRequest) GetNetwork() *Network

func (*AnnounceHostRequest) GetOs added in v1.2.5 

func (x *AnnounceHostRequest) GetOs() string

func (*AnnounceHostRequest) GetPlatform added in v1.2.5 

func (x *AnnounceHostRequest) GetPlatform() string

func (*AnnounceHostRequest) GetPlatformFamily added in v1.2.5 

func (x *AnnounceHostRequest) GetPlatformFamily() string

func (*AnnounceHostRequest) GetPlatformVersion added in v1.2.5 

func (x *AnnounceHostRequest) GetPlatformVersion() string

func (*AnnounceHostRequest) GetPort added in v1.2.5 

func (x *AnnounceHostRequest) GetPort() int32

func (*AnnounceHostRequest) GetType added in v1.2.6 

func (x *AnnounceHostRequest) GetType() uint32

func (*AnnounceHostRequest) ProtoMessage added in v1.2.5 

func (*AnnounceHostRequest) ProtoMessage()

func (*AnnounceHostRequest) ProtoReflect added in v1.2.5 

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

func (*AnnounceHostRequest) Reset added in v1.2.5 

func (x *AnnounceHostRequest) Reset()

func (*AnnounceHostRequest) String added in v1.2.5 

func (x *AnnounceHostRequest) String() string

func (*AnnounceHostRequest) Validate added in v1.2.5 

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 added in v1.2.5 

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 added in v1.2.5 

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 added in v1.2.5 

func (m AnnounceHostRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnounceHostRequestMultiError) Error added in v1.2.5 

func (m AnnounceHostRequestMultiError) Error() string

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

type AnnounceHostRequestValidationError added in v1.2.5 

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 added in v1.2.5 

func (e AnnounceHostRequestValidationError) Cause() error

Cause function returns cause value.

func (AnnounceHostRequestValidationError) Error added in v1.2.5 

func (e AnnounceHostRequestValidationError) Error() string

Error satisfies the builtin error interface

func (AnnounceHostRequestValidationError) ErrorName added in v1.2.5 

func (e AnnounceHostRequestValidationError) ErrorName() string

ErrorName returns error name.

func (AnnounceHostRequestValidationError) Field added in v1.2.5 

func (e AnnounceHostRequestValidationError) Field() string

Field function returns field value.

func (AnnounceHostRequestValidationError) Key added in v1.2.5 

func (e AnnounceHostRequestValidationError) Key() bool

Key function returns key value.

func (AnnounceHostRequestValidationError) Reason added in v1.2.5 

func (e AnnounceHostRequestValidationError) Reason() string

Reason function returns reason value.

type AnnouncePeerRequest 

type AnnouncePeerRequest struct {

	// Types that are assignable to Request:
	//	*AnnouncePeerRequest_RegisterRequest
	//	*AnnouncePeerRequest_PeerDownloadStartedRequest
	//	*AnnouncePeerRequest_PeerDownloadBackToSourceRequest
	//	*AnnouncePeerRequest_PeerDownloadFinishedRequest
	//	*AnnouncePeerRequest_PieceDownloadFinishedRequest
	//	*AnnouncePeerRequest_PeerDownloadBackToSourceFailed
	//	*AnnouncePeerRequest_PieceDownloadFailed
	//	*AnnouncePeerRequest_PieceInfoSyncFailed
	//	*AnnouncePeerRequest_ScheduleFailed
	Request isAnnouncePeerRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

AnnouncePeerRequest represents request of AnnouncePeer.

func (*AnnouncePeerRequest) Descriptor deprecated 

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

Deprecated: Use AnnouncePeerRequest.ProtoReflect.Descriptor instead.

func (*AnnouncePeerRequest) GetPeerDownloadBackToSourceFailed 

func (x *AnnouncePeerRequest) GetPeerDownloadBackToSourceFailed() *v21.PeerDownloadBackToSourceFailed

func (*AnnouncePeerRequest) GetPeerDownloadBackToSourceRequest 

func (x *AnnouncePeerRequest) GetPeerDownloadBackToSourceRequest() *PeerDownloadBackToSourceRequest

func (*AnnouncePeerRequest) GetPeerDownloadFinishedRequest 

func (x *AnnouncePeerRequest) GetPeerDownloadFinishedRequest() *PeerDownloadFinishedRequest

func (*AnnouncePeerRequest) GetPeerDownloadStartedRequest 

func (x *AnnouncePeerRequest) GetPeerDownloadStartedRequest() *PeerDownloadStartedRequest

func (*AnnouncePeerRequest) GetPieceDownloadFailed 

func (x *AnnouncePeerRequest) GetPieceDownloadFailed() *v21.PieceDownloadFailed

func (*AnnouncePeerRequest) GetPieceDownloadFinishedRequest 

func (x *AnnouncePeerRequest) GetPieceDownloadFinishedRequest() *PieceDownloadFinishedRequest

func (*AnnouncePeerRequest) GetPieceInfoSyncFailed 

func (x *AnnouncePeerRequest) GetPieceInfoSyncFailed() *v21.PieceInfoSyncFailed

func (*AnnouncePeerRequest) GetRegisterRequest 

func (x *AnnouncePeerRequest) GetRegisterRequest() *RegisterRequest

func (*AnnouncePeerRequest) GetRequest 

func (m *AnnouncePeerRequest) GetRequest() isAnnouncePeerRequest_Request

func (*AnnouncePeerRequest) GetScheduleFailed 

func (x *AnnouncePeerRequest) GetScheduleFailed() *v21.ScheduleFailed

func (*AnnouncePeerRequest) ProtoMessage 

func (*AnnouncePeerRequest) ProtoMessage()

func (*AnnouncePeerRequest) ProtoReflect 

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

func (*AnnouncePeerRequest) Reset 

func (x *AnnouncePeerRequest) Reset()

func (*AnnouncePeerRequest) String 

func (x *AnnouncePeerRequest) String() string

func (*AnnouncePeerRequest) Validate 

func (m *AnnouncePeerRequest) Validate() error

Validate checks the field values on AnnouncePeerRequest 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 (*AnnouncePeerRequest) ValidateAll 

func (m *AnnouncePeerRequest) ValidateAll() error

ValidateAll checks the field values on AnnouncePeerRequest 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 AnnouncePeerRequestMultiError, or nil if none found.

type AnnouncePeerRequestMultiError 

type AnnouncePeerRequestMultiError []error

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

func (AnnouncePeerRequestMultiError) AllErrors 

func (m AnnouncePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnouncePeerRequestMultiError) Error 

func (m AnnouncePeerRequestMultiError) Error() string

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

type AnnouncePeerRequestValidationError 

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

AnnouncePeerRequestValidationError is the validation error returned by AnnouncePeerRequest.Validate if the designated constraints aren't met.

func (AnnouncePeerRequestValidationError) Cause 

func (e AnnouncePeerRequestValidationError) Cause() error

Cause function returns cause value.

func (AnnouncePeerRequestValidationError) Error 

func (e AnnouncePeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (AnnouncePeerRequestValidationError) ErrorName 

func (e AnnouncePeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (AnnouncePeerRequestValidationError) Field 

func (e AnnouncePeerRequestValidationError) Field() string

Field function returns field value.

func (AnnouncePeerRequestValidationError) Key 

func (e AnnouncePeerRequestValidationError) Key() bool

Key function returns key value.

func (AnnouncePeerRequestValidationError) Reason 

func (e AnnouncePeerRequestValidationError) Reason() string

Reason function returns reason value.

type AnnouncePeerRequest_PeerDownloadBackToSourceFailed 

type AnnouncePeerRequest_PeerDownloadBackToSourceFailed struct {
	PeerDownloadBackToSourceFailed *v21.PeerDownloadBackToSourceFailed `protobuf:"bytes,6,opt,name=peer_download_back_to_source_failed,json=peerDownloadBackToSourceFailed,proto3,oneof"`
}

type AnnouncePeerRequest_PeerDownloadBackToSourceRequest 

type AnnouncePeerRequest_PeerDownloadBackToSourceRequest struct {
	PeerDownloadBackToSourceRequest *PeerDownloadBackToSourceRequest `protobuf:"bytes,3,opt,name=peer_download_back_to_source_request,json=peerDownloadBackToSourceRequest,proto3,oneof"`
}

type AnnouncePeerRequest_PeerDownloadFinishedRequest 

type AnnouncePeerRequest_PeerDownloadFinishedRequest struct {
	PeerDownloadFinishedRequest *PeerDownloadFinishedRequest `protobuf:"bytes,4,opt,name=peer_download_finished_request,json=peerDownloadFinishedRequest,proto3,oneof"`
}

type AnnouncePeerRequest_PeerDownloadStartedRequest 

type AnnouncePeerRequest_PeerDownloadStartedRequest struct {
	PeerDownloadStartedRequest *PeerDownloadStartedRequest `protobuf:"bytes,2,opt,name=peer_download_started_request,json=peerDownloadStartedRequest,proto3,oneof"`
}

type AnnouncePeerRequest_PieceDownloadFailed 

type AnnouncePeerRequest_PieceDownloadFailed struct {
	PieceDownloadFailed *v21.PieceDownloadFailed `protobuf:"bytes,7,opt,name=piece_download_failed,json=pieceDownloadFailed,proto3,oneof"`
}

type AnnouncePeerRequest_PieceDownloadFinishedRequest 

type AnnouncePeerRequest_PieceDownloadFinishedRequest struct {
	PieceDownloadFinishedRequest *PieceDownloadFinishedRequest `protobuf:"bytes,5,opt,name=piece_download_finished_request,json=pieceDownloadFinishedRequest,proto3,oneof"`
}

type AnnouncePeerRequest_PieceInfoSyncFailed 

type AnnouncePeerRequest_PieceInfoSyncFailed struct {
	PieceInfoSyncFailed *v21.PieceInfoSyncFailed `protobuf:"bytes,8,opt,name=piece_info_sync_failed,json=pieceInfoSyncFailed,proto3,oneof"`
}

type AnnouncePeerRequest_RegisterRequest 

type AnnouncePeerRequest_RegisterRequest struct {
	RegisterRequest *RegisterRequest `protobuf:"bytes,1,opt,name=register_request,json=registerRequest,proto3,oneof"`
}

type AnnouncePeerRequest_ScheduleFailed 

type AnnouncePeerRequest_ScheduleFailed struct {
	ScheduleFailed *v21.ScheduleFailed `protobuf:"bytes,9,opt,name=schedule_failed,json=scheduleFailed,proto3,oneof"`
}

type AnnouncePeerResponse 

type AnnouncePeerResponse struct {

	// Types that are assignable to Response:
	//	*AnnouncePeerResponse_TinyTaskResponse
	//	*AnnouncePeerResponse_SmallTaskResponse
	//	*AnnouncePeerResponse_NormalTaskResponse
	//	*AnnouncePeerResponse_NeedBackToSourceResponse
	//	*AnnouncePeerResponse_ScheduleFailed
	Response isAnnouncePeerResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

AnnouncePeerResponse represents response of AnnouncePeer.

func (*AnnouncePeerResponse) Descriptor deprecated 

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

Deprecated: Use AnnouncePeerResponse.ProtoReflect.Descriptor instead.

func (*AnnouncePeerResponse) GetNeedBackToSourceResponse 

func (x *AnnouncePeerResponse) GetNeedBackToSourceResponse() *NeedBackToSourceResponse

func (*AnnouncePeerResponse) GetNormalTaskResponse 

func (x *AnnouncePeerResponse) GetNormalTaskResponse() *NormalTaskResponse

func (*AnnouncePeerResponse) GetResponse 

func (m *AnnouncePeerResponse) GetResponse() isAnnouncePeerResponse_Response

func (*AnnouncePeerResponse) GetScheduleFailed 

func (x *AnnouncePeerResponse) GetScheduleFailed() *v21.ScheduleFailed

func (*AnnouncePeerResponse) GetSmallTaskResponse 

func (x *AnnouncePeerResponse) GetSmallTaskResponse() *SmallTaskResponse

func (*AnnouncePeerResponse) GetTinyTaskResponse 

func (x *AnnouncePeerResponse) GetTinyTaskResponse() *TinyTaskResponse

func (*AnnouncePeerResponse) ProtoMessage 

func (*AnnouncePeerResponse) ProtoMessage()

func (*AnnouncePeerResponse) ProtoReflect 

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

func (*AnnouncePeerResponse) Reset 

func (x *AnnouncePeerResponse) Reset()

func (*AnnouncePeerResponse) String 

func (x *AnnouncePeerResponse) String() string

func (*AnnouncePeerResponse) Validate 

func (m *AnnouncePeerResponse) Validate() error

Validate checks the field values on AnnouncePeerResponse 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 (*AnnouncePeerResponse) ValidateAll 

func (m *AnnouncePeerResponse) ValidateAll() error

ValidateAll checks the field values on AnnouncePeerResponse 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 AnnouncePeerResponseMultiError, or nil if none found.

type AnnouncePeerResponseMultiError 

type AnnouncePeerResponseMultiError []error

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

func (AnnouncePeerResponseMultiError) AllErrors 

func (m AnnouncePeerResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnouncePeerResponseMultiError) Error 

func (m AnnouncePeerResponseMultiError) Error() string

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

type AnnouncePeerResponseValidationError 

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

AnnouncePeerResponseValidationError is the validation error returned by AnnouncePeerResponse.Validate if the designated constraints aren't met.

func (AnnouncePeerResponseValidationError) Cause 

func (e AnnouncePeerResponseValidationError) Cause() error

Cause function returns cause value.

func (AnnouncePeerResponseValidationError) Error 

func (e AnnouncePeerResponseValidationError) Error() string

Error satisfies the builtin error interface

func (AnnouncePeerResponseValidationError) ErrorName 

func (e AnnouncePeerResponseValidationError) ErrorName() string

ErrorName returns error name.

func (AnnouncePeerResponseValidationError) Field 

func (e AnnouncePeerResponseValidationError) Field() string

Field function returns field value.

func (AnnouncePeerResponseValidationError) Key 

func (e AnnouncePeerResponseValidationError) Key() bool

Key function returns key value.

func (AnnouncePeerResponseValidationError) Reason 

func (e AnnouncePeerResponseValidationError) Reason() string

Reason function returns reason value.

type AnnouncePeerResponse_NeedBackToSourceResponse 

type AnnouncePeerResponse_NeedBackToSourceResponse struct {
	NeedBackToSourceResponse *NeedBackToSourceResponse `protobuf:"bytes,4,opt,name=need_back_to_source_response,json=needBackToSourceResponse,proto3,oneof"`
}

type AnnouncePeerResponse_NormalTaskResponse 

type AnnouncePeerResponse_NormalTaskResponse struct {
	NormalTaskResponse *NormalTaskResponse `protobuf:"bytes,3,opt,name=normal_task_response,json=normalTaskResponse,proto3,oneof"`
}

type AnnouncePeerResponse_ScheduleFailed 

type AnnouncePeerResponse_ScheduleFailed struct {
	ScheduleFailed *v21.ScheduleFailed `protobuf:"bytes,5,opt,name=scheduleFailed,proto3,oneof"`
}

type AnnouncePeerResponse_SmallTaskResponse 

type AnnouncePeerResponse_SmallTaskResponse struct {
	SmallTaskResponse *SmallTaskResponse `protobuf:"bytes,2,opt,name=small_task_response,json=smallTaskResponse,proto3,oneof"`
}

type AnnouncePeerResponse_TinyTaskResponse 

type AnnouncePeerResponse_TinyTaskResponse struct {
	TinyTaskResponse *TinyTaskResponse `protobuf:"bytes,1,opt,name=tiny_task_response,json=tinyTaskResponse,proto3,oneof"`
}

type Build added in v1.2.5 

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 added in v1.2.5 

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

Deprecated: Use Build.ProtoReflect.Descriptor instead.

func (*Build) GetGitCommit added in v1.2.5 

func (x *Build) GetGitCommit() string

func (*Build) GetGitVersion added in v1.2.5 

func (x *Build) GetGitVersion() string

func (*Build) GetGoVersion added in v1.2.5 

func (x *Build) GetGoVersion() string

func (*Build) GetPlatform added in v1.2.5 

func (x *Build) GetPlatform() string

func (*Build) ProtoMessage added in v1.2.5 

func (*Build) ProtoMessage()

func (*Build) ProtoReflect added in v1.2.5 

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

func (*Build) Reset added in v1.2.5 

func (x *Build) Reset()

func (*Build) String added in v1.2.5 

func (x *Build) String() string

func (*Build) Validate added in v1.2.5 

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 added in v1.2.5 

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 added in v1.2.5 

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 added in v1.2.5 

func (m BuildMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (BuildMultiError) Error added in v1.2.5 

func (m BuildMultiError) Error() string

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

type BuildValidationError added in v1.2.5 

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 added in v1.2.5 

func (e BuildValidationError) Cause() error

Cause function returns cause value.

func (BuildValidationError) Error added in v1.2.5 

func (e BuildValidationError) Error() string

Error satisfies the builtin error interface

func (BuildValidationError) ErrorName added in v1.2.5 

func (e BuildValidationError) ErrorName() string

ErrorName returns error name.

func (BuildValidationError) Field added in v1.2.5 

func (e BuildValidationError) Field() string

Field function returns field value.

func (BuildValidationError) Key added in v1.2.5 

func (e BuildValidationError) Key() bool

Key function returns key value.

func (BuildValidationError) Reason added in v1.2.5 

func (e BuildValidationError) Reason() string

Reason function returns reason value.

type CPU added in v1.2.5 

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 added in v1.2.5 

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

Deprecated: Use CPU.ProtoReflect.Descriptor instead.

func (*CPU) GetLogicalCount added in v1.2.5 

func (x *CPU) GetLogicalCount() uint32

func (*CPU) GetPercent added in v1.2.5 

func (x *CPU) GetPercent() float64

func (*CPU) GetPhysicalCount added in v1.2.5 

func (x *CPU) GetPhysicalCount() uint32

func (*CPU) GetProcessPercent added in v1.2.5 

func (x *CPU) GetProcessPercent() float64

func (*CPU) GetTimes added in v1.2.5 

func (x *CPU) GetTimes() *CPUTimes

func (*CPU) ProtoMessage added in v1.2.5 

func (*CPU) ProtoMessage()

func (*CPU) ProtoReflect added in v1.2.5 

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

func (*CPU) Reset added in v1.2.5 

func (x *CPU) Reset()

func (*CPU) String added in v1.2.5 

func (x *CPU) String() string

func (*CPU) Validate added in v1.2.5 

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 added in v1.2.5 

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 added in v1.2.5 

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 added in v1.2.5 

func (m CPUMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CPUMultiError) Error added in v1.2.5 

func (m CPUMultiError) Error() string

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

type CPUTimes added in v1.2.5 

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 added in v1.2.5 

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

Deprecated: Use CPUTimes.ProtoReflect.Descriptor instead.

func (*CPUTimes) GetGuest added in v1.2.5 

func (x *CPUTimes) GetGuest() float64

func (*CPUTimes) GetGuestNice added in v1.2.5 

func (x *CPUTimes) GetGuestNice() float64

func (*CPUTimes) GetIdle added in v1.2.5 

func (x *CPUTimes) GetIdle() float64

func (*CPUTimes) GetIowait added in v1.2.5 

func (x *CPUTimes) GetIowait() float64

func (*CPUTimes) GetIrq added in v1.2.5 

func (x *CPUTimes) GetIrq() float64

func (*CPUTimes) GetNice added in v1.2.5 

func (x *CPUTimes) GetNice() float64

func (*CPUTimes) GetSoftirq added in v1.2.5 

func (x *CPUTimes) GetSoftirq() float64

func (*CPUTimes) GetSteal added in v1.2.5 

func (x *CPUTimes) GetSteal() float64

func (*CPUTimes) GetSystem added in v1.2.5 

func (x *CPUTimes) GetSystem() float64

func (*CPUTimes) GetUser added in v1.2.5 

func (x *CPUTimes) GetUser() float64

func (*CPUTimes) ProtoMessage added in v1.2.5 

func (*CPUTimes) ProtoMessage()

func (*CPUTimes) ProtoReflect added in v1.2.5 

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

func (*CPUTimes) Reset added in v1.2.5 

func (x *CPUTimes) Reset()

func (*CPUTimes) String added in v1.2.5 

func (x *CPUTimes) String() string

func (*CPUTimes) Validate added in v1.2.5 

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 added in v1.2.5 

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 added in v1.2.5 

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 added in v1.2.5 

func (m CPUTimesMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CPUTimesMultiError) Error added in v1.2.5 

func (m CPUTimesMultiError) Error() string

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

type CPUTimesValidationError added in v1.2.5 

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 added in v1.2.5 

func (e CPUTimesValidationError) Cause() error

Cause function returns cause value.

func (CPUTimesValidationError) Error added in v1.2.5 

func (e CPUTimesValidationError) Error() string

Error satisfies the builtin error interface

func (CPUTimesValidationError) ErrorName added in v1.2.5 

func (e CPUTimesValidationError) ErrorName() string

ErrorName returns error name.

func (CPUTimesValidationError) Field added in v1.2.5 

func (e CPUTimesValidationError) Field() string

Field function returns field value.

func (CPUTimesValidationError) Key added in v1.2.5 

func (e CPUTimesValidationError) Key() bool

Key function returns key value.

func (CPUTimesValidationError) Reason added in v1.2.5 

func (e CPUTimesValidationError) Reason() string

Reason function returns reason value.

type CPUValidationError added in v1.2.5 

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 added in v1.2.5 

func (e CPUValidationError) Cause() error

Cause function returns cause value.

func (CPUValidationError) Error added in v1.2.5 

func (e CPUValidationError) Error() string

Error satisfies the builtin error interface

func (CPUValidationError) ErrorName added in v1.2.5 

func (e CPUValidationError) ErrorName() string

ErrorName returns error name.

func (CPUValidationError) Field added in v1.2.5 

func (e CPUValidationError) Field() string

Field function returns field value.

func (CPUValidationError) Key added in v1.2.5 

func (e CPUValidationError) Key() bool

Key function returns key value.

func (CPUValidationError) Reason added in v1.2.5 

func (e CPUValidationError) Reason() string

Reason function returns reason value.

type Disk added in v1.2.5 

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 added in v1.2.5 

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

Deprecated: Use Disk.ProtoReflect.Descriptor instead.

func (*Disk) GetFree added in v1.2.5 

func (x *Disk) GetFree() uint64

func (*Disk) GetInodesFree added in v1.2.5 

func (x *Disk) GetInodesFree() uint64

func (*Disk) GetInodesTotal added in v1.2.5 

func (x *Disk) GetInodesTotal() uint64

func (*Disk) GetInodesUsed added in v1.2.5 

func (x *Disk) GetInodesUsed() uint64

func (*Disk) GetInodesUsedPercent added in v1.2.5 

func (x *Disk) GetInodesUsedPercent() float64

func (*Disk) GetTotal added in v1.2.5 

func (x *Disk) GetTotal() uint64

func (*Disk) GetUsed added in v1.2.5 

func (x *Disk) GetUsed() uint64

func (*Disk) GetUsedPercent added in v1.2.5 

func (x *Disk) GetUsedPercent() float64

func (*Disk) ProtoMessage added in v1.2.5 

func (*Disk) ProtoMessage()

func (*Disk) ProtoReflect added in v1.2.5 

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

func (*Disk) Reset added in v1.2.5 

func (x *Disk) Reset()

func (*Disk) String added in v1.2.5 

func (x *Disk) String() string

func (*Disk) Validate added in v1.2.5 

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 added in v1.2.5 

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 added in v1.2.5 

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 added in v1.2.5 

func (m DiskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DiskMultiError) Error added in v1.2.5 

func (m DiskMultiError) Error() string

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

type DiskValidationError added in v1.2.5 

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 added in v1.2.5 

func (e DiskValidationError) Cause() error

Cause function returns cause value.

func (DiskValidationError) Error added in v1.2.5 

func (e DiskValidationError) Error() string

Error satisfies the builtin error interface

func (DiskValidationError) ErrorName added in v1.2.5 

func (e DiskValidationError) ErrorName() string

ErrorName returns error name.

func (DiskValidationError) Field added in v1.2.5 

func (e DiskValidationError) Field() string

Field function returns field value.

func (DiskValidationError) Key added in v1.2.5 

func (e DiskValidationError) Key() bool

Key function returns key value.

func (DiskValidationError) Reason added in v1.2.5 

func (e DiskValidationError) Reason() string

Reason function returns reason value.

type ExchangePeerRequest 

type ExchangePeerRequest 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
}

TODO exchange peer request definition. ExchangePeerRequest represents request of ExchangePeer.

func (*ExchangePeerRequest) Descriptor deprecated 

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

Deprecated: Use ExchangePeerRequest.ProtoReflect.Descriptor instead.

func (*ExchangePeerRequest) GetPeerId added in v1.1.6 

func (x *ExchangePeerRequest) GetPeerId() string

func (*ExchangePeerRequest) GetTaskId added in v1.1.6 

func (x *ExchangePeerRequest) GetTaskId() string

func (*ExchangePeerRequest) ProtoMessage 

func (*ExchangePeerRequest) ProtoMessage()

func (*ExchangePeerRequest) ProtoReflect 

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

func (*ExchangePeerRequest) Reset 

func (x *ExchangePeerRequest) Reset()

func (*ExchangePeerRequest) String 

func (x *ExchangePeerRequest) String() string

func (*ExchangePeerRequest) Validate 

func (m *ExchangePeerRequest) Validate() error

Validate checks the field values on ExchangePeerRequest 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 (*ExchangePeerRequest) ValidateAll 

func (m *ExchangePeerRequest) ValidateAll() error

ValidateAll checks the field values on ExchangePeerRequest 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 ExchangePeerRequestMultiError, or nil if none found.

type ExchangePeerRequestMultiError 

type ExchangePeerRequestMultiError []error

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

func (ExchangePeerRequestMultiError) AllErrors 

func (m ExchangePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExchangePeerRequestMultiError) Error 

func (m ExchangePeerRequestMultiError) Error() string

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

type ExchangePeerRequestValidationError 

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

ExchangePeerRequestValidationError is the validation error returned by ExchangePeerRequest.Validate if the designated constraints aren't met.

func (ExchangePeerRequestValidationError) Cause 

func (e ExchangePeerRequestValidationError) Cause() error

Cause function returns cause value.

func (ExchangePeerRequestValidationError) Error 

func (e ExchangePeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ExchangePeerRequestValidationError) ErrorName 

func (e ExchangePeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ExchangePeerRequestValidationError) Field 

func (e ExchangePeerRequestValidationError) Field() string

Field function returns field value.

func (ExchangePeerRequestValidationError) Key 

func (e ExchangePeerRequestValidationError) Key() bool

Key function returns key value.

func (ExchangePeerRequestValidationError) Reason 

func (e ExchangePeerRequestValidationError) Reason() string

Reason function returns reason value.

type ExchangePeerResponse 

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

TODO exchange peer response definition. ExchangePeerResponse represents response of ExchangePeer.

func (*ExchangePeerResponse) Descriptor deprecated 

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

Deprecated: Use ExchangePeerResponse.ProtoReflect.Descriptor instead.

func (*ExchangePeerResponse) ProtoMessage 

func (*ExchangePeerResponse) ProtoMessage()

func (*ExchangePeerResponse) ProtoReflect 

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

func (*ExchangePeerResponse) Reset 

func (x *ExchangePeerResponse) Reset()

func (*ExchangePeerResponse) String 

func (x *ExchangePeerResponse) String() string

func (*ExchangePeerResponse) Validate 

func (m *ExchangePeerResponse) Validate() error

Validate checks the field values on ExchangePeerResponse 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 (*ExchangePeerResponse) ValidateAll 

func (m *ExchangePeerResponse) ValidateAll() error

ValidateAll checks the field values on ExchangePeerResponse 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 ExchangePeerResponseMultiError, or nil if none found.

type ExchangePeerResponseMultiError 

type ExchangePeerResponseMultiError []error

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

func (ExchangePeerResponseMultiError) AllErrors 

func (m ExchangePeerResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExchangePeerResponseMultiError) Error 

func (m ExchangePeerResponseMultiError) Error() string

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

type ExchangePeerResponseValidationError 

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

ExchangePeerResponseValidationError is the validation error returned by ExchangePeerResponse.Validate if the designated constraints aren't met.

func (ExchangePeerResponseValidationError) Cause 

func (e ExchangePeerResponseValidationError) Cause() error

Cause function returns cause value.

func (ExchangePeerResponseValidationError) Error 

func (e ExchangePeerResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ExchangePeerResponseValidationError) ErrorName 

func (e ExchangePeerResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ExchangePeerResponseValidationError) Field 

func (e ExchangePeerResponseValidationError) Field() string

Field function returns field value.

func (ExchangePeerResponseValidationError) Key 

func (e ExchangePeerResponseValidationError) Key() bool

Key function returns key value.

func (ExchangePeerResponseValidationError) Reason 

func (e ExchangePeerResponseValidationError) Reason() string

Reason function returns reason value.

type Host 

type Host struct {

	// Host id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Host ipv4.
	Ipv4 string `protobuf:"bytes,2,opt,name=ipv4,proto3" json:"ipv4,omitempty"`
	// Host ipv6.
	Ipv6 string `protobuf:"bytes,3,opt,name=ipv6,proto3" json:"ipv6,omitempty"`
	// Peer hostname.
	Hostname string `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,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"`
	// Security domain for network.
	SecurityDomain string `protobuf:"bytes,7,opt,name=security_domain,json=securityDomain,proto3" json:"security_domain,omitempty"`
	// Host location(area, country, province, city, etc.).
	Location []string `protobuf:"bytes,8,rep,name=location,proto3" json:"location,omitempty"`
	// IDC where the peer host is located.
	Idc string `protobuf:"bytes,9,opt,name=idc,proto3" json:"idc,omitempty"`
	// Network topology(switch, router, etc.).
	NetTopology []string `protobuf:"bytes,10,rep,name=net_topology,json=netTopology,proto3" json:"net_topology,omitempty"`
	// contains filtered or unexported fields
}

Host metadata.

func (*Host) Descriptor deprecated 

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

Deprecated: Use Host.ProtoReflect.Descriptor instead.

func (*Host) GetDownloadPort 

func (x *Host) GetDownloadPort() int32

func (*Host) GetHostname 

func (x *Host) GetHostname() string

func (*Host) GetId 

func (x *Host) GetId() string

func (*Host) GetIdc 

func (x *Host) GetIdc() string

func (*Host) GetIpv4 

func (x *Host) GetIpv4() string

func (*Host) GetIpv6 

func (x *Host) GetIpv6() string

func (*Host) GetLocation 

func (x *Host) GetLocation() []string

func (*Host) GetNetTopology 

func (x *Host) GetNetTopology() []string

func (*Host) GetPort 

func (x *Host) GetPort() int32

func (*Host) GetSecurityDomain 

func (x *Host) GetSecurityDomain() string

func (*Host) ProtoMessage 

func (*Host) ProtoMessage()

func (*Host) ProtoReflect 

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

func (*Host) Reset 

func (x *Host) Reset()

func (*Host) String 

func (x *Host) String() string

func (*Host) Validate 

func (m *Host) Validate() error

Validate checks the field values on Host 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 (*Host) ValidateAll 

func (m *Host) ValidateAll() error

ValidateAll checks the field values on Host 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 HostMultiError, or nil if none found.

type HostMultiError 

type HostMultiError []error

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

func (HostMultiError) AllErrors 

func (m HostMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (HostMultiError) Error 

func (m HostMultiError) Error() string

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

type HostValidationError 

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

HostValidationError is the validation error returned by Host.Validate if the designated constraints aren't met.

func (HostValidationError) Cause 

func (e HostValidationError) Cause() error

Cause function returns cause value.

func (HostValidationError) Error 

func (e HostValidationError) Error() string

Error satisfies the builtin error interface

func (HostValidationError) ErrorName 

func (e HostValidationError) ErrorName() string

ErrorName returns error name.

func (HostValidationError) Field 

func (e HostValidationError) Field() string

Field function returns field value.

func (HostValidationError) Key 

func (e HostValidationError) Key() bool

Key function returns key value.

func (HostValidationError) Reason 

func (e HostValidationError) Reason() string

Reason function returns reason value.

type LeaveHostRequest added in v1.2.2 

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 added in v1.2.2 

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

Deprecated: Use LeaveHostRequest.ProtoReflect.Descriptor instead.

func (*LeaveHostRequest) GetId added in v1.2.2 

func (x *LeaveHostRequest) GetId() string

func (*LeaveHostRequest) ProtoMessage added in v1.2.2 

func (*LeaveHostRequest) ProtoMessage()

func (*LeaveHostRequest) ProtoReflect added in v1.2.2 

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

func (*LeaveHostRequest) Reset added in v1.2.2 

func (x *LeaveHostRequest) Reset()

func (*LeaveHostRequest) String added in v1.2.2 

func (x *LeaveHostRequest) String() string

func (*LeaveHostRequest) Validate added in v1.2.2 

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 added in v1.2.2 

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 added in v1.2.2 

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 added in v1.2.2 

func (m LeaveHostRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LeaveHostRequestMultiError) Error added in v1.2.2 

func (m LeaveHostRequestMultiError) Error() string

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

type LeaveHostRequestValidationError added in v1.2.2 

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 added in v1.2.2 

func (e LeaveHostRequestValidationError) Cause() error

Cause function returns cause value.

func (LeaveHostRequestValidationError) Error added in v1.2.2 

func (e LeaveHostRequestValidationError) Error() string

Error satisfies the builtin error interface

func (LeaveHostRequestValidationError) ErrorName added in v1.2.2 

func (e LeaveHostRequestValidationError) ErrorName() string

ErrorName returns error name.

func (LeaveHostRequestValidationError) Field added in v1.2.2 

func (e LeaveHostRequestValidationError) Field() string

Field function returns field value.

func (LeaveHostRequestValidationError) Key added in v1.2.2 

func (e LeaveHostRequestValidationError) Key() bool

Key function returns key value.

func (LeaveHostRequestValidationError) Reason added in v1.2.2 

func (e LeaveHostRequestValidationError) Reason() string

Reason function returns reason value.

type LeavePeerRequest 

type LeavePeerRequest struct {

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

LeavePeerRequest represents request of LeavePeer.

func (*LeavePeerRequest) Descriptor deprecated 

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

Deprecated: Use LeavePeerRequest.ProtoReflect.Descriptor instead.

func (*LeavePeerRequest) GetId added in v1.2.2 

func (x *LeavePeerRequest) GetId() string

func (*LeavePeerRequest) ProtoMessage 

func (*LeavePeerRequest) ProtoMessage()

func (*LeavePeerRequest) ProtoReflect 

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

func (*LeavePeerRequest) Reset 

func (x *LeavePeerRequest) Reset()

func (*LeavePeerRequest) String 

func (x *LeavePeerRequest) String() string

func (*LeavePeerRequest) Validate 

func (m *LeavePeerRequest) Validate() error

Validate checks the field values on LeavePeerRequest 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 (*LeavePeerRequest) ValidateAll 

func (m *LeavePeerRequest) ValidateAll() error

ValidateAll checks the field values on LeavePeerRequest 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 LeavePeerRequestMultiError, or nil if none found.

type LeavePeerRequestMultiError 

type LeavePeerRequestMultiError []error

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

func (LeavePeerRequestMultiError) AllErrors 

func (m LeavePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LeavePeerRequestMultiError) Error 

func (m LeavePeerRequestMultiError) Error() string

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

type LeavePeerRequestValidationError 

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

LeavePeerRequestValidationError is the validation error returned by LeavePeerRequest.Validate if the designated constraints aren't met.

func (LeavePeerRequestValidationError) Cause 

func (e LeavePeerRequestValidationError) Cause() error

Cause function returns cause value.

func (LeavePeerRequestValidationError) Error 

func (e LeavePeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (LeavePeerRequestValidationError) ErrorName 

func (e LeavePeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (LeavePeerRequestValidationError) Field 

func (e LeavePeerRequestValidationError) Field() string

Field function returns field value.

func (LeavePeerRequestValidationError) Key 

func (e LeavePeerRequestValidationError) Key() bool

Key function returns key value.

func (LeavePeerRequestValidationError) Reason 

func (e LeavePeerRequestValidationError) Reason() string

Reason function returns reason value.

type Memory added in v1.2.5 

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 added in v1.2.5 

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

Deprecated: Use Memory.ProtoReflect.Descriptor instead.

func (*Memory) GetAvailable added in v1.2.5 

func (x *Memory) GetAvailable() uint64

func (*Memory) GetFree added in v1.2.5 

func (x *Memory) GetFree() uint64

func (*Memory) GetProcessUsedPercent added in v1.2.5 

func (x *Memory) GetProcessUsedPercent() float64

func (*Memory) GetTotal added in v1.2.5 

func (x *Memory) GetTotal() uint64

func (*Memory) GetUsed added in v1.2.5 

func (x *Memory) GetUsed() uint64

func (*Memory) GetUsedPercent added in v1.2.5 

func (x *Memory) GetUsedPercent() float64

func (*Memory) ProtoMessage added in v1.2.5 

func (*Memory) ProtoMessage()

func (*Memory) ProtoReflect added in v1.2.5 

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

func (*Memory) Reset added in v1.2.5 

func (x *Memory) Reset()

func (*Memory) String added in v1.2.5 

func (x *Memory) String() string

func (*Memory) Validate added in v1.2.5 

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 added in v1.2.5 

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 added in v1.2.5 

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 added in v1.2.5 

func (m MemoryMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (MemoryMultiError) Error added in v1.2.5 

func (m MemoryMultiError) Error() string

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

type MemoryValidationError added in v1.2.5 

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 added in v1.2.5 

func (e MemoryValidationError) Cause() error

Cause function returns cause value.

func (MemoryValidationError) Error added in v1.2.5 

func (e MemoryValidationError) Error() string

Error satisfies the builtin error interface

func (MemoryValidationError) ErrorName added in v1.2.5 

func (e MemoryValidationError) ErrorName() string

ErrorName returns error name.

func (MemoryValidationError) Field added in v1.2.5 

func (e MemoryValidationError) Field() string

Field function returns field value.

func (MemoryValidationError) Key added in v1.2.5 

func (e MemoryValidationError) Key() bool

Key function returns key value.

func (MemoryValidationError) Reason added in v1.2.5 

func (e MemoryValidationError) Reason() string

Reason function returns reason value.

type NeedBackToSourceResponse 

type NeedBackToSourceResponse struct {

	// Download back-to-source reason.
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

NeedBackToSourceResponse represents need back-to-source response of AnnouncePeerResponse.

func (*NeedBackToSourceResponse) Descriptor deprecated 

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

Deprecated: Use NeedBackToSourceResponse.ProtoReflect.Descriptor instead.

func (*NeedBackToSourceResponse) GetReason 

func (x *NeedBackToSourceResponse) GetReason() string

func (*NeedBackToSourceResponse) ProtoMessage 

func (*NeedBackToSourceResponse) ProtoMessage()

func (*NeedBackToSourceResponse) ProtoReflect 

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

func (*NeedBackToSourceResponse) Reset 

func (x *NeedBackToSourceResponse) Reset()

func (*NeedBackToSourceResponse) String 

func (x *NeedBackToSourceResponse) String() string

func (*NeedBackToSourceResponse) Validate 

func (m *NeedBackToSourceResponse) Validate() error

Validate checks the field values on NeedBackToSourceResponse 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 (*NeedBackToSourceResponse) ValidateAll 

func (m *NeedBackToSourceResponse) ValidateAll() error

ValidateAll checks the field values on NeedBackToSourceResponse 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 NeedBackToSourceResponseMultiError, or nil if none found.

type NeedBackToSourceResponseMultiError 

type NeedBackToSourceResponseMultiError []error

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

func (NeedBackToSourceResponseMultiError) AllErrors 

func (m NeedBackToSourceResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NeedBackToSourceResponseMultiError) Error 

func (m NeedBackToSourceResponseMultiError) Error() string

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

type NeedBackToSourceResponseValidationError 

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

NeedBackToSourceResponseValidationError is the validation error returned by NeedBackToSourceResponse.Validate if the designated constraints aren't met.

func (NeedBackToSourceResponseValidationError) Cause 

func (e NeedBackToSourceResponseValidationError) Cause() error

Cause function returns cause value.

func (NeedBackToSourceResponseValidationError) Error 

func (e NeedBackToSourceResponseValidationError) Error() string

Error satisfies the builtin error interface

func (NeedBackToSourceResponseValidationError) ErrorName 

func (e NeedBackToSourceResponseValidationError) ErrorName() string

ErrorName returns error name.

func (NeedBackToSourceResponseValidationError) Field 

func (e NeedBackToSourceResponseValidationError) Field() string

Field function returns field value.

func (NeedBackToSourceResponseValidationError) Key 

func (e NeedBackToSourceResponseValidationError) Key() bool

Key function returns key value.

func (NeedBackToSourceResponseValidationError) Reason 

func (e NeedBackToSourceResponseValidationError) Reason() string

Reason function returns reason value.

type Network added in v1.2.5 

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 */
	// Security domain for network.
	SecurityDomain string `protobuf:"bytes,3,opt,name=security_domain,json=securityDomain,proto3" json:"security_domain,omitempty"`
	// 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"`
	// Network topology(switch|router|...).
	NetTopology string `protobuf:"bytes,6,opt,name=net_topology,json=netTopology,proto3" json:"net_topology,omitempty"`
	// contains filtered or unexported fields
}

Network Stat.

func (*Network) Descriptor deprecated added in v1.2.5 

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

Deprecated: Use Network.ProtoReflect.Descriptor instead.

func (*Network) GetIdc added in v1.2.5 

func (x *Network) GetIdc() string

func (*Network) GetLocation added in v1.2.5 

func (x *Network) GetLocation() string

func (*Network) GetNetTopology added in v1.2.5 

func (x *Network) GetNetTopology() string

func (*Network) GetSecurityDomain added in v1.2.5 

func (x *Network) GetSecurityDomain() string

func (*Network) GetTcpConnectionCount added in v1.2.5 

func (x *Network) GetTcpConnectionCount() uint32

func (*Network) GetUploadTcpConnectionCount added in v1.2.5 

func (x *Network) GetUploadTcpConnectionCount() uint32

func (*Network) ProtoMessage added in v1.2.5 

func (*Network) ProtoMessage()

func (*Network) ProtoReflect added in v1.2.5 

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

func (*Network) Reset added in v1.2.5 

func (x *Network) Reset()

func (*Network) String added in v1.2.5 

func (x *Network) String() string

func (*Network) Validate added in v1.2.5 

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 added in v1.2.5 

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 added in v1.2.5 

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 added in v1.2.5 

func (m NetworkMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NetworkMultiError) Error added in v1.2.5 

func (m NetworkMultiError) Error() string

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

type NetworkValidationError added in v1.2.5 

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 added in v1.2.5 

func (e NetworkValidationError) Cause() error

Cause function returns cause value.

func (NetworkValidationError) Error added in v1.2.5 

func (e NetworkValidationError) Error() string

Error satisfies the builtin error interface

func (NetworkValidationError) ErrorName added in v1.2.5 

func (e NetworkValidationError) ErrorName() string

ErrorName returns error name.

func (NetworkValidationError) Field added in v1.2.5 

func (e NetworkValidationError) Field() string

Field function returns field value.

func (NetworkValidationError) Key added in v1.2.5 

func (e NetworkValidationError) Key() bool

Key function returns key value.

func (NetworkValidationError) Reason added in v1.2.5 

func (e NetworkValidationError) Reason() string

Reason function returns reason value.

type NormalTaskResponse 

type NormalTaskResponse struct {

	// Candidate parents.
	CandidateParents []*Peer `protobuf:"bytes,1,rep,name=candidate_parents,json=candidateParents,proto3" json:"candidate_parents,omitempty"`
	// Concurrent downloading count from main peer.
	ParallelCount int32 `protobuf:"varint,2,opt,name=parallel_count,json=parallelCount,proto3" json:"parallel_count,omitempty"`
	// contains filtered or unexported fields
}

NormalTaskResponse represents normal task response of AnnouncePeerResponse.

func (*NormalTaskResponse) Descriptor deprecated 

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

Deprecated: Use NormalTaskResponse.ProtoReflect.Descriptor instead.

func (*NormalTaskResponse) GetCandidateParents 

func (x *NormalTaskResponse) GetCandidateParents() []*Peer

func (*NormalTaskResponse) GetParallelCount 

func (x *NormalTaskResponse) GetParallelCount() int32

func (*NormalTaskResponse) ProtoMessage 

func (*NormalTaskResponse) ProtoMessage()

func (*NormalTaskResponse) ProtoReflect 

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

func (*NormalTaskResponse) Reset 

func (x *NormalTaskResponse) Reset()

func (*NormalTaskResponse) String 

func (x *NormalTaskResponse) String() string

func (*NormalTaskResponse) Validate 

func (m *NormalTaskResponse) Validate() error

Validate checks the field values on NormalTaskResponse 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 (*NormalTaskResponse) ValidateAll 

func (m *NormalTaskResponse) ValidateAll() error

ValidateAll checks the field values on NormalTaskResponse 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 NormalTaskResponseMultiError, or nil if none found.

type NormalTaskResponseMultiError 

type NormalTaskResponseMultiError []error

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

func (NormalTaskResponseMultiError) AllErrors 

func (m NormalTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NormalTaskResponseMultiError) Error 

func (m NormalTaskResponseMultiError) Error() string

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

type NormalTaskResponseValidationError 

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

NormalTaskResponseValidationError is the validation error returned by NormalTaskResponse.Validate if the designated constraints aren't met.

func (NormalTaskResponseValidationError) Cause 

func (e NormalTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (NormalTaskResponseValidationError) Error 

func (e NormalTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (NormalTaskResponseValidationError) ErrorName 

func (e NormalTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (NormalTaskResponseValidationError) Field 

func (e NormalTaskResponseValidationError) Field() string

Field function returns field value.

func (NormalTaskResponseValidationError) Key 

func (e NormalTaskResponseValidationError) Key() bool

Key function returns key value.

func (NormalTaskResponseValidationError) Reason 

func (e NormalTaskResponseValidationError) Reason() string

Reason function returns reason value.

type Peer 

type Peer struct {

	// Peer id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Pieces of peer.
	Pieces []*v2.Piece `protobuf:"bytes,2,rep,name=pieces,proto3" json:"pieces,omitempty"`
	// Task info.
	Task *Task `protobuf:"bytes,3,opt,name=task,proto3" json:"task,omitempty"`
	// Host info.
	Host *Host `protobuf:"bytes,4,opt,name=host,proto3" json:"host,omitempty"`
	// Peer state.
	State string `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	// Peer create time.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Peer update time.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

Peer metadata.

func (*Peer) Descriptor deprecated 

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

Deprecated: Use Peer.ProtoReflect.Descriptor instead.

func (*Peer) GetCreatedAt 

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

func (*Peer) GetHost 

func (x *Peer) GetHost() *Host

func (*Peer) GetId 

func (x *Peer) GetId() string

func (*Peer) GetPieces 

func (x *Peer) GetPieces() []*v2.Piece

func (*Peer) GetState 

func (x *Peer) GetState() string

func (*Peer) GetTask 

func (x *Peer) GetTask() *Task

func (*Peer) GetUpdatedAt 

func (x *Peer) GetUpdatedAt() *timestamppb.Timestamp

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) ProtoReflect 

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

func (*Peer) Reset 

func (x *Peer) Reset()

func (*Peer) String 

func (x *Peer) String() string

func (*Peer) Validate 

func (m *Peer) Validate() error

Validate checks the field values on Peer 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 (*Peer) ValidateAll 

func (m *Peer) ValidateAll() error

ValidateAll checks the field values on Peer 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 PeerMultiError, or nil if none found.

type PeerDownloadBackToSourceRequest 

type PeerDownloadBackToSourceRequest struct {

	// Download back-to-source reason.
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

PeerDownloadBackToSourceRequest represents peer download back-to-source request of AnnouncePeerRequest.

func (*PeerDownloadBackToSourceRequest) Descriptor deprecated 

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

Deprecated: Use PeerDownloadBackToSourceRequest.ProtoReflect.Descriptor instead.

func (*PeerDownloadBackToSourceRequest) GetReason 

func (x *PeerDownloadBackToSourceRequest) GetReason() string

func (*PeerDownloadBackToSourceRequest) ProtoMessage 

func (*PeerDownloadBackToSourceRequest) ProtoMessage()

func (*PeerDownloadBackToSourceRequest) ProtoReflect 

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

func (*PeerDownloadBackToSourceRequest) Reset 

func (x *PeerDownloadBackToSourceRequest) Reset()

func (*PeerDownloadBackToSourceRequest) String 

func (x *PeerDownloadBackToSourceRequest) String() string

func (*PeerDownloadBackToSourceRequest) Validate 

func (m *PeerDownloadBackToSourceRequest) Validate() error

Validate checks the field values on PeerDownloadBackToSourceRequest 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 (*PeerDownloadBackToSourceRequest) ValidateAll 

func (m *PeerDownloadBackToSourceRequest) ValidateAll() error

ValidateAll checks the field values on PeerDownloadBackToSourceRequest 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 PeerDownloadBackToSourceRequestMultiError, or nil if none found.

type PeerDownloadBackToSourceRequestMultiError 

type PeerDownloadBackToSourceRequestMultiError []error

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

func (PeerDownloadBackToSourceRequestMultiError) AllErrors 

func (m PeerDownloadBackToSourceRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerDownloadBackToSourceRequestMultiError) Error 

func (m PeerDownloadBackToSourceRequestMultiError) Error() string

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

type PeerDownloadBackToSourceRequestValidationError 

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

PeerDownloadBackToSourceRequestValidationError is the validation error returned by PeerDownloadBackToSourceRequest.Validate if the designated constraints aren't met.

func (PeerDownloadBackToSourceRequestValidationError) Cause 

func (e PeerDownloadBackToSourceRequestValidationError) Cause() error

Cause function returns cause value.

func (PeerDownloadBackToSourceRequestValidationError) Error 

func (e PeerDownloadBackToSourceRequestValidationError) Error() string

Error satisfies the builtin error interface

func (PeerDownloadBackToSourceRequestValidationError) ErrorName 

func (e PeerDownloadBackToSourceRequestValidationError) ErrorName() string

ErrorName returns error name.

func (PeerDownloadBackToSourceRequestValidationError) Field 

func (e PeerDownloadBackToSourceRequestValidationError) Field() string

Field function returns field value.

func (PeerDownloadBackToSourceRequestValidationError) Key 

func (e PeerDownloadBackToSourceRequestValidationError) Key() bool

Key function returns key value.

func (PeerDownloadBackToSourceRequestValidationError) Reason 

func (e PeerDownloadBackToSourceRequestValidationError) Reason() string

Reason function returns reason value.

type PeerDownloadFinishedRequest 

type PeerDownloadFinishedRequest struct {

	// Total content length.
	ContentLength int64 `protobuf:"varint,1,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// Total piece count.
	PieceCount int64 `protobuf:"varint,2,opt,name=piece_count,json=pieceCount,proto3" json:"piece_count,omitempty"`
	// contains filtered or unexported fields
}

PeerDownloadFinishedRequest represents peer download finished request of AnnouncePeerRequest.

func (*PeerDownloadFinishedRequest) Descriptor deprecated 

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

Deprecated: Use PeerDownloadFinishedRequest.ProtoReflect.Descriptor instead.

func (*PeerDownloadFinishedRequest) GetContentLength 

func (x *PeerDownloadFinishedRequest) GetContentLength() int64

func (*PeerDownloadFinishedRequest) GetPieceCount added in v1.2.3 

func (x *PeerDownloadFinishedRequest) GetPieceCount() int64

func (*PeerDownloadFinishedRequest) ProtoMessage 

func (*PeerDownloadFinishedRequest) ProtoMessage()

func (*PeerDownloadFinishedRequest) ProtoReflect 

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

func (*PeerDownloadFinishedRequest) Reset 

func (x *PeerDownloadFinishedRequest) Reset()

func (*PeerDownloadFinishedRequest) String 

func (x *PeerDownloadFinishedRequest) String() string

func (*PeerDownloadFinishedRequest) Validate 

func (m *PeerDownloadFinishedRequest) Validate() error

Validate checks the field values on PeerDownloadFinishedRequest 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 (*PeerDownloadFinishedRequest) ValidateAll 

func (m *PeerDownloadFinishedRequest) ValidateAll() error

ValidateAll checks the field values on PeerDownloadFinishedRequest 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 PeerDownloadFinishedRequestMultiError, or nil if none found.

type PeerDownloadFinishedRequestMultiError 

type PeerDownloadFinishedRequestMultiError []error

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

func (PeerDownloadFinishedRequestMultiError) AllErrors 

func (m PeerDownloadFinishedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerDownloadFinishedRequestMultiError) Error 

func (m PeerDownloadFinishedRequestMultiError) Error() string

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

type PeerDownloadFinishedRequestValidationError 

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

PeerDownloadFinishedRequestValidationError is the validation error returned by PeerDownloadFinishedRequest.Validate if the designated constraints aren't met.

func (PeerDownloadFinishedRequestValidationError) Cause 

func (e PeerDownloadFinishedRequestValidationError) Cause() error

Cause function returns cause value.

func (PeerDownloadFinishedRequestValidationError) Error 

func (e PeerDownloadFinishedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (PeerDownloadFinishedRequestValidationError) ErrorName 

func (e PeerDownloadFinishedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (PeerDownloadFinishedRequestValidationError) Field 

func (e PeerDownloadFinishedRequestValidationError) Field() string

Field function returns field value.

func (PeerDownloadFinishedRequestValidationError) Key 

func (e PeerDownloadFinishedRequestValidationError) Key() bool

Key function returns key value.

func (PeerDownloadFinishedRequestValidationError) Reason 

func (e PeerDownloadFinishedRequestValidationError) Reason() string

Reason function returns reason value.

type PeerDownloadStartedRequest 

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

TaskDownloadStartedRequest represents peer download started request of AnnouncePeerRequest.

func (*PeerDownloadStartedRequest) Descriptor deprecated 

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

Deprecated: Use PeerDownloadStartedRequest.ProtoReflect.Descriptor instead.

func (*PeerDownloadStartedRequest) ProtoMessage 

func (*PeerDownloadStartedRequest) ProtoMessage()

func (*PeerDownloadStartedRequest) ProtoReflect 

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

func (*PeerDownloadStartedRequest) Reset 

func (x *PeerDownloadStartedRequest) Reset()

func (*PeerDownloadStartedRequest) String 

func (x *PeerDownloadStartedRequest) String() string

func (*PeerDownloadStartedRequest) Validate 

func (m *PeerDownloadStartedRequest) Validate() error

Validate checks the field values on PeerDownloadStartedRequest 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 (*PeerDownloadStartedRequest) ValidateAll 

func (m *PeerDownloadStartedRequest) ValidateAll() error

ValidateAll checks the field values on PeerDownloadStartedRequest 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 PeerDownloadStartedRequestMultiError, or nil if none found.

type PeerDownloadStartedRequestMultiError 

type PeerDownloadStartedRequestMultiError []error

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

func (PeerDownloadStartedRequestMultiError) AllErrors 

func (m PeerDownloadStartedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerDownloadStartedRequestMultiError) Error 

func (m PeerDownloadStartedRequestMultiError) Error() string

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

type PeerDownloadStartedRequestValidationError 

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

PeerDownloadStartedRequestValidationError is the validation error returned by PeerDownloadStartedRequest.Validate if the designated constraints aren't met.

func (PeerDownloadStartedRequestValidationError) Cause 

func (e PeerDownloadStartedRequestValidationError) Cause() error

Cause function returns cause value.

func (PeerDownloadStartedRequestValidationError) Error 

func (e PeerDownloadStartedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (PeerDownloadStartedRequestValidationError) ErrorName 

func (e PeerDownloadStartedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (PeerDownloadStartedRequestValidationError) Field 

func (e PeerDownloadStartedRequestValidationError) Field() string

Field function returns field value.

func (PeerDownloadStartedRequestValidationError) Key 

func (e PeerDownloadStartedRequestValidationError) Key() bool

Key function returns key value.

func (PeerDownloadStartedRequestValidationError) Reason 

func (e PeerDownloadStartedRequestValidationError) Reason() string

Reason function returns reason value.

type PeerMultiError 

type PeerMultiError []error

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

func (PeerMultiError) AllErrors 

func (m PeerMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerMultiError) Error 

func (m PeerMultiError) Error() string

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

type PeerValidationError 

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

PeerValidationError is the validation error returned by Peer.Validate if the designated constraints aren't met.

func (PeerValidationError) Cause 

func (e PeerValidationError) Cause() error

Cause function returns cause value.

func (PeerValidationError) Error 

func (e PeerValidationError) Error() string

Error satisfies the builtin error interface

func (PeerValidationError) ErrorName 

func (e PeerValidationError) ErrorName() string

ErrorName returns error name.

func (PeerValidationError) Field 

func (e PeerValidationError) Field() string

Field function returns field value.

func (PeerValidationError) Key 

func (e PeerValidationError) Key() bool

Key function returns key value.

func (PeerValidationError) Reason 

func (e PeerValidationError) Reason() string

Reason function returns reason value.

type PieceDownloadFinishedRequest 

type PieceDownloadFinishedRequest struct {

	// Piece info.
	Piece *v2.Piece `protobuf:"bytes,1,opt,name=piece,proto3" json:"piece,omitempty"`
	// contains filtered or unexported fields
}

PieceDownloadFinishedRequest represents piece download finished request of AnnouncePeerRequest.

func (*PieceDownloadFinishedRequest) Descriptor deprecated 

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

Deprecated: Use PieceDownloadFinishedRequest.ProtoReflect.Descriptor instead.

func (*PieceDownloadFinishedRequest) GetPiece 

func (x *PieceDownloadFinishedRequest) GetPiece() *v2.Piece

func (*PieceDownloadFinishedRequest) ProtoMessage 

func (*PieceDownloadFinishedRequest) ProtoMessage()

func (*PieceDownloadFinishedRequest) ProtoReflect 

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

func (*PieceDownloadFinishedRequest) Reset 

func (x *PieceDownloadFinishedRequest) Reset()

func (*PieceDownloadFinishedRequest) String 

func (x *PieceDownloadFinishedRequest) String() string

func (*PieceDownloadFinishedRequest) Validate 

func (m *PieceDownloadFinishedRequest) Validate() error

Validate checks the field values on PieceDownloadFinishedRequest 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 (*PieceDownloadFinishedRequest) ValidateAll 

func (m *PieceDownloadFinishedRequest) ValidateAll() error

ValidateAll checks the field values on PieceDownloadFinishedRequest 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 PieceDownloadFinishedRequestMultiError, or nil if none found.

type PieceDownloadFinishedRequestMultiError 

type PieceDownloadFinishedRequestMultiError []error

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

func (PieceDownloadFinishedRequestMultiError) AllErrors 

func (m PieceDownloadFinishedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PieceDownloadFinishedRequestMultiError) Error 

func (m PieceDownloadFinishedRequestMultiError) Error() string

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

type PieceDownloadFinishedRequestValidationError 

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

PieceDownloadFinishedRequestValidationError is the validation error returned by PieceDownloadFinishedRequest.Validate if the designated constraints aren't met.

func (PieceDownloadFinishedRequestValidationError) Cause 

func (e PieceDownloadFinishedRequestValidationError) Cause() error

Cause function returns cause value.

func (PieceDownloadFinishedRequestValidationError) Error 

func (e PieceDownloadFinishedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (PieceDownloadFinishedRequestValidationError) ErrorName 

func (e PieceDownloadFinishedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (PieceDownloadFinishedRequestValidationError) Field 

func (e PieceDownloadFinishedRequestValidationError) Field() string

Field function returns field value.

func (PieceDownloadFinishedRequestValidationError) Key 

func (e PieceDownloadFinishedRequestValidationError) Key() bool

Key function returns key value.

func (PieceDownloadFinishedRequestValidationError) Reason 

func (e PieceDownloadFinishedRequestValidationError) Reason() string

Reason function returns reason value.

type RegisterRequest 

type RegisterRequest 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"`
	// Task metadata.
	Metadata *v2.Metadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Host info.
	Host *Host `protobuf:"bytes,4,opt,name=host,proto3" json:"host,omitempty"`
	// Task type.
	TaskType v2.TaskType `protobuf:"varint,5,opt,name=task_type,json=taskType,proto3,enum=common.TaskType" json:"task_type,omitempty"`
	// contains filtered or unexported fields
}

RegisteredRequest represents registered request of AnnouncePeerRequest.

func (*RegisterRequest) Descriptor deprecated 

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetHost 

func (x *RegisterRequest) GetHost() *Host

func (*RegisterRequest) GetMetadata 

func (x *RegisterRequest) GetMetadata() *v2.Metadata

func (*RegisterRequest) GetPeerId 

func (x *RegisterRequest) GetPeerId() string

func (*RegisterRequest) GetTaskId 

func (x *RegisterRequest) GetTaskId() string

func (*RegisterRequest) GetTaskType 

func (x *RegisterRequest) GetTaskType() v2.TaskType

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect 

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

func (*RegisterRequest) Reset 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (x *RegisterRequest) String() string

func (*RegisterRequest) Validate 

func (m *RegisterRequest) Validate() error

Validate checks the field values on RegisterRequest 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 (*RegisterRequest) ValidateAll 

func (m *RegisterRequest) ValidateAll() error

ValidateAll checks the field values on RegisterRequest 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 RegisterRequestMultiError, or nil if none found.

type RegisterRequestMultiError 

type RegisterRequestMultiError []error

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

func (RegisterRequestMultiError) AllErrors 

func (m RegisterRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RegisterRequestMultiError) Error 

func (m RegisterRequestMultiError) Error() string

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

type RegisterRequestValidationError 

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

RegisterRequestValidationError is the validation error returned by RegisterRequest.Validate if the designated constraints aren't met.

func (RegisterRequestValidationError) Cause 

func (e RegisterRequestValidationError) Cause() error

Cause function returns cause value.

func (RegisterRequestValidationError) Error 

func (e RegisterRequestValidationError) Error() string

Error satisfies the builtin error interface

func (RegisterRequestValidationError) ErrorName 

func (e RegisterRequestValidationError) ErrorName() string

ErrorName returns error name.

func (RegisterRequestValidationError) Field 

func (e RegisterRequestValidationError) Field() string

Field function returns field value.

func (RegisterRequestValidationError) Key 

func (e RegisterRequestValidationError) Key() bool

Key function returns key value.

func (RegisterRequestValidationError) Reason 

func (e RegisterRequestValidationError) Reason() string

Reason function returns reason value.

type SchedulerClient 

type SchedulerClient interface {
	// AnnouncePeer announces peer to scheduler.
	AnnouncePeer(ctx context.Context, opts ...grpc.CallOption) (Scheduler_AnnouncePeerClient, error)
	// Checks information of peer.
	StatPeer(ctx context.Context, in *StatPeerRequest, opts ...grpc.CallOption) (*Peer, error)
	// LeavePeer releases peer in scheduler.
	LeavePeer(ctx context.Context, in *LeavePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// TODO exchange peer api definition.
	// ExchangePeer exchanges peer information.
	ExchangePeer(ctx context.Context, in *ExchangePeerRequest, opts ...grpc.CallOption) (*ExchangePeerResponse, error)
	// Checks information of task.
	StatTask(ctx context.Context, in *StatTaskRequest, opts ...grpc.CallOption) (*Task, error)
	// AnnounceHost announces host to scheduler.
	AnnounceHost(ctx context.Context, in *AnnounceHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// LeaveHost releases host in scheduler.
	LeaveHost(ctx context.Context, in *LeaveHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

SchedulerClient is the client API for Scheduler service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSchedulerClient 

func NewSchedulerClient(cc grpc.ClientConnInterface) SchedulerClient

type SchedulerServer 

type SchedulerServer interface {
	// AnnouncePeer announces peer to scheduler.
	AnnouncePeer(Scheduler_AnnouncePeerServer) error
	// Checks information of peer.
	StatPeer(context.Context, *StatPeerRequest) (*Peer, error)
	// LeavePeer releases peer in scheduler.
	LeavePeer(context.Context, *LeavePeerRequest) (*emptypb.Empty, error)
	// TODO exchange peer api definition.
	// ExchangePeer exchanges peer information.
	ExchangePeer(context.Context, *ExchangePeerRequest) (*ExchangePeerResponse, error)
	// Checks information of task.
	StatTask(context.Context, *StatTaskRequest) (*Task, error)
	// AnnounceHost announces host to scheduler.
	AnnounceHost(context.Context, *AnnounceHostRequest) (*emptypb.Empty, error)
	// LeaveHost releases host in scheduler.
	LeaveHost(context.Context, *LeaveHostRequest) (*emptypb.Empty, error)
}

SchedulerServer is the server API for Scheduler service.

type Scheduler_AnnouncePeerClient 

type Scheduler_AnnouncePeerClient interface {
	Send(*AnnouncePeerRequest) error
	Recv() (*AnnouncePeerResponse, error)
	grpc.ClientStream
}

type Scheduler_AnnouncePeerServer 

type Scheduler_AnnouncePeerServer interface {
	Send(*AnnouncePeerResponse) error
	Recv() (*AnnouncePeerRequest, error)
	grpc.ServerStream
}

type SmallTaskResponse 

type SmallTaskResponse struct {

	// Piece info.
	Piece *v2.Piece `protobuf:"bytes,1,opt,name=piece,proto3" json:"piece,omitempty"`
	// contains filtered or unexported fields
}

SmallTaskResponse represents small task response of AnnouncePeerResponse.

func (*SmallTaskResponse) Descriptor deprecated 

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

Deprecated: Use SmallTaskResponse.ProtoReflect.Descriptor instead.

func (*SmallTaskResponse) GetPiece 

func (x *SmallTaskResponse) GetPiece() *v2.Piece

func (*SmallTaskResponse) ProtoMessage 

func (*SmallTaskResponse) ProtoMessage()

func (*SmallTaskResponse) ProtoReflect 

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

func (*SmallTaskResponse) Reset 

func (x *SmallTaskResponse) Reset()

func (*SmallTaskResponse) String 

func (x *SmallTaskResponse) String() string

func (*SmallTaskResponse) Validate 

func (m *SmallTaskResponse) Validate() error

Validate checks the field values on SmallTaskResponse 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 (*SmallTaskResponse) ValidateAll 

func (m *SmallTaskResponse) ValidateAll() error

ValidateAll checks the field values on SmallTaskResponse 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 SmallTaskResponseMultiError, or nil if none found.

type SmallTaskResponseMultiError 

type SmallTaskResponseMultiError []error

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

func (SmallTaskResponseMultiError) AllErrors 

func (m SmallTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SmallTaskResponseMultiError) Error 

func (m SmallTaskResponseMultiError) Error() string

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

type SmallTaskResponseValidationError 

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

SmallTaskResponseValidationError is the validation error returned by SmallTaskResponse.Validate if the designated constraints aren't met.

func (SmallTaskResponseValidationError) Cause 

func (e SmallTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (SmallTaskResponseValidationError) Error 

func (e SmallTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (SmallTaskResponseValidationError) ErrorName 

func (e SmallTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (SmallTaskResponseValidationError) Field 

func (e SmallTaskResponseValidationError) Field() string

Field function returns field value.

func (SmallTaskResponseValidationError) Key 

func (e SmallTaskResponseValidationError) Key() bool

Key function returns key value.

func (SmallTaskResponseValidationError) Reason 

func (e SmallTaskResponseValidationError) Reason() string

Reason function returns reason value.

type StatPeerRequest 

type StatPeerRequest 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
}

StatPeerRequest represents request of StatPeer.

func (*StatPeerRequest) Descriptor deprecated 

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

Deprecated: Use StatPeerRequest.ProtoReflect.Descriptor instead.

func (*StatPeerRequest) GetPeerId 

func (x *StatPeerRequest) GetPeerId() string

func (*StatPeerRequest) GetTaskId added in v1.1.6 

func (x *StatPeerRequest) GetTaskId() string

func (*StatPeerRequest) ProtoMessage 

func (*StatPeerRequest) ProtoMessage()

func (*StatPeerRequest) ProtoReflect 

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

func (*StatPeerRequest) Reset 

func (x *StatPeerRequest) Reset()

func (*StatPeerRequest) String 

func (x *StatPeerRequest) String() string

func (*StatPeerRequest) Validate 

func (m *StatPeerRequest) Validate() error

Validate checks the field values on StatPeerRequest 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 (*StatPeerRequest) ValidateAll 

func (m *StatPeerRequest) ValidateAll() error

ValidateAll checks the field values on StatPeerRequest 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 StatPeerRequestMultiError, or nil if none found.

type StatPeerRequestMultiError 

type StatPeerRequestMultiError []error

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

func (StatPeerRequestMultiError) AllErrors 

func (m StatPeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatPeerRequestMultiError) Error 

func (m StatPeerRequestMultiError) Error() string

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

type StatPeerRequestValidationError 

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

StatPeerRequestValidationError is the validation error returned by StatPeerRequest.Validate if the designated constraints aren't met.

func (StatPeerRequestValidationError) Cause 

func (e StatPeerRequestValidationError) Cause() error

Cause function returns cause value.

func (StatPeerRequestValidationError) Error 

func (e StatPeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatPeerRequestValidationError) ErrorName 

func (e StatPeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatPeerRequestValidationError) Field 

func (e StatPeerRequestValidationError) Field() string

Field function returns field value.

func (StatPeerRequestValidationError) Key 

func (e StatPeerRequestValidationError) Key() bool

Key function returns key value.

func (StatPeerRequestValidationError) Reason 

func (e StatPeerRequestValidationError) Reason() string

Reason function returns reason value.

type StatTaskRequest 

type StatTaskRequest struct {

	// Task id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"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) GetId added in v1.2.2 

func (x *StatTaskRequest) GetId() 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 

func (m StatTaskRequestMultiError) Error() string

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 

func (e StatTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (StatTaskRequestValidationError) Error 

func (e StatTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatTaskRequestValidationError) ErrorName 

func (e StatTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatTaskRequestValidationError) Field 

func (e StatTaskRequestValidationError) Field() string

Field function returns field value.

func (StatTaskRequestValidationError) Key 

func (e StatTaskRequestValidationError) Key() bool

Key function returns key value.

func (StatTaskRequestValidationError) Reason 

func (e StatTaskRequestValidationError) Reason() string

Reason function returns reason value.

type Task 

type Task struct {

	// Task 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"`
	// Task size scope.
	SizeScope v2.SizeScope `protobuf:"varint,3,opt,name=size_scope,json=sizeScope,proto3,enum=common.SizeScope" json:"size_scope,omitempty"`
	// Pieces of task.
	Pieces []*v2.Piece `protobuf:"bytes,4,rep,name=pieces,proto3" json:"pieces,omitempty"`
	// Task state.
	State string `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	// Task metadata.
	Metadata *v2.Metadata `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Task content length.
	ContentLength int64 `protobuf:"varint,7,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// Task peer count.
	PeerCount int32 `protobuf:"varint,8,opt,name=peer_count,json=peerCount,proto3" json:"peer_count,omitempty"`
	// Task contains available peer.
	HasAvailablePeer bool `protobuf:"varint,9,opt,name=hasAvailablePeer,proto3" json:"hasAvailablePeer,omitempty"`
	// Task create time.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Task update time.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

Task metadata.

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) GetCreatedAt 

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

func (*Task) GetHasAvailablePeer 

func (x *Task) GetHasAvailablePeer() bool

func (*Task) GetId 

func (x *Task) GetId() string

func (*Task) GetMetadata 

func (x *Task) GetMetadata() *v2.Metadata

func (*Task) GetPeerCount 

func (x *Task) GetPeerCount() int32

func (*Task) GetPieces 

func (x *Task) GetPieces() []*v2.Piece

func (*Task) GetSizeScope 

func (x *Task) GetSizeScope() v2.SizeScope

func (*Task) GetState 

func (x *Task) GetState() string

func (*Task) GetType 

func (x *Task) GetType() string

func (*Task) GetUpdatedAt 

func (x *Task) GetUpdatedAt() *timestamppb.Timestamp

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 TinyTaskResponse 

type TinyTaskResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

TinyTaskResponse represents tiny task response of AnnouncePeerResponse.

func (*TinyTaskResponse) Descriptor deprecated 

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

Deprecated: Use TinyTaskResponse.ProtoReflect.Descriptor instead.

func (*TinyTaskResponse) GetData 

func (x *TinyTaskResponse) GetData() []byte

func (*TinyTaskResponse) ProtoMessage 

func (*TinyTaskResponse) ProtoMessage()

func (*TinyTaskResponse) ProtoReflect 

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

func (*TinyTaskResponse) Reset 

func (x *TinyTaskResponse) Reset()

func (*TinyTaskResponse) String 

func (x *TinyTaskResponse) String() string

func (*TinyTaskResponse) Validate 

func (m *TinyTaskResponse) Validate() error

Validate checks the field values on TinyTaskResponse 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 (*TinyTaskResponse) ValidateAll 

func (m *TinyTaskResponse) ValidateAll() error

ValidateAll checks the field values on TinyTaskResponse 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 TinyTaskResponseMultiError, or nil if none found.

type TinyTaskResponseMultiError 

type TinyTaskResponseMultiError []error

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

func (TinyTaskResponseMultiError) AllErrors 

func (m TinyTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TinyTaskResponseMultiError) Error 

func (m TinyTaskResponseMultiError) Error() string

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

type TinyTaskResponseValidationError 

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

TinyTaskResponseValidationError is the validation error returned by TinyTaskResponse.Validate if the designated constraints aren't met.

func (TinyTaskResponseValidationError) Cause 

func (e TinyTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (TinyTaskResponseValidationError) Error 

func (e TinyTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (TinyTaskResponseValidationError) ErrorName 

func (e TinyTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (TinyTaskResponseValidationError) Field 

func (e TinyTaskResponseValidationError) Field() string

Field function returns field value.

func (TinyTaskResponseValidationError) Key 

func (e TinyTaskResponseValidationError) Key() bool

Key function returns key value.

func (TinyTaskResponseValidationError) Reason 

func (e TinyTaskResponseValidationError) Reason() string

Reason function returns reason value.

type UnimplementedSchedulerServer 

type UnimplementedSchedulerServer struct {
}

UnimplementedSchedulerServer can be embedded to have forward compatible implementations.

func (*UnimplementedSchedulerServer) AnnounceHost added in v1.2.5 

func (*UnimplementedSchedulerServer) AnnounceHost(context.Context, *AnnounceHostRequest) (*emptypb.Empty, error)

func (*UnimplementedSchedulerServer) AnnouncePeer 

func (*UnimplementedSchedulerServer) AnnouncePeer(Scheduler_AnnouncePeerServer) error

func (*UnimplementedSchedulerServer) ExchangePeer 

func (*UnimplementedSchedulerServer) ExchangePeer(context.Context, *ExchangePeerRequest) (*ExchangePeerResponse, error)

func (*UnimplementedSchedulerServer) LeaveHost added in v1.2.2 

func (*UnimplementedSchedulerServer) LeaveHost(context.Context, *LeaveHostRequest) (*emptypb.Empty, error)

func (*UnimplementedSchedulerServer) LeavePeer 

func (*UnimplementedSchedulerServer) LeavePeer(context.Context, *LeavePeerRequest) (*emptypb.Empty, error)

func (*UnimplementedSchedulerServer) StatPeer 

func (*UnimplementedSchedulerServer) StatPeer(context.Context, *StatPeerRequest) (*Peer, error)

func (*UnimplementedSchedulerServer) StatTask 

func (*UnimplementedSchedulerServer) StatTask(context.Context, *StatTaskRequest) (*Task, error)

Source Files

View all Source files

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
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.