v1

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Aug 2, 2022 License: Apache-2.0 Imports: 24 Imported by: 12

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_apis_scheduler_v1_scheduler_proto protoreflect.FileDescriptor

Functions

func RegisterSchedulerServer 

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

Types

type AnnounceTaskRequest 

type AnnounceTaskRequest struct {

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

AnnounceTaskRequest represents request of AnnounceTask.

func (*AnnounceTaskRequest) Descriptor deprecated 

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

Deprecated: Use AnnounceTaskRequest.ProtoReflect.Descriptor instead.

func (*AnnounceTaskRequest) GetPeerHost 

func (x *AnnounceTaskRequest) GetPeerHost() *PeerHost

func (*AnnounceTaskRequest) GetPiecePacket 

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

func (*AnnounceTaskRequest) GetTaskId 

func (x *AnnounceTaskRequest) GetTaskId() string

func (*AnnounceTaskRequest) GetTaskType 

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

func (*AnnounceTaskRequest) GetUrl 

func (x *AnnounceTaskRequest) GetUrl() string

func (*AnnounceTaskRequest) GetUrlMeta 

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

func (*AnnounceTaskRequest) ProtoMessage 

func (*AnnounceTaskRequest) ProtoMessage()

func (*AnnounceTaskRequest) ProtoReflect 

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

func (*AnnounceTaskRequest) Reset 

func (x *AnnounceTaskRequest) Reset()

func (*AnnounceTaskRequest) String 

func (x *AnnounceTaskRequest) String() string

func (*AnnounceTaskRequest) Validate 

func (m *AnnounceTaskRequest) Validate() error

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

func (*AnnounceTaskRequest) ValidateAll 

func (m *AnnounceTaskRequest) ValidateAll() error

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

type AnnounceTaskRequestMultiError 

type AnnounceTaskRequestMultiError []error

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

func (AnnounceTaskRequestMultiError) AllErrors 

func (m AnnounceTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnounceTaskRequestMultiError) Error 

func (m AnnounceTaskRequestMultiError) Error() string

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

type AnnounceTaskRequestValidationError 

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

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

func (AnnounceTaskRequestValidationError) Cause 

func (e AnnounceTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (AnnounceTaskRequestValidationError) Error 

func (e AnnounceTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (AnnounceTaskRequestValidationError) ErrorName 

func (e AnnounceTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (AnnounceTaskRequestValidationError) Field 

func (e AnnounceTaskRequestValidationError) Field() string

Field function returns field value.

func (AnnounceTaskRequestValidationError) Key 

func (e AnnounceTaskRequestValidationError) Key() bool

Key function returns key value.

func (AnnounceTaskRequestValidationError) Reason 

func (e AnnounceTaskRequestValidationError) Reason() string

Reason function returns reason value.

type PeerHost 

type PeerHost struct {

	// Peer host id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// peer host ip
	Ip string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	// Port of grpc service.
	RpcPort int32 `protobuf:"varint,3,opt,name=rpc_port,json=rpcPort,proto3" json:"rpc_port,omitempty"`
	// Port of download server.
	DownPort int32 `protobuf:"varint,4,opt,name=down_port,json=downPort,proto3" json:"down_port,omitempty"`
	// Peer hostname.
	HostName string `protobuf:"bytes,5,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	// Security domain for network.
	SecurityDomain string `protobuf:"bytes,6,opt,name=security_domain,json=securityDomain,proto3" json:"security_domain,omitempty"`
	// Location path(area|country|province|city|...).
	Location string `protobuf:"bytes,7,opt,name=location,proto3" json:"location,omitempty"`
	// IDC where the peer host is located
	Idc string `protobuf:"bytes,8,opt,name=idc,proto3" json:"idc,omitempty"`
	// Network topology(switch|router|...).
	NetTopology string `protobuf:"bytes,9,opt,name=net_topology,json=netTopology,proto3" json:"net_topology,omitempty"`
	// contains filtered or unexported fields
}

PeerHost represents information of peer host.

func (*PeerHost) Descriptor deprecated 

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

Deprecated: Use PeerHost.ProtoReflect.Descriptor instead.

func (*PeerHost) GetDownPort 

func (x *PeerHost) GetDownPort() int32

func (*PeerHost) GetHostName 

func (x *PeerHost) GetHostName() string

func (*PeerHost) GetId 

func (x *PeerHost) GetId() string

func (*PeerHost) GetIdc 

func (x *PeerHost) GetIdc() string

func (*PeerHost) GetIp 

func (x *PeerHost) GetIp() string

func (*PeerHost) GetLocation 

func (x *PeerHost) GetLocation() string

func (*PeerHost) GetNetTopology 

func (x *PeerHost) GetNetTopology() string

func (*PeerHost) GetRpcPort 

func (x *PeerHost) GetRpcPort() int32

func (*PeerHost) GetSecurityDomain 

func (x *PeerHost) GetSecurityDomain() string

func (*PeerHost) ProtoMessage 

func (*PeerHost) ProtoMessage()

func (*PeerHost) ProtoReflect 

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

func (*PeerHost) Reset 

func (x *PeerHost) Reset()

func (*PeerHost) String 

func (x *PeerHost) String() string

func (*PeerHost) Validate 

func (m *PeerHost) Validate() error

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

func (*PeerHost) ValidateAll 

func (m *PeerHost) ValidateAll() error

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

type PeerHostMultiError 

type PeerHostMultiError []error

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

func (PeerHostMultiError) AllErrors 

func (m PeerHostMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerHostMultiError) Error 

func (m PeerHostMultiError) Error() string

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

type PeerHostValidationError 

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

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

func (PeerHostValidationError) Cause 

func (e PeerHostValidationError) Cause() error

Cause function returns cause value.

func (PeerHostValidationError) Error 

func (e PeerHostValidationError) Error() string

Error satisfies the builtin error interface

func (PeerHostValidationError) ErrorName 

func (e PeerHostValidationError) ErrorName() string

ErrorName returns error name.

func (PeerHostValidationError) Field 

func (e PeerHostValidationError) Field() string

Field function returns field value.

func (PeerHostValidationError) Key 

func (e PeerHostValidationError) Key() bool

Key function returns key value.

func (PeerHostValidationError) Reason 

func (e PeerHostValidationError) Reason() string

Reason function returns reason value.

type PeerPacket 

type PeerPacket struct {

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

PeerPacket represents response of ReportPieceResult.

func (*PeerPacket) Descriptor deprecated 

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

Deprecated: Use PeerPacket.ProtoReflect.Descriptor instead.

func (*PeerPacket) GetCandidatePeers 

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

func (*PeerPacket) GetCode 

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

func (*PeerPacket) GetErrordetails 

func (m *PeerPacket) GetErrordetails() isPeerPacket_Errordetails

func (*PeerPacket) GetMainPeer 

func (x *PeerPacket) GetMainPeer() *PeerPacket_DestPeer

func (*PeerPacket) GetParallelCount 

func (x *PeerPacket) GetParallelCount() int32

func (*PeerPacket) GetSourceError 

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

func (*PeerPacket) GetSrcPid 

func (x *PeerPacket) GetSrcPid() string

func (*PeerPacket) GetTaskId 

func (x *PeerPacket) GetTaskId() string

func (*PeerPacket) ProtoMessage 

func (*PeerPacket) ProtoMessage()

func (*PeerPacket) ProtoReflect 

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

func (*PeerPacket) Reset 

func (x *PeerPacket) Reset()

func (*PeerPacket) String 

func (x *PeerPacket) String() string

func (*PeerPacket) Validate 

func (m *PeerPacket) Validate() error

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

func (*PeerPacket) ValidateAll 

func (m *PeerPacket) ValidateAll() error

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

type PeerPacketMultiError 

type PeerPacketMultiError []error

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

func (PeerPacketMultiError) AllErrors 

func (m PeerPacketMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerPacketMultiError) Error 

func (m PeerPacketMultiError) Error() string

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

type PeerPacketValidationError 

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

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

func (PeerPacketValidationError) Cause 

func (e PeerPacketValidationError) Cause() error

Cause function returns cause value.

func (PeerPacketValidationError) Error 

func (e PeerPacketValidationError) Error() string

Error satisfies the builtin error interface

func (PeerPacketValidationError) ErrorName 

func (e PeerPacketValidationError) ErrorName() string

ErrorName returns error name.

func (PeerPacketValidationError) Field 

func (e PeerPacketValidationError) Field() string

Field function returns field value.

func (PeerPacketValidationError) Key 

func (e PeerPacketValidationError) Key() bool

Key function returns key value.

func (PeerPacketValidationError) Reason 

func (e PeerPacketValidationError) Reason() string

Reason function returns reason value.

type PeerPacket_DestPeer 

type PeerPacket_DestPeer struct {

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

func (*PeerPacket_DestPeer) Descriptor deprecated 

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

Deprecated: Use PeerPacket_DestPeer.ProtoReflect.Descriptor instead.

func (*PeerPacket_DestPeer) GetIp 

func (x *PeerPacket_DestPeer) GetIp() string

func (*PeerPacket_DestPeer) GetPeerId 

func (x *PeerPacket_DestPeer) GetPeerId() string

func (*PeerPacket_DestPeer) GetRpcPort 

func (x *PeerPacket_DestPeer) GetRpcPort() int32

func (*PeerPacket_DestPeer) ProtoMessage 

func (*PeerPacket_DestPeer) ProtoMessage()

func (*PeerPacket_DestPeer) ProtoReflect 

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

func (*PeerPacket_DestPeer) Reset 

func (x *PeerPacket_DestPeer) Reset()

func (*PeerPacket_DestPeer) String 

func (x *PeerPacket_DestPeer) String() string

func (*PeerPacket_DestPeer) Validate 

func (m *PeerPacket_DestPeer) Validate() error

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

func (*PeerPacket_DestPeer) ValidateAll 

func (m *PeerPacket_DestPeer) ValidateAll() error

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

type PeerPacket_DestPeerMultiError 

type PeerPacket_DestPeerMultiError []error

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

func (PeerPacket_DestPeerMultiError) AllErrors 

func (m PeerPacket_DestPeerMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerPacket_DestPeerMultiError) Error 

func (m PeerPacket_DestPeerMultiError) Error() string

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

type PeerPacket_DestPeerValidationError 

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

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

func (PeerPacket_DestPeerValidationError) Cause 

func (e PeerPacket_DestPeerValidationError) Cause() error

Cause function returns cause value.

func (PeerPacket_DestPeerValidationError) Error 

func (e PeerPacket_DestPeerValidationError) Error() string

Error satisfies the builtin error interface

func (PeerPacket_DestPeerValidationError) ErrorName 

func (e PeerPacket_DestPeerValidationError) ErrorName() string

ErrorName returns error name.

func (PeerPacket_DestPeerValidationError) Field 

func (e PeerPacket_DestPeerValidationError) Field() string

Field function returns field value.

func (PeerPacket_DestPeerValidationError) Key 

func (e PeerPacket_DestPeerValidationError) Key() bool

Key function returns key value.

func (PeerPacket_DestPeerValidationError) Reason 

func (e PeerPacket_DestPeerValidationError) Reason() string

Reason function returns reason value.

type PeerPacket_SourceError 

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

type PeerResult 

type PeerResult struct {

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

PeerResult represents response of ReportPeerResult.

func (*PeerResult) Descriptor deprecated 

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

Deprecated: Use PeerResult.ProtoReflect.Descriptor instead.

func (*PeerResult) GetCode 

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

func (*PeerResult) GetContentLength 

func (x *PeerResult) GetContentLength() int64

func (*PeerResult) GetCost 

func (x *PeerResult) GetCost() uint32

func (*PeerResult) GetErrordetails 

func (m *PeerResult) GetErrordetails() isPeerResult_Errordetails

func (*PeerResult) GetIdc 

func (x *PeerResult) GetIdc() string

func (*PeerResult) GetPeerId 

func (x *PeerResult) GetPeerId() string

func (*PeerResult) GetSecurityDomain 

func (x *PeerResult) GetSecurityDomain() string

func (*PeerResult) GetSourceError 

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

func (*PeerResult) GetSrcIp 

func (x *PeerResult) GetSrcIp() string

func (*PeerResult) GetSuccess 

func (x *PeerResult) GetSuccess() bool

func (*PeerResult) GetTaskId 

func (x *PeerResult) GetTaskId() string

func (*PeerResult) GetTotalPieceCount 

func (x *PeerResult) GetTotalPieceCount() int32

func (*PeerResult) GetTraffic 

func (x *PeerResult) GetTraffic() uint64

func (*PeerResult) GetUrl 

func (x *PeerResult) GetUrl() string

func (*PeerResult) ProtoMessage 

func (*PeerResult) ProtoMessage()

func (*PeerResult) ProtoReflect 

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

func (*PeerResult) Reset 

func (x *PeerResult) Reset()

func (*PeerResult) String 

func (x *PeerResult) String() string

func (*PeerResult) Validate 

func (m *PeerResult) Validate() error

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

func (*PeerResult) ValidateAll 

func (m *PeerResult) ValidateAll() error

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

type PeerResultMultiError 

type PeerResultMultiError []error

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

func (PeerResultMultiError) AllErrors 

func (m PeerResultMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerResultMultiError) Error 

func (m PeerResultMultiError) Error() string

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

type PeerResultValidationError 

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

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

func (PeerResultValidationError) Cause 

func (e PeerResultValidationError) Cause() error

Cause function returns cause value.

func (PeerResultValidationError) Error 

func (e PeerResultValidationError) Error() string

Error satisfies the builtin error interface

func (PeerResultValidationError) ErrorName 

func (e PeerResultValidationError) ErrorName() string

ErrorName returns error name.

func (PeerResultValidationError) Field 

func (e PeerResultValidationError) Field() string

Field function returns field value.

func (PeerResultValidationError) Key 

func (e PeerResultValidationError) Key() bool

Key function returns key value.

func (PeerResultValidationError) Reason 

func (e PeerResultValidationError) Reason() string

Reason function returns reason value.

type PeerResult_SourceError 

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

type PeerTarget 

type PeerTarget struct {

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

PeerTarget represents request of LeaveTask.

func (*PeerTarget) Descriptor deprecated 

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

Deprecated: Use PeerTarget.ProtoReflect.Descriptor instead.

func (*PeerTarget) GetPeerId 

func (x *PeerTarget) GetPeerId() string

func (*PeerTarget) GetTaskId 

func (x *PeerTarget) GetTaskId() string

func (*PeerTarget) ProtoMessage 

func (*PeerTarget) ProtoMessage()

func (*PeerTarget) ProtoReflect 

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

func (*PeerTarget) Reset 

func (x *PeerTarget) Reset()

func (*PeerTarget) String 

func (x *PeerTarget) String() string

func (*PeerTarget) Validate 

func (m *PeerTarget) Validate() error

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

func (*PeerTarget) ValidateAll 

func (m *PeerTarget) ValidateAll() error

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

type PeerTargetMultiError 

type PeerTargetMultiError []error

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

func (PeerTargetMultiError) AllErrors 

func (m PeerTargetMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerTargetMultiError) Error 

func (m PeerTargetMultiError) Error() string

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

type PeerTargetValidationError 

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

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

func (PeerTargetValidationError) Cause 

func (e PeerTargetValidationError) Cause() error

Cause function returns cause value.

func (PeerTargetValidationError) Error 

func (e PeerTargetValidationError) Error() string

Error satisfies the builtin error interface

func (PeerTargetValidationError) ErrorName 

func (e PeerTargetValidationError) ErrorName() string

ErrorName returns error name.

func (PeerTargetValidationError) Field 

func (e PeerTargetValidationError) Field() string

Field function returns field value.

func (PeerTargetValidationError) Key 

func (e PeerTargetValidationError) Key() bool

Key function returns key value.

func (PeerTargetValidationError) Reason 

func (e PeerTargetValidationError) Reason() string

Reason function returns reason value.

type PeerTaskRequest 

type PeerTaskRequest struct {

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

PeerTaskRequest represents request of RegisterPeerTask.

func (*PeerTaskRequest) Descriptor deprecated 

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

Deprecated: Use PeerTaskRequest.ProtoReflect.Descriptor instead.

func (*PeerTaskRequest) GetHostLoad 

func (x *PeerTaskRequest) GetHostLoad() *v1.HostLoad

func (*PeerTaskRequest) GetIsMigrating 

func (x *PeerTaskRequest) GetIsMigrating() bool

func (*PeerTaskRequest) GetPattern 

func (x *PeerTaskRequest) GetPattern() v1.Pattern

func (*PeerTaskRequest) GetPeerHost 

func (x *PeerTaskRequest) GetPeerHost() *PeerHost

func (*PeerTaskRequest) GetPeerId 

func (x *PeerTaskRequest) GetPeerId() string

func (*PeerTaskRequest) GetTaskId 

func (x *PeerTaskRequest) GetTaskId() string

func (*PeerTaskRequest) GetUrl 

func (x *PeerTaskRequest) GetUrl() string

func (*PeerTaskRequest) GetUrlMeta 

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

func (*PeerTaskRequest) ProtoMessage 

func (*PeerTaskRequest) ProtoMessage()

func (*PeerTaskRequest) ProtoReflect 

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

func (*PeerTaskRequest) Reset 

func (x *PeerTaskRequest) Reset()

func (*PeerTaskRequest) String 

func (x *PeerTaskRequest) String() string

func (*PeerTaskRequest) Validate 

func (m *PeerTaskRequest) Validate() error

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

func (*PeerTaskRequest) ValidateAll 

func (m *PeerTaskRequest) ValidateAll() error

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

type PeerTaskRequestMultiError 

type PeerTaskRequestMultiError []error

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

func (PeerTaskRequestMultiError) AllErrors 

func (m PeerTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerTaskRequestMultiError) Error 

func (m PeerTaskRequestMultiError) Error() string

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

type PeerTaskRequestValidationError 

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

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

func (PeerTaskRequestValidationError) Cause 

func (e PeerTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (PeerTaskRequestValidationError) Error 

func (e PeerTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (PeerTaskRequestValidationError) ErrorName 

func (e PeerTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (PeerTaskRequestValidationError) Field 

func (e PeerTaskRequestValidationError) Field() string

Field function returns field value.

func (PeerTaskRequestValidationError) Key 

func (e PeerTaskRequestValidationError) Key() bool

Key function returns key value.

func (PeerTaskRequestValidationError) Reason 

func (e PeerTaskRequestValidationError) Reason() string

Reason function returns reason value.

type PieceResult 

type PieceResult struct {

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

PieceResult represents request of ReportPieceResult.

func (*PieceResult) Descriptor deprecated 

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

Deprecated: Use PieceResult.ProtoReflect.Descriptor instead.

func (*PieceResult) GetBeginTime 

func (x *PieceResult) GetBeginTime() uint64

func (*PieceResult) GetCode 

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

func (*PieceResult) GetDstPid 

func (x *PieceResult) GetDstPid() string

func (*PieceResult) GetEndTime 

func (x *PieceResult) GetEndTime() uint64

func (*PieceResult) GetExtendAttribute 

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

func (*PieceResult) GetFinishedCount 

func (x *PieceResult) GetFinishedCount() int32

func (*PieceResult) GetHostLoad 

func (x *PieceResult) GetHostLoad() *v1.HostLoad

func (*PieceResult) GetPieceInfo 

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

func (*PieceResult) GetSrcPid 

func (x *PieceResult) GetSrcPid() string

func (*PieceResult) GetSuccess 

func (x *PieceResult) GetSuccess() bool

func (*PieceResult) GetTaskId 

func (x *PieceResult) GetTaskId() string

func (*PieceResult) ProtoMessage 

func (*PieceResult) ProtoMessage()

func (*PieceResult) ProtoReflect 

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

func (*PieceResult) Reset 

func (x *PieceResult) Reset()

func (*PieceResult) String 

func (x *PieceResult) String() string

func (*PieceResult) Validate 

func (m *PieceResult) Validate() error

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

func (*PieceResult) ValidateAll 

func (m *PieceResult) ValidateAll() error

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

type PieceResultMultiError 

type PieceResultMultiError []error

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

func (PieceResultMultiError) AllErrors 

func (m PieceResultMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PieceResultMultiError) Error 

func (m PieceResultMultiError) Error() string

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

type PieceResultValidationError 

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

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

func (PieceResultValidationError) Cause 

func (e PieceResultValidationError) Cause() error

Cause function returns cause value.

func (PieceResultValidationError) Error 

func (e PieceResultValidationError) Error() string

Error satisfies the builtin error interface

func (PieceResultValidationError) ErrorName 

func (e PieceResultValidationError) ErrorName() string

ErrorName returns error name.

func (PieceResultValidationError) Field 

func (e PieceResultValidationError) Field() string

Field function returns field value.

func (PieceResultValidationError) Key 

func (e PieceResultValidationError) Key() bool

Key function returns key value.

func (PieceResultValidationError) Reason 

func (e PieceResultValidationError) Reason() string

Reason function returns reason value.

type RegisterResult 

type RegisterResult struct {

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

RegisterResult represents response of RegisterPeerTask.

func (*RegisterResult) Descriptor deprecated 

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

Deprecated: Use RegisterResult.ProtoReflect.Descriptor instead.

func (*RegisterResult) GetDirectPiece 

func (m *RegisterResult) GetDirectPiece() isRegisterResult_DirectPiece

func (*RegisterResult) GetExtendAttribute 

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

func (*RegisterResult) GetPieceContent 

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

func (*RegisterResult) GetSinglePiece 

func (x *RegisterResult) GetSinglePiece() *SinglePiece

func (*RegisterResult) GetSizeScope 

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

func (*RegisterResult) GetTaskId 

func (x *RegisterResult) GetTaskId() string

func (*RegisterResult) GetTaskType 

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

func (*RegisterResult) ProtoMessage 

func (*RegisterResult) ProtoMessage()

func (*RegisterResult) ProtoReflect 

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

func (*RegisterResult) Reset 

func (x *RegisterResult) Reset()

func (*RegisterResult) String 

func (x *RegisterResult) String() string

func (*RegisterResult) Validate 

func (m *RegisterResult) Validate() error

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

func (*RegisterResult) ValidateAll 

func (m *RegisterResult) ValidateAll() error

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

type RegisterResultMultiError 

type RegisterResultMultiError []error

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

func (RegisterResultMultiError) AllErrors 

func (m RegisterResultMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RegisterResultMultiError) Error 

func (m RegisterResultMultiError) Error() string

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

type RegisterResultValidationError 

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

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

func (RegisterResultValidationError) Cause 

func (e RegisterResultValidationError) Cause() error

Cause function returns cause value.

func (RegisterResultValidationError) Error 

func (e RegisterResultValidationError) Error() string

Error satisfies the builtin error interface

func (RegisterResultValidationError) ErrorName 

func (e RegisterResultValidationError) ErrorName() string

ErrorName returns error name.

func (RegisterResultValidationError) Field 

func (e RegisterResultValidationError) Field() string

Field function returns field value.

func (RegisterResultValidationError) Key 

func (e RegisterResultValidationError) Key() bool

Key function returns key value.

func (RegisterResultValidationError) Reason 

func (e RegisterResultValidationError) Reason() string

Reason function returns reason value.

type RegisterResult_PieceContent 

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

type RegisterResult_SinglePiece 

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

type SchedulerClient 

type SchedulerClient interface {
	// RegisterPeerTask registers a peer into task.
	RegisterPeerTask(ctx context.Context, in *PeerTaskRequest, opts ...grpc.CallOption) (*RegisterResult, error)
	// ReportPieceResult reports piece results and receives peer packets.
	ReportPieceResult(ctx context.Context, opts ...grpc.CallOption) (Scheduler_ReportPieceResultClient, error)
	// ReportPeerResult reports downloading result for the peer.
	ReportPeerResult(ctx context.Context, in *PeerResult, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// LeaveTask makes the peer leaving from task.
	LeaveTask(ctx context.Context, in *PeerTarget, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Checks if any peer has the given task.
	StatTask(ctx context.Context, in *StatTaskRequest, opts ...grpc.CallOption) (*Task, error)
	// A peer announces that it has the announced task to other peers.
	AnnounceTask(ctx context.Context, in *AnnounceTaskRequest, 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 {
	// RegisterPeerTask registers a peer into task.
	RegisterPeerTask(context.Context, *PeerTaskRequest) (*RegisterResult, error)
	// ReportPieceResult reports piece results and receives peer packets.
	ReportPieceResult(Scheduler_ReportPieceResultServer) error
	// ReportPeerResult reports downloading result for the peer.
	ReportPeerResult(context.Context, *PeerResult) (*emptypb.Empty, error)
	// LeaveTask makes the peer leaving from task.
	LeaveTask(context.Context, *PeerTarget) (*emptypb.Empty, error)
	// Checks if any peer has the given task.
	StatTask(context.Context, *StatTaskRequest) (*Task, error)
	// A peer announces that it has the announced task to other peers.
	AnnounceTask(context.Context, *AnnounceTaskRequest) (*emptypb.Empty, error)
}

SchedulerServer is the server API for Scheduler service.

type Scheduler_ReportPieceResultClient 

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

type Scheduler_ReportPieceResultServer 

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

type SinglePiece 

type SinglePiece struct {

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

SinglePiece represents information of single piece.

func (*SinglePiece) Descriptor deprecated 

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

Deprecated: Use SinglePiece.ProtoReflect.Descriptor instead.

func (*SinglePiece) GetDstAddr 

func (x *SinglePiece) GetDstAddr() string

func (*SinglePiece) GetDstPid 

func (x *SinglePiece) GetDstPid() string

func (*SinglePiece) GetPieceInfo 

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

func (*SinglePiece) ProtoMessage 

func (*SinglePiece) ProtoMessage()

func (*SinglePiece) ProtoReflect 

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

func (*SinglePiece) Reset 

func (x *SinglePiece) Reset()

func (*SinglePiece) String 

func (x *SinglePiece) String() string

func (*SinglePiece) Validate 

func (m *SinglePiece) Validate() error

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

func (*SinglePiece) ValidateAll 

func (m *SinglePiece) ValidateAll() error

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

type SinglePieceMultiError 

type SinglePieceMultiError []error

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

func (SinglePieceMultiError) AllErrors 

func (m SinglePieceMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SinglePieceMultiError) Error 

func (m SinglePieceMultiError) Error() string

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

type SinglePieceValidationError 

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

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

func (SinglePieceValidationError) Cause 

func (e SinglePieceValidationError) Cause() error

Cause function returns cause value.

func (SinglePieceValidationError) Error 

func (e SinglePieceValidationError) Error() string

Error satisfies the builtin error interface

func (SinglePieceValidationError) ErrorName 

func (e SinglePieceValidationError) ErrorName() string

ErrorName returns error name.

func (SinglePieceValidationError) Field 

func (e SinglePieceValidationError) Field() string

Field function returns field value.

func (SinglePieceValidationError) Key 

func (e SinglePieceValidationError) Key() bool

Key function returns key value.

func (SinglePieceValidationError) Reason 

func (e SinglePieceValidationError) Reason() string

Reason function returns reason value.

type StatTaskRequest 

type StatTaskRequest struct {

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

StatTaskRequest represents request of StatTask.

func (*StatTaskRequest) Descriptor deprecated 

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

Deprecated: Use StatTaskRequest.ProtoReflect.Descriptor instead.

func (*StatTaskRequest) GetTaskId 

func (x *StatTaskRequest) GetTaskId() string

func (*StatTaskRequest) ProtoMessage 

func (*StatTaskRequest) ProtoMessage()

func (*StatTaskRequest) ProtoReflect 

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

func (*StatTaskRequest) Reset 

func (x *StatTaskRequest) Reset()

func (*StatTaskRequest) String 

func (x *StatTaskRequest) String() string

func (*StatTaskRequest) Validate 

func (m *StatTaskRequest) Validate() error

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

func (*StatTaskRequest) ValidateAll 

func (m *StatTaskRequest) ValidateAll() error

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

type StatTaskRequestMultiError 

type StatTaskRequestMultiError []error

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

func (StatTaskRequestMultiError) AllErrors 

func (m StatTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatTaskRequestMultiError) Error 

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

Task represents download task.

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetContentLength 

func (x *Task) GetContentLength() int64

func (*Task) GetHasAvailablePeer 

func (x *Task) GetHasAvailablePeer() bool

func (*Task) GetId 

func (x *Task) GetId() string

func (*Task) GetPeerCount 

func (x *Task) GetPeerCount() int32

func (*Task) GetState 

func (x *Task) GetState() string

func (*Task) GetTotalPieceCount 

func (x *Task) GetTotalPieceCount() int32

func (*Task) GetType 

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

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

func (*Task) Validate 

func (m *Task) Validate() error

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

func (*Task) ValidateAll 

func (m *Task) ValidateAll() error

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

type TaskMultiError 

type TaskMultiError []error

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

func (TaskMultiError) AllErrors 

func (m TaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskMultiError) Error 

func (m TaskMultiError) Error() string

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

type TaskValidationError 

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

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

func (TaskValidationError) Cause 

func (e TaskValidationError) Cause() error

Cause function returns cause value.

func (TaskValidationError) Error 

func (e TaskValidationError) Error() string

Error satisfies the builtin error interface

func (TaskValidationError) ErrorName 

func (e TaskValidationError) ErrorName() string

ErrorName returns error name.

func (TaskValidationError) Field 

func (e TaskValidationError) Field() string

Field function returns field value.

func (TaskValidationError) Key 

func (e TaskValidationError) Key() bool

Key function returns key value.

func (TaskValidationError) Reason 

func (e TaskValidationError) Reason() string

Reason function returns reason value.

type UnimplementedSchedulerServer 

type UnimplementedSchedulerServer struct {
}

UnimplementedSchedulerServer can be embedded to have forward compatible implementations.

func (*UnimplementedSchedulerServer) AnnounceTask 

func (*UnimplementedSchedulerServer) AnnounceTask(context.Context, *AnnounceTaskRequest) (*emptypb.Empty, error)

func (*UnimplementedSchedulerServer) LeaveTask 

func (*UnimplementedSchedulerServer) LeaveTask(context.Context, *PeerTarget) (*emptypb.Empty, error)

func (*UnimplementedSchedulerServer) RegisterPeerTask 

func (*UnimplementedSchedulerServer) RegisterPeerTask(context.Context, *PeerTaskRequest) (*RegisterResult, error)

func (*UnimplementedSchedulerServer) ReportPeerResult 

func (*UnimplementedSchedulerServer) ReportPeerResult(context.Context, *PeerResult) (*emptypb.Empty, error)

func (*UnimplementedSchedulerServer) ReportPieceResult 

func (*UnimplementedSchedulerServer) ReportPieceResult(Scheduler_ReportPieceResultServer) 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.