Documentation
¶
Index ¶
- Variables
- func RegisterSchedulerServer(s grpc.ServiceRegistrar, srv SchedulerServer)
- type AnnounceHostRequest
- func (*AnnounceHostRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AnnounceHostRequest) GetHost() *v2.Host
- func (*AnnounceHostRequest) ProtoMessage()
- func (x *AnnounceHostRequest) ProtoReflect() protoreflect.Message
- func (x *AnnounceHostRequest) Reset()
- func (x *AnnounceHostRequest) String() string
- func (m *AnnounceHostRequest) Validate() error
- func (m *AnnounceHostRequest) ValidateAll() error
- type AnnounceHostRequestMultiError
- type AnnounceHostRequestValidationError
- func (e AnnounceHostRequestValidationError) Cause() error
- func (e AnnounceHostRequestValidationError) Error() string
- func (e AnnounceHostRequestValidationError) ErrorName() string
- func (e AnnounceHostRequestValidationError) Field() string
- func (e AnnounceHostRequestValidationError) Key() bool
- func (e AnnounceHostRequestValidationError) Reason() string
- type AnnouncePeerRequest
- func (*AnnouncePeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AnnouncePeerRequest) GetDownloadPeerBackToSourceFailedRequest() *DownloadPeerBackToSourceFailedRequest
- func (x *AnnouncePeerRequest) GetDownloadPeerBackToSourceFinishedRequest() *DownloadPeerBackToSourceFinishedRequest
- func (x *AnnouncePeerRequest) GetDownloadPeerBackToSourceStartedRequest() *DownloadPeerBackToSourceStartedRequest
- func (x *AnnouncePeerRequest) GetDownloadPeerFailedRequest() *DownloadPeerFailedRequest
- func (x *AnnouncePeerRequest) GetDownloadPeerFinishedRequest() *DownloadPeerFinishedRequest
- func (x *AnnouncePeerRequest) GetDownloadPeerStartedRequest() *DownloadPeerStartedRequest
- func (x *AnnouncePeerRequest) GetDownloadPieceBackToSourceFailedRequest() *DownloadPieceBackToSourceFailedRequest
- func (x *AnnouncePeerRequest) GetDownloadPieceBackToSourceFinishedRequest() *DownloadPieceBackToSourceFinishedRequest
- func (x *AnnouncePeerRequest) GetDownloadPieceFailedRequest() *DownloadPieceFailedRequest
- func (x *AnnouncePeerRequest) GetDownloadPieceFinishedRequest() *DownloadPieceFinishedRequest
- func (x *AnnouncePeerRequest) GetHostId() string
- func (x *AnnouncePeerRequest) GetPeerId() string
- func (x *AnnouncePeerRequest) GetRegisterPeerRequest() *RegisterPeerRequest
- func (m *AnnouncePeerRequest) GetRequest() isAnnouncePeerRequest_Request
- func (x *AnnouncePeerRequest) GetRescheduleRequest() *RescheduleRequest
- func (x *AnnouncePeerRequest) GetTaskId() string
- func (*AnnouncePeerRequest) ProtoMessage()
- func (x *AnnouncePeerRequest) ProtoReflect() protoreflect.Message
- func (x *AnnouncePeerRequest) Reset()
- func (x *AnnouncePeerRequest) String() string
- func (m *AnnouncePeerRequest) Validate() error
- func (m *AnnouncePeerRequest) ValidateAll() error
- type AnnouncePeerRequestMultiError
- type AnnouncePeerRequestValidationError
- func (e AnnouncePeerRequestValidationError) Cause() error
- func (e AnnouncePeerRequestValidationError) Error() string
- func (e AnnouncePeerRequestValidationError) ErrorName() string
- func (e AnnouncePeerRequestValidationError) Field() string
- func (e AnnouncePeerRequestValidationError) Key() bool
- func (e AnnouncePeerRequestValidationError) Reason() string
- type AnnouncePeerRequest_DownloadPeerBackToSourceFailedRequest
- type AnnouncePeerRequest_DownloadPeerBackToSourceFinishedRequest
- type AnnouncePeerRequest_DownloadPeerBackToSourceStartedRequest
- type AnnouncePeerRequest_DownloadPeerFailedRequest
- type AnnouncePeerRequest_DownloadPeerFinishedRequest
- type AnnouncePeerRequest_DownloadPeerStartedRequest
- type AnnouncePeerRequest_DownloadPieceBackToSourceFailedRequest
- type AnnouncePeerRequest_DownloadPieceBackToSourceFinishedRequest
- type AnnouncePeerRequest_DownloadPieceFailedRequest
- type AnnouncePeerRequest_DownloadPieceFinishedRequest
- type AnnouncePeerRequest_RegisterPeerRequest
- type AnnouncePeerRequest_RescheduleRequest
- type AnnouncePeerResponse
- func (*AnnouncePeerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AnnouncePeerResponse) GetEmptyTaskResponse() *EmptyTaskResponse
- func (x *AnnouncePeerResponse) GetNeedBackToSourceResponse() *NeedBackToSourceResponse
- func (x *AnnouncePeerResponse) GetNormalTaskResponse() *NormalTaskResponse
- func (m *AnnouncePeerResponse) GetResponse() isAnnouncePeerResponse_Response
- func (*AnnouncePeerResponse) ProtoMessage()
- func (x *AnnouncePeerResponse) ProtoReflect() protoreflect.Message
- func (x *AnnouncePeerResponse) Reset()
- func (x *AnnouncePeerResponse) String() string
- func (m *AnnouncePeerResponse) Validate() error
- func (m *AnnouncePeerResponse) ValidateAll() error
- type AnnouncePeerResponseMultiError
- type AnnouncePeerResponseValidationError
- func (e AnnouncePeerResponseValidationError) Cause() error
- func (e AnnouncePeerResponseValidationError) Error() string
- func (e AnnouncePeerResponseValidationError) ErrorName() string
- func (e AnnouncePeerResponseValidationError) Field() string
- func (e AnnouncePeerResponseValidationError) Key() bool
- func (e AnnouncePeerResponseValidationError) Reason() string
- type AnnouncePeerResponse_EmptyTaskResponse
- type AnnouncePeerResponse_NeedBackToSourceResponse
- type AnnouncePeerResponse_NormalTaskResponse
- type DownloadPeerBackToSourceFailedRequest
- func (*DownloadPeerBackToSourceFailedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadPeerBackToSourceFailedRequest) GetDescription() string
- func (*DownloadPeerBackToSourceFailedRequest) ProtoMessage()
- func (x *DownloadPeerBackToSourceFailedRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadPeerBackToSourceFailedRequest) Reset()
- func (x *DownloadPeerBackToSourceFailedRequest) String() string
- func (m *DownloadPeerBackToSourceFailedRequest) Validate() error
- func (m *DownloadPeerBackToSourceFailedRequest) ValidateAll() error
- type DownloadPeerBackToSourceFailedRequestMultiError
- type DownloadPeerBackToSourceFailedRequestValidationError
- func (e DownloadPeerBackToSourceFailedRequestValidationError) Cause() error
- func (e DownloadPeerBackToSourceFailedRequestValidationError) Error() string
- func (e DownloadPeerBackToSourceFailedRequestValidationError) ErrorName() string
- func (e DownloadPeerBackToSourceFailedRequestValidationError) Field() string
- func (e DownloadPeerBackToSourceFailedRequestValidationError) Key() bool
- func (e DownloadPeerBackToSourceFailedRequestValidationError) Reason() string
- type DownloadPeerBackToSourceFinishedRequest
- func (*DownloadPeerBackToSourceFinishedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadPeerBackToSourceFinishedRequest) GetContentLength() uint64
- func (x *DownloadPeerBackToSourceFinishedRequest) GetPieceCount() uint32
- func (*DownloadPeerBackToSourceFinishedRequest) ProtoMessage()
- func (x *DownloadPeerBackToSourceFinishedRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadPeerBackToSourceFinishedRequest) Reset()
- func (x *DownloadPeerBackToSourceFinishedRequest) String() string
- func (m *DownloadPeerBackToSourceFinishedRequest) Validate() error
- func (m *DownloadPeerBackToSourceFinishedRequest) ValidateAll() error
- type DownloadPeerBackToSourceFinishedRequestMultiError
- type DownloadPeerBackToSourceFinishedRequestValidationError
- func (e DownloadPeerBackToSourceFinishedRequestValidationError) Cause() error
- func (e DownloadPeerBackToSourceFinishedRequestValidationError) Error() string
- func (e DownloadPeerBackToSourceFinishedRequestValidationError) ErrorName() string
- func (e DownloadPeerBackToSourceFinishedRequestValidationError) Field() string
- func (e DownloadPeerBackToSourceFinishedRequestValidationError) Key() bool
- func (e DownloadPeerBackToSourceFinishedRequestValidationError) Reason() string
- type DownloadPeerBackToSourceStartedRequest
- func (*DownloadPeerBackToSourceStartedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadPeerBackToSourceStartedRequest) GetDescription() string
- func (*DownloadPeerBackToSourceStartedRequest) ProtoMessage()
- func (x *DownloadPeerBackToSourceStartedRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadPeerBackToSourceStartedRequest) Reset()
- func (x *DownloadPeerBackToSourceStartedRequest) String() string
- func (m *DownloadPeerBackToSourceStartedRequest) Validate() error
- func (m *DownloadPeerBackToSourceStartedRequest) ValidateAll() error
- type DownloadPeerBackToSourceStartedRequestMultiError
- type DownloadPeerBackToSourceStartedRequestValidationError
- func (e DownloadPeerBackToSourceStartedRequestValidationError) Cause() error
- func (e DownloadPeerBackToSourceStartedRequestValidationError) Error() string
- func (e DownloadPeerBackToSourceStartedRequestValidationError) ErrorName() string
- func (e DownloadPeerBackToSourceStartedRequestValidationError) Field() string
- func (e DownloadPeerBackToSourceStartedRequestValidationError) Key() bool
- func (e DownloadPeerBackToSourceStartedRequestValidationError) Reason() string
- type DownloadPeerFailedRequest
- func (*DownloadPeerFailedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadPeerFailedRequest) GetDescription() string
- func (*DownloadPeerFailedRequest) ProtoMessage()
- func (x *DownloadPeerFailedRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadPeerFailedRequest) Reset()
- func (x *DownloadPeerFailedRequest) String() string
- func (m *DownloadPeerFailedRequest) Validate() error
- func (m *DownloadPeerFailedRequest) ValidateAll() error
- type DownloadPeerFailedRequestMultiError
- type DownloadPeerFailedRequestValidationError
- func (e DownloadPeerFailedRequestValidationError) Cause() error
- func (e DownloadPeerFailedRequestValidationError) Error() string
- func (e DownloadPeerFailedRequestValidationError) ErrorName() string
- func (e DownloadPeerFailedRequestValidationError) Field() string
- func (e DownloadPeerFailedRequestValidationError) Key() bool
- func (e DownloadPeerFailedRequestValidationError) Reason() string
- type DownloadPeerFinishedRequest
- func (*DownloadPeerFinishedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadPeerFinishedRequest) GetContentLength() uint64
- func (x *DownloadPeerFinishedRequest) GetPieceCount() uint32
- func (*DownloadPeerFinishedRequest) ProtoMessage()
- func (x *DownloadPeerFinishedRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadPeerFinishedRequest) Reset()
- func (x *DownloadPeerFinishedRequest) String() string
- func (m *DownloadPeerFinishedRequest) Validate() error
- func (m *DownloadPeerFinishedRequest) ValidateAll() error
- type DownloadPeerFinishedRequestMultiError
- type DownloadPeerFinishedRequestValidationError
- func (e DownloadPeerFinishedRequestValidationError) Cause() error
- func (e DownloadPeerFinishedRequestValidationError) Error() string
- func (e DownloadPeerFinishedRequestValidationError) ErrorName() string
- func (e DownloadPeerFinishedRequestValidationError) Field() string
- func (e DownloadPeerFinishedRequestValidationError) Key() bool
- func (e DownloadPeerFinishedRequestValidationError) Reason() string
- type DownloadPeerStartedRequest
- func (*DownloadPeerStartedRequest) Descriptor() ([]byte, []int)deprecated
- func (*DownloadPeerStartedRequest) ProtoMessage()
- func (x *DownloadPeerStartedRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadPeerStartedRequest) Reset()
- func (x *DownloadPeerStartedRequest) String() string
- func (m *DownloadPeerStartedRequest) Validate() error
- func (m *DownloadPeerStartedRequest) ValidateAll() error
- type DownloadPeerStartedRequestMultiError
- type DownloadPeerStartedRequestValidationError
- func (e DownloadPeerStartedRequestValidationError) Cause() error
- func (e DownloadPeerStartedRequestValidationError) Error() string
- func (e DownloadPeerStartedRequestValidationError) ErrorName() string
- func (e DownloadPeerStartedRequestValidationError) Field() string
- func (e DownloadPeerStartedRequestValidationError) Key() bool
- func (e DownloadPeerStartedRequestValidationError) Reason() string
- type DownloadPieceBackToSourceFailedRequest
- func (*DownloadPieceBackToSourceFailedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadPieceBackToSourceFailedRequest) GetBackend() *v21.Backend
- func (x *DownloadPieceBackToSourceFailedRequest) GetPieceNumber() uint32
- func (m *DownloadPieceBackToSourceFailedRequest) GetResponse() isDownloadPieceBackToSourceFailedRequest_Response
- func (*DownloadPieceBackToSourceFailedRequest) ProtoMessage()
- func (x *DownloadPieceBackToSourceFailedRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadPieceBackToSourceFailedRequest) Reset()
- func (x *DownloadPieceBackToSourceFailedRequest) String() string
- func (m *DownloadPieceBackToSourceFailedRequest) Validate() error
- func (m *DownloadPieceBackToSourceFailedRequest) ValidateAll() error
- type DownloadPieceBackToSourceFailedRequestMultiError
- type DownloadPieceBackToSourceFailedRequestValidationError
- func (e DownloadPieceBackToSourceFailedRequestValidationError) Cause() error
- func (e DownloadPieceBackToSourceFailedRequestValidationError) Error() string
- func (e DownloadPieceBackToSourceFailedRequestValidationError) ErrorName() string
- func (e DownloadPieceBackToSourceFailedRequestValidationError) Field() string
- func (e DownloadPieceBackToSourceFailedRequestValidationError) Key() bool
- func (e DownloadPieceBackToSourceFailedRequestValidationError) Reason() string
- type DownloadPieceBackToSourceFailedRequest_Backend
- type DownloadPieceBackToSourceFinishedRequest
- func (*DownloadPieceBackToSourceFinishedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadPieceBackToSourceFinishedRequest) GetPiece() *v2.Piece
- func (*DownloadPieceBackToSourceFinishedRequest) ProtoMessage()
- func (x *DownloadPieceBackToSourceFinishedRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadPieceBackToSourceFinishedRequest) Reset()
- func (x *DownloadPieceBackToSourceFinishedRequest) String() string
- func (m *DownloadPieceBackToSourceFinishedRequest) Validate() error
- func (m *DownloadPieceBackToSourceFinishedRequest) ValidateAll() error
- type DownloadPieceBackToSourceFinishedRequestMultiError
- type DownloadPieceBackToSourceFinishedRequestValidationError
- func (e DownloadPieceBackToSourceFinishedRequestValidationError) Cause() error
- func (e DownloadPieceBackToSourceFinishedRequestValidationError) Error() string
- func (e DownloadPieceBackToSourceFinishedRequestValidationError) ErrorName() string
- func (e DownloadPieceBackToSourceFinishedRequestValidationError) Field() string
- func (e DownloadPieceBackToSourceFinishedRequestValidationError) Key() bool
- func (e DownloadPieceBackToSourceFinishedRequestValidationError) Reason() string
- type DownloadPieceFailedRequest
- func (*DownloadPieceFailedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadPieceFailedRequest) GetParentId() string
- func (x *DownloadPieceFailedRequest) GetPieceNumber() uint32
- func (x *DownloadPieceFailedRequest) GetTemporary() bool
- func (*DownloadPieceFailedRequest) ProtoMessage()
- func (x *DownloadPieceFailedRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadPieceFailedRequest) Reset()
- func (x *DownloadPieceFailedRequest) String() string
- func (m *DownloadPieceFailedRequest) Validate() error
- func (m *DownloadPieceFailedRequest) ValidateAll() error
- type DownloadPieceFailedRequestMultiError
- type DownloadPieceFailedRequestValidationError
- func (e DownloadPieceFailedRequestValidationError) Cause() error
- func (e DownloadPieceFailedRequestValidationError) Error() string
- func (e DownloadPieceFailedRequestValidationError) ErrorName() string
- func (e DownloadPieceFailedRequestValidationError) Field() string
- func (e DownloadPieceFailedRequestValidationError) Key() bool
- func (e DownloadPieceFailedRequestValidationError) Reason() string
- type DownloadPieceFinishedRequest
- func (*DownloadPieceFinishedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadPieceFinishedRequest) GetPiece() *v2.Piece
- func (*DownloadPieceFinishedRequest) ProtoMessage()
- func (x *DownloadPieceFinishedRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadPieceFinishedRequest) Reset()
- func (x *DownloadPieceFinishedRequest) String() string
- func (m *DownloadPieceFinishedRequest) Validate() error
- func (m *DownloadPieceFinishedRequest) ValidateAll() error
- type DownloadPieceFinishedRequestMultiError
- type DownloadPieceFinishedRequestValidationError
- func (e DownloadPieceFinishedRequestValidationError) Cause() error
- func (e DownloadPieceFinishedRequestValidationError) Error() string
- func (e DownloadPieceFinishedRequestValidationError) ErrorName() string
- func (e DownloadPieceFinishedRequestValidationError) Field() string
- func (e DownloadPieceFinishedRequestValidationError) Key() bool
- func (e DownloadPieceFinishedRequestValidationError) Reason() string
- type EmptyTaskResponse
- func (*EmptyTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (*EmptyTaskResponse) ProtoMessage()
- func (x *EmptyTaskResponse) ProtoReflect() protoreflect.Message
- func (x *EmptyTaskResponse) Reset()
- func (x *EmptyTaskResponse) String() string
- func (m *EmptyTaskResponse) Validate() error
- func (m *EmptyTaskResponse) ValidateAll() error
- type EmptyTaskResponseMultiError
- type EmptyTaskResponseValidationError
- func (e EmptyTaskResponseValidationError) Cause() error
- func (e EmptyTaskResponseValidationError) Error() string
- func (e EmptyTaskResponseValidationError) ErrorName() string
- func (e EmptyTaskResponseValidationError) Field() string
- func (e EmptyTaskResponseValidationError) Key() bool
- func (e EmptyTaskResponseValidationError) Reason() string
- type ExchangePeerRequest
- func (*ExchangePeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExchangePeerRequest) GetHostId() string
- func (x *ExchangePeerRequest) GetPeerId() string
- func (x *ExchangePeerRequest) GetTaskId() string
- func (*ExchangePeerRequest) ProtoMessage()
- func (x *ExchangePeerRequest) ProtoReflect() protoreflect.Message
- func (x *ExchangePeerRequest) Reset()
- func (x *ExchangePeerRequest) String() string
- func (m *ExchangePeerRequest) Validate() error
- func (m *ExchangePeerRequest) ValidateAll() error
- type ExchangePeerRequestMultiError
- type ExchangePeerRequestValidationError
- func (e ExchangePeerRequestValidationError) Cause() error
- func (e ExchangePeerRequestValidationError) Error() string
- func (e ExchangePeerRequestValidationError) ErrorName() string
- func (e ExchangePeerRequestValidationError) Field() string
- func (e ExchangePeerRequestValidationError) Key() bool
- func (e ExchangePeerRequestValidationError) Reason() string
- type ExchangePeerResponse
- func (*ExchangePeerResponse) Descriptor() ([]byte, []int)deprecated
- func (*ExchangePeerResponse) ProtoMessage()
- func (x *ExchangePeerResponse) ProtoReflect() protoreflect.Message
- func (x *ExchangePeerResponse) Reset()
- func (x *ExchangePeerResponse) String() string
- func (m *ExchangePeerResponse) Validate() error
- func (m *ExchangePeerResponse) ValidateAll() error
- type ExchangePeerResponseMultiError
- type ExchangePeerResponseValidationError
- func (e ExchangePeerResponseValidationError) Cause() error
- func (e ExchangePeerResponseValidationError) Error() string
- func (e ExchangePeerResponseValidationError) ErrorName() string
- func (e ExchangePeerResponseValidationError) Field() string
- func (e ExchangePeerResponseValidationError) Key() bool
- func (e ExchangePeerResponseValidationError) Reason() string
- type FailedProbe
- func (*FailedProbe) Descriptor() ([]byte, []int)deprecated
- func (x *FailedProbe) GetDescription() string
- func (x *FailedProbe) GetHost() *v2.Host
- func (*FailedProbe) ProtoMessage()
- func (x *FailedProbe) ProtoReflect() protoreflect.Message
- func (x *FailedProbe) Reset()
- func (x *FailedProbe) String() string
- func (m *FailedProbe) Validate() error
- func (m *FailedProbe) ValidateAll() error
- type FailedProbeMultiError
- type FailedProbeValidationError
- func (e FailedProbeValidationError) Cause() error
- func (e FailedProbeValidationError) Error() string
- func (e FailedProbeValidationError) ErrorName() string
- func (e FailedProbeValidationError) Field() string
- func (e FailedProbeValidationError) Key() bool
- func (e FailedProbeValidationError) Reason() string
- type LeaveHostRequest
- func (*LeaveHostRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LeaveHostRequest) GetId() string
- func (*LeaveHostRequest) ProtoMessage()
- func (x *LeaveHostRequest) ProtoReflect() protoreflect.Message
- func (x *LeaveHostRequest) Reset()
- func (x *LeaveHostRequest) String() string
- func (m *LeaveHostRequest) Validate() error
- func (m *LeaveHostRequest) ValidateAll() error
- type LeaveHostRequestMultiError
- type LeaveHostRequestValidationError
- func (e LeaveHostRequestValidationError) Cause() error
- func (e LeaveHostRequestValidationError) Error() string
- func (e LeaveHostRequestValidationError) ErrorName() string
- func (e LeaveHostRequestValidationError) Field() string
- func (e LeaveHostRequestValidationError) Key() bool
- func (e LeaveHostRequestValidationError) Reason() string
- type LeavePeerRequest
- func (*LeavePeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LeavePeerRequest) GetHostId() string
- func (x *LeavePeerRequest) GetPeerId() string
- func (x *LeavePeerRequest) GetTaskId() string
- func (*LeavePeerRequest) ProtoMessage()
- func (x *LeavePeerRequest) ProtoReflect() protoreflect.Message
- func (x *LeavePeerRequest) Reset()
- func (x *LeavePeerRequest) String() string
- func (m *LeavePeerRequest) Validate() error
- func (m *LeavePeerRequest) ValidateAll() error
- type LeavePeerRequestMultiError
- type LeavePeerRequestValidationError
- func (e LeavePeerRequestValidationError) Cause() error
- func (e LeavePeerRequestValidationError) Error() string
- func (e LeavePeerRequestValidationError) ErrorName() string
- func (e LeavePeerRequestValidationError) Field() string
- func (e LeavePeerRequestValidationError) Key() bool
- func (e LeavePeerRequestValidationError) Reason() string
- type LeaveTaskRequest
- func (*LeaveTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LeaveTaskRequest) GetHostId() string
- func (x *LeaveTaskRequest) GetTaskId() string
- func (*LeaveTaskRequest) ProtoMessage()
- func (x *LeaveTaskRequest) ProtoReflect() protoreflect.Message
- func (x *LeaveTaskRequest) Reset()
- func (x *LeaveTaskRequest) String() string
- func (m *LeaveTaskRequest) Validate() error
- func (m *LeaveTaskRequest) ValidateAll() error
- type LeaveTaskRequestMultiError
- type LeaveTaskRequestValidationError
- func (e LeaveTaskRequestValidationError) Cause() error
- func (e LeaveTaskRequestValidationError) Error() string
- func (e LeaveTaskRequestValidationError) ErrorName() string
- func (e LeaveTaskRequestValidationError) Field() string
- func (e LeaveTaskRequestValidationError) Key() bool
- func (e LeaveTaskRequestValidationError) Reason() string
- type NeedBackToSourceResponse
- func (*NeedBackToSourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *NeedBackToSourceResponse) GetDescription() string
- func (*NeedBackToSourceResponse) ProtoMessage()
- func (x *NeedBackToSourceResponse) ProtoReflect() protoreflect.Message
- func (x *NeedBackToSourceResponse) Reset()
- func (x *NeedBackToSourceResponse) String() string
- func (m *NeedBackToSourceResponse) Validate() error
- func (m *NeedBackToSourceResponse) ValidateAll() error
- type NeedBackToSourceResponseMultiError
- type NeedBackToSourceResponseValidationError
- func (e NeedBackToSourceResponseValidationError) Cause() error
- func (e NeedBackToSourceResponseValidationError) Error() string
- func (e NeedBackToSourceResponseValidationError) ErrorName() string
- func (e NeedBackToSourceResponseValidationError) Field() string
- func (e NeedBackToSourceResponseValidationError) Key() bool
- func (e NeedBackToSourceResponseValidationError) Reason() string
- type NormalTaskResponse
- func (*NormalTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *NormalTaskResponse) GetCandidateParents() []*v2.Peer
- func (*NormalTaskResponse) ProtoMessage()
- func (x *NormalTaskResponse) ProtoReflect() protoreflect.Message
- func (x *NormalTaskResponse) Reset()
- func (x *NormalTaskResponse) String() string
- func (m *NormalTaskResponse) Validate() error
- func (m *NormalTaskResponse) ValidateAll() error
- type NormalTaskResponseMultiError
- type NormalTaskResponseValidationError
- func (e NormalTaskResponseValidationError) Cause() error
- func (e NormalTaskResponseValidationError) Error() string
- func (e NormalTaskResponseValidationError) ErrorName() string
- func (e NormalTaskResponseValidationError) Field() string
- func (e NormalTaskResponseValidationError) Key() bool
- func (e NormalTaskResponseValidationError) Reason() string
- type Probe
- func (*Probe) Descriptor() ([]byte, []int)deprecated
- func (x *Probe) GetCreatedAt() *timestamppb.Timestamp
- func (x *Probe) GetHost() *v2.Host
- func (x *Probe) GetRtt() *durationpb.Duration
- func (*Probe) ProtoMessage()
- func (x *Probe) ProtoReflect() protoreflect.Message
- func (x *Probe) Reset()
- func (x *Probe) String() string
- func (m *Probe) Validate() error
- func (m *Probe) ValidateAll() error
- type ProbeFailedRequest
- func (*ProbeFailedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ProbeFailedRequest) GetProbes() []*FailedProbe
- func (*ProbeFailedRequest) ProtoMessage()
- func (x *ProbeFailedRequest) ProtoReflect() protoreflect.Message
- func (x *ProbeFailedRequest) Reset()
- func (x *ProbeFailedRequest) String() string
- func (m *ProbeFailedRequest) Validate() error
- func (m *ProbeFailedRequest) ValidateAll() error
- type ProbeFailedRequestMultiError
- type ProbeFailedRequestValidationError
- func (e ProbeFailedRequestValidationError) Cause() error
- func (e ProbeFailedRequestValidationError) Error() string
- func (e ProbeFailedRequestValidationError) ErrorName() string
- func (e ProbeFailedRequestValidationError) Field() string
- func (e ProbeFailedRequestValidationError) Key() bool
- func (e ProbeFailedRequestValidationError) Reason() string
- type ProbeFinishedRequest
- func (*ProbeFinishedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ProbeFinishedRequest) GetProbes() []*Probe
- func (*ProbeFinishedRequest) ProtoMessage()
- func (x *ProbeFinishedRequest) ProtoReflect() protoreflect.Message
- func (x *ProbeFinishedRequest) Reset()
- func (x *ProbeFinishedRequest) String() string
- func (m *ProbeFinishedRequest) Validate() error
- func (m *ProbeFinishedRequest) ValidateAll() error
- type ProbeFinishedRequestMultiError
- type ProbeFinishedRequestValidationError
- func (e ProbeFinishedRequestValidationError) Cause() error
- func (e ProbeFinishedRequestValidationError) Error() string
- func (e ProbeFinishedRequestValidationError) ErrorName() string
- func (e ProbeFinishedRequestValidationError) Field() string
- func (e ProbeFinishedRequestValidationError) Key() bool
- func (e ProbeFinishedRequestValidationError) Reason() string
- type ProbeMultiError
- type ProbeStartedRequest
- func (*ProbeStartedRequest) Descriptor() ([]byte, []int)deprecated
- func (*ProbeStartedRequest) ProtoMessage()
- func (x *ProbeStartedRequest) ProtoReflect() protoreflect.Message
- func (x *ProbeStartedRequest) Reset()
- func (x *ProbeStartedRequest) String() string
- func (m *ProbeStartedRequest) Validate() error
- func (m *ProbeStartedRequest) ValidateAll() error
- type ProbeStartedRequestMultiError
- type ProbeStartedRequestValidationError
- func (e ProbeStartedRequestValidationError) Cause() error
- func (e ProbeStartedRequestValidationError) Error() string
- func (e ProbeStartedRequestValidationError) ErrorName() string
- func (e ProbeStartedRequestValidationError) Field() string
- func (e ProbeStartedRequestValidationError) Key() bool
- func (e ProbeStartedRequestValidationError) Reason() string
- type ProbeValidationError
- type RegisterPeerRequest
- func (*RegisterPeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterPeerRequest) GetDownloadTask() *v2.DownloadTask
- func (*RegisterPeerRequest) ProtoMessage()
- func (x *RegisterPeerRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterPeerRequest) Reset()
- func (x *RegisterPeerRequest) String() string
- func (m *RegisterPeerRequest) Validate() error
- func (m *RegisterPeerRequest) ValidateAll() error
- type RegisterPeerRequestMultiError
- type RegisterPeerRequestValidationError
- func (e RegisterPeerRequestValidationError) Cause() error
- func (e RegisterPeerRequestValidationError) Error() string
- func (e RegisterPeerRequestValidationError) ErrorName() string
- func (e RegisterPeerRequestValidationError) Field() string
- func (e RegisterPeerRequestValidationError) Key() bool
- func (e RegisterPeerRequestValidationError) Reason() string
- type RescheduleRequest
- func (*RescheduleRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RescheduleRequest) GetCandidateParents() []*v2.Peer
- func (x *RescheduleRequest) GetDescription() string
- func (*RescheduleRequest) ProtoMessage()
- func (x *RescheduleRequest) ProtoReflect() protoreflect.Message
- func (x *RescheduleRequest) Reset()
- func (x *RescheduleRequest) String() string
- func (m *RescheduleRequest) Validate() error
- func (m *RescheduleRequest) ValidateAll() error
- type RescheduleRequestMultiError
- type RescheduleRequestValidationError
- func (e RescheduleRequestValidationError) Cause() error
- func (e RescheduleRequestValidationError) Error() string
- func (e RescheduleRequestValidationError) ErrorName() string
- func (e RescheduleRequestValidationError) Field() string
- func (e RescheduleRequestValidationError) Key() bool
- func (e RescheduleRequestValidationError) Reason() string
- type SchedulerClient
- type SchedulerServer
- type Scheduler_AnnouncePeerClient
- type Scheduler_AnnouncePeerServer
- type Scheduler_SyncProbesClient
- type Scheduler_SyncProbesServer
- type StatPeerRequest
- func (*StatPeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatPeerRequest) GetHostId() string
- func (x *StatPeerRequest) GetPeerId() string
- func (x *StatPeerRequest) GetTaskId() string
- func (*StatPeerRequest) ProtoMessage()
- func (x *StatPeerRequest) ProtoReflect() protoreflect.Message
- func (x *StatPeerRequest) Reset()
- func (x *StatPeerRequest) String() string
- func (m *StatPeerRequest) Validate() error
- func (m *StatPeerRequest) ValidateAll() error
- type StatPeerRequestMultiError
- type StatPeerRequestValidationError
- func (e StatPeerRequestValidationError) Cause() error
- func (e StatPeerRequestValidationError) Error() string
- func (e StatPeerRequestValidationError) ErrorName() string
- func (e StatPeerRequestValidationError) Field() string
- func (e StatPeerRequestValidationError) Key() bool
- func (e StatPeerRequestValidationError) Reason() string
- type StatTaskRequest
- func (*StatTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatTaskRequest) GetId() string
- func (*StatTaskRequest) ProtoMessage()
- func (x *StatTaskRequest) ProtoReflect() protoreflect.Message
- func (x *StatTaskRequest) Reset()
- func (x *StatTaskRequest) String() string
- func (m *StatTaskRequest) Validate() error
- func (m *StatTaskRequest) ValidateAll() error
- type StatTaskRequestMultiError
- type StatTaskRequestValidationError
- func (e StatTaskRequestValidationError) Cause() error
- func (e StatTaskRequestValidationError) Error() string
- func (e StatTaskRequestValidationError) ErrorName() string
- func (e StatTaskRequestValidationError) Field() string
- func (e StatTaskRequestValidationError) Key() bool
- func (e StatTaskRequestValidationError) Reason() string
- type SyncProbesRequest
- func (*SyncProbesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SyncProbesRequest) GetHost() *v2.Host
- func (x *SyncProbesRequest) GetProbeFailedRequest() *ProbeFailedRequest
- func (x *SyncProbesRequest) GetProbeFinishedRequest() *ProbeFinishedRequest
- func (x *SyncProbesRequest) GetProbeStartedRequest() *ProbeStartedRequest
- func (m *SyncProbesRequest) GetRequest() isSyncProbesRequest_Request
- func (*SyncProbesRequest) ProtoMessage()
- func (x *SyncProbesRequest) ProtoReflect() protoreflect.Message
- func (x *SyncProbesRequest) Reset()
- func (x *SyncProbesRequest) String() string
- func (m *SyncProbesRequest) Validate() error
- func (m *SyncProbesRequest) ValidateAll() error
- type SyncProbesRequestMultiError
- type SyncProbesRequestValidationError
- func (e SyncProbesRequestValidationError) Cause() error
- func (e SyncProbesRequestValidationError) Error() string
- func (e SyncProbesRequestValidationError) ErrorName() string
- func (e SyncProbesRequestValidationError) Field() string
- func (e SyncProbesRequestValidationError) Key() bool
- func (e SyncProbesRequestValidationError) Reason() string
- type SyncProbesRequest_ProbeFailedRequest
- type SyncProbesRequest_ProbeFinishedRequest
- type SyncProbesRequest_ProbeStartedRequest
- type SyncProbesResponse
- func (*SyncProbesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SyncProbesResponse) GetHosts() []*v2.Host
- func (*SyncProbesResponse) ProtoMessage()
- func (x *SyncProbesResponse) ProtoReflect() protoreflect.Message
- func (x *SyncProbesResponse) Reset()
- func (x *SyncProbesResponse) String() string
- func (m *SyncProbesResponse) Validate() error
- func (m *SyncProbesResponse) ValidateAll() error
- type SyncProbesResponseMultiError
- type SyncProbesResponseValidationError
- func (e SyncProbesResponseValidationError) Cause() error
- func (e SyncProbesResponseValidationError) Error() string
- func (e SyncProbesResponseValidationError) ErrorName() string
- func (e SyncProbesResponseValidationError) Field() string
- func (e SyncProbesResponseValidationError) Key() bool
- func (e SyncProbesResponseValidationError) Reason() string
- type UnimplementedSchedulerServer
- func (UnimplementedSchedulerServer) AnnounceHost(context.Context, *AnnounceHostRequest) (*emptypb.Empty, error)
- func (UnimplementedSchedulerServer) AnnouncePeer(Scheduler_AnnouncePeerServer) error
- func (UnimplementedSchedulerServer) ExchangePeer(context.Context, *ExchangePeerRequest) (*ExchangePeerResponse, error)
- func (UnimplementedSchedulerServer) LeaveHost(context.Context, *LeaveHostRequest) (*emptypb.Empty, error)
- func (UnimplementedSchedulerServer) LeavePeer(context.Context, *LeavePeerRequest) (*emptypb.Empty, error)
- func (UnimplementedSchedulerServer) LeaveTask(context.Context, *LeaveTaskRequest) (*emptypb.Empty, error)
- func (UnimplementedSchedulerServer) StatPeer(context.Context, *StatPeerRequest) (*v2.Peer, error)
- func (UnimplementedSchedulerServer) StatTask(context.Context, *StatTaskRequest) (*v2.Task, error)
- func (UnimplementedSchedulerServer) SyncProbes(Scheduler_SyncProbesServer) error
- type UnsafeSchedulerServer
Constants ¶
This section is empty.
Variables ¶
var File_pkg_apis_scheduler_v2_scheduler_proto protoreflect.FileDescriptor
var Scheduler_ServiceDesc = grpc.ServiceDesc{ ServiceName: "scheduler.v2.Scheduler", HandlerType: (*SchedulerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "StatPeer", Handler: _Scheduler_StatPeer_Handler, }, { MethodName: "LeavePeer", Handler: _Scheduler_LeavePeer_Handler, }, { MethodName: "ExchangePeer", Handler: _Scheduler_ExchangePeer_Handler, }, { MethodName: "StatTask", Handler: _Scheduler_StatTask_Handler, }, { MethodName: "LeaveTask", Handler: _Scheduler_LeaveTask_Handler, }, { MethodName: "AnnounceHost", Handler: _Scheduler_AnnounceHost_Handler, }, { MethodName: "LeaveHost", Handler: _Scheduler_LeaveHost_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "AnnouncePeer", Handler: _Scheduler_AnnouncePeer_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "SyncProbes", Handler: _Scheduler_SyncProbes_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "pkg/apis/scheduler/v2/scheduler.proto", }
Scheduler_ServiceDesc is the grpc.ServiceDesc for Scheduler service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSchedulerServer ¶
func RegisterSchedulerServer(s grpc.ServiceRegistrar, srv SchedulerServer)
Types ¶
type AnnounceHostRequest ¶
type AnnounceHostRequest struct { // Host info. Host *v2.Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` // contains filtered or unexported fields }
AnnounceHostRequest represents request of AnnounceHost.
func (*AnnounceHostRequest) Descriptor
deprecated
func (*AnnounceHostRequest) Descriptor() ([]byte, []int)
Deprecated: Use AnnounceHostRequest.ProtoReflect.Descriptor instead.
func (*AnnounceHostRequest) GetHost ¶
func (x *AnnounceHostRequest) GetHost() *v2.Host
func (*AnnounceHostRequest) ProtoMessage ¶
func (*AnnounceHostRequest) ProtoMessage()
func (*AnnounceHostRequest) ProtoReflect ¶
func (x *AnnounceHostRequest) ProtoReflect() protoreflect.Message
func (*AnnounceHostRequest) Reset ¶
func (x *AnnounceHostRequest) Reset()
func (*AnnounceHostRequest) String ¶
func (x *AnnounceHostRequest) String() string
func (*AnnounceHostRequest) Validate ¶
func (m *AnnounceHostRequest) Validate() error
Validate checks the field values on AnnounceHostRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*AnnounceHostRequest) ValidateAll ¶
func (m *AnnounceHostRequest) ValidateAll() error
ValidateAll checks the field values on AnnounceHostRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AnnounceHostRequestMultiError, or nil if none found.
type AnnounceHostRequestMultiError ¶
type AnnounceHostRequestMultiError []error
AnnounceHostRequestMultiError is an error wrapping multiple validation errors returned by AnnounceHostRequest.ValidateAll() if the designated constraints aren't met.
func (AnnounceHostRequestMultiError) AllErrors ¶
func (m AnnounceHostRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (AnnounceHostRequestMultiError) Error ¶
func (m AnnounceHostRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type AnnounceHostRequestValidationError ¶
type AnnounceHostRequestValidationError struct {
// contains filtered or unexported fields
}
AnnounceHostRequestValidationError is the validation error returned by AnnounceHostRequest.Validate if the designated constraints aren't met.
func (AnnounceHostRequestValidationError) Cause ¶
func (e AnnounceHostRequestValidationError) Cause() error
Cause function returns cause value.
func (AnnounceHostRequestValidationError) Error ¶
func (e AnnounceHostRequestValidationError) Error() string
Error satisfies the builtin error interface
func (AnnounceHostRequestValidationError) ErrorName ¶
func (e AnnounceHostRequestValidationError) ErrorName() string
ErrorName returns error name.
func (AnnounceHostRequestValidationError) Field ¶
func (e AnnounceHostRequestValidationError) Field() string
Field function returns field value.
func (AnnounceHostRequestValidationError) Key ¶
func (e AnnounceHostRequestValidationError) Key() bool
Key function returns key value.
func (AnnounceHostRequestValidationError) Reason ¶
func (e AnnounceHostRequestValidationError) Reason() string
Reason function returns reason value.
type AnnouncePeerRequest ¶
type AnnouncePeerRequest struct { // Host id. HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"` // Task id. TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // Peer id. PeerId string `protobuf:"bytes,3,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"` // Types that are assignable to Request: // // *AnnouncePeerRequest_RegisterPeerRequest // *AnnouncePeerRequest_DownloadPeerStartedRequest // *AnnouncePeerRequest_DownloadPeerBackToSourceStartedRequest // *AnnouncePeerRequest_RescheduleRequest // *AnnouncePeerRequest_DownloadPeerFinishedRequest // *AnnouncePeerRequest_DownloadPeerBackToSourceFinishedRequest // *AnnouncePeerRequest_DownloadPeerFailedRequest // *AnnouncePeerRequest_DownloadPeerBackToSourceFailedRequest // *AnnouncePeerRequest_DownloadPieceFinishedRequest // *AnnouncePeerRequest_DownloadPieceBackToSourceFinishedRequest // *AnnouncePeerRequest_DownloadPieceFailedRequest // *AnnouncePeerRequest_DownloadPieceBackToSourceFailedRequest 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) GetDownloadPeerBackToSourceFailedRequest ¶
func (x *AnnouncePeerRequest) GetDownloadPeerBackToSourceFailedRequest() *DownloadPeerBackToSourceFailedRequest
func (*AnnouncePeerRequest) GetDownloadPeerBackToSourceFinishedRequest ¶
func (x *AnnouncePeerRequest) GetDownloadPeerBackToSourceFinishedRequest() *DownloadPeerBackToSourceFinishedRequest
func (*AnnouncePeerRequest) GetDownloadPeerBackToSourceStartedRequest ¶
func (x *AnnouncePeerRequest) GetDownloadPeerBackToSourceStartedRequest() *DownloadPeerBackToSourceStartedRequest
func (*AnnouncePeerRequest) GetDownloadPeerFailedRequest ¶
func (x *AnnouncePeerRequest) GetDownloadPeerFailedRequest() *DownloadPeerFailedRequest
func (*AnnouncePeerRequest) GetDownloadPeerFinishedRequest ¶
func (x *AnnouncePeerRequest) GetDownloadPeerFinishedRequest() *DownloadPeerFinishedRequest
func (*AnnouncePeerRequest) GetDownloadPeerStartedRequest ¶
func (x *AnnouncePeerRequest) GetDownloadPeerStartedRequest() *DownloadPeerStartedRequest
func (*AnnouncePeerRequest) GetDownloadPieceBackToSourceFailedRequest ¶
func (x *AnnouncePeerRequest) GetDownloadPieceBackToSourceFailedRequest() *DownloadPieceBackToSourceFailedRequest
func (*AnnouncePeerRequest) GetDownloadPieceBackToSourceFinishedRequest ¶
func (x *AnnouncePeerRequest) GetDownloadPieceBackToSourceFinishedRequest() *DownloadPieceBackToSourceFinishedRequest
func (*AnnouncePeerRequest) GetDownloadPieceFailedRequest ¶
func (x *AnnouncePeerRequest) GetDownloadPieceFailedRequest() *DownloadPieceFailedRequest
func (*AnnouncePeerRequest) GetDownloadPieceFinishedRequest ¶
func (x *AnnouncePeerRequest) GetDownloadPieceFinishedRequest() *DownloadPieceFinishedRequest
func (*AnnouncePeerRequest) GetHostId ¶
func (x *AnnouncePeerRequest) GetHostId() string
func (*AnnouncePeerRequest) GetPeerId ¶
func (x *AnnouncePeerRequest) GetPeerId() string
func (*AnnouncePeerRequest) GetRegisterPeerRequest ¶
func (x *AnnouncePeerRequest) GetRegisterPeerRequest() *RegisterPeerRequest
func (*AnnouncePeerRequest) GetRequest ¶
func (m *AnnouncePeerRequest) GetRequest() isAnnouncePeerRequest_Request
func (*AnnouncePeerRequest) GetRescheduleRequest ¶ added in v2.0.46
func (x *AnnouncePeerRequest) GetRescheduleRequest() *RescheduleRequest
func (*AnnouncePeerRequest) GetTaskId ¶
func (x *AnnouncePeerRequest) GetTaskId() string
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_DownloadPeerBackToSourceFailedRequest ¶
type AnnouncePeerRequest_DownloadPeerBackToSourceFailedRequest struct {
DownloadPeerBackToSourceFailedRequest *DownloadPeerBackToSourceFailedRequest `` /* 128-byte string literal not displayed */
}
type AnnouncePeerRequest_DownloadPeerBackToSourceFinishedRequest ¶
type AnnouncePeerRequest_DownloadPeerBackToSourceFinishedRequest struct {
DownloadPeerBackToSourceFinishedRequest *DownloadPeerBackToSourceFinishedRequest `` /* 131-byte string literal not displayed */
}
type AnnouncePeerRequest_DownloadPeerBackToSourceStartedRequest ¶
type AnnouncePeerRequest_DownloadPeerBackToSourceStartedRequest struct {
DownloadPeerBackToSourceStartedRequest *DownloadPeerBackToSourceStartedRequest `` /* 129-byte string literal not displayed */
}
type AnnouncePeerRequest_DownloadPeerFailedRequest ¶
type AnnouncePeerRequest_DownloadPeerFailedRequest struct {
DownloadPeerFailedRequest *DownloadPeerFailedRequest `protobuf:"bytes,10,opt,name=download_peer_failed_request,json=downloadPeerFailedRequest,proto3,oneof"`
}
type AnnouncePeerRequest_DownloadPeerFinishedRequest ¶
type AnnouncePeerRequest_DownloadPeerFinishedRequest struct {
DownloadPeerFinishedRequest *DownloadPeerFinishedRequest `protobuf:"bytes,8,opt,name=download_peer_finished_request,json=downloadPeerFinishedRequest,proto3,oneof"`
}
type AnnouncePeerRequest_DownloadPeerStartedRequest ¶
type AnnouncePeerRequest_DownloadPeerStartedRequest struct {
DownloadPeerStartedRequest *DownloadPeerStartedRequest `protobuf:"bytes,5,opt,name=download_peer_started_request,json=downloadPeerStartedRequest,proto3,oneof"`
}
type AnnouncePeerRequest_DownloadPieceBackToSourceFailedRequest ¶
type AnnouncePeerRequest_DownloadPieceBackToSourceFailedRequest struct {
DownloadPieceBackToSourceFailedRequest *DownloadPieceBackToSourceFailedRequest `` /* 130-byte string literal not displayed */
}
type AnnouncePeerRequest_DownloadPieceBackToSourceFinishedRequest ¶
type AnnouncePeerRequest_DownloadPieceBackToSourceFinishedRequest struct {
DownloadPieceBackToSourceFinishedRequest *DownloadPieceBackToSourceFinishedRequest `` /* 134-byte string literal not displayed */
}
type AnnouncePeerRequest_DownloadPieceFailedRequest ¶
type AnnouncePeerRequest_DownloadPieceFailedRequest struct {
DownloadPieceFailedRequest *DownloadPieceFailedRequest `protobuf:"bytes,14,opt,name=download_piece_failed_request,json=downloadPieceFailedRequest,proto3,oneof"`
}
type AnnouncePeerRequest_DownloadPieceFinishedRequest ¶
type AnnouncePeerRequest_DownloadPieceFinishedRequest struct {
DownloadPieceFinishedRequest *DownloadPieceFinishedRequest `protobuf:"bytes,12,opt,name=download_piece_finished_request,json=downloadPieceFinishedRequest,proto3,oneof"`
}
type AnnouncePeerRequest_RegisterPeerRequest ¶
type AnnouncePeerRequest_RegisterPeerRequest struct {
RegisterPeerRequest *RegisterPeerRequest `protobuf:"bytes,4,opt,name=register_peer_request,json=registerPeerRequest,proto3,oneof"`
}
type AnnouncePeerRequest_RescheduleRequest ¶ added in v2.0.46
type AnnouncePeerRequest_RescheduleRequest struct {
RescheduleRequest *RescheduleRequest `protobuf:"bytes,7,opt,name=reschedule_request,json=rescheduleRequest,proto3,oneof"`
}
type AnnouncePeerResponse ¶
type AnnouncePeerResponse struct { // Types that are assignable to Response: // // *AnnouncePeerResponse_EmptyTaskResponse // *AnnouncePeerResponse_NormalTaskResponse // *AnnouncePeerResponse_NeedBackToSourceResponse 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) GetEmptyTaskResponse ¶
func (x *AnnouncePeerResponse) GetEmptyTaskResponse() *EmptyTaskResponse
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) 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_EmptyTaskResponse ¶
type AnnouncePeerResponse_EmptyTaskResponse struct {
EmptyTaskResponse *EmptyTaskResponse `protobuf:"bytes,1,opt,name=empty_task_response,json=emptyTaskResponse,proto3,oneof"`
}
type AnnouncePeerResponse_NeedBackToSourceResponse ¶
type AnnouncePeerResponse_NeedBackToSourceResponse struct {
NeedBackToSourceResponse *NeedBackToSourceResponse `protobuf:"bytes,3,opt,name=need_back_to_source_response,json=needBackToSourceResponse,proto3,oneof"`
}
type AnnouncePeerResponse_NormalTaskResponse ¶
type AnnouncePeerResponse_NormalTaskResponse struct {
NormalTaskResponse *NormalTaskResponse `protobuf:"bytes,2,opt,name=normal_task_response,json=normalTaskResponse,proto3,oneof"`
}
type DownloadPeerBackToSourceFailedRequest ¶
type DownloadPeerBackToSourceFailedRequest struct { // The description of the download back-to-source failed. Description *string `protobuf:"bytes,1,opt,name=description,proto3,oneof" json:"description,omitempty"` // contains filtered or unexported fields }
DownloadPeerBackToSourceFailedRequest represents peer download back-to-source failed request of AnnouncePeerRequest.
func (*DownloadPeerBackToSourceFailedRequest) Descriptor
deprecated
func (*DownloadPeerBackToSourceFailedRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadPeerBackToSourceFailedRequest.ProtoReflect.Descriptor instead.
func (*DownloadPeerBackToSourceFailedRequest) GetDescription ¶
func (x *DownloadPeerBackToSourceFailedRequest) GetDescription() string
func (*DownloadPeerBackToSourceFailedRequest) ProtoMessage ¶
func (*DownloadPeerBackToSourceFailedRequest) ProtoMessage()
func (*DownloadPeerBackToSourceFailedRequest) ProtoReflect ¶
func (x *DownloadPeerBackToSourceFailedRequest) ProtoReflect() protoreflect.Message
func (*DownloadPeerBackToSourceFailedRequest) Reset ¶
func (x *DownloadPeerBackToSourceFailedRequest) Reset()
func (*DownloadPeerBackToSourceFailedRequest) String ¶
func (x *DownloadPeerBackToSourceFailedRequest) String() string
func (*DownloadPeerBackToSourceFailedRequest) Validate ¶
func (m *DownloadPeerBackToSourceFailedRequest) Validate() error
Validate checks the field values on DownloadPeerBackToSourceFailedRequest 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 (*DownloadPeerBackToSourceFailedRequest) ValidateAll ¶
func (m *DownloadPeerBackToSourceFailedRequest) ValidateAll() error
ValidateAll checks the field values on DownloadPeerBackToSourceFailedRequest 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 DownloadPeerBackToSourceFailedRequestMultiError, or nil if none found.
type DownloadPeerBackToSourceFailedRequestMultiError ¶
type DownloadPeerBackToSourceFailedRequestMultiError []error
DownloadPeerBackToSourceFailedRequestMultiError is an error wrapping multiple validation errors returned by DownloadPeerBackToSourceFailedRequest.ValidateAll() if the designated constraints aren't met.
func (DownloadPeerBackToSourceFailedRequestMultiError) AllErrors ¶
func (m DownloadPeerBackToSourceFailedRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadPeerBackToSourceFailedRequestMultiError) Error ¶
func (m DownloadPeerBackToSourceFailedRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadPeerBackToSourceFailedRequestValidationError ¶
type DownloadPeerBackToSourceFailedRequestValidationError struct {
// contains filtered or unexported fields
}
DownloadPeerBackToSourceFailedRequestValidationError is the validation error returned by DownloadPeerBackToSourceFailedRequest.Validate if the designated constraints aren't met.
func (DownloadPeerBackToSourceFailedRequestValidationError) Cause ¶
func (e DownloadPeerBackToSourceFailedRequestValidationError) Cause() error
Cause function returns cause value.
func (DownloadPeerBackToSourceFailedRequestValidationError) Error ¶
func (e DownloadPeerBackToSourceFailedRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadPeerBackToSourceFailedRequestValidationError) ErrorName ¶
func (e DownloadPeerBackToSourceFailedRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadPeerBackToSourceFailedRequestValidationError) Field ¶
func (e DownloadPeerBackToSourceFailedRequestValidationError) Field() string
Field function returns field value.
func (DownloadPeerBackToSourceFailedRequestValidationError) Key ¶
func (e DownloadPeerBackToSourceFailedRequestValidationError) Key() bool
Key function returns key value.
func (DownloadPeerBackToSourceFailedRequestValidationError) Reason ¶
func (e DownloadPeerBackToSourceFailedRequestValidationError) Reason() string
Reason function returns reason value.
type DownloadPeerBackToSourceFinishedRequest ¶
type DownloadPeerBackToSourceFinishedRequest struct { // Total content length. ContentLength uint64 `protobuf:"varint,1,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"` // Total piece count. PieceCount uint32 `protobuf:"varint,2,opt,name=piece_count,json=pieceCount,proto3" json:"piece_count,omitempty"` // contains filtered or unexported fields }
DownloadPeerBackToSourceFinishedRequest represents peer download back-to-source finished request of AnnouncePeerRequest.
func (*DownloadPeerBackToSourceFinishedRequest) Descriptor
deprecated
func (*DownloadPeerBackToSourceFinishedRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadPeerBackToSourceFinishedRequest.ProtoReflect.Descriptor instead.
func (*DownloadPeerBackToSourceFinishedRequest) GetContentLength ¶
func (x *DownloadPeerBackToSourceFinishedRequest) GetContentLength() uint64
func (*DownloadPeerBackToSourceFinishedRequest) GetPieceCount ¶
func (x *DownloadPeerBackToSourceFinishedRequest) GetPieceCount() uint32
func (*DownloadPeerBackToSourceFinishedRequest) ProtoMessage ¶
func (*DownloadPeerBackToSourceFinishedRequest) ProtoMessage()
func (*DownloadPeerBackToSourceFinishedRequest) ProtoReflect ¶
func (x *DownloadPeerBackToSourceFinishedRequest) ProtoReflect() protoreflect.Message
func (*DownloadPeerBackToSourceFinishedRequest) Reset ¶
func (x *DownloadPeerBackToSourceFinishedRequest) Reset()
func (*DownloadPeerBackToSourceFinishedRequest) String ¶
func (x *DownloadPeerBackToSourceFinishedRequest) String() string
func (*DownloadPeerBackToSourceFinishedRequest) Validate ¶
func (m *DownloadPeerBackToSourceFinishedRequest) Validate() error
Validate checks the field values on DownloadPeerBackToSourceFinishedRequest 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 (*DownloadPeerBackToSourceFinishedRequest) ValidateAll ¶
func (m *DownloadPeerBackToSourceFinishedRequest) ValidateAll() error
ValidateAll checks the field values on DownloadPeerBackToSourceFinishedRequest 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 DownloadPeerBackToSourceFinishedRequestMultiError, or nil if none found.
type DownloadPeerBackToSourceFinishedRequestMultiError ¶
type DownloadPeerBackToSourceFinishedRequestMultiError []error
DownloadPeerBackToSourceFinishedRequestMultiError is an error wrapping multiple validation errors returned by DownloadPeerBackToSourceFinishedRequest.ValidateAll() if the designated constraints aren't met.
func (DownloadPeerBackToSourceFinishedRequestMultiError) AllErrors ¶
func (m DownloadPeerBackToSourceFinishedRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadPeerBackToSourceFinishedRequestMultiError) Error ¶
func (m DownloadPeerBackToSourceFinishedRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadPeerBackToSourceFinishedRequestValidationError ¶
type DownloadPeerBackToSourceFinishedRequestValidationError struct {
// contains filtered or unexported fields
}
DownloadPeerBackToSourceFinishedRequestValidationError is the validation error returned by DownloadPeerBackToSourceFinishedRequest.Validate if the designated constraints aren't met.
func (DownloadPeerBackToSourceFinishedRequestValidationError) Cause ¶
func (e DownloadPeerBackToSourceFinishedRequestValidationError) Cause() error
Cause function returns cause value.
func (DownloadPeerBackToSourceFinishedRequestValidationError) Error ¶
func (e DownloadPeerBackToSourceFinishedRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadPeerBackToSourceFinishedRequestValidationError) ErrorName ¶
func (e DownloadPeerBackToSourceFinishedRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadPeerBackToSourceFinishedRequestValidationError) Field ¶
func (e DownloadPeerBackToSourceFinishedRequestValidationError) Field() string
Field function returns field value.
func (DownloadPeerBackToSourceFinishedRequestValidationError) Key ¶
func (e DownloadPeerBackToSourceFinishedRequestValidationError) Key() bool
Key function returns key value.
func (DownloadPeerBackToSourceFinishedRequestValidationError) Reason ¶
func (e DownloadPeerBackToSourceFinishedRequestValidationError) Reason() string
Reason function returns reason value.
type DownloadPeerBackToSourceStartedRequest ¶
type DownloadPeerBackToSourceStartedRequest struct { // The description of the back-to-source reason. Description *string `protobuf:"bytes,1,opt,name=description,proto3,oneof" json:"description,omitempty"` // contains filtered or unexported fields }
DownloadPeerBackToSourceStartedRequest represents peer download back-to-source started request of AnnouncePeerRequest.
func (*DownloadPeerBackToSourceStartedRequest) Descriptor
deprecated
func (*DownloadPeerBackToSourceStartedRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadPeerBackToSourceStartedRequest.ProtoReflect.Descriptor instead.
func (*DownloadPeerBackToSourceStartedRequest) GetDescription ¶
func (x *DownloadPeerBackToSourceStartedRequest) GetDescription() string
func (*DownloadPeerBackToSourceStartedRequest) ProtoMessage ¶
func (*DownloadPeerBackToSourceStartedRequest) ProtoMessage()
func (*DownloadPeerBackToSourceStartedRequest) ProtoReflect ¶
func (x *DownloadPeerBackToSourceStartedRequest) ProtoReflect() protoreflect.Message
func (*DownloadPeerBackToSourceStartedRequest) Reset ¶
func (x *DownloadPeerBackToSourceStartedRequest) Reset()
func (*DownloadPeerBackToSourceStartedRequest) String ¶
func (x *DownloadPeerBackToSourceStartedRequest) String() string
func (*DownloadPeerBackToSourceStartedRequest) Validate ¶
func (m *DownloadPeerBackToSourceStartedRequest) Validate() error
Validate checks the field values on DownloadPeerBackToSourceStartedRequest 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 (*DownloadPeerBackToSourceStartedRequest) ValidateAll ¶
func (m *DownloadPeerBackToSourceStartedRequest) ValidateAll() error
ValidateAll checks the field values on DownloadPeerBackToSourceStartedRequest 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 DownloadPeerBackToSourceStartedRequestMultiError, or nil if none found.
type DownloadPeerBackToSourceStartedRequestMultiError ¶
type DownloadPeerBackToSourceStartedRequestMultiError []error
DownloadPeerBackToSourceStartedRequestMultiError is an error wrapping multiple validation errors returned by DownloadPeerBackToSourceStartedRequest.ValidateAll() if the designated constraints aren't met.
func (DownloadPeerBackToSourceStartedRequestMultiError) AllErrors ¶
func (m DownloadPeerBackToSourceStartedRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadPeerBackToSourceStartedRequestMultiError) Error ¶
func (m DownloadPeerBackToSourceStartedRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadPeerBackToSourceStartedRequestValidationError ¶
type DownloadPeerBackToSourceStartedRequestValidationError struct {
// contains filtered or unexported fields
}
DownloadPeerBackToSourceStartedRequestValidationError is the validation error returned by DownloadPeerBackToSourceStartedRequest.Validate if the designated constraints aren't met.
func (DownloadPeerBackToSourceStartedRequestValidationError) Cause ¶
func (e DownloadPeerBackToSourceStartedRequestValidationError) Cause() error
Cause function returns cause value.
func (DownloadPeerBackToSourceStartedRequestValidationError) Error ¶
func (e DownloadPeerBackToSourceStartedRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadPeerBackToSourceStartedRequestValidationError) ErrorName ¶
func (e DownloadPeerBackToSourceStartedRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadPeerBackToSourceStartedRequestValidationError) Field ¶
func (e DownloadPeerBackToSourceStartedRequestValidationError) Field() string
Field function returns field value.
func (DownloadPeerBackToSourceStartedRequestValidationError) Key ¶
func (e DownloadPeerBackToSourceStartedRequestValidationError) Key() bool
Key function returns key value.
func (DownloadPeerBackToSourceStartedRequestValidationError) Reason ¶
func (e DownloadPeerBackToSourceStartedRequestValidationError) Reason() string
Reason function returns reason value.
type DownloadPeerFailedRequest ¶
type DownloadPeerFailedRequest struct { // The description of the download failed. Description *string `protobuf:"bytes,1,opt,name=description,proto3,oneof" json:"description,omitempty"` // contains filtered or unexported fields }
DownloadPeerFailedRequest represents peer download failed request of AnnouncePeerRequest.
func (*DownloadPeerFailedRequest) Descriptor
deprecated
func (*DownloadPeerFailedRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadPeerFailedRequest.ProtoReflect.Descriptor instead.
func (*DownloadPeerFailedRequest) GetDescription ¶
func (x *DownloadPeerFailedRequest) GetDescription() string
func (*DownloadPeerFailedRequest) ProtoMessage ¶
func (*DownloadPeerFailedRequest) ProtoMessage()
func (*DownloadPeerFailedRequest) ProtoReflect ¶
func (x *DownloadPeerFailedRequest) ProtoReflect() protoreflect.Message
func (*DownloadPeerFailedRequest) Reset ¶
func (x *DownloadPeerFailedRequest) Reset()
func (*DownloadPeerFailedRequest) String ¶
func (x *DownloadPeerFailedRequest) String() string
func (*DownloadPeerFailedRequest) Validate ¶
func (m *DownloadPeerFailedRequest) Validate() error
Validate checks the field values on DownloadPeerFailedRequest 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 (*DownloadPeerFailedRequest) ValidateAll ¶
func (m *DownloadPeerFailedRequest) ValidateAll() error
ValidateAll checks the field values on DownloadPeerFailedRequest 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 DownloadPeerFailedRequestMultiError, or nil if none found.
type DownloadPeerFailedRequestMultiError ¶
type DownloadPeerFailedRequestMultiError []error
DownloadPeerFailedRequestMultiError is an error wrapping multiple validation errors returned by DownloadPeerFailedRequest.ValidateAll() if the designated constraints aren't met.
func (DownloadPeerFailedRequestMultiError) AllErrors ¶
func (m DownloadPeerFailedRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadPeerFailedRequestMultiError) Error ¶
func (m DownloadPeerFailedRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadPeerFailedRequestValidationError ¶
type DownloadPeerFailedRequestValidationError struct {
// contains filtered or unexported fields
}
DownloadPeerFailedRequestValidationError is the validation error returned by DownloadPeerFailedRequest.Validate if the designated constraints aren't met.
func (DownloadPeerFailedRequestValidationError) Cause ¶
func (e DownloadPeerFailedRequestValidationError) Cause() error
Cause function returns cause value.
func (DownloadPeerFailedRequestValidationError) Error ¶
func (e DownloadPeerFailedRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadPeerFailedRequestValidationError) ErrorName ¶
func (e DownloadPeerFailedRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadPeerFailedRequestValidationError) Field ¶
func (e DownloadPeerFailedRequestValidationError) Field() string
Field function returns field value.
func (DownloadPeerFailedRequestValidationError) Key ¶
func (e DownloadPeerFailedRequestValidationError) Key() bool
Key function returns key value.
func (DownloadPeerFailedRequestValidationError) Reason ¶
func (e DownloadPeerFailedRequestValidationError) Reason() string
Reason function returns reason value.
type DownloadPeerFinishedRequest ¶
type DownloadPeerFinishedRequest struct { // Total content length. ContentLength uint64 `protobuf:"varint,1,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"` // Total piece count. PieceCount uint32 `protobuf:"varint,2,opt,name=piece_count,json=pieceCount,proto3" json:"piece_count,omitempty"` // contains filtered or unexported fields }
DownloadPeerFinishedRequest represents peer download finished request of AnnouncePeerRequest.
func (*DownloadPeerFinishedRequest) Descriptor
deprecated
func (*DownloadPeerFinishedRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadPeerFinishedRequest.ProtoReflect.Descriptor instead.
func (*DownloadPeerFinishedRequest) GetContentLength ¶
func (x *DownloadPeerFinishedRequest) GetContentLength() uint64
func (*DownloadPeerFinishedRequest) GetPieceCount ¶
func (x *DownloadPeerFinishedRequest) GetPieceCount() uint32
func (*DownloadPeerFinishedRequest) ProtoMessage ¶
func (*DownloadPeerFinishedRequest) ProtoMessage()
func (*DownloadPeerFinishedRequest) ProtoReflect ¶
func (x *DownloadPeerFinishedRequest) ProtoReflect() protoreflect.Message
func (*DownloadPeerFinishedRequest) Reset ¶
func (x *DownloadPeerFinishedRequest) Reset()
func (*DownloadPeerFinishedRequest) String ¶
func (x *DownloadPeerFinishedRequest) String() string
func (*DownloadPeerFinishedRequest) Validate ¶
func (m *DownloadPeerFinishedRequest) Validate() error
Validate checks the field values on DownloadPeerFinishedRequest 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 (*DownloadPeerFinishedRequest) ValidateAll ¶
func (m *DownloadPeerFinishedRequest) ValidateAll() error
ValidateAll checks the field values on DownloadPeerFinishedRequest 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 DownloadPeerFinishedRequestMultiError, or nil if none found.
type DownloadPeerFinishedRequestMultiError ¶
type DownloadPeerFinishedRequestMultiError []error
DownloadPeerFinishedRequestMultiError is an error wrapping multiple validation errors returned by DownloadPeerFinishedRequest.ValidateAll() if the designated constraints aren't met.
func (DownloadPeerFinishedRequestMultiError) AllErrors ¶
func (m DownloadPeerFinishedRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadPeerFinishedRequestMultiError) Error ¶
func (m DownloadPeerFinishedRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadPeerFinishedRequestValidationError ¶
type DownloadPeerFinishedRequestValidationError struct {
// contains filtered or unexported fields
}
DownloadPeerFinishedRequestValidationError is the validation error returned by DownloadPeerFinishedRequest.Validate if the designated constraints aren't met.
func (DownloadPeerFinishedRequestValidationError) Cause ¶
func (e DownloadPeerFinishedRequestValidationError) Cause() error
Cause function returns cause value.
func (DownloadPeerFinishedRequestValidationError) Error ¶
func (e DownloadPeerFinishedRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadPeerFinishedRequestValidationError) ErrorName ¶
func (e DownloadPeerFinishedRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadPeerFinishedRequestValidationError) Field ¶
func (e DownloadPeerFinishedRequestValidationError) Field() string
Field function returns field value.
func (DownloadPeerFinishedRequestValidationError) Key ¶
func (e DownloadPeerFinishedRequestValidationError) Key() bool
Key function returns key value.
func (DownloadPeerFinishedRequestValidationError) Reason ¶
func (e DownloadPeerFinishedRequestValidationError) Reason() string
Reason function returns reason value.
type DownloadPeerStartedRequest ¶
type DownloadPeerStartedRequest struct {
// contains filtered or unexported fields
}
DownloadPeerStartedRequest represents peer download started request of AnnouncePeerRequest.
func (*DownloadPeerStartedRequest) Descriptor
deprecated
func (*DownloadPeerStartedRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadPeerStartedRequest.ProtoReflect.Descriptor instead.
func (*DownloadPeerStartedRequest) ProtoMessage ¶
func (*DownloadPeerStartedRequest) ProtoMessage()
func (*DownloadPeerStartedRequest) ProtoReflect ¶
func (x *DownloadPeerStartedRequest) ProtoReflect() protoreflect.Message
func (*DownloadPeerStartedRequest) Reset ¶
func (x *DownloadPeerStartedRequest) Reset()
func (*DownloadPeerStartedRequest) String ¶
func (x *DownloadPeerStartedRequest) String() string
func (*DownloadPeerStartedRequest) Validate ¶
func (m *DownloadPeerStartedRequest) Validate() error
Validate checks the field values on DownloadPeerStartedRequest 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 (*DownloadPeerStartedRequest) ValidateAll ¶
func (m *DownloadPeerStartedRequest) ValidateAll() error
ValidateAll checks the field values on DownloadPeerStartedRequest 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 DownloadPeerStartedRequestMultiError, or nil if none found.
type DownloadPeerStartedRequestMultiError ¶
type DownloadPeerStartedRequestMultiError []error
DownloadPeerStartedRequestMultiError is an error wrapping multiple validation errors returned by DownloadPeerStartedRequest.ValidateAll() if the designated constraints aren't met.
func (DownloadPeerStartedRequestMultiError) AllErrors ¶
func (m DownloadPeerStartedRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadPeerStartedRequestMultiError) Error ¶
func (m DownloadPeerStartedRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadPeerStartedRequestValidationError ¶
type DownloadPeerStartedRequestValidationError struct {
// contains filtered or unexported fields
}
DownloadPeerStartedRequestValidationError is the validation error returned by DownloadPeerStartedRequest.Validate if the designated constraints aren't met.
func (DownloadPeerStartedRequestValidationError) Cause ¶
func (e DownloadPeerStartedRequestValidationError) Cause() error
Cause function returns cause value.
func (DownloadPeerStartedRequestValidationError) Error ¶
func (e DownloadPeerStartedRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadPeerStartedRequestValidationError) ErrorName ¶
func (e DownloadPeerStartedRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadPeerStartedRequestValidationError) Field ¶
func (e DownloadPeerStartedRequestValidationError) Field() string
Field function returns field value.
func (DownloadPeerStartedRequestValidationError) Key ¶
func (e DownloadPeerStartedRequestValidationError) Key() bool
Key function returns key value.
func (DownloadPeerStartedRequestValidationError) Reason ¶
func (e DownloadPeerStartedRequestValidationError) Reason() string
Reason function returns reason value.
type DownloadPieceBackToSourceFailedRequest ¶
type DownloadPieceBackToSourceFailedRequest struct { // Piece number. PieceNumber *uint32 `protobuf:"varint,1,opt,name=piece_number,json=pieceNumber,proto3,oneof" json:"piece_number,omitempty"` // Types that are assignable to Response: // // *DownloadPieceBackToSourceFailedRequest_Backend Response isDownloadPieceBackToSourceFailedRequest_Response `protobuf_oneof:"response"` // contains filtered or unexported fields }
DownloadPieceBackToSourceFailedRequest downloads piece back-to-source failed request of AnnouncePeerRequest.
func (*DownloadPieceBackToSourceFailedRequest) Descriptor
deprecated
func (*DownloadPieceBackToSourceFailedRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadPieceBackToSourceFailedRequest.ProtoReflect.Descriptor instead.
func (*DownloadPieceBackToSourceFailedRequest) GetBackend ¶ added in v2.0.114
func (x *DownloadPieceBackToSourceFailedRequest) GetBackend() *v21.Backend
func (*DownloadPieceBackToSourceFailedRequest) GetPieceNumber ¶ added in v2.0.47
func (x *DownloadPieceBackToSourceFailedRequest) GetPieceNumber() uint32
func (*DownloadPieceBackToSourceFailedRequest) GetResponse ¶
func (m *DownloadPieceBackToSourceFailedRequest) GetResponse() isDownloadPieceBackToSourceFailedRequest_Response
func (*DownloadPieceBackToSourceFailedRequest) ProtoMessage ¶
func (*DownloadPieceBackToSourceFailedRequest) ProtoMessage()
func (*DownloadPieceBackToSourceFailedRequest) ProtoReflect ¶
func (x *DownloadPieceBackToSourceFailedRequest) ProtoReflect() protoreflect.Message
func (*DownloadPieceBackToSourceFailedRequest) Reset ¶
func (x *DownloadPieceBackToSourceFailedRequest) Reset()
func (*DownloadPieceBackToSourceFailedRequest) String ¶
func (x *DownloadPieceBackToSourceFailedRequest) String() string
func (*DownloadPieceBackToSourceFailedRequest) Validate ¶
func (m *DownloadPieceBackToSourceFailedRequest) Validate() error
Validate checks the field values on DownloadPieceBackToSourceFailedRequest 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 (*DownloadPieceBackToSourceFailedRequest) ValidateAll ¶
func (m *DownloadPieceBackToSourceFailedRequest) ValidateAll() error
ValidateAll checks the field values on DownloadPieceBackToSourceFailedRequest 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 DownloadPieceBackToSourceFailedRequestMultiError, or nil if none found.
type DownloadPieceBackToSourceFailedRequestMultiError ¶
type DownloadPieceBackToSourceFailedRequestMultiError []error
DownloadPieceBackToSourceFailedRequestMultiError is an error wrapping multiple validation errors returned by DownloadPieceBackToSourceFailedRequest.ValidateAll() if the designated constraints aren't met.
func (DownloadPieceBackToSourceFailedRequestMultiError) AllErrors ¶
func (m DownloadPieceBackToSourceFailedRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadPieceBackToSourceFailedRequestMultiError) Error ¶
func (m DownloadPieceBackToSourceFailedRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadPieceBackToSourceFailedRequestValidationError ¶
type DownloadPieceBackToSourceFailedRequestValidationError struct {
// contains filtered or unexported fields
}
DownloadPieceBackToSourceFailedRequestValidationError is the validation error returned by DownloadPieceBackToSourceFailedRequest.Validate if the designated constraints aren't met.
func (DownloadPieceBackToSourceFailedRequestValidationError) Cause ¶
func (e DownloadPieceBackToSourceFailedRequestValidationError) Cause() error
Cause function returns cause value.
func (DownloadPieceBackToSourceFailedRequestValidationError) Error ¶
func (e DownloadPieceBackToSourceFailedRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadPieceBackToSourceFailedRequestValidationError) ErrorName ¶
func (e DownloadPieceBackToSourceFailedRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadPieceBackToSourceFailedRequestValidationError) Field ¶
func (e DownloadPieceBackToSourceFailedRequestValidationError) Field() string
Field function returns field value.
func (DownloadPieceBackToSourceFailedRequestValidationError) Key ¶
func (e DownloadPieceBackToSourceFailedRequestValidationError) Key() bool
Key function returns key value.
func (DownloadPieceBackToSourceFailedRequestValidationError) Reason ¶
func (e DownloadPieceBackToSourceFailedRequestValidationError) Reason() string
Reason function returns reason value.
type DownloadPieceBackToSourceFailedRequest_Backend ¶ added in v2.0.114
type DownloadPieceBackToSourceFinishedRequest ¶
type DownloadPieceBackToSourceFinishedRequest struct { // Piece info. Piece *v2.Piece `protobuf:"bytes,1,opt,name=piece,proto3" json:"piece,omitempty"` // contains filtered or unexported fields }
DownloadPieceBackToSourceFinishedRequest represents piece download back-to-source finished request of AnnouncePeerRequest.
func (*DownloadPieceBackToSourceFinishedRequest) Descriptor
deprecated
func (*DownloadPieceBackToSourceFinishedRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadPieceBackToSourceFinishedRequest.ProtoReflect.Descriptor instead.
func (*DownloadPieceBackToSourceFinishedRequest) GetPiece ¶
func (x *DownloadPieceBackToSourceFinishedRequest) GetPiece() *v2.Piece
func (*DownloadPieceBackToSourceFinishedRequest) ProtoMessage ¶
func (*DownloadPieceBackToSourceFinishedRequest) ProtoMessage()
func (*DownloadPieceBackToSourceFinishedRequest) ProtoReflect ¶
func (x *DownloadPieceBackToSourceFinishedRequest) ProtoReflect() protoreflect.Message
func (*DownloadPieceBackToSourceFinishedRequest) Reset ¶
func (x *DownloadPieceBackToSourceFinishedRequest) Reset()
func (*DownloadPieceBackToSourceFinishedRequest) String ¶
func (x *DownloadPieceBackToSourceFinishedRequest) String() string
func (*DownloadPieceBackToSourceFinishedRequest) Validate ¶
func (m *DownloadPieceBackToSourceFinishedRequest) Validate() error
Validate checks the field values on DownloadPieceBackToSourceFinishedRequest 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 (*DownloadPieceBackToSourceFinishedRequest) ValidateAll ¶
func (m *DownloadPieceBackToSourceFinishedRequest) ValidateAll() error
ValidateAll checks the field values on DownloadPieceBackToSourceFinishedRequest 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 DownloadPieceBackToSourceFinishedRequestMultiError, or nil if none found.
type DownloadPieceBackToSourceFinishedRequestMultiError ¶
type DownloadPieceBackToSourceFinishedRequestMultiError []error
DownloadPieceBackToSourceFinishedRequestMultiError is an error wrapping multiple validation errors returned by DownloadPieceBackToSourceFinishedRequest.ValidateAll() if the designated constraints aren't met.
func (DownloadPieceBackToSourceFinishedRequestMultiError) AllErrors ¶
func (m DownloadPieceBackToSourceFinishedRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadPieceBackToSourceFinishedRequestMultiError) Error ¶
func (m DownloadPieceBackToSourceFinishedRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadPieceBackToSourceFinishedRequestValidationError ¶
type DownloadPieceBackToSourceFinishedRequestValidationError struct {
// contains filtered or unexported fields
}
DownloadPieceBackToSourceFinishedRequestValidationError is the validation error returned by DownloadPieceBackToSourceFinishedRequest.Validate if the designated constraints aren't met.
func (DownloadPieceBackToSourceFinishedRequestValidationError) Cause ¶
func (e DownloadPieceBackToSourceFinishedRequestValidationError) Cause() error
Cause function returns cause value.
func (DownloadPieceBackToSourceFinishedRequestValidationError) Error ¶
func (e DownloadPieceBackToSourceFinishedRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadPieceBackToSourceFinishedRequestValidationError) ErrorName ¶
func (e DownloadPieceBackToSourceFinishedRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadPieceBackToSourceFinishedRequestValidationError) Field ¶
func (e DownloadPieceBackToSourceFinishedRequestValidationError) Field() string
Field function returns field value.
func (DownloadPieceBackToSourceFinishedRequestValidationError) Key ¶
func (e DownloadPieceBackToSourceFinishedRequestValidationError) Key() bool
Key function returns key value.
func (DownloadPieceBackToSourceFinishedRequestValidationError) Reason ¶
func (e DownloadPieceBackToSourceFinishedRequestValidationError) Reason() string
Reason function returns reason value.
type DownloadPieceFailedRequest ¶
type DownloadPieceFailedRequest struct { // Piece number. PieceNumber *uint32 `protobuf:"varint,1,opt,name=piece_number,json=pieceNumber,proto3,oneof" json:"piece_number,omitempty"` // Parent id. ParentId string `protobuf:"bytes,2,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"` // Temporary indicates whether the error is temporary. Temporary bool `protobuf:"varint,3,opt,name=temporary,proto3" json:"temporary,omitempty"` // contains filtered or unexported fields }
DownloadPieceFailedRequest downloads piece failed request of AnnouncePeerRequest.
func (*DownloadPieceFailedRequest) Descriptor
deprecated
func (*DownloadPieceFailedRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadPieceFailedRequest.ProtoReflect.Descriptor instead.
func (*DownloadPieceFailedRequest) GetParentId ¶ added in v2.0.47
func (x *DownloadPieceFailedRequest) GetParentId() string
func (*DownloadPieceFailedRequest) GetPieceNumber ¶ added in v2.0.47
func (x *DownloadPieceFailedRequest) GetPieceNumber() uint32
func (*DownloadPieceFailedRequest) GetTemporary ¶
func (x *DownloadPieceFailedRequest) GetTemporary() bool
func (*DownloadPieceFailedRequest) ProtoMessage ¶
func (*DownloadPieceFailedRequest) ProtoMessage()
func (*DownloadPieceFailedRequest) ProtoReflect ¶
func (x *DownloadPieceFailedRequest) ProtoReflect() protoreflect.Message
func (*DownloadPieceFailedRequest) Reset ¶
func (x *DownloadPieceFailedRequest) Reset()
func (*DownloadPieceFailedRequest) String ¶
func (x *DownloadPieceFailedRequest) String() string
func (*DownloadPieceFailedRequest) Validate ¶
func (m *DownloadPieceFailedRequest) Validate() error
Validate checks the field values on DownloadPieceFailedRequest 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 (*DownloadPieceFailedRequest) ValidateAll ¶
func (m *DownloadPieceFailedRequest) ValidateAll() error
ValidateAll checks the field values on DownloadPieceFailedRequest 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 DownloadPieceFailedRequestMultiError, or nil if none found.
type DownloadPieceFailedRequestMultiError ¶
type DownloadPieceFailedRequestMultiError []error
DownloadPieceFailedRequestMultiError is an error wrapping multiple validation errors returned by DownloadPieceFailedRequest.ValidateAll() if the designated constraints aren't met.
func (DownloadPieceFailedRequestMultiError) AllErrors ¶
func (m DownloadPieceFailedRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadPieceFailedRequestMultiError) Error ¶
func (m DownloadPieceFailedRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadPieceFailedRequestValidationError ¶
type DownloadPieceFailedRequestValidationError struct {
// contains filtered or unexported fields
}
DownloadPieceFailedRequestValidationError is the validation error returned by DownloadPieceFailedRequest.Validate if the designated constraints aren't met.
func (DownloadPieceFailedRequestValidationError) Cause ¶
func (e DownloadPieceFailedRequestValidationError) Cause() error
Cause function returns cause value.
func (DownloadPieceFailedRequestValidationError) Error ¶
func (e DownloadPieceFailedRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadPieceFailedRequestValidationError) ErrorName ¶
func (e DownloadPieceFailedRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadPieceFailedRequestValidationError) Field ¶
func (e DownloadPieceFailedRequestValidationError) Field() string
Field function returns field value.
func (DownloadPieceFailedRequestValidationError) Key ¶
func (e DownloadPieceFailedRequestValidationError) Key() bool
Key function returns key value.
func (DownloadPieceFailedRequestValidationError) Reason ¶
func (e DownloadPieceFailedRequestValidationError) Reason() string
Reason function returns reason value.
type DownloadPieceFinishedRequest ¶
type DownloadPieceFinishedRequest struct { // Piece info. Piece *v2.Piece `protobuf:"bytes,1,opt,name=piece,proto3" json:"piece,omitempty"` // contains filtered or unexported fields }
DownloadPieceFinishedRequest represents piece download finished request of AnnouncePeerRequest.
func (*DownloadPieceFinishedRequest) Descriptor
deprecated
func (*DownloadPieceFinishedRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadPieceFinishedRequest.ProtoReflect.Descriptor instead.
func (*DownloadPieceFinishedRequest) GetPiece ¶
func (x *DownloadPieceFinishedRequest) GetPiece() *v2.Piece
func (*DownloadPieceFinishedRequest) ProtoMessage ¶
func (*DownloadPieceFinishedRequest) ProtoMessage()
func (*DownloadPieceFinishedRequest) ProtoReflect ¶
func (x *DownloadPieceFinishedRequest) ProtoReflect() protoreflect.Message
func (*DownloadPieceFinishedRequest) Reset ¶
func (x *DownloadPieceFinishedRequest) Reset()
func (*DownloadPieceFinishedRequest) String ¶
func (x *DownloadPieceFinishedRequest) String() string
func (*DownloadPieceFinishedRequest) Validate ¶
func (m *DownloadPieceFinishedRequest) Validate() error
Validate checks the field values on DownloadPieceFinishedRequest 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 (*DownloadPieceFinishedRequest) ValidateAll ¶
func (m *DownloadPieceFinishedRequest) ValidateAll() error
ValidateAll checks the field values on DownloadPieceFinishedRequest 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 DownloadPieceFinishedRequestMultiError, or nil if none found.
type DownloadPieceFinishedRequestMultiError ¶
type DownloadPieceFinishedRequestMultiError []error
DownloadPieceFinishedRequestMultiError is an error wrapping multiple validation errors returned by DownloadPieceFinishedRequest.ValidateAll() if the designated constraints aren't met.
func (DownloadPieceFinishedRequestMultiError) AllErrors ¶
func (m DownloadPieceFinishedRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadPieceFinishedRequestMultiError) Error ¶
func (m DownloadPieceFinishedRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadPieceFinishedRequestValidationError ¶
type DownloadPieceFinishedRequestValidationError struct {
// contains filtered or unexported fields
}
DownloadPieceFinishedRequestValidationError is the validation error returned by DownloadPieceFinishedRequest.Validate if the designated constraints aren't met.
func (DownloadPieceFinishedRequestValidationError) Cause ¶
func (e DownloadPieceFinishedRequestValidationError) Cause() error
Cause function returns cause value.
func (DownloadPieceFinishedRequestValidationError) Error ¶
func (e DownloadPieceFinishedRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadPieceFinishedRequestValidationError) ErrorName ¶
func (e DownloadPieceFinishedRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadPieceFinishedRequestValidationError) Field ¶
func (e DownloadPieceFinishedRequestValidationError) Field() string
Field function returns field value.
func (DownloadPieceFinishedRequestValidationError) Key ¶
func (e DownloadPieceFinishedRequestValidationError) Key() bool
Key function returns key value.
func (DownloadPieceFinishedRequestValidationError) Reason ¶
func (e DownloadPieceFinishedRequestValidationError) Reason() string
Reason function returns reason value.
type EmptyTaskResponse ¶
type EmptyTaskResponse struct {
// contains filtered or unexported fields
}
EmptyTaskResponse represents empty task response of AnnouncePeerResponse.
func (*EmptyTaskResponse) Descriptor
deprecated
func (*EmptyTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use EmptyTaskResponse.ProtoReflect.Descriptor instead.
func (*EmptyTaskResponse) ProtoMessage ¶
func (*EmptyTaskResponse) ProtoMessage()
func (*EmptyTaskResponse) ProtoReflect ¶
func (x *EmptyTaskResponse) ProtoReflect() protoreflect.Message
func (*EmptyTaskResponse) Reset ¶
func (x *EmptyTaskResponse) Reset()
func (*EmptyTaskResponse) String ¶
func (x *EmptyTaskResponse) String() string
func (*EmptyTaskResponse) Validate ¶
func (m *EmptyTaskResponse) Validate() error
Validate checks the field values on EmptyTaskResponse 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 (*EmptyTaskResponse) ValidateAll ¶
func (m *EmptyTaskResponse) ValidateAll() error
ValidateAll checks the field values on EmptyTaskResponse 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 EmptyTaskResponseMultiError, or nil if none found.
type EmptyTaskResponseMultiError ¶
type EmptyTaskResponseMultiError []error
EmptyTaskResponseMultiError is an error wrapping multiple validation errors returned by EmptyTaskResponse.ValidateAll() if the designated constraints aren't met.
func (EmptyTaskResponseMultiError) AllErrors ¶
func (m EmptyTaskResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (EmptyTaskResponseMultiError) Error ¶
func (m EmptyTaskResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type EmptyTaskResponseValidationError ¶
type EmptyTaskResponseValidationError struct {
// contains filtered or unexported fields
}
EmptyTaskResponseValidationError is the validation error returned by EmptyTaskResponse.Validate if the designated constraints aren't met.
func (EmptyTaskResponseValidationError) Cause ¶
func (e EmptyTaskResponseValidationError) Cause() error
Cause function returns cause value.
func (EmptyTaskResponseValidationError) Error ¶
func (e EmptyTaskResponseValidationError) Error() string
Error satisfies the builtin error interface
func (EmptyTaskResponseValidationError) ErrorName ¶
func (e EmptyTaskResponseValidationError) ErrorName() string
ErrorName returns error name.
func (EmptyTaskResponseValidationError) Field ¶
func (e EmptyTaskResponseValidationError) Field() string
Field function returns field value.
func (EmptyTaskResponseValidationError) Key ¶
func (e EmptyTaskResponseValidationError) Key() bool
Key function returns key value.
func (EmptyTaskResponseValidationError) Reason ¶
func (e EmptyTaskResponseValidationError) Reason() string
Reason function returns reason value.
type ExchangePeerRequest ¶
type ExchangePeerRequest struct { // Host id. HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"` // Task id. TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // Peer id. PeerId string `protobuf:"bytes,3,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) GetHostId ¶
func (x *ExchangePeerRequest) GetHostId() string
func (*ExchangePeerRequest) GetPeerId ¶
func (x *ExchangePeerRequest) GetPeerId() string
func (*ExchangePeerRequest) GetTaskId ¶
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 FailedProbe ¶
type FailedProbe struct { // Destination host metadata. Host *v2.Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` // The description of probing failed. Description *string `protobuf:"bytes,2,opt,name=description,proto3,oneof" json:"description,omitempty"` // contains filtered or unexported fields }
FailedProbe information.
func (*FailedProbe) Descriptor
deprecated
func (*FailedProbe) Descriptor() ([]byte, []int)
Deprecated: Use FailedProbe.ProtoReflect.Descriptor instead.
func (*FailedProbe) GetDescription ¶
func (x *FailedProbe) GetDescription() string
func (*FailedProbe) GetHost ¶
func (x *FailedProbe) GetHost() *v2.Host
func (*FailedProbe) ProtoMessage ¶
func (*FailedProbe) ProtoMessage()
func (*FailedProbe) ProtoReflect ¶
func (x *FailedProbe) ProtoReflect() protoreflect.Message
func (*FailedProbe) Reset ¶
func (x *FailedProbe) Reset()
func (*FailedProbe) String ¶
func (x *FailedProbe) String() string
func (*FailedProbe) Validate ¶
func (m *FailedProbe) Validate() error
Validate checks the field values on FailedProbe with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*FailedProbe) ValidateAll ¶
func (m *FailedProbe) ValidateAll() error
ValidateAll checks the field values on FailedProbe with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in FailedProbeMultiError, or nil if none found.
type FailedProbeMultiError ¶
type FailedProbeMultiError []error
FailedProbeMultiError is an error wrapping multiple validation errors returned by FailedProbe.ValidateAll() if the designated constraints aren't met.
func (FailedProbeMultiError) AllErrors ¶
func (m FailedProbeMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (FailedProbeMultiError) Error ¶
func (m FailedProbeMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type FailedProbeValidationError ¶
type FailedProbeValidationError struct {
// contains filtered or unexported fields
}
FailedProbeValidationError is the validation error returned by FailedProbe.Validate if the designated constraints aren't met.
func (FailedProbeValidationError) Cause ¶
func (e FailedProbeValidationError) Cause() error
Cause function returns cause value.
func (FailedProbeValidationError) Error ¶
func (e FailedProbeValidationError) Error() string
Error satisfies the builtin error interface
func (FailedProbeValidationError) ErrorName ¶
func (e FailedProbeValidationError) ErrorName() string
ErrorName returns error name.
func (FailedProbeValidationError) Field ¶
func (e FailedProbeValidationError) Field() string
Field function returns field value.
func (FailedProbeValidationError) Key ¶
func (e FailedProbeValidationError) Key() bool
Key function returns key value.
func (FailedProbeValidationError) Reason ¶
func (e FailedProbeValidationError) Reason() string
Reason function returns reason value.
type LeaveHostRequest ¶
type LeaveHostRequest struct { // Host id. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
LeaveHostRequest represents request of LeaveHost.
func (*LeaveHostRequest) Descriptor
deprecated
func (*LeaveHostRequest) Descriptor() ([]byte, []int)
Deprecated: Use LeaveHostRequest.ProtoReflect.Descriptor instead.
func (*LeaveHostRequest) GetId ¶
func (x *LeaveHostRequest) GetId() string
func (*LeaveHostRequest) ProtoMessage ¶
func (*LeaveHostRequest) ProtoMessage()
func (*LeaveHostRequest) ProtoReflect ¶
func (x *LeaveHostRequest) ProtoReflect() protoreflect.Message
func (*LeaveHostRequest) Reset ¶
func (x *LeaveHostRequest) Reset()
func (*LeaveHostRequest) String ¶
func (x *LeaveHostRequest) String() string
func (*LeaveHostRequest) Validate ¶
func (m *LeaveHostRequest) Validate() error
Validate checks the field values on LeaveHostRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*LeaveHostRequest) ValidateAll ¶
func (m *LeaveHostRequest) ValidateAll() error
ValidateAll checks the field values on LeaveHostRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LeaveHostRequestMultiError, or nil if none found.
type LeaveHostRequestMultiError ¶
type LeaveHostRequestMultiError []error
LeaveHostRequestMultiError is an error wrapping multiple validation errors returned by LeaveHostRequest.ValidateAll() if the designated constraints aren't met.
func (LeaveHostRequestMultiError) AllErrors ¶
func (m LeaveHostRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (LeaveHostRequestMultiError) Error ¶
func (m LeaveHostRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type LeaveHostRequestValidationError ¶
type LeaveHostRequestValidationError struct {
// contains filtered or unexported fields
}
LeaveHostRequestValidationError is the validation error returned by LeaveHostRequest.Validate if the designated constraints aren't met.
func (LeaveHostRequestValidationError) Cause ¶
func (e LeaveHostRequestValidationError) Cause() error
Cause function returns cause value.
func (LeaveHostRequestValidationError) Error ¶
func (e LeaveHostRequestValidationError) Error() string
Error satisfies the builtin error interface
func (LeaveHostRequestValidationError) ErrorName ¶
func (e LeaveHostRequestValidationError) ErrorName() string
ErrorName returns error name.
func (LeaveHostRequestValidationError) Field ¶
func (e LeaveHostRequestValidationError) Field() string
Field function returns field value.
func (LeaveHostRequestValidationError) Key ¶
func (e LeaveHostRequestValidationError) Key() bool
Key function returns key value.
func (LeaveHostRequestValidationError) Reason ¶
func (e LeaveHostRequestValidationError) Reason() string
Reason function returns reason value.
type LeavePeerRequest ¶
type LeavePeerRequest struct { // Host id. HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"` // Task id. TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // Peer id. PeerId string `protobuf:"bytes,3,opt,name=peer_id,json=peerId,proto3" json:"peer_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) GetHostId ¶
func (x *LeavePeerRequest) GetHostId() string
func (*LeavePeerRequest) GetPeerId ¶
func (x *LeavePeerRequest) GetPeerId() string
func (*LeavePeerRequest) GetTaskId ¶
func (x *LeavePeerRequest) GetTaskId() 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 LeaveTaskRequest ¶ added in v2.0.113
type LeaveTaskRequest struct { // Host id. HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"` // Task id. TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // contains filtered or unexported fields }
LeaveTaskRequest represents request of LeaveTask.
func (*LeaveTaskRequest) Descriptor
deprecated
added in
v2.0.113
func (*LeaveTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use LeaveTaskRequest.ProtoReflect.Descriptor instead.
func (*LeaveTaskRequest) GetHostId ¶ added in v2.0.113
func (x *LeaveTaskRequest) GetHostId() string
func (*LeaveTaskRequest) GetTaskId ¶ added in v2.0.113
func (x *LeaveTaskRequest) GetTaskId() string
func (*LeaveTaskRequest) ProtoMessage ¶ added in v2.0.113
func (*LeaveTaskRequest) ProtoMessage()
func (*LeaveTaskRequest) ProtoReflect ¶ added in v2.0.113
func (x *LeaveTaskRequest) ProtoReflect() protoreflect.Message
func (*LeaveTaskRequest) Reset ¶ added in v2.0.113
func (x *LeaveTaskRequest) Reset()
func (*LeaveTaskRequest) String ¶ added in v2.0.113
func (x *LeaveTaskRequest) String() string
func (*LeaveTaskRequest) Validate ¶ added in v2.0.113
func (m *LeaveTaskRequest) Validate() error
Validate checks the field values on LeaveTaskRequest 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 (*LeaveTaskRequest) ValidateAll ¶ added in v2.0.113
func (m *LeaveTaskRequest) ValidateAll() error
ValidateAll checks the field values on LeaveTaskRequest 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 LeaveTaskRequestMultiError, or nil if none found.
type LeaveTaskRequestMultiError ¶ added in v2.0.113
type LeaveTaskRequestMultiError []error
LeaveTaskRequestMultiError is an error wrapping multiple validation errors returned by LeaveTaskRequest.ValidateAll() if the designated constraints aren't met.
func (LeaveTaskRequestMultiError) AllErrors ¶ added in v2.0.113
func (m LeaveTaskRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (LeaveTaskRequestMultiError) Error ¶ added in v2.0.113
func (m LeaveTaskRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type LeaveTaskRequestValidationError ¶ added in v2.0.113
type LeaveTaskRequestValidationError struct {
// contains filtered or unexported fields
}
LeaveTaskRequestValidationError is the validation error returned by LeaveTaskRequest.Validate if the designated constraints aren't met.
func (LeaveTaskRequestValidationError) Cause ¶ added in v2.0.113
func (e LeaveTaskRequestValidationError) Cause() error
Cause function returns cause value.
func (LeaveTaskRequestValidationError) Error ¶ added in v2.0.113
func (e LeaveTaskRequestValidationError) Error() string
Error satisfies the builtin error interface
func (LeaveTaskRequestValidationError) ErrorName ¶ added in v2.0.113
func (e LeaveTaskRequestValidationError) ErrorName() string
ErrorName returns error name.
func (LeaveTaskRequestValidationError) Field ¶ added in v2.0.113
func (e LeaveTaskRequestValidationError) Field() string
Field function returns field value.
func (LeaveTaskRequestValidationError) Key ¶ added in v2.0.113
func (e LeaveTaskRequestValidationError) Key() bool
Key function returns key value.
func (LeaveTaskRequestValidationError) Reason ¶ added in v2.0.113
func (e LeaveTaskRequestValidationError) Reason() string
Reason function returns reason value.
type NeedBackToSourceResponse ¶
type NeedBackToSourceResponse struct { // The description of the back-to-source reason. Description *string `protobuf:"bytes,1,opt,name=description,proto3,oneof" json:"description,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) GetDescription ¶
func (x *NeedBackToSourceResponse) GetDescription() 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 NormalTaskResponse ¶
type NormalTaskResponse struct { // Candidate parents. CandidateParents []*v2.Peer `protobuf:"bytes,1,rep,name=candidate_parents,json=candidateParents,proto3" json:"candidate_parents,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() []*v2.Peer
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 Probe ¶
type Probe struct { // Destination host metadata. Host *v2.Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` // RTT is the round-trip time sent via this pinger. Rtt *durationpb.Duration `protobuf:"bytes,2,opt,name=rtt,proto3" json:"rtt,omitempty"` // Probe create time. CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` // contains filtered or unexported fields }
Probe information.
func (*Probe) Descriptor
deprecated
func (*Probe) GetCreatedAt ¶
func (x *Probe) GetCreatedAt() *timestamppb.Timestamp
func (*Probe) GetRtt ¶
func (x *Probe) GetRtt() *durationpb.Duration
func (*Probe) ProtoMessage ¶
func (*Probe) ProtoMessage()
func (*Probe) ProtoReflect ¶
func (x *Probe) ProtoReflect() protoreflect.Message
func (*Probe) Validate ¶
Validate checks the field values on Probe with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*Probe) ValidateAll ¶
ValidateAll checks the field values on Probe with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ProbeMultiError, or nil if none found.
type ProbeFailedRequest ¶
type ProbeFailedRequest struct { // Failed probes information. Probes []*FailedProbe `protobuf:"bytes,1,rep,name=probes,proto3" json:"probes,omitempty"` // contains filtered or unexported fields }
ProbeFailedRequest represents failed request of SyncProbesRequest.
func (*ProbeFailedRequest) Descriptor
deprecated
func (*ProbeFailedRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProbeFailedRequest.ProtoReflect.Descriptor instead.
func (*ProbeFailedRequest) GetProbes ¶
func (x *ProbeFailedRequest) GetProbes() []*FailedProbe
func (*ProbeFailedRequest) ProtoMessage ¶
func (*ProbeFailedRequest) ProtoMessage()
func (*ProbeFailedRequest) ProtoReflect ¶
func (x *ProbeFailedRequest) ProtoReflect() protoreflect.Message
func (*ProbeFailedRequest) Reset ¶
func (x *ProbeFailedRequest) Reset()
func (*ProbeFailedRequest) String ¶
func (x *ProbeFailedRequest) String() string
func (*ProbeFailedRequest) Validate ¶
func (m *ProbeFailedRequest) Validate() error
Validate checks the field values on ProbeFailedRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ProbeFailedRequest) ValidateAll ¶
func (m *ProbeFailedRequest) ValidateAll() error
ValidateAll checks the field values on ProbeFailedRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ProbeFailedRequestMultiError, or nil if none found.
type ProbeFailedRequestMultiError ¶
type ProbeFailedRequestMultiError []error
ProbeFailedRequestMultiError is an error wrapping multiple validation errors returned by ProbeFailedRequest.ValidateAll() if the designated constraints aren't met.
func (ProbeFailedRequestMultiError) AllErrors ¶
func (m ProbeFailedRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ProbeFailedRequestMultiError) Error ¶
func (m ProbeFailedRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ProbeFailedRequestValidationError ¶
type ProbeFailedRequestValidationError struct {
// contains filtered or unexported fields
}
ProbeFailedRequestValidationError is the validation error returned by ProbeFailedRequest.Validate if the designated constraints aren't met.
func (ProbeFailedRequestValidationError) Cause ¶
func (e ProbeFailedRequestValidationError) Cause() error
Cause function returns cause value.
func (ProbeFailedRequestValidationError) Error ¶
func (e ProbeFailedRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ProbeFailedRequestValidationError) ErrorName ¶
func (e ProbeFailedRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ProbeFailedRequestValidationError) Field ¶
func (e ProbeFailedRequestValidationError) Field() string
Field function returns field value.
func (ProbeFailedRequestValidationError) Key ¶
func (e ProbeFailedRequestValidationError) Key() bool
Key function returns key value.
func (ProbeFailedRequestValidationError) Reason ¶
func (e ProbeFailedRequestValidationError) Reason() string
Reason function returns reason value.
type ProbeFinishedRequest ¶
type ProbeFinishedRequest struct { // Probes information. Probes []*Probe `protobuf:"bytes,1,rep,name=probes,proto3" json:"probes,omitempty"` // contains filtered or unexported fields }
ProbeFinishedRequest represents finished request of SyncProbesRequest.
func (*ProbeFinishedRequest) Descriptor
deprecated
func (*ProbeFinishedRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProbeFinishedRequest.ProtoReflect.Descriptor instead.
func (*ProbeFinishedRequest) GetProbes ¶
func (x *ProbeFinishedRequest) GetProbes() []*Probe
func (*ProbeFinishedRequest) ProtoMessage ¶
func (*ProbeFinishedRequest) ProtoMessage()
func (*ProbeFinishedRequest) ProtoReflect ¶
func (x *ProbeFinishedRequest) ProtoReflect() protoreflect.Message
func (*ProbeFinishedRequest) Reset ¶
func (x *ProbeFinishedRequest) Reset()
func (*ProbeFinishedRequest) String ¶
func (x *ProbeFinishedRequest) String() string
func (*ProbeFinishedRequest) Validate ¶
func (m *ProbeFinishedRequest) Validate() error
Validate checks the field values on ProbeFinishedRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ProbeFinishedRequest) ValidateAll ¶
func (m *ProbeFinishedRequest) ValidateAll() error
ValidateAll checks the field values on ProbeFinishedRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ProbeFinishedRequestMultiError, or nil if none found.
type ProbeFinishedRequestMultiError ¶
type ProbeFinishedRequestMultiError []error
ProbeFinishedRequestMultiError is an error wrapping multiple validation errors returned by ProbeFinishedRequest.ValidateAll() if the designated constraints aren't met.
func (ProbeFinishedRequestMultiError) AllErrors ¶
func (m ProbeFinishedRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ProbeFinishedRequestMultiError) Error ¶
func (m ProbeFinishedRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ProbeFinishedRequestValidationError ¶
type ProbeFinishedRequestValidationError struct {
// contains filtered or unexported fields
}
ProbeFinishedRequestValidationError is the validation error returned by ProbeFinishedRequest.Validate if the designated constraints aren't met.
func (ProbeFinishedRequestValidationError) Cause ¶
func (e ProbeFinishedRequestValidationError) Cause() error
Cause function returns cause value.
func (ProbeFinishedRequestValidationError) Error ¶
func (e ProbeFinishedRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ProbeFinishedRequestValidationError) ErrorName ¶
func (e ProbeFinishedRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ProbeFinishedRequestValidationError) Field ¶
func (e ProbeFinishedRequestValidationError) Field() string
Field function returns field value.
func (ProbeFinishedRequestValidationError) Key ¶
func (e ProbeFinishedRequestValidationError) Key() bool
Key function returns key value.
func (ProbeFinishedRequestValidationError) Reason ¶
func (e ProbeFinishedRequestValidationError) Reason() string
Reason function returns reason value.
type ProbeMultiError ¶
type ProbeMultiError []error
ProbeMultiError is an error wrapping multiple validation errors returned by Probe.ValidateAll() if the designated constraints aren't met.
func (ProbeMultiError) AllErrors ¶
func (m ProbeMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ProbeMultiError) Error ¶
func (m ProbeMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ProbeStartedRequest ¶
type ProbeStartedRequest struct {
// contains filtered or unexported fields
}
ProbeStartedRequest represents started request of SyncProbesRequest.
func (*ProbeStartedRequest) Descriptor
deprecated
func (*ProbeStartedRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProbeStartedRequest.ProtoReflect.Descriptor instead.
func (*ProbeStartedRequest) ProtoMessage ¶
func (*ProbeStartedRequest) ProtoMessage()
func (*ProbeStartedRequest) ProtoReflect ¶
func (x *ProbeStartedRequest) ProtoReflect() protoreflect.Message
func (*ProbeStartedRequest) Reset ¶
func (x *ProbeStartedRequest) Reset()
func (*ProbeStartedRequest) String ¶
func (x *ProbeStartedRequest) String() string
func (*ProbeStartedRequest) Validate ¶
func (m *ProbeStartedRequest) Validate() error
Validate checks the field values on ProbeStartedRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ProbeStartedRequest) ValidateAll ¶
func (m *ProbeStartedRequest) ValidateAll() error
ValidateAll checks the field values on ProbeStartedRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ProbeStartedRequestMultiError, or nil if none found.
type ProbeStartedRequestMultiError ¶
type ProbeStartedRequestMultiError []error
ProbeStartedRequestMultiError is an error wrapping multiple validation errors returned by ProbeStartedRequest.ValidateAll() if the designated constraints aren't met.
func (ProbeStartedRequestMultiError) AllErrors ¶
func (m ProbeStartedRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ProbeStartedRequestMultiError) Error ¶
func (m ProbeStartedRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ProbeStartedRequestValidationError ¶
type ProbeStartedRequestValidationError struct {
// contains filtered or unexported fields
}
ProbeStartedRequestValidationError is the validation error returned by ProbeStartedRequest.Validate if the designated constraints aren't met.
func (ProbeStartedRequestValidationError) Cause ¶
func (e ProbeStartedRequestValidationError) Cause() error
Cause function returns cause value.
func (ProbeStartedRequestValidationError) Error ¶
func (e ProbeStartedRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ProbeStartedRequestValidationError) ErrorName ¶
func (e ProbeStartedRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ProbeStartedRequestValidationError) Field ¶
func (e ProbeStartedRequestValidationError) Field() string
Field function returns field value.
func (ProbeStartedRequestValidationError) Key ¶
func (e ProbeStartedRequestValidationError) Key() bool
Key function returns key value.
func (ProbeStartedRequestValidationError) Reason ¶
func (e ProbeStartedRequestValidationError) Reason() string
Reason function returns reason value.
type ProbeValidationError ¶
type ProbeValidationError struct {
// contains filtered or unexported fields
}
ProbeValidationError is the validation error returned by Probe.Validate if the designated constraints aren't met.
func (ProbeValidationError) Cause ¶
func (e ProbeValidationError) Cause() error
Cause function returns cause value.
func (ProbeValidationError) Error ¶
func (e ProbeValidationError) Error() string
Error satisfies the builtin error interface
func (ProbeValidationError) ErrorName ¶
func (e ProbeValidationError) ErrorName() string
ErrorName returns error name.
func (ProbeValidationError) Field ¶
func (e ProbeValidationError) Field() string
Field function returns field value.
func (ProbeValidationError) Key ¶
func (e ProbeValidationError) Key() bool
Key function returns key value.
func (ProbeValidationError) Reason ¶
func (e ProbeValidationError) Reason() string
Reason function returns reason value.
type RegisterPeerRequest ¶
type RegisterPeerRequest struct { // Download information. DownloadTask *v2.DownloadTask `protobuf:"bytes,1,opt,name=download_task,json=downloadTask,proto3" json:"download_task,omitempty"` // contains filtered or unexported fields }
RegisterPeerRequest represents peer registered request of AnnouncePeerRequest.
func (*RegisterPeerRequest) Descriptor
deprecated
func (*RegisterPeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterPeerRequest.ProtoReflect.Descriptor instead.
func (*RegisterPeerRequest) GetDownloadTask ¶ added in v2.0.116
func (x *RegisterPeerRequest) GetDownloadTask() *v2.DownloadTask
func (*RegisterPeerRequest) ProtoMessage ¶
func (*RegisterPeerRequest) ProtoMessage()
func (*RegisterPeerRequest) ProtoReflect ¶
func (x *RegisterPeerRequest) ProtoReflect() protoreflect.Message
func (*RegisterPeerRequest) Reset ¶
func (x *RegisterPeerRequest) Reset()
func (*RegisterPeerRequest) String ¶
func (x *RegisterPeerRequest) String() string
func (*RegisterPeerRequest) Validate ¶
func (m *RegisterPeerRequest) Validate() error
Validate checks the field values on RegisterPeerRequest 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 (*RegisterPeerRequest) ValidateAll ¶
func (m *RegisterPeerRequest) ValidateAll() error
ValidateAll checks the field values on RegisterPeerRequest 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 RegisterPeerRequestMultiError, or nil if none found.
type RegisterPeerRequestMultiError ¶
type RegisterPeerRequestMultiError []error
RegisterPeerRequestMultiError is an error wrapping multiple validation errors returned by RegisterPeerRequest.ValidateAll() if the designated constraints aren't met.
func (RegisterPeerRequestMultiError) AllErrors ¶
func (m RegisterPeerRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RegisterPeerRequestMultiError) Error ¶
func (m RegisterPeerRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RegisterPeerRequestValidationError ¶
type RegisterPeerRequestValidationError struct {
// contains filtered or unexported fields
}
RegisterPeerRequestValidationError is the validation error returned by RegisterPeerRequest.Validate if the designated constraints aren't met.
func (RegisterPeerRequestValidationError) Cause ¶
func (e RegisterPeerRequestValidationError) Cause() error
Cause function returns cause value.
func (RegisterPeerRequestValidationError) Error ¶
func (e RegisterPeerRequestValidationError) Error() string
Error satisfies the builtin error interface
func (RegisterPeerRequestValidationError) ErrorName ¶
func (e RegisterPeerRequestValidationError) ErrorName() string
ErrorName returns error name.
func (RegisterPeerRequestValidationError) Field ¶
func (e RegisterPeerRequestValidationError) Field() string
Field function returns field value.
func (RegisterPeerRequestValidationError) Key ¶
func (e RegisterPeerRequestValidationError) Key() bool
Key function returns key value.
func (RegisterPeerRequestValidationError) Reason ¶
func (e RegisterPeerRequestValidationError) Reason() string
Reason function returns reason value.
type RescheduleRequest ¶ added in v2.0.46
type RescheduleRequest struct { // Candidate parent ids. CandidateParents []*v2.Peer `protobuf:"bytes,1,rep,name=candidate_parents,json=candidateParents,proto3" json:"candidate_parents,omitempty"` // The description of the reschedule reason. Description *string `protobuf:"bytes,2,opt,name=description,proto3,oneof" json:"description,omitempty"` // contains filtered or unexported fields }
RescheduleRequest represents reschedule request of AnnouncePeerRequest.
func (*RescheduleRequest) Descriptor
deprecated
added in
v2.0.46
func (*RescheduleRequest) Descriptor() ([]byte, []int)
Deprecated: Use RescheduleRequest.ProtoReflect.Descriptor instead.
func (*RescheduleRequest) GetCandidateParents ¶ added in v2.0.75
func (x *RescheduleRequest) GetCandidateParents() []*v2.Peer
func (*RescheduleRequest) GetDescription ¶ added in v2.0.46
func (x *RescheduleRequest) GetDescription() string
func (*RescheduleRequest) ProtoMessage ¶ added in v2.0.46
func (*RescheduleRequest) ProtoMessage()
func (*RescheduleRequest) ProtoReflect ¶ added in v2.0.46
func (x *RescheduleRequest) ProtoReflect() protoreflect.Message
func (*RescheduleRequest) Reset ¶ added in v2.0.46
func (x *RescheduleRequest) Reset()
func (*RescheduleRequest) String ¶ added in v2.0.46
func (x *RescheduleRequest) String() string
func (*RescheduleRequest) Validate ¶ added in v2.0.46
func (m *RescheduleRequest) Validate() error
Validate checks the field values on RescheduleRequest 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 (*RescheduleRequest) ValidateAll ¶ added in v2.0.46
func (m *RescheduleRequest) ValidateAll() error
ValidateAll checks the field values on RescheduleRequest 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 RescheduleRequestMultiError, or nil if none found.
type RescheduleRequestMultiError ¶ added in v2.0.46
type RescheduleRequestMultiError []error
RescheduleRequestMultiError is an error wrapping multiple validation errors returned by RescheduleRequest.ValidateAll() if the designated constraints aren't met.
func (RescheduleRequestMultiError) AllErrors ¶ added in v2.0.46
func (m RescheduleRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RescheduleRequestMultiError) Error ¶ added in v2.0.46
func (m RescheduleRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RescheduleRequestValidationError ¶ added in v2.0.46
type RescheduleRequestValidationError struct {
// contains filtered or unexported fields
}
RescheduleRequestValidationError is the validation error returned by RescheduleRequest.Validate if the designated constraints aren't met.
func (RescheduleRequestValidationError) Cause ¶ added in v2.0.46
func (e RescheduleRequestValidationError) Cause() error
Cause function returns cause value.
func (RescheduleRequestValidationError) Error ¶ added in v2.0.46
func (e RescheduleRequestValidationError) Error() string
Error satisfies the builtin error interface
func (RescheduleRequestValidationError) ErrorName ¶ added in v2.0.46
func (e RescheduleRequestValidationError) ErrorName() string
ErrorName returns error name.
func (RescheduleRequestValidationError) Field ¶ added in v2.0.46
func (e RescheduleRequestValidationError) Field() string
Field function returns field value.
func (RescheduleRequestValidationError) Key ¶ added in v2.0.46
func (e RescheduleRequestValidationError) Key() bool
Key function returns key value.
func (RescheduleRequestValidationError) Reason ¶ added in v2.0.46
func (e RescheduleRequestValidationError) 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) (*v2.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) (*v2.Task, error) // LeaveTask releases task in scheduler. LeaveTask(ctx context.Context, in *LeaveTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, 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) // SyncProbes sync probes of the host. SyncProbes(ctx context.Context, opts ...grpc.CallOption) (Scheduler_SyncProbesClient, error) }
SchedulerClient is the client API for Scheduler service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSchedulerClient ¶
func NewSchedulerClient(cc grpc.ClientConnInterface) SchedulerClient
type SchedulerServer ¶
type SchedulerServer interface { // AnnouncePeer announces peer to scheduler. AnnouncePeer(Scheduler_AnnouncePeerServer) error // Checks information of peer. StatPeer(context.Context, *StatPeerRequest) (*v2.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) (*v2.Task, error) // LeaveTask releases task in scheduler. LeaveTask(context.Context, *LeaveTaskRequest) (*emptypb.Empty, 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) // SyncProbes sync probes of the host. SyncProbes(Scheduler_SyncProbesServer) error }
SchedulerServer is the server API for Scheduler service. All implementations should embed UnimplementedSchedulerServer for forward compatibility
type Scheduler_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 Scheduler_SyncProbesClient ¶
type Scheduler_SyncProbesClient interface { Send(*SyncProbesRequest) error Recv() (*SyncProbesResponse, error) grpc.ClientStream }
type Scheduler_SyncProbesServer ¶
type Scheduler_SyncProbesServer interface { Send(*SyncProbesResponse) error Recv() (*SyncProbesRequest, error) grpc.ServerStream }
type StatPeerRequest ¶
type StatPeerRequest struct { // Host id. HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"` // Task id. TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // Peer id. PeerId string `protobuf:"bytes,3,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) GetHostId ¶
func (x *StatPeerRequest) GetHostId() string
func (*StatPeerRequest) GetPeerId ¶
func (x *StatPeerRequest) GetPeerId() string
func (*StatPeerRequest) GetTaskId ¶
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 ¶
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 SyncProbesRequest ¶
type SyncProbesRequest struct { // Source host metadata. Host *v2.Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` // Types that are assignable to Request: // // *SyncProbesRequest_ProbeStartedRequest // *SyncProbesRequest_ProbeFinishedRequest // *SyncProbesRequest_ProbeFailedRequest Request isSyncProbesRequest_Request `protobuf_oneof:"request"` // contains filtered or unexported fields }
SyncProbesRequest represents request of SyncProbes.
func (*SyncProbesRequest) Descriptor
deprecated
func (*SyncProbesRequest) Descriptor() ([]byte, []int)
Deprecated: Use SyncProbesRequest.ProtoReflect.Descriptor instead.
func (*SyncProbesRequest) GetHost ¶
func (x *SyncProbesRequest) GetHost() *v2.Host
func (*SyncProbesRequest) GetProbeFailedRequest ¶
func (x *SyncProbesRequest) GetProbeFailedRequest() *ProbeFailedRequest
func (*SyncProbesRequest) GetProbeFinishedRequest ¶
func (x *SyncProbesRequest) GetProbeFinishedRequest() *ProbeFinishedRequest
func (*SyncProbesRequest) GetProbeStartedRequest ¶
func (x *SyncProbesRequest) GetProbeStartedRequest() *ProbeStartedRequest
func (*SyncProbesRequest) GetRequest ¶
func (m *SyncProbesRequest) GetRequest() isSyncProbesRequest_Request
func (*SyncProbesRequest) ProtoMessage ¶
func (*SyncProbesRequest) ProtoMessage()
func (*SyncProbesRequest) ProtoReflect ¶
func (x *SyncProbesRequest) ProtoReflect() protoreflect.Message
func (*SyncProbesRequest) Reset ¶
func (x *SyncProbesRequest) Reset()
func (*SyncProbesRequest) String ¶
func (x *SyncProbesRequest) String() string
func (*SyncProbesRequest) Validate ¶
func (m *SyncProbesRequest) Validate() error
Validate checks the field values on SyncProbesRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*SyncProbesRequest) ValidateAll ¶
func (m *SyncProbesRequest) ValidateAll() error
ValidateAll checks the field values on SyncProbesRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SyncProbesRequestMultiError, or nil if none found.
type SyncProbesRequestMultiError ¶
type SyncProbesRequestMultiError []error
SyncProbesRequestMultiError is an error wrapping multiple validation errors returned by SyncProbesRequest.ValidateAll() if the designated constraints aren't met.
func (SyncProbesRequestMultiError) AllErrors ¶
func (m SyncProbesRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (SyncProbesRequestMultiError) Error ¶
func (m SyncProbesRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type SyncProbesRequestValidationError ¶
type SyncProbesRequestValidationError struct {
// contains filtered or unexported fields
}
SyncProbesRequestValidationError is the validation error returned by SyncProbesRequest.Validate if the designated constraints aren't met.
func (SyncProbesRequestValidationError) Cause ¶
func (e SyncProbesRequestValidationError) Cause() error
Cause function returns cause value.
func (SyncProbesRequestValidationError) Error ¶
func (e SyncProbesRequestValidationError) Error() string
Error satisfies the builtin error interface
func (SyncProbesRequestValidationError) ErrorName ¶
func (e SyncProbesRequestValidationError) ErrorName() string
ErrorName returns error name.
func (SyncProbesRequestValidationError) Field ¶
func (e SyncProbesRequestValidationError) Field() string
Field function returns field value.
func (SyncProbesRequestValidationError) Key ¶
func (e SyncProbesRequestValidationError) Key() bool
Key function returns key value.
func (SyncProbesRequestValidationError) Reason ¶
func (e SyncProbesRequestValidationError) Reason() string
Reason function returns reason value.
type SyncProbesRequest_ProbeFailedRequest ¶
type SyncProbesRequest_ProbeFailedRequest struct {
ProbeFailedRequest *ProbeFailedRequest `protobuf:"bytes,4,opt,name=probe_failed_request,json=probeFailedRequest,proto3,oneof"`
}
type SyncProbesRequest_ProbeFinishedRequest ¶
type SyncProbesRequest_ProbeFinishedRequest struct {
ProbeFinishedRequest *ProbeFinishedRequest `protobuf:"bytes,3,opt,name=probe_finished_request,json=probeFinishedRequest,proto3,oneof"`
}
type SyncProbesRequest_ProbeStartedRequest ¶
type SyncProbesRequest_ProbeStartedRequest struct {
ProbeStartedRequest *ProbeStartedRequest `protobuf:"bytes,2,opt,name=probe_started_request,json=probeStartedRequest,proto3,oneof"`
}
type SyncProbesResponse ¶
type SyncProbesResponse struct { // Hosts needs to be probed. Hosts []*v2.Host `protobuf:"bytes,1,rep,name=hosts,proto3" json:"hosts,omitempty"` // contains filtered or unexported fields }
SyncProbesResponse represents response of SyncProbes.
func (*SyncProbesResponse) Descriptor
deprecated
func (*SyncProbesResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncProbesResponse.ProtoReflect.Descriptor instead.
func (*SyncProbesResponse) GetHosts ¶
func (x *SyncProbesResponse) GetHosts() []*v2.Host
func (*SyncProbesResponse) ProtoMessage ¶
func (*SyncProbesResponse) ProtoMessage()
func (*SyncProbesResponse) ProtoReflect ¶
func (x *SyncProbesResponse) ProtoReflect() protoreflect.Message
func (*SyncProbesResponse) Reset ¶
func (x *SyncProbesResponse) Reset()
func (*SyncProbesResponse) String ¶
func (x *SyncProbesResponse) String() string
func (*SyncProbesResponse) Validate ¶
func (m *SyncProbesResponse) Validate() error
Validate checks the field values on SyncProbesResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*SyncProbesResponse) ValidateAll ¶
func (m *SyncProbesResponse) ValidateAll() error
ValidateAll checks the field values on SyncProbesResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SyncProbesResponseMultiError, or nil if none found.
type SyncProbesResponseMultiError ¶
type SyncProbesResponseMultiError []error
SyncProbesResponseMultiError is an error wrapping multiple validation errors returned by SyncProbesResponse.ValidateAll() if the designated constraints aren't met.
func (SyncProbesResponseMultiError) AllErrors ¶
func (m SyncProbesResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (SyncProbesResponseMultiError) Error ¶
func (m SyncProbesResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type SyncProbesResponseValidationError ¶
type SyncProbesResponseValidationError struct {
// contains filtered or unexported fields
}
SyncProbesResponseValidationError is the validation error returned by SyncProbesResponse.Validate if the designated constraints aren't met.
func (SyncProbesResponseValidationError) Cause ¶
func (e SyncProbesResponseValidationError) Cause() error
Cause function returns cause value.
func (SyncProbesResponseValidationError) Error ¶
func (e SyncProbesResponseValidationError) Error() string
Error satisfies the builtin error interface
func (SyncProbesResponseValidationError) ErrorName ¶
func (e SyncProbesResponseValidationError) ErrorName() string
ErrorName returns error name.
func (SyncProbesResponseValidationError) Field ¶
func (e SyncProbesResponseValidationError) Field() string
Field function returns field value.
func (SyncProbesResponseValidationError) Key ¶
func (e SyncProbesResponseValidationError) Key() bool
Key function returns key value.
func (SyncProbesResponseValidationError) Reason ¶
func (e SyncProbesResponseValidationError) Reason() string
Reason function returns reason value.
type UnimplementedSchedulerServer ¶
type UnimplementedSchedulerServer struct { }
UnimplementedSchedulerServer should be embedded to have forward compatible implementations.
func (UnimplementedSchedulerServer) AnnounceHost ¶
func (UnimplementedSchedulerServer) 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 ¶
func (UnimplementedSchedulerServer) LeaveHost(context.Context, *LeaveHostRequest) (*emptypb.Empty, error)
func (UnimplementedSchedulerServer) LeavePeer ¶
func (UnimplementedSchedulerServer) LeavePeer(context.Context, *LeavePeerRequest) (*emptypb.Empty, error)
func (UnimplementedSchedulerServer) LeaveTask ¶ added in v2.0.113
func (UnimplementedSchedulerServer) LeaveTask(context.Context, *LeaveTaskRequest) (*emptypb.Empty, error)
func (UnimplementedSchedulerServer) StatPeer ¶
func (UnimplementedSchedulerServer) StatPeer(context.Context, *StatPeerRequest) (*v2.Peer, error)
func (UnimplementedSchedulerServer) StatTask ¶
func (UnimplementedSchedulerServer) StatTask(context.Context, *StatTaskRequest) (*v2.Task, error)
func (UnimplementedSchedulerServer) SyncProbes ¶
func (UnimplementedSchedulerServer) SyncProbes(Scheduler_SyncProbesServer) error
type UnsafeSchedulerServer ¶
type UnsafeSchedulerServer interface {
// contains filtered or unexported methods
}
UnsafeSchedulerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SchedulerServer will result in compilation errors.