Documentation ¶
Index ¶
- Variables
- func RegisterSchedulerServer(s grpc.ServiceRegistrar, srv SchedulerServer)
- type AnnounceCachePeerRequest
- func (*AnnounceCachePeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AnnounceCachePeerRequest) GetDownloadCachePeerFailedRequest() *DownloadCachePeerFailedRequest
- func (x *AnnounceCachePeerRequest) GetDownloadCachePeerFinishedRequest() *DownloadCachePeerFinishedRequest
- func (x *AnnounceCachePeerRequest) GetDownloadCachePeerStartedRequest() *DownloadCachePeerStartedRequest
- func (x *AnnounceCachePeerRequest) GetDownloadPieceFailedRequest() *DownloadPieceFailedRequest
- func (x *AnnounceCachePeerRequest) GetDownloadPieceFinishedRequest() *DownloadPieceFinishedRequest
- func (x *AnnounceCachePeerRequest) GetHostId() string
- func (x *AnnounceCachePeerRequest) GetPeerId() string
- func (x *AnnounceCachePeerRequest) GetRegisterCachePeerRequest() *RegisterCachePeerRequest
- func (m *AnnounceCachePeerRequest) GetRequest() isAnnounceCachePeerRequest_Request
- func (x *AnnounceCachePeerRequest) GetRescheduleCachePeerRequest() *RescheduleCachePeerRequest
- func (x *AnnounceCachePeerRequest) GetTaskId() string
- func (*AnnounceCachePeerRequest) ProtoMessage()
- func (x *AnnounceCachePeerRequest) ProtoReflect() protoreflect.Message
- func (x *AnnounceCachePeerRequest) Reset()
- func (x *AnnounceCachePeerRequest) String() string
- func (m *AnnounceCachePeerRequest) Validate() error
- func (m *AnnounceCachePeerRequest) ValidateAll() error
- type AnnounceCachePeerRequestMultiError
- type AnnounceCachePeerRequestValidationError
- func (e AnnounceCachePeerRequestValidationError) Cause() error
- func (e AnnounceCachePeerRequestValidationError) Error() string
- func (e AnnounceCachePeerRequestValidationError) ErrorName() string
- func (e AnnounceCachePeerRequestValidationError) Field() string
- func (e AnnounceCachePeerRequestValidationError) Key() bool
- func (e AnnounceCachePeerRequestValidationError) Reason() string
- type AnnounceCachePeerRequest_DownloadCachePeerFailedRequest
- type AnnounceCachePeerRequest_DownloadCachePeerFinishedRequest
- type AnnounceCachePeerRequest_DownloadCachePeerStartedRequest
- type AnnounceCachePeerRequest_DownloadPieceFailedRequest
- type AnnounceCachePeerRequest_DownloadPieceFinishedRequest
- type AnnounceCachePeerRequest_RegisterCachePeerRequest
- type AnnounceCachePeerRequest_RescheduleCachePeerRequest
- type AnnounceCachePeerResponse
- func (*AnnounceCachePeerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AnnounceCachePeerResponse) GetEmptyTaskResponse() *EmptyCacheTaskResponse
- func (x *AnnounceCachePeerResponse) GetNormalTaskResponse() *NormalCacheTaskResponse
- func (m *AnnounceCachePeerResponse) GetResponse() isAnnounceCachePeerResponse_Response
- func (*AnnounceCachePeerResponse) ProtoMessage()
- func (x *AnnounceCachePeerResponse) ProtoReflect() protoreflect.Message
- func (x *AnnounceCachePeerResponse) Reset()
- func (x *AnnounceCachePeerResponse) String() string
- func (m *AnnounceCachePeerResponse) Validate() error
- func (m *AnnounceCachePeerResponse) ValidateAll() error
- type AnnounceCachePeerResponseMultiError
- type AnnounceCachePeerResponseValidationError
- func (e AnnounceCachePeerResponseValidationError) Cause() error
- func (e AnnounceCachePeerResponseValidationError) Error() string
- func (e AnnounceCachePeerResponseValidationError) ErrorName() string
- func (e AnnounceCachePeerResponseValidationError) Field() string
- func (e AnnounceCachePeerResponseValidationError) Key() bool
- func (e AnnounceCachePeerResponseValidationError) Reason() string
- type AnnounceCachePeerResponse_EmptyTaskResponse
- type AnnounceCachePeerResponse_NormalTaskResponse
- type AnnounceHostRequest
- func (*AnnounceHostRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AnnounceHostRequest) GetHost() *v2.Host
- func (x *AnnounceHostRequest) GetInterval() *durationpb.Duration
- 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) GetReschedulePeerRequest() *ReschedulePeerRequest
- 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_ReschedulePeerRequest
- 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 DeleteCachePeerRequest
- func (*DeleteCachePeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteCachePeerRequest) GetHostId() string
- func (x *DeleteCachePeerRequest) GetPeerId() string
- func (x *DeleteCachePeerRequest) GetTaskId() string
- func (*DeleteCachePeerRequest) ProtoMessage()
- func (x *DeleteCachePeerRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteCachePeerRequest) Reset()
- func (x *DeleteCachePeerRequest) String() string
- func (m *DeleteCachePeerRequest) Validate() error
- func (m *DeleteCachePeerRequest) ValidateAll() error
- type DeleteCachePeerRequestMultiError
- type DeleteCachePeerRequestValidationError
- func (e DeleteCachePeerRequestValidationError) Cause() error
- func (e DeleteCachePeerRequestValidationError) Error() string
- func (e DeleteCachePeerRequestValidationError) ErrorName() string
- func (e DeleteCachePeerRequestValidationError) Field() string
- func (e DeleteCachePeerRequestValidationError) Key() bool
- func (e DeleteCachePeerRequestValidationError) Reason() string
- type DeleteCacheTaskRequest
- func (*DeleteCacheTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteCacheTaskRequest) GetHostId() string
- func (x *DeleteCacheTaskRequest) GetTaskId() string
- func (*DeleteCacheTaskRequest) ProtoMessage()
- func (x *DeleteCacheTaskRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteCacheTaskRequest) Reset()
- func (x *DeleteCacheTaskRequest) String() string
- func (m *DeleteCacheTaskRequest) Validate() error
- func (m *DeleteCacheTaskRequest) ValidateAll() error
- type DeleteCacheTaskRequestMultiError
- type DeleteCacheTaskRequestValidationError
- func (e DeleteCacheTaskRequestValidationError) Cause() error
- func (e DeleteCacheTaskRequestValidationError) Error() string
- func (e DeleteCacheTaskRequestValidationError) ErrorName() string
- func (e DeleteCacheTaskRequestValidationError) Field() string
- func (e DeleteCacheTaskRequestValidationError) Key() bool
- func (e DeleteCacheTaskRequestValidationError) Reason() string
- type DeleteHostRequest
- func (*DeleteHostRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteHostRequest) GetHostId() string
- func (*DeleteHostRequest) ProtoMessage()
- func (x *DeleteHostRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteHostRequest) Reset()
- func (x *DeleteHostRequest) String() string
- func (m *DeleteHostRequest) Validate() error
- func (m *DeleteHostRequest) ValidateAll() error
- type DeleteHostRequestMultiError
- type DeleteHostRequestValidationError
- func (e DeleteHostRequestValidationError) Cause() error
- func (e DeleteHostRequestValidationError) Error() string
- func (e DeleteHostRequestValidationError) ErrorName() string
- func (e DeleteHostRequestValidationError) Field() string
- func (e DeleteHostRequestValidationError) Key() bool
- func (e DeleteHostRequestValidationError) Reason() string
- type DeletePeerRequest
- func (*DeletePeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeletePeerRequest) GetHostId() string
- func (x *DeletePeerRequest) GetPeerId() string
- func (x *DeletePeerRequest) GetTaskId() string
- func (*DeletePeerRequest) ProtoMessage()
- func (x *DeletePeerRequest) ProtoReflect() protoreflect.Message
- func (x *DeletePeerRequest) Reset()
- func (x *DeletePeerRequest) String() string
- func (m *DeletePeerRequest) Validate() error
- func (m *DeletePeerRequest) ValidateAll() error
- type DeletePeerRequestMultiError
- type DeletePeerRequestValidationError
- func (e DeletePeerRequestValidationError) Cause() error
- func (e DeletePeerRequestValidationError) Error() string
- func (e DeletePeerRequestValidationError) ErrorName() string
- func (e DeletePeerRequestValidationError) Field() string
- func (e DeletePeerRequestValidationError) Key() bool
- func (e DeletePeerRequestValidationError) Reason() string
- type DeleteTaskRequest
- func (*DeleteTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteTaskRequest) GetHostId() string
- func (x *DeleteTaskRequest) GetTaskId() string
- func (*DeleteTaskRequest) ProtoMessage()
- func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteTaskRequest) Reset()
- func (x *DeleteTaskRequest) String() string
- func (m *DeleteTaskRequest) Validate() error
- func (m *DeleteTaskRequest) ValidateAll() error
- type DeleteTaskRequestMultiError
- type DeleteTaskRequestValidationError
- func (e DeleteTaskRequestValidationError) Cause() error
- func (e DeleteTaskRequestValidationError) Error() string
- func (e DeleteTaskRequestValidationError) ErrorName() string
- func (e DeleteTaskRequestValidationError) Field() string
- func (e DeleteTaskRequestValidationError) Key() bool
- func (e DeleteTaskRequestValidationError) Reason() string
- type DownloadCachePeerFailedRequest
- func (*DownloadCachePeerFailedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadCachePeerFailedRequest) GetDescription() string
- func (*DownloadCachePeerFailedRequest) ProtoMessage()
- func (x *DownloadCachePeerFailedRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadCachePeerFailedRequest) Reset()
- func (x *DownloadCachePeerFailedRequest) String() string
- func (m *DownloadCachePeerFailedRequest) Validate() error
- func (m *DownloadCachePeerFailedRequest) ValidateAll() error
- type DownloadCachePeerFailedRequestMultiError
- type DownloadCachePeerFailedRequestValidationError
- func (e DownloadCachePeerFailedRequestValidationError) Cause() error
- func (e DownloadCachePeerFailedRequestValidationError) Error() string
- func (e DownloadCachePeerFailedRequestValidationError) ErrorName() string
- func (e DownloadCachePeerFailedRequestValidationError) Field() string
- func (e DownloadCachePeerFailedRequestValidationError) Key() bool
- func (e DownloadCachePeerFailedRequestValidationError) Reason() string
- type DownloadCachePeerFinishedRequest
- func (*DownloadCachePeerFinishedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadCachePeerFinishedRequest) GetPieceCount() uint32
- func (*DownloadCachePeerFinishedRequest) ProtoMessage()
- func (x *DownloadCachePeerFinishedRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadCachePeerFinishedRequest) Reset()
- func (x *DownloadCachePeerFinishedRequest) String() string
- func (m *DownloadCachePeerFinishedRequest) Validate() error
- func (m *DownloadCachePeerFinishedRequest) ValidateAll() error
- type DownloadCachePeerFinishedRequestMultiError
- type DownloadCachePeerFinishedRequestValidationError
- func (e DownloadCachePeerFinishedRequestValidationError) Cause() error
- func (e DownloadCachePeerFinishedRequestValidationError) Error() string
- func (e DownloadCachePeerFinishedRequestValidationError) ErrorName() string
- func (e DownloadCachePeerFinishedRequestValidationError) Field() string
- func (e DownloadCachePeerFinishedRequestValidationError) Key() bool
- func (e DownloadCachePeerFinishedRequestValidationError) Reason() string
- type DownloadCachePeerStartedRequest
- func (*DownloadCachePeerStartedRequest) Descriptor() ([]byte, []int)deprecated
- func (*DownloadCachePeerStartedRequest) ProtoMessage()
- func (x *DownloadCachePeerStartedRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadCachePeerStartedRequest) Reset()
- func (x *DownloadCachePeerStartedRequest) String() string
- func (m *DownloadCachePeerStartedRequest) Validate() error
- func (m *DownloadCachePeerStartedRequest) ValidateAll() error
- type DownloadCachePeerStartedRequestMultiError
- type DownloadCachePeerStartedRequestValidationError
- func (e DownloadCachePeerStartedRequestValidationError) Cause() error
- func (e DownloadCachePeerStartedRequestValidationError) Error() string
- func (e DownloadCachePeerStartedRequestValidationError) ErrorName() string
- func (e DownloadCachePeerStartedRequestValidationError) Field() string
- func (e DownloadCachePeerStartedRequestValidationError) Key() bool
- func (e DownloadCachePeerStartedRequestValidationError) Reason() string
- 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 EmptyCacheTaskResponse
- func (*EmptyCacheTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (*EmptyCacheTaskResponse) ProtoMessage()
- func (x *EmptyCacheTaskResponse) ProtoReflect() protoreflect.Message
- func (x *EmptyCacheTaskResponse) Reset()
- func (x *EmptyCacheTaskResponse) String() string
- func (m *EmptyCacheTaskResponse) Validate() error
- func (m *EmptyCacheTaskResponse) ValidateAll() error
- type EmptyCacheTaskResponseMultiError
- type EmptyCacheTaskResponseValidationError
- func (e EmptyCacheTaskResponseValidationError) Cause() error
- func (e EmptyCacheTaskResponseValidationError) Error() string
- func (e EmptyCacheTaskResponseValidationError) ErrorName() string
- func (e EmptyCacheTaskResponseValidationError) Field() string
- func (e EmptyCacheTaskResponseValidationError) Key() bool
- func (e EmptyCacheTaskResponseValidationError) 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 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 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 NormalCacheTaskResponse
- func (*NormalCacheTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *NormalCacheTaskResponse) GetCandidateParents() []*v2.CachePeer
- func (*NormalCacheTaskResponse) ProtoMessage()
- func (x *NormalCacheTaskResponse) ProtoReflect() protoreflect.Message
- func (x *NormalCacheTaskResponse) Reset()
- func (x *NormalCacheTaskResponse) String() string
- func (m *NormalCacheTaskResponse) Validate() error
- func (m *NormalCacheTaskResponse) ValidateAll() error
- type NormalCacheTaskResponseMultiError
- type NormalCacheTaskResponseValidationError
- func (e NormalCacheTaskResponseValidationError) Cause() error
- func (e NormalCacheTaskResponseValidationError) Error() string
- func (e NormalCacheTaskResponseValidationError) ErrorName() string
- func (e NormalCacheTaskResponseValidationError) Field() string
- func (e NormalCacheTaskResponseValidationError) Key() bool
- func (e NormalCacheTaskResponseValidationError) 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 RegisterCachePeerRequest
- func (*RegisterCachePeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterCachePeerRequest) GetApplication() string
- func (x *RegisterCachePeerRequest) GetHostId() string
- func (x *RegisterCachePeerRequest) GetOutputPath() string
- func (x *RegisterCachePeerRequest) GetPieceLength() uint64
- func (x *RegisterCachePeerRequest) GetTag() string
- func (x *RegisterCachePeerRequest) GetTaskId() string
- func (x *RegisterCachePeerRequest) GetTimeout() *durationpb.Duration
- func (*RegisterCachePeerRequest) ProtoMessage()
- func (x *RegisterCachePeerRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterCachePeerRequest) Reset()
- func (x *RegisterCachePeerRequest) String() string
- func (m *RegisterCachePeerRequest) Validate() error
- func (m *RegisterCachePeerRequest) ValidateAll() error
- type RegisterCachePeerRequestMultiError
- type RegisterCachePeerRequestValidationError
- func (e RegisterCachePeerRequestValidationError) Cause() error
- func (e RegisterCachePeerRequestValidationError) Error() string
- func (e RegisterCachePeerRequestValidationError) ErrorName() string
- func (e RegisterCachePeerRequestValidationError) Field() string
- func (e RegisterCachePeerRequestValidationError) Key() bool
- func (e RegisterCachePeerRequestValidationError) Reason() string
- type RegisterPeerRequest
- func (*RegisterPeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterPeerRequest) GetDownload() *v2.Download
- 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 RescheduleCachePeerRequest
- func (*RescheduleCachePeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RescheduleCachePeerRequest) GetCandidateParents() []*v2.CachePeer
- func (x *RescheduleCachePeerRequest) GetDescription() string
- func (*RescheduleCachePeerRequest) ProtoMessage()
- func (x *RescheduleCachePeerRequest) ProtoReflect() protoreflect.Message
- func (x *RescheduleCachePeerRequest) Reset()
- func (x *RescheduleCachePeerRequest) String() string
- func (m *RescheduleCachePeerRequest) Validate() error
- func (m *RescheduleCachePeerRequest) ValidateAll() error
- type RescheduleCachePeerRequestMultiError
- type RescheduleCachePeerRequestValidationError
- func (e RescheduleCachePeerRequestValidationError) Cause() error
- func (e RescheduleCachePeerRequestValidationError) Error() string
- func (e RescheduleCachePeerRequestValidationError) ErrorName() string
- func (e RescheduleCachePeerRequestValidationError) Field() string
- func (e RescheduleCachePeerRequestValidationError) Key() bool
- func (e RescheduleCachePeerRequestValidationError) Reason() string
- type ReschedulePeerRequest
- func (*ReschedulePeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReschedulePeerRequest) GetCandidateParents() []*v2.Peer
- func (x *ReschedulePeerRequest) GetDescription() string
- func (*ReschedulePeerRequest) ProtoMessage()
- func (x *ReschedulePeerRequest) ProtoReflect() protoreflect.Message
- func (x *ReschedulePeerRequest) Reset()
- func (x *ReschedulePeerRequest) String() string
- func (m *ReschedulePeerRequest) Validate() error
- func (m *ReschedulePeerRequest) ValidateAll() error
- type ReschedulePeerRequestMultiError
- type ReschedulePeerRequestValidationError
- func (e ReschedulePeerRequestValidationError) Cause() error
- func (e ReschedulePeerRequestValidationError) Error() string
- func (e ReschedulePeerRequestValidationError) ErrorName() string
- func (e ReschedulePeerRequestValidationError) Field() string
- func (e ReschedulePeerRequestValidationError) Key() bool
- func (e ReschedulePeerRequestValidationError) Reason() string
- type SchedulerClient
- type SchedulerServer
- type Scheduler_AnnounceCachePeerClient
- type Scheduler_AnnounceCachePeerServer
- type Scheduler_AnnouncePeerClient
- type Scheduler_AnnouncePeerServer
- type Scheduler_SyncProbesClient
- type Scheduler_SyncProbesServer
- type StatCachePeerRequest
- func (*StatCachePeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatCachePeerRequest) GetHostId() string
- func (x *StatCachePeerRequest) GetPeerId() string
- func (x *StatCachePeerRequest) GetTaskId() string
- func (*StatCachePeerRequest) ProtoMessage()
- func (x *StatCachePeerRequest) ProtoReflect() protoreflect.Message
- func (x *StatCachePeerRequest) Reset()
- func (x *StatCachePeerRequest) String() string
- func (m *StatCachePeerRequest) Validate() error
- func (m *StatCachePeerRequest) ValidateAll() error
- type StatCachePeerRequestMultiError
- type StatCachePeerRequestValidationError
- func (e StatCachePeerRequestValidationError) Cause() error
- func (e StatCachePeerRequestValidationError) Error() string
- func (e StatCachePeerRequestValidationError) ErrorName() string
- func (e StatCachePeerRequestValidationError) Field() string
- func (e StatCachePeerRequestValidationError) Key() bool
- func (e StatCachePeerRequestValidationError) Reason() string
- type StatCacheTaskRequest
- func (*StatCacheTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatCacheTaskRequest) GetTaskId() string
- func (*StatCacheTaskRequest) ProtoMessage()
- func (x *StatCacheTaskRequest) ProtoReflect() protoreflect.Message
- func (x *StatCacheTaskRequest) Reset()
- func (x *StatCacheTaskRequest) String() string
- func (m *StatCacheTaskRequest) Validate() error
- func (m *StatCacheTaskRequest) ValidateAll() error
- type StatCacheTaskRequestMultiError
- type StatCacheTaskRequestValidationError
- func (e StatCacheTaskRequestValidationError) Cause() error
- func (e StatCacheTaskRequestValidationError) Error() string
- func (e StatCacheTaskRequestValidationError) ErrorName() string
- func (e StatCacheTaskRequestValidationError) Field() string
- func (e StatCacheTaskRequestValidationError) Key() bool
- func (e StatCacheTaskRequestValidationError) Reason() string
- 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) GetTaskId() 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) AnnounceCachePeer(Scheduler_AnnounceCachePeerServer) error
- func (UnimplementedSchedulerServer) AnnounceHost(context.Context, *AnnounceHostRequest) (*emptypb.Empty, error)
- func (UnimplementedSchedulerServer) AnnouncePeer(Scheduler_AnnouncePeerServer) error
- func (UnimplementedSchedulerServer) DeleteCachePeer(context.Context, *DeleteCachePeerRequest) (*emptypb.Empty, error)
- func (UnimplementedSchedulerServer) DeleteCacheTask(context.Context, *DeleteCacheTaskRequest) (*emptypb.Empty, error)
- func (UnimplementedSchedulerServer) DeleteHost(context.Context, *DeleteHostRequest) (*emptypb.Empty, error)
- func (UnimplementedSchedulerServer) DeletePeer(context.Context, *DeletePeerRequest) (*emptypb.Empty, error)
- func (UnimplementedSchedulerServer) DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)
- func (UnimplementedSchedulerServer) StatCachePeer(context.Context, *StatCachePeerRequest) (*v2.CachePeer, error)
- func (UnimplementedSchedulerServer) StatCacheTask(context.Context, *StatCacheTaskRequest) (*v2.CacheTask, 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
- func (UnimplementedSchedulerServer) UploadCacheTask(context.Context, *UploadCacheTaskRequest) (*v2.CacheTask, error)
- type UnsafeSchedulerServer
- type UploadCacheTaskRequest
- func (*UploadCacheTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UploadCacheTaskRequest) GetApplication() string
- func (x *UploadCacheTaskRequest) GetHostId() string
- func (x *UploadCacheTaskRequest) GetPeerId() string
- func (x *UploadCacheTaskRequest) GetPersistentReplicaCount() uint64
- func (x *UploadCacheTaskRequest) GetPieceLength() uint64
- func (x *UploadCacheTaskRequest) GetTag() string
- func (x *UploadCacheTaskRequest) GetTaskId() string
- func (x *UploadCacheTaskRequest) GetTimeout() *durationpb.Duration
- func (x *UploadCacheTaskRequest) GetTtl() *durationpb.Duration
- func (*UploadCacheTaskRequest) ProtoMessage()
- func (x *UploadCacheTaskRequest) ProtoReflect() protoreflect.Message
- func (x *UploadCacheTaskRequest) Reset()
- func (x *UploadCacheTaskRequest) String() string
- func (m *UploadCacheTaskRequest) Validate() error
- func (m *UploadCacheTaskRequest) ValidateAll() error
- type UploadCacheTaskRequestMultiError
- type UploadCacheTaskRequestValidationError
- func (e UploadCacheTaskRequestValidationError) Cause() error
- func (e UploadCacheTaskRequestValidationError) Error() string
- func (e UploadCacheTaskRequestValidationError) ErrorName() string
- func (e UploadCacheTaskRequestValidationError) Field() string
- func (e UploadCacheTaskRequestValidationError) Key() bool
- func (e UploadCacheTaskRequestValidationError) Reason() string
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: "DeletePeer", Handler: _Scheduler_DeletePeer_Handler, }, { MethodName: "StatTask", Handler: _Scheduler_StatTask_Handler, }, { MethodName: "DeleteTask", Handler: _Scheduler_DeleteTask_Handler, }, { MethodName: "AnnounceHost", Handler: _Scheduler_AnnounceHost_Handler, }, { MethodName: "DeleteHost", Handler: _Scheduler_DeleteHost_Handler, }, { MethodName: "StatCachePeer", Handler: _Scheduler_StatCachePeer_Handler, }, { MethodName: "DeleteCachePeer", Handler: _Scheduler_DeleteCachePeer_Handler, }, { MethodName: "UploadCacheTask", Handler: _Scheduler_UploadCacheTask_Handler, }, { MethodName: "StatCacheTask", Handler: _Scheduler_StatCacheTask_Handler, }, { MethodName: "DeleteCacheTask", Handler: _Scheduler_DeleteCacheTask_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "AnnouncePeer", Handler: _Scheduler_AnnouncePeer_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "SyncProbes", Handler: _Scheduler_SyncProbes_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "AnnounceCachePeer", Handler: _Scheduler_AnnounceCachePeer_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 AnnounceCachePeerRequest ¶ added in v2.0.121
type AnnounceCachePeerRequest 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: // // *AnnounceCachePeerRequest_RegisterCachePeerRequest // *AnnounceCachePeerRequest_DownloadCachePeerStartedRequest // *AnnounceCachePeerRequest_RescheduleCachePeerRequest // *AnnounceCachePeerRequest_DownloadCachePeerFinishedRequest // *AnnounceCachePeerRequest_DownloadCachePeerFailedRequest // *AnnounceCachePeerRequest_DownloadPieceFinishedRequest // *AnnounceCachePeerRequest_DownloadPieceFailedRequest Request isAnnounceCachePeerRequest_Request `protobuf_oneof:"request"` // contains filtered or unexported fields }
AnnounceCachePeerRequest represents request of AnnounceCachePeer.
func (*AnnounceCachePeerRequest) Descriptor
deprecated
added in
v2.0.121
func (*AnnounceCachePeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use AnnounceCachePeerRequest.ProtoReflect.Descriptor instead.
func (*AnnounceCachePeerRequest) GetDownloadCachePeerFailedRequest ¶ added in v2.0.121
func (x *AnnounceCachePeerRequest) GetDownloadCachePeerFailedRequest() *DownloadCachePeerFailedRequest
func (*AnnounceCachePeerRequest) GetDownloadCachePeerFinishedRequest ¶ added in v2.0.121
func (x *AnnounceCachePeerRequest) GetDownloadCachePeerFinishedRequest() *DownloadCachePeerFinishedRequest
func (*AnnounceCachePeerRequest) GetDownloadCachePeerStartedRequest ¶ added in v2.0.121
func (x *AnnounceCachePeerRequest) GetDownloadCachePeerStartedRequest() *DownloadCachePeerStartedRequest
func (*AnnounceCachePeerRequest) GetDownloadPieceFailedRequest ¶ added in v2.0.121
func (x *AnnounceCachePeerRequest) GetDownloadPieceFailedRequest() *DownloadPieceFailedRequest
func (*AnnounceCachePeerRequest) GetDownloadPieceFinishedRequest ¶ added in v2.0.121
func (x *AnnounceCachePeerRequest) GetDownloadPieceFinishedRequest() *DownloadPieceFinishedRequest
func (*AnnounceCachePeerRequest) GetHostId ¶ added in v2.0.121
func (x *AnnounceCachePeerRequest) GetHostId() string
func (*AnnounceCachePeerRequest) GetPeerId ¶ added in v2.0.121
func (x *AnnounceCachePeerRequest) GetPeerId() string
func (*AnnounceCachePeerRequest) GetRegisterCachePeerRequest ¶ added in v2.0.121
func (x *AnnounceCachePeerRequest) GetRegisterCachePeerRequest() *RegisterCachePeerRequest
func (*AnnounceCachePeerRequest) GetRequest ¶ added in v2.0.121
func (m *AnnounceCachePeerRequest) GetRequest() isAnnounceCachePeerRequest_Request
func (*AnnounceCachePeerRequest) GetRescheduleCachePeerRequest ¶ added in v2.0.121
func (x *AnnounceCachePeerRequest) GetRescheduleCachePeerRequest() *RescheduleCachePeerRequest
func (*AnnounceCachePeerRequest) GetTaskId ¶ added in v2.0.121
func (x *AnnounceCachePeerRequest) GetTaskId() string
func (*AnnounceCachePeerRequest) ProtoMessage ¶ added in v2.0.121
func (*AnnounceCachePeerRequest) ProtoMessage()
func (*AnnounceCachePeerRequest) ProtoReflect ¶ added in v2.0.121
func (x *AnnounceCachePeerRequest) ProtoReflect() protoreflect.Message
func (*AnnounceCachePeerRequest) Reset ¶ added in v2.0.121
func (x *AnnounceCachePeerRequest) Reset()
func (*AnnounceCachePeerRequest) String ¶ added in v2.0.121
func (x *AnnounceCachePeerRequest) String() string
func (*AnnounceCachePeerRequest) Validate ¶ added in v2.0.121
func (m *AnnounceCachePeerRequest) Validate() error
Validate checks the field values on AnnounceCachePeerRequest 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 (*AnnounceCachePeerRequest) ValidateAll ¶ added in v2.0.121
func (m *AnnounceCachePeerRequest) ValidateAll() error
ValidateAll checks the field values on AnnounceCachePeerRequest 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 AnnounceCachePeerRequestMultiError, or nil if none found.
type AnnounceCachePeerRequestMultiError ¶ added in v2.0.121
type AnnounceCachePeerRequestMultiError []error
AnnounceCachePeerRequestMultiError is an error wrapping multiple validation errors returned by AnnounceCachePeerRequest.ValidateAll() if the designated constraints aren't met.
func (AnnounceCachePeerRequestMultiError) AllErrors ¶ added in v2.0.121
func (m AnnounceCachePeerRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (AnnounceCachePeerRequestMultiError) Error ¶ added in v2.0.121
func (m AnnounceCachePeerRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type AnnounceCachePeerRequestValidationError ¶ added in v2.0.121
type AnnounceCachePeerRequestValidationError struct {
// contains filtered or unexported fields
}
AnnounceCachePeerRequestValidationError is the validation error returned by AnnounceCachePeerRequest.Validate if the designated constraints aren't met.
func (AnnounceCachePeerRequestValidationError) Cause ¶ added in v2.0.121
func (e AnnounceCachePeerRequestValidationError) Cause() error
Cause function returns cause value.
func (AnnounceCachePeerRequestValidationError) Error ¶ added in v2.0.121
func (e AnnounceCachePeerRequestValidationError) Error() string
Error satisfies the builtin error interface
func (AnnounceCachePeerRequestValidationError) ErrorName ¶ added in v2.0.121
func (e AnnounceCachePeerRequestValidationError) ErrorName() string
ErrorName returns error name.
func (AnnounceCachePeerRequestValidationError) Field ¶ added in v2.0.121
func (e AnnounceCachePeerRequestValidationError) Field() string
Field function returns field value.
func (AnnounceCachePeerRequestValidationError) Key ¶ added in v2.0.121
func (e AnnounceCachePeerRequestValidationError) Key() bool
Key function returns key value.
func (AnnounceCachePeerRequestValidationError) Reason ¶ added in v2.0.121
func (e AnnounceCachePeerRequestValidationError) Reason() string
Reason function returns reason value.
type AnnounceCachePeerRequest_DownloadCachePeerFailedRequest ¶ added in v2.0.121
type AnnounceCachePeerRequest_DownloadCachePeerFailedRequest struct {
DownloadCachePeerFailedRequest *DownloadCachePeerFailedRequest `protobuf:"bytes,8,opt,name=download_cache_peer_failed_request,json=downloadCachePeerFailedRequest,proto3,oneof"`
}
type AnnounceCachePeerRequest_DownloadCachePeerFinishedRequest ¶ added in v2.0.121
type AnnounceCachePeerRequest_DownloadCachePeerFinishedRequest struct {
DownloadCachePeerFinishedRequest *DownloadCachePeerFinishedRequest `protobuf:"bytes,7,opt,name=download_cache_peer_finished_request,json=downloadCachePeerFinishedRequest,proto3,oneof"`
}
type AnnounceCachePeerRequest_DownloadCachePeerStartedRequest ¶ added in v2.0.121
type AnnounceCachePeerRequest_DownloadCachePeerStartedRequest struct {
DownloadCachePeerStartedRequest *DownloadCachePeerStartedRequest `protobuf:"bytes,5,opt,name=download_cache_peer_started_request,json=downloadCachePeerStartedRequest,proto3,oneof"`
}
type AnnounceCachePeerRequest_DownloadPieceFailedRequest ¶ added in v2.0.121
type AnnounceCachePeerRequest_DownloadPieceFailedRequest struct {
DownloadPieceFailedRequest *DownloadPieceFailedRequest `protobuf:"bytes,10,opt,name=download_piece_failed_request,json=downloadPieceFailedRequest,proto3,oneof"`
}
type AnnounceCachePeerRequest_DownloadPieceFinishedRequest ¶ added in v2.0.121
type AnnounceCachePeerRequest_DownloadPieceFinishedRequest struct {
DownloadPieceFinishedRequest *DownloadPieceFinishedRequest `protobuf:"bytes,9,opt,name=download_piece_finished_request,json=downloadPieceFinishedRequest,proto3,oneof"`
}
type AnnounceCachePeerRequest_RegisterCachePeerRequest ¶ added in v2.0.121
type AnnounceCachePeerRequest_RegisterCachePeerRequest struct {
RegisterCachePeerRequest *RegisterCachePeerRequest `protobuf:"bytes,4,opt,name=register_cache_peer_request,json=registerCachePeerRequest,proto3,oneof"`
}
type AnnounceCachePeerRequest_RescheduleCachePeerRequest ¶ added in v2.0.121
type AnnounceCachePeerRequest_RescheduleCachePeerRequest struct {
RescheduleCachePeerRequest *RescheduleCachePeerRequest `protobuf:"bytes,6,opt,name=reschedule_cache_peer_request,json=rescheduleCachePeerRequest,proto3,oneof"`
}
type AnnounceCachePeerResponse ¶ added in v2.0.121
type AnnounceCachePeerResponse struct { // Types that are assignable to Response: // // *AnnounceCachePeerResponse_EmptyTaskResponse // *AnnounceCachePeerResponse_NormalTaskResponse Response isAnnounceCachePeerResponse_Response `protobuf_oneof:"response"` // contains filtered or unexported fields }
AnnounceCachePeerResponse represents response of AnnounceCachePeer.
func (*AnnounceCachePeerResponse) Descriptor
deprecated
added in
v2.0.121
func (*AnnounceCachePeerResponse) Descriptor() ([]byte, []int)
Deprecated: Use AnnounceCachePeerResponse.ProtoReflect.Descriptor instead.
func (*AnnounceCachePeerResponse) GetEmptyTaskResponse ¶ added in v2.0.121
func (x *AnnounceCachePeerResponse) GetEmptyTaskResponse() *EmptyCacheTaskResponse
func (*AnnounceCachePeerResponse) GetNormalTaskResponse ¶ added in v2.0.121
func (x *AnnounceCachePeerResponse) GetNormalTaskResponse() *NormalCacheTaskResponse
func (*AnnounceCachePeerResponse) GetResponse ¶ added in v2.0.121
func (m *AnnounceCachePeerResponse) GetResponse() isAnnounceCachePeerResponse_Response
func (*AnnounceCachePeerResponse) ProtoMessage ¶ added in v2.0.121
func (*AnnounceCachePeerResponse) ProtoMessage()
func (*AnnounceCachePeerResponse) ProtoReflect ¶ added in v2.0.121
func (x *AnnounceCachePeerResponse) ProtoReflect() protoreflect.Message
func (*AnnounceCachePeerResponse) Reset ¶ added in v2.0.121
func (x *AnnounceCachePeerResponse) Reset()
func (*AnnounceCachePeerResponse) String ¶ added in v2.0.121
func (x *AnnounceCachePeerResponse) String() string
func (*AnnounceCachePeerResponse) Validate ¶ added in v2.0.121
func (m *AnnounceCachePeerResponse) Validate() error
Validate checks the field values on AnnounceCachePeerResponse 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 (*AnnounceCachePeerResponse) ValidateAll ¶ added in v2.0.121
func (m *AnnounceCachePeerResponse) ValidateAll() error
ValidateAll checks the field values on AnnounceCachePeerResponse 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 AnnounceCachePeerResponseMultiError, or nil if none found.
type AnnounceCachePeerResponseMultiError ¶ added in v2.0.121
type AnnounceCachePeerResponseMultiError []error
AnnounceCachePeerResponseMultiError is an error wrapping multiple validation errors returned by AnnounceCachePeerResponse.ValidateAll() if the designated constraints aren't met.
func (AnnounceCachePeerResponseMultiError) AllErrors ¶ added in v2.0.121
func (m AnnounceCachePeerResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (AnnounceCachePeerResponseMultiError) Error ¶ added in v2.0.121
func (m AnnounceCachePeerResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type AnnounceCachePeerResponseValidationError ¶ added in v2.0.121
type AnnounceCachePeerResponseValidationError struct {
// contains filtered or unexported fields
}
AnnounceCachePeerResponseValidationError is the validation error returned by AnnounceCachePeerResponse.Validate if the designated constraints aren't met.
func (AnnounceCachePeerResponseValidationError) Cause ¶ added in v2.0.121
func (e AnnounceCachePeerResponseValidationError) Cause() error
Cause function returns cause value.
func (AnnounceCachePeerResponseValidationError) Error ¶ added in v2.0.121
func (e AnnounceCachePeerResponseValidationError) Error() string
Error satisfies the builtin error interface
func (AnnounceCachePeerResponseValidationError) ErrorName ¶ added in v2.0.121
func (e AnnounceCachePeerResponseValidationError) ErrorName() string
ErrorName returns error name.
func (AnnounceCachePeerResponseValidationError) Field ¶ added in v2.0.121
func (e AnnounceCachePeerResponseValidationError) Field() string
Field function returns field value.
func (AnnounceCachePeerResponseValidationError) Key ¶ added in v2.0.121
func (e AnnounceCachePeerResponseValidationError) Key() bool
Key function returns key value.
func (AnnounceCachePeerResponseValidationError) Reason ¶ added in v2.0.121
func (e AnnounceCachePeerResponseValidationError) Reason() string
Reason function returns reason value.
type AnnounceCachePeerResponse_EmptyTaskResponse ¶ added in v2.0.121
type AnnounceCachePeerResponse_EmptyTaskResponse struct {
EmptyTaskResponse *EmptyCacheTaskResponse `protobuf:"bytes,1,opt,name=empty_task_response,json=emptyTaskResponse,proto3,oneof"`
}
type AnnounceCachePeerResponse_NormalTaskResponse ¶ added in v2.0.121
type AnnounceCachePeerResponse_NormalTaskResponse struct {
NormalTaskResponse *NormalCacheTaskResponse `protobuf:"bytes,2,opt,name=normal_task_response,json=normalTaskResponse,proto3,oneof"`
}
type AnnounceHostRequest ¶
type AnnounceHostRequest struct { // Host info. Host *v2.Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` // The interval between dfdaemon announces to scheduler. Interval *durationpb.Duration `protobuf:"bytes,2,opt,name=interval,proto3,oneof" json:"interval,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) GetInterval ¶ added in v2.0.125
func (x *AnnounceHostRequest) GetInterval() *durationpb.Duration
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_ReschedulePeerRequest // *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) GetReschedulePeerRequest ¶ added in v2.0.121
func (x *AnnouncePeerRequest) GetReschedulePeerRequest() *ReschedulePeerRequest
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_ReschedulePeerRequest ¶ added in v2.0.121
type AnnouncePeerRequest_ReschedulePeerRequest struct {
ReschedulePeerRequest *ReschedulePeerRequest `protobuf:"bytes,7,opt,name=reschedule_peer_request,json=reschedulePeerRequest,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 DeleteCachePeerRequest ¶ added in v2.0.121
type DeleteCachePeerRequest 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 }
DeleteCachePeerRequest represents request of DeleteCachePeer.
func (*DeleteCachePeerRequest) Descriptor
deprecated
added in
v2.0.121
func (*DeleteCachePeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteCachePeerRequest.ProtoReflect.Descriptor instead.
func (*DeleteCachePeerRequest) GetHostId ¶ added in v2.0.121
func (x *DeleteCachePeerRequest) GetHostId() string
func (*DeleteCachePeerRequest) GetPeerId ¶ added in v2.0.121
func (x *DeleteCachePeerRequest) GetPeerId() string
func (*DeleteCachePeerRequest) GetTaskId ¶ added in v2.0.121
func (x *DeleteCachePeerRequest) GetTaskId() string
func (*DeleteCachePeerRequest) ProtoMessage ¶ added in v2.0.121
func (*DeleteCachePeerRequest) ProtoMessage()
func (*DeleteCachePeerRequest) ProtoReflect ¶ added in v2.0.121
func (x *DeleteCachePeerRequest) ProtoReflect() protoreflect.Message
func (*DeleteCachePeerRequest) Reset ¶ added in v2.0.121
func (x *DeleteCachePeerRequest) Reset()
func (*DeleteCachePeerRequest) String ¶ added in v2.0.121
func (x *DeleteCachePeerRequest) String() string
func (*DeleteCachePeerRequest) Validate ¶ added in v2.0.121
func (m *DeleteCachePeerRequest) Validate() error
Validate checks the field values on DeleteCachePeerRequest 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 (*DeleteCachePeerRequest) ValidateAll ¶ added in v2.0.121
func (m *DeleteCachePeerRequest) ValidateAll() error
ValidateAll checks the field values on DeleteCachePeerRequest 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 DeleteCachePeerRequestMultiError, or nil if none found.
type DeleteCachePeerRequestMultiError ¶ added in v2.0.121
type DeleteCachePeerRequestMultiError []error
DeleteCachePeerRequestMultiError is an error wrapping multiple validation errors returned by DeleteCachePeerRequest.ValidateAll() if the designated constraints aren't met.
func (DeleteCachePeerRequestMultiError) AllErrors ¶ added in v2.0.121
func (m DeleteCachePeerRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DeleteCachePeerRequestMultiError) Error ¶ added in v2.0.121
func (m DeleteCachePeerRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DeleteCachePeerRequestValidationError ¶ added in v2.0.121
type DeleteCachePeerRequestValidationError struct {
// contains filtered or unexported fields
}
DeleteCachePeerRequestValidationError is the validation error returned by DeleteCachePeerRequest.Validate if the designated constraints aren't met.
func (DeleteCachePeerRequestValidationError) Cause ¶ added in v2.0.121
func (e DeleteCachePeerRequestValidationError) Cause() error
Cause function returns cause value.
func (DeleteCachePeerRequestValidationError) Error ¶ added in v2.0.121
func (e DeleteCachePeerRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DeleteCachePeerRequestValidationError) ErrorName ¶ added in v2.0.121
func (e DeleteCachePeerRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DeleteCachePeerRequestValidationError) Field ¶ added in v2.0.121
func (e DeleteCachePeerRequestValidationError) Field() string
Field function returns field value.
func (DeleteCachePeerRequestValidationError) Key ¶ added in v2.0.121
func (e DeleteCachePeerRequestValidationError) Key() bool
Key function returns key value.
func (DeleteCachePeerRequestValidationError) Reason ¶ added in v2.0.121
func (e DeleteCachePeerRequestValidationError) Reason() string
Reason function returns reason value.
type DeleteCacheTaskRequest ¶ added in v2.0.121
type DeleteCacheTaskRequest 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 }
DeleteCacheTaskRequest represents request of DeleteCacheTask.
func (*DeleteCacheTaskRequest) Descriptor
deprecated
added in
v2.0.121
func (*DeleteCacheTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteCacheTaskRequest.ProtoReflect.Descriptor instead.
func (*DeleteCacheTaskRequest) GetHostId ¶ added in v2.0.121
func (x *DeleteCacheTaskRequest) GetHostId() string
func (*DeleteCacheTaskRequest) GetTaskId ¶ added in v2.0.121
func (x *DeleteCacheTaskRequest) GetTaskId() string
func (*DeleteCacheTaskRequest) ProtoMessage ¶ added in v2.0.121
func (*DeleteCacheTaskRequest) ProtoMessage()
func (*DeleteCacheTaskRequest) ProtoReflect ¶ added in v2.0.121
func (x *DeleteCacheTaskRequest) ProtoReflect() protoreflect.Message
func (*DeleteCacheTaskRequest) Reset ¶ added in v2.0.121
func (x *DeleteCacheTaskRequest) Reset()
func (*DeleteCacheTaskRequest) String ¶ added in v2.0.121
func (x *DeleteCacheTaskRequest) String() string
func (*DeleteCacheTaskRequest) Validate ¶ added in v2.0.121
func (m *DeleteCacheTaskRequest) Validate() error
Validate checks the field values on DeleteCacheTaskRequest 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 (*DeleteCacheTaskRequest) ValidateAll ¶ added in v2.0.121
func (m *DeleteCacheTaskRequest) ValidateAll() error
ValidateAll checks the field values on DeleteCacheTaskRequest 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 DeleteCacheTaskRequestMultiError, or nil if none found.
type DeleteCacheTaskRequestMultiError ¶ added in v2.0.121
type DeleteCacheTaskRequestMultiError []error
DeleteCacheTaskRequestMultiError is an error wrapping multiple validation errors returned by DeleteCacheTaskRequest.ValidateAll() if the designated constraints aren't met.
func (DeleteCacheTaskRequestMultiError) AllErrors ¶ added in v2.0.121
func (m DeleteCacheTaskRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DeleteCacheTaskRequestMultiError) Error ¶ added in v2.0.121
func (m DeleteCacheTaskRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DeleteCacheTaskRequestValidationError ¶ added in v2.0.121
type DeleteCacheTaskRequestValidationError struct {
// contains filtered or unexported fields
}
DeleteCacheTaskRequestValidationError is the validation error returned by DeleteCacheTaskRequest.Validate if the designated constraints aren't met.
func (DeleteCacheTaskRequestValidationError) Cause ¶ added in v2.0.121
func (e DeleteCacheTaskRequestValidationError) Cause() error
Cause function returns cause value.
func (DeleteCacheTaskRequestValidationError) Error ¶ added in v2.0.121
func (e DeleteCacheTaskRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DeleteCacheTaskRequestValidationError) ErrorName ¶ added in v2.0.121
func (e DeleteCacheTaskRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DeleteCacheTaskRequestValidationError) Field ¶ added in v2.0.121
func (e DeleteCacheTaskRequestValidationError) Field() string
Field function returns field value.
func (DeleteCacheTaskRequestValidationError) Key ¶ added in v2.0.121
func (e DeleteCacheTaskRequestValidationError) Key() bool
Key function returns key value.
func (DeleteCacheTaskRequestValidationError) Reason ¶ added in v2.0.121
func (e DeleteCacheTaskRequestValidationError) Reason() string
Reason function returns reason value.
type DeleteHostRequest ¶ added in v2.0.118
type DeleteHostRequest struct { // Host id. HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"` // contains filtered or unexported fields }
DeleteHostRequest represents request of DeleteHost.
func (*DeleteHostRequest) Descriptor
deprecated
added in
v2.0.118
func (*DeleteHostRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteHostRequest.ProtoReflect.Descriptor instead.
func (*DeleteHostRequest) GetHostId ¶ added in v2.0.121
func (x *DeleteHostRequest) GetHostId() string
func (*DeleteHostRequest) ProtoMessage ¶ added in v2.0.118
func (*DeleteHostRequest) ProtoMessage()
func (*DeleteHostRequest) ProtoReflect ¶ added in v2.0.118
func (x *DeleteHostRequest) ProtoReflect() protoreflect.Message
func (*DeleteHostRequest) Reset ¶ added in v2.0.118
func (x *DeleteHostRequest) Reset()
func (*DeleteHostRequest) String ¶ added in v2.0.118
func (x *DeleteHostRequest) String() string
func (*DeleteHostRequest) Validate ¶ added in v2.0.118
func (m *DeleteHostRequest) Validate() error
Validate checks the field values on DeleteHostRequest 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 (*DeleteHostRequest) ValidateAll ¶ added in v2.0.118
func (m *DeleteHostRequest) ValidateAll() error
ValidateAll checks the field values on DeleteHostRequest 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 DeleteHostRequestMultiError, or nil if none found.
type DeleteHostRequestMultiError ¶ added in v2.0.118
type DeleteHostRequestMultiError []error
DeleteHostRequestMultiError is an error wrapping multiple validation errors returned by DeleteHostRequest.ValidateAll() if the designated constraints aren't met.
func (DeleteHostRequestMultiError) AllErrors ¶ added in v2.0.118
func (m DeleteHostRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DeleteHostRequestMultiError) Error ¶ added in v2.0.118
func (m DeleteHostRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DeleteHostRequestValidationError ¶ added in v2.0.118
type DeleteHostRequestValidationError struct {
// contains filtered or unexported fields
}
DeleteHostRequestValidationError is the validation error returned by DeleteHostRequest.Validate if the designated constraints aren't met.
func (DeleteHostRequestValidationError) Cause ¶ added in v2.0.118
func (e DeleteHostRequestValidationError) Cause() error
Cause function returns cause value.
func (DeleteHostRequestValidationError) Error ¶ added in v2.0.118
func (e DeleteHostRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DeleteHostRequestValidationError) ErrorName ¶ added in v2.0.118
func (e DeleteHostRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DeleteHostRequestValidationError) Field ¶ added in v2.0.118
func (e DeleteHostRequestValidationError) Field() string
Field function returns field value.
func (DeleteHostRequestValidationError) Key ¶ added in v2.0.118
func (e DeleteHostRequestValidationError) Key() bool
Key function returns key value.
func (DeleteHostRequestValidationError) Reason ¶ added in v2.0.118
func (e DeleteHostRequestValidationError) Reason() string
Reason function returns reason value.
type DeletePeerRequest ¶ added in v2.0.118
type DeletePeerRequest 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 }
DeletePeerRequest represents request of DeletePeer.
func (*DeletePeerRequest) Descriptor
deprecated
added in
v2.0.118
func (*DeletePeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeletePeerRequest.ProtoReflect.Descriptor instead.
func (*DeletePeerRequest) GetHostId ¶ added in v2.0.118
func (x *DeletePeerRequest) GetHostId() string
func (*DeletePeerRequest) GetPeerId ¶ added in v2.0.118
func (x *DeletePeerRequest) GetPeerId() string
func (*DeletePeerRequest) GetTaskId ¶ added in v2.0.118
func (x *DeletePeerRequest) GetTaskId() string
func (*DeletePeerRequest) ProtoMessage ¶ added in v2.0.118
func (*DeletePeerRequest) ProtoMessage()
func (*DeletePeerRequest) ProtoReflect ¶ added in v2.0.118
func (x *DeletePeerRequest) ProtoReflect() protoreflect.Message
func (*DeletePeerRequest) Reset ¶ added in v2.0.118
func (x *DeletePeerRequest) Reset()
func (*DeletePeerRequest) String ¶ added in v2.0.118
func (x *DeletePeerRequest) String() string
func (*DeletePeerRequest) Validate ¶ added in v2.0.118
func (m *DeletePeerRequest) Validate() error
Validate checks the field values on DeletePeerRequest 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 (*DeletePeerRequest) ValidateAll ¶ added in v2.0.118
func (m *DeletePeerRequest) ValidateAll() error
ValidateAll checks the field values on DeletePeerRequest 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 DeletePeerRequestMultiError, or nil if none found.
type DeletePeerRequestMultiError ¶ added in v2.0.118
type DeletePeerRequestMultiError []error
DeletePeerRequestMultiError is an error wrapping multiple validation errors returned by DeletePeerRequest.ValidateAll() if the designated constraints aren't met.
func (DeletePeerRequestMultiError) AllErrors ¶ added in v2.0.118
func (m DeletePeerRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DeletePeerRequestMultiError) Error ¶ added in v2.0.118
func (m DeletePeerRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DeletePeerRequestValidationError ¶ added in v2.0.118
type DeletePeerRequestValidationError struct {
// contains filtered or unexported fields
}
DeletePeerRequestValidationError is the validation error returned by DeletePeerRequest.Validate if the designated constraints aren't met.
func (DeletePeerRequestValidationError) Cause ¶ added in v2.0.118
func (e DeletePeerRequestValidationError) Cause() error
Cause function returns cause value.
func (DeletePeerRequestValidationError) Error ¶ added in v2.0.118
func (e DeletePeerRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DeletePeerRequestValidationError) ErrorName ¶ added in v2.0.118
func (e DeletePeerRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DeletePeerRequestValidationError) Field ¶ added in v2.0.118
func (e DeletePeerRequestValidationError) Field() string
Field function returns field value.
func (DeletePeerRequestValidationError) Key ¶ added in v2.0.118
func (e DeletePeerRequestValidationError) Key() bool
Key function returns key value.
func (DeletePeerRequestValidationError) Reason ¶ added in v2.0.118
func (e DeletePeerRequestValidationError) Reason() string
Reason function returns reason value.
type DeleteTaskRequest ¶ added in v2.0.118
type DeleteTaskRequest 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 }
DeleteTaskRequest represents request of DeleteTask.
func (*DeleteTaskRequest) Descriptor
deprecated
added in
v2.0.118
func (*DeleteTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.
func (*DeleteTaskRequest) GetHostId ¶ added in v2.0.118
func (x *DeleteTaskRequest) GetHostId() string
func (*DeleteTaskRequest) GetTaskId ¶ added in v2.0.118
func (x *DeleteTaskRequest) GetTaskId() string
func (*DeleteTaskRequest) ProtoMessage ¶ added in v2.0.118
func (*DeleteTaskRequest) ProtoMessage()
func (*DeleteTaskRequest) ProtoReflect ¶ added in v2.0.118
func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message
func (*DeleteTaskRequest) Reset ¶ added in v2.0.118
func (x *DeleteTaskRequest) Reset()
func (*DeleteTaskRequest) String ¶ added in v2.0.118
func (x *DeleteTaskRequest) String() string
func (*DeleteTaskRequest) Validate ¶ added in v2.0.118
func (m *DeleteTaskRequest) Validate() error
Validate checks the field values on DeleteTaskRequest 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 (*DeleteTaskRequest) ValidateAll ¶ added in v2.0.118
func (m *DeleteTaskRequest) ValidateAll() error
ValidateAll checks the field values on DeleteTaskRequest 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 DeleteTaskRequestMultiError, or nil if none found.
type DeleteTaskRequestMultiError ¶ added in v2.0.118
type DeleteTaskRequestMultiError []error
DeleteTaskRequestMultiError is an error wrapping multiple validation errors returned by DeleteTaskRequest.ValidateAll() if the designated constraints aren't met.
func (DeleteTaskRequestMultiError) AllErrors ¶ added in v2.0.118
func (m DeleteTaskRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DeleteTaskRequestMultiError) Error ¶ added in v2.0.118
func (m DeleteTaskRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DeleteTaskRequestValidationError ¶ added in v2.0.118
type DeleteTaskRequestValidationError struct {
// contains filtered or unexported fields
}
DeleteTaskRequestValidationError is the validation error returned by DeleteTaskRequest.Validate if the designated constraints aren't met.
func (DeleteTaskRequestValidationError) Cause ¶ added in v2.0.118
func (e DeleteTaskRequestValidationError) Cause() error
Cause function returns cause value.
func (DeleteTaskRequestValidationError) Error ¶ added in v2.0.118
func (e DeleteTaskRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DeleteTaskRequestValidationError) ErrorName ¶ added in v2.0.118
func (e DeleteTaskRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DeleteTaskRequestValidationError) Field ¶ added in v2.0.118
func (e DeleteTaskRequestValidationError) Field() string
Field function returns field value.
func (DeleteTaskRequestValidationError) Key ¶ added in v2.0.118
func (e DeleteTaskRequestValidationError) Key() bool
Key function returns key value.
func (DeleteTaskRequestValidationError) Reason ¶ added in v2.0.118
func (e DeleteTaskRequestValidationError) Reason() string
Reason function returns reason value.
type DownloadCachePeerFailedRequest ¶ added in v2.0.121
type DownloadCachePeerFailedRequest 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 }
DownloadCachePeerFailedRequest represents cache peer download failed request of AnnounceCachePeerRequest.
func (*DownloadCachePeerFailedRequest) Descriptor
deprecated
added in
v2.0.121
func (*DownloadCachePeerFailedRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadCachePeerFailedRequest.ProtoReflect.Descriptor instead.
func (*DownloadCachePeerFailedRequest) GetDescription ¶ added in v2.0.121
func (x *DownloadCachePeerFailedRequest) GetDescription() string
func (*DownloadCachePeerFailedRequest) ProtoMessage ¶ added in v2.0.121
func (*DownloadCachePeerFailedRequest) ProtoMessage()
func (*DownloadCachePeerFailedRequest) ProtoReflect ¶ added in v2.0.121
func (x *DownloadCachePeerFailedRequest) ProtoReflect() protoreflect.Message
func (*DownloadCachePeerFailedRequest) Reset ¶ added in v2.0.121
func (x *DownloadCachePeerFailedRequest) Reset()
func (*DownloadCachePeerFailedRequest) String ¶ added in v2.0.121
func (x *DownloadCachePeerFailedRequest) String() string
func (*DownloadCachePeerFailedRequest) Validate ¶ added in v2.0.121
func (m *DownloadCachePeerFailedRequest) Validate() error
Validate checks the field values on DownloadCachePeerFailedRequest 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 (*DownloadCachePeerFailedRequest) ValidateAll ¶ added in v2.0.121
func (m *DownloadCachePeerFailedRequest) ValidateAll() error
ValidateAll checks the field values on DownloadCachePeerFailedRequest 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 DownloadCachePeerFailedRequestMultiError, or nil if none found.
type DownloadCachePeerFailedRequestMultiError ¶ added in v2.0.121
type DownloadCachePeerFailedRequestMultiError []error
DownloadCachePeerFailedRequestMultiError is an error wrapping multiple validation errors returned by DownloadCachePeerFailedRequest.ValidateAll() if the designated constraints aren't met.
func (DownloadCachePeerFailedRequestMultiError) AllErrors ¶ added in v2.0.121
func (m DownloadCachePeerFailedRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadCachePeerFailedRequestMultiError) Error ¶ added in v2.0.121
func (m DownloadCachePeerFailedRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadCachePeerFailedRequestValidationError ¶ added in v2.0.121
type DownloadCachePeerFailedRequestValidationError struct {
// contains filtered or unexported fields
}
DownloadCachePeerFailedRequestValidationError is the validation error returned by DownloadCachePeerFailedRequest.Validate if the designated constraints aren't met.
func (DownloadCachePeerFailedRequestValidationError) Cause ¶ added in v2.0.121
func (e DownloadCachePeerFailedRequestValidationError) Cause() error
Cause function returns cause value.
func (DownloadCachePeerFailedRequestValidationError) Error ¶ added in v2.0.121
func (e DownloadCachePeerFailedRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadCachePeerFailedRequestValidationError) ErrorName ¶ added in v2.0.121
func (e DownloadCachePeerFailedRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadCachePeerFailedRequestValidationError) Field ¶ added in v2.0.121
func (e DownloadCachePeerFailedRequestValidationError) Field() string
Field function returns field value.
func (DownloadCachePeerFailedRequestValidationError) Key ¶ added in v2.0.121
func (e DownloadCachePeerFailedRequestValidationError) Key() bool
Key function returns key value.
func (DownloadCachePeerFailedRequestValidationError) Reason ¶ added in v2.0.121
func (e DownloadCachePeerFailedRequestValidationError) Reason() string
Reason function returns reason value.
type DownloadCachePeerFinishedRequest ¶ added in v2.0.121
type DownloadCachePeerFinishedRequest struct { // Total piece count. PieceCount uint32 `protobuf:"varint,1,opt,name=piece_count,json=pieceCount,proto3" json:"piece_count,omitempty"` // contains filtered or unexported fields }
DownloadCachePeerFinishedRequest represents cache peer download finished request of AnnounceCachePeerRequest.
func (*DownloadCachePeerFinishedRequest) Descriptor
deprecated
added in
v2.0.121
func (*DownloadCachePeerFinishedRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadCachePeerFinishedRequest.ProtoReflect.Descriptor instead.
func (*DownloadCachePeerFinishedRequest) GetPieceCount ¶ added in v2.0.121
func (x *DownloadCachePeerFinishedRequest) GetPieceCount() uint32
func (*DownloadCachePeerFinishedRequest) ProtoMessage ¶ added in v2.0.121
func (*DownloadCachePeerFinishedRequest) ProtoMessage()
func (*DownloadCachePeerFinishedRequest) ProtoReflect ¶ added in v2.0.121
func (x *DownloadCachePeerFinishedRequest) ProtoReflect() protoreflect.Message
func (*DownloadCachePeerFinishedRequest) Reset ¶ added in v2.0.121
func (x *DownloadCachePeerFinishedRequest) Reset()
func (*DownloadCachePeerFinishedRequest) String ¶ added in v2.0.121
func (x *DownloadCachePeerFinishedRequest) String() string
func (*DownloadCachePeerFinishedRequest) Validate ¶ added in v2.0.121
func (m *DownloadCachePeerFinishedRequest) Validate() error
Validate checks the field values on DownloadCachePeerFinishedRequest 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 (*DownloadCachePeerFinishedRequest) ValidateAll ¶ added in v2.0.121
func (m *DownloadCachePeerFinishedRequest) ValidateAll() error
ValidateAll checks the field values on DownloadCachePeerFinishedRequest 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 DownloadCachePeerFinishedRequestMultiError, or nil if none found.
type DownloadCachePeerFinishedRequestMultiError ¶ added in v2.0.121
type DownloadCachePeerFinishedRequestMultiError []error
DownloadCachePeerFinishedRequestMultiError is an error wrapping multiple validation errors returned by DownloadCachePeerFinishedRequest.ValidateAll() if the designated constraints aren't met.
func (DownloadCachePeerFinishedRequestMultiError) AllErrors ¶ added in v2.0.121
func (m DownloadCachePeerFinishedRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadCachePeerFinishedRequestMultiError) Error ¶ added in v2.0.121
func (m DownloadCachePeerFinishedRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadCachePeerFinishedRequestValidationError ¶ added in v2.0.121
type DownloadCachePeerFinishedRequestValidationError struct {
// contains filtered or unexported fields
}
DownloadCachePeerFinishedRequestValidationError is the validation error returned by DownloadCachePeerFinishedRequest.Validate if the designated constraints aren't met.
func (DownloadCachePeerFinishedRequestValidationError) Cause ¶ added in v2.0.121
func (e DownloadCachePeerFinishedRequestValidationError) Cause() error
Cause function returns cause value.
func (DownloadCachePeerFinishedRequestValidationError) Error ¶ added in v2.0.121
func (e DownloadCachePeerFinishedRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadCachePeerFinishedRequestValidationError) ErrorName ¶ added in v2.0.121
func (e DownloadCachePeerFinishedRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadCachePeerFinishedRequestValidationError) Field ¶ added in v2.0.121
func (e DownloadCachePeerFinishedRequestValidationError) Field() string
Field function returns field value.
func (DownloadCachePeerFinishedRequestValidationError) Key ¶ added in v2.0.121
func (e DownloadCachePeerFinishedRequestValidationError) Key() bool
Key function returns key value.
func (DownloadCachePeerFinishedRequestValidationError) Reason ¶ added in v2.0.121
func (e DownloadCachePeerFinishedRequestValidationError) Reason() string
Reason function returns reason value.
type DownloadCachePeerStartedRequest ¶ added in v2.0.121
type DownloadCachePeerStartedRequest struct {
// contains filtered or unexported fields
}
DownloadCachePeerStartedRequest represents cache peer download started request of AnnounceCachePeerRequest.
func (*DownloadCachePeerStartedRequest) Descriptor
deprecated
added in
v2.0.121
func (*DownloadCachePeerStartedRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadCachePeerStartedRequest.ProtoReflect.Descriptor instead.
func (*DownloadCachePeerStartedRequest) ProtoMessage ¶ added in v2.0.121
func (*DownloadCachePeerStartedRequest) ProtoMessage()
func (*DownloadCachePeerStartedRequest) ProtoReflect ¶ added in v2.0.121
func (x *DownloadCachePeerStartedRequest) ProtoReflect() protoreflect.Message
func (*DownloadCachePeerStartedRequest) Reset ¶ added in v2.0.121
func (x *DownloadCachePeerStartedRequest) Reset()
func (*DownloadCachePeerStartedRequest) String ¶ added in v2.0.121
func (x *DownloadCachePeerStartedRequest) String() string
func (*DownloadCachePeerStartedRequest) Validate ¶ added in v2.0.121
func (m *DownloadCachePeerStartedRequest) Validate() error
Validate checks the field values on DownloadCachePeerStartedRequest 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 (*DownloadCachePeerStartedRequest) ValidateAll ¶ added in v2.0.121
func (m *DownloadCachePeerStartedRequest) ValidateAll() error
ValidateAll checks the field values on DownloadCachePeerStartedRequest 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 DownloadCachePeerStartedRequestMultiError, or nil if none found.
type DownloadCachePeerStartedRequestMultiError ¶ added in v2.0.121
type DownloadCachePeerStartedRequestMultiError []error
DownloadCachePeerStartedRequestMultiError is an error wrapping multiple validation errors returned by DownloadCachePeerStartedRequest.ValidateAll() if the designated constraints aren't met.
func (DownloadCachePeerStartedRequestMultiError) AllErrors ¶ added in v2.0.121
func (m DownloadCachePeerStartedRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadCachePeerStartedRequestMultiError) Error ¶ added in v2.0.121
func (m DownloadCachePeerStartedRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadCachePeerStartedRequestValidationError ¶ added in v2.0.121
type DownloadCachePeerStartedRequestValidationError struct {
// contains filtered or unexported fields
}
DownloadCachePeerStartedRequestValidationError is the validation error returned by DownloadCachePeerStartedRequest.Validate if the designated constraints aren't met.
func (DownloadCachePeerStartedRequestValidationError) Cause ¶ added in v2.0.121
func (e DownloadCachePeerStartedRequestValidationError) Cause() error
Cause function returns cause value.
func (DownloadCachePeerStartedRequestValidationError) Error ¶ added in v2.0.121
func (e DownloadCachePeerStartedRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadCachePeerStartedRequestValidationError) ErrorName ¶ added in v2.0.121
func (e DownloadCachePeerStartedRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadCachePeerStartedRequestValidationError) Field ¶ added in v2.0.121
func (e DownloadCachePeerStartedRequestValidationError) Field() string
Field function returns field value.
func (DownloadCachePeerStartedRequestValidationError) Key ¶ added in v2.0.121
func (e DownloadCachePeerStartedRequestValidationError) Key() bool
Key function returns key value.
func (DownloadCachePeerStartedRequestValidationError) Reason ¶ added in v2.0.121
func (e DownloadCachePeerStartedRequestValidationError) Reason() string
Reason function returns reason value.
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 EmptyCacheTaskResponse ¶ added in v2.0.121
type EmptyCacheTaskResponse struct {
// contains filtered or unexported fields
}
EmptyCacheTaskResponse represents empty cache task response of AnnounceCachePeerResponse.
func (*EmptyCacheTaskResponse) Descriptor
deprecated
added in
v2.0.121
func (*EmptyCacheTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use EmptyCacheTaskResponse.ProtoReflect.Descriptor instead.
func (*EmptyCacheTaskResponse) ProtoMessage ¶ added in v2.0.121
func (*EmptyCacheTaskResponse) ProtoMessage()
func (*EmptyCacheTaskResponse) ProtoReflect ¶ added in v2.0.121
func (x *EmptyCacheTaskResponse) ProtoReflect() protoreflect.Message
func (*EmptyCacheTaskResponse) Reset ¶ added in v2.0.121
func (x *EmptyCacheTaskResponse) Reset()
func (*EmptyCacheTaskResponse) String ¶ added in v2.0.121
func (x *EmptyCacheTaskResponse) String() string
func (*EmptyCacheTaskResponse) Validate ¶ added in v2.0.121
func (m *EmptyCacheTaskResponse) Validate() error
Validate checks the field values on EmptyCacheTaskResponse 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 (*EmptyCacheTaskResponse) ValidateAll ¶ added in v2.0.121
func (m *EmptyCacheTaskResponse) ValidateAll() error
ValidateAll checks the field values on EmptyCacheTaskResponse 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 EmptyCacheTaskResponseMultiError, or nil if none found.
type EmptyCacheTaskResponseMultiError ¶ added in v2.0.121
type EmptyCacheTaskResponseMultiError []error
EmptyCacheTaskResponseMultiError is an error wrapping multiple validation errors returned by EmptyCacheTaskResponse.ValidateAll() if the designated constraints aren't met.
func (EmptyCacheTaskResponseMultiError) AllErrors ¶ added in v2.0.121
func (m EmptyCacheTaskResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (EmptyCacheTaskResponseMultiError) Error ¶ added in v2.0.121
func (m EmptyCacheTaskResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type EmptyCacheTaskResponseValidationError ¶ added in v2.0.121
type EmptyCacheTaskResponseValidationError struct {
// contains filtered or unexported fields
}
EmptyCacheTaskResponseValidationError is the validation error returned by EmptyCacheTaskResponse.Validate if the designated constraints aren't met.
func (EmptyCacheTaskResponseValidationError) Cause ¶ added in v2.0.121
func (e EmptyCacheTaskResponseValidationError) Cause() error
Cause function returns cause value.
func (EmptyCacheTaskResponseValidationError) Error ¶ added in v2.0.121
func (e EmptyCacheTaskResponseValidationError) Error() string
Error satisfies the builtin error interface
func (EmptyCacheTaskResponseValidationError) ErrorName ¶ added in v2.0.121
func (e EmptyCacheTaskResponseValidationError) ErrorName() string
ErrorName returns error name.
func (EmptyCacheTaskResponseValidationError) Field ¶ added in v2.0.121
func (e EmptyCacheTaskResponseValidationError) Field() string
Field function returns field value.
func (EmptyCacheTaskResponseValidationError) Key ¶ added in v2.0.121
func (e EmptyCacheTaskResponseValidationError) Key() bool
Key function returns key value.
func (EmptyCacheTaskResponseValidationError) Reason ¶ added in v2.0.121
func (e EmptyCacheTaskResponseValidationError) 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 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 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 NormalCacheTaskResponse ¶ added in v2.0.121
type NormalCacheTaskResponse struct { // Candidate parents. CandidateParents []*v2.CachePeer `protobuf:"bytes,1,rep,name=candidate_parents,json=candidateParents,proto3" json:"candidate_parents,omitempty"` // contains filtered or unexported fields }
NormalCacheTaskResponse represents normal cache task response of AnnounceCachePeerResponse.
func (*NormalCacheTaskResponse) Descriptor
deprecated
added in
v2.0.121
func (*NormalCacheTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use NormalCacheTaskResponse.ProtoReflect.Descriptor instead.
func (*NormalCacheTaskResponse) GetCandidateParents ¶ added in v2.0.121
func (x *NormalCacheTaskResponse) GetCandidateParents() []*v2.CachePeer
func (*NormalCacheTaskResponse) ProtoMessage ¶ added in v2.0.121
func (*NormalCacheTaskResponse) ProtoMessage()
func (*NormalCacheTaskResponse) ProtoReflect ¶ added in v2.0.121
func (x *NormalCacheTaskResponse) ProtoReflect() protoreflect.Message
func (*NormalCacheTaskResponse) Reset ¶ added in v2.0.121
func (x *NormalCacheTaskResponse) Reset()
func (*NormalCacheTaskResponse) String ¶ added in v2.0.121
func (x *NormalCacheTaskResponse) String() string
func (*NormalCacheTaskResponse) Validate ¶ added in v2.0.121
func (m *NormalCacheTaskResponse) Validate() error
Validate checks the field values on NormalCacheTaskResponse 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 (*NormalCacheTaskResponse) ValidateAll ¶ added in v2.0.121
func (m *NormalCacheTaskResponse) ValidateAll() error
ValidateAll checks the field values on NormalCacheTaskResponse 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 NormalCacheTaskResponseMultiError, or nil if none found.
type NormalCacheTaskResponseMultiError ¶ added in v2.0.121
type NormalCacheTaskResponseMultiError []error
NormalCacheTaskResponseMultiError is an error wrapping multiple validation errors returned by NormalCacheTaskResponse.ValidateAll() if the designated constraints aren't met.
func (NormalCacheTaskResponseMultiError) AllErrors ¶ added in v2.0.121
func (m NormalCacheTaskResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (NormalCacheTaskResponseMultiError) Error ¶ added in v2.0.121
func (m NormalCacheTaskResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type NormalCacheTaskResponseValidationError ¶ added in v2.0.121
type NormalCacheTaskResponseValidationError struct {
// contains filtered or unexported fields
}
NormalCacheTaskResponseValidationError is the validation error returned by NormalCacheTaskResponse.Validate if the designated constraints aren't met.
func (NormalCacheTaskResponseValidationError) Cause ¶ added in v2.0.121
func (e NormalCacheTaskResponseValidationError) Cause() error
Cause function returns cause value.
func (NormalCacheTaskResponseValidationError) Error ¶ added in v2.0.121
func (e NormalCacheTaskResponseValidationError) Error() string
Error satisfies the builtin error interface
func (NormalCacheTaskResponseValidationError) ErrorName ¶ added in v2.0.121
func (e NormalCacheTaskResponseValidationError) ErrorName() string
ErrorName returns error name.
func (NormalCacheTaskResponseValidationError) Field ¶ added in v2.0.121
func (e NormalCacheTaskResponseValidationError) Field() string
Field function returns field value.
func (NormalCacheTaskResponseValidationError) Key ¶ added in v2.0.121
func (e NormalCacheTaskResponseValidationError) Key() bool
Key function returns key value.
func (NormalCacheTaskResponseValidationError) Reason ¶ added in v2.0.121
func (e NormalCacheTaskResponseValidationError) 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 RegisterCachePeerRequest ¶ added in v2.0.121
type RegisterCachePeerRequest 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"` // Tag is used to distinguish different cache tasks. Tag *string `protobuf:"bytes,3,opt,name=tag,proto3,oneof" json:"tag,omitempty"` // Application of task. Application *string `protobuf:"bytes,4,opt,name=application,proto3,oneof" json:"application,omitempty"` // Task piece length. PieceLength uint64 `protobuf:"varint,5,opt,name=piece_length,json=pieceLength,proto3" json:"piece_length,omitempty"` // File path to be exported. OutputPath string `protobuf:"bytes,6,opt,name=output_path,json=outputPath,proto3" json:"output_path,omitempty"` // Download timeout. Timeout *durationpb.Duration `protobuf:"bytes,7,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"` // contains filtered or unexported fields }
RegisterCachePeerRequest represents cache peer registered request of AnnounceCachePeerRequest.
func (*RegisterCachePeerRequest) Descriptor
deprecated
added in
v2.0.121
func (*RegisterCachePeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterCachePeerRequest.ProtoReflect.Descriptor instead.
func (*RegisterCachePeerRequest) GetApplication ¶ added in v2.0.121
func (x *RegisterCachePeerRequest) GetApplication() string
func (*RegisterCachePeerRequest) GetHostId ¶ added in v2.0.121
func (x *RegisterCachePeerRequest) GetHostId() string
func (*RegisterCachePeerRequest) GetOutputPath ¶ added in v2.0.121
func (x *RegisterCachePeerRequest) GetOutputPath() string
func (*RegisterCachePeerRequest) GetPieceLength ¶ added in v2.0.121
func (x *RegisterCachePeerRequest) GetPieceLength() uint64
func (*RegisterCachePeerRequest) GetTag ¶ added in v2.0.121
func (x *RegisterCachePeerRequest) GetTag() string
func (*RegisterCachePeerRequest) GetTaskId ¶ added in v2.0.121
func (x *RegisterCachePeerRequest) GetTaskId() string
func (*RegisterCachePeerRequest) GetTimeout ¶ added in v2.0.121
func (x *RegisterCachePeerRequest) GetTimeout() *durationpb.Duration
func (*RegisterCachePeerRequest) ProtoMessage ¶ added in v2.0.121
func (*RegisterCachePeerRequest) ProtoMessage()
func (*RegisterCachePeerRequest) ProtoReflect ¶ added in v2.0.121
func (x *RegisterCachePeerRequest) ProtoReflect() protoreflect.Message
func (*RegisterCachePeerRequest) Reset ¶ added in v2.0.121
func (x *RegisterCachePeerRequest) Reset()
func (*RegisterCachePeerRequest) String ¶ added in v2.0.121
func (x *RegisterCachePeerRequest) String() string
func (*RegisterCachePeerRequest) Validate ¶ added in v2.0.121
func (m *RegisterCachePeerRequest) Validate() error
Validate checks the field values on RegisterCachePeerRequest 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 (*RegisterCachePeerRequest) ValidateAll ¶ added in v2.0.121
func (m *RegisterCachePeerRequest) ValidateAll() error
ValidateAll checks the field values on RegisterCachePeerRequest 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 RegisterCachePeerRequestMultiError, or nil if none found.
type RegisterCachePeerRequestMultiError ¶ added in v2.0.121
type RegisterCachePeerRequestMultiError []error
RegisterCachePeerRequestMultiError is an error wrapping multiple validation errors returned by RegisterCachePeerRequest.ValidateAll() if the designated constraints aren't met.
func (RegisterCachePeerRequestMultiError) AllErrors ¶ added in v2.0.121
func (m RegisterCachePeerRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RegisterCachePeerRequestMultiError) Error ¶ added in v2.0.121
func (m RegisterCachePeerRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RegisterCachePeerRequestValidationError ¶ added in v2.0.121
type RegisterCachePeerRequestValidationError struct {
// contains filtered or unexported fields
}
RegisterCachePeerRequestValidationError is the validation error returned by RegisterCachePeerRequest.Validate if the designated constraints aren't met.
func (RegisterCachePeerRequestValidationError) Cause ¶ added in v2.0.121
func (e RegisterCachePeerRequestValidationError) Cause() error
Cause function returns cause value.
func (RegisterCachePeerRequestValidationError) Error ¶ added in v2.0.121
func (e RegisterCachePeerRequestValidationError) Error() string
Error satisfies the builtin error interface
func (RegisterCachePeerRequestValidationError) ErrorName ¶ added in v2.0.121
func (e RegisterCachePeerRequestValidationError) ErrorName() string
ErrorName returns error name.
func (RegisterCachePeerRequestValidationError) Field ¶ added in v2.0.121
func (e RegisterCachePeerRequestValidationError) Field() string
Field function returns field value.
func (RegisterCachePeerRequestValidationError) Key ¶ added in v2.0.121
func (e RegisterCachePeerRequestValidationError) Key() bool
Key function returns key value.
func (RegisterCachePeerRequestValidationError) Reason ¶ added in v2.0.121
func (e RegisterCachePeerRequestValidationError) Reason() string
Reason function returns reason value.
type RegisterPeerRequest ¶
type RegisterPeerRequest struct { // Download information. Download *v2.Download `protobuf:"bytes,1,opt,name=download,proto3" json:"download,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) GetDownload ¶
func (x *RegisterPeerRequest) GetDownload() *v2.Download
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 RescheduleCachePeerRequest ¶ added in v2.0.121
type RescheduleCachePeerRequest struct { // Candidate parent ids. CandidateParents []*v2.CachePeer `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 }
RescheduleCachePeerRequest represents reschedule request of AnnounceCachePeerRequest.
func (*RescheduleCachePeerRequest) Descriptor
deprecated
added in
v2.0.121
func (*RescheduleCachePeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use RescheduleCachePeerRequest.ProtoReflect.Descriptor instead.
func (*RescheduleCachePeerRequest) GetCandidateParents ¶ added in v2.0.121
func (x *RescheduleCachePeerRequest) GetCandidateParents() []*v2.CachePeer
func (*RescheduleCachePeerRequest) GetDescription ¶ added in v2.0.121
func (x *RescheduleCachePeerRequest) GetDescription() string
func (*RescheduleCachePeerRequest) ProtoMessage ¶ added in v2.0.121
func (*RescheduleCachePeerRequest) ProtoMessage()
func (*RescheduleCachePeerRequest) ProtoReflect ¶ added in v2.0.121
func (x *RescheduleCachePeerRequest) ProtoReflect() protoreflect.Message
func (*RescheduleCachePeerRequest) Reset ¶ added in v2.0.121
func (x *RescheduleCachePeerRequest) Reset()
func (*RescheduleCachePeerRequest) String ¶ added in v2.0.121
func (x *RescheduleCachePeerRequest) String() string
func (*RescheduleCachePeerRequest) Validate ¶ added in v2.0.121
func (m *RescheduleCachePeerRequest) Validate() error
Validate checks the field values on RescheduleCachePeerRequest 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 (*RescheduleCachePeerRequest) ValidateAll ¶ added in v2.0.121
func (m *RescheduleCachePeerRequest) ValidateAll() error
ValidateAll checks the field values on RescheduleCachePeerRequest 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 RescheduleCachePeerRequestMultiError, or nil if none found.
type RescheduleCachePeerRequestMultiError ¶ added in v2.0.121
type RescheduleCachePeerRequestMultiError []error
RescheduleCachePeerRequestMultiError is an error wrapping multiple validation errors returned by RescheduleCachePeerRequest.ValidateAll() if the designated constraints aren't met.
func (RescheduleCachePeerRequestMultiError) AllErrors ¶ added in v2.0.121
func (m RescheduleCachePeerRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RescheduleCachePeerRequestMultiError) Error ¶ added in v2.0.121
func (m RescheduleCachePeerRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RescheduleCachePeerRequestValidationError ¶ added in v2.0.121
type RescheduleCachePeerRequestValidationError struct {
// contains filtered or unexported fields
}
RescheduleCachePeerRequestValidationError is the validation error returned by RescheduleCachePeerRequest.Validate if the designated constraints aren't met.
func (RescheduleCachePeerRequestValidationError) Cause ¶ added in v2.0.121
func (e RescheduleCachePeerRequestValidationError) Cause() error
Cause function returns cause value.
func (RescheduleCachePeerRequestValidationError) Error ¶ added in v2.0.121
func (e RescheduleCachePeerRequestValidationError) Error() string
Error satisfies the builtin error interface
func (RescheduleCachePeerRequestValidationError) ErrorName ¶ added in v2.0.121
func (e RescheduleCachePeerRequestValidationError) ErrorName() string
ErrorName returns error name.
func (RescheduleCachePeerRequestValidationError) Field ¶ added in v2.0.121
func (e RescheduleCachePeerRequestValidationError) Field() string
Field function returns field value.
func (RescheduleCachePeerRequestValidationError) Key ¶ added in v2.0.121
func (e RescheduleCachePeerRequestValidationError) Key() bool
Key function returns key value.
func (RescheduleCachePeerRequestValidationError) Reason ¶ added in v2.0.121
func (e RescheduleCachePeerRequestValidationError) Reason() string
Reason function returns reason value.
type ReschedulePeerRequest ¶ added in v2.0.121
type ReschedulePeerRequest 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 }
ReschedulePeerRequest represents reschedule request of AnnouncePeerRequest.
func (*ReschedulePeerRequest) Descriptor
deprecated
added in
v2.0.121
func (*ReschedulePeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReschedulePeerRequest.ProtoReflect.Descriptor instead.
func (*ReschedulePeerRequest) GetCandidateParents ¶ added in v2.0.121
func (x *ReschedulePeerRequest) GetCandidateParents() []*v2.Peer
func (*ReschedulePeerRequest) GetDescription ¶ added in v2.0.121
func (x *ReschedulePeerRequest) GetDescription() string
func (*ReschedulePeerRequest) ProtoMessage ¶ added in v2.0.121
func (*ReschedulePeerRequest) ProtoMessage()
func (*ReschedulePeerRequest) ProtoReflect ¶ added in v2.0.121
func (x *ReschedulePeerRequest) ProtoReflect() protoreflect.Message
func (*ReschedulePeerRequest) Reset ¶ added in v2.0.121
func (x *ReschedulePeerRequest) Reset()
func (*ReschedulePeerRequest) String ¶ added in v2.0.121
func (x *ReschedulePeerRequest) String() string
func (*ReschedulePeerRequest) Validate ¶ added in v2.0.121
func (m *ReschedulePeerRequest) Validate() error
Validate checks the field values on ReschedulePeerRequest 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 (*ReschedulePeerRequest) ValidateAll ¶ added in v2.0.121
func (m *ReschedulePeerRequest) ValidateAll() error
ValidateAll checks the field values on ReschedulePeerRequest 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 ReschedulePeerRequestMultiError, or nil if none found.
type ReschedulePeerRequestMultiError ¶ added in v2.0.121
type ReschedulePeerRequestMultiError []error
ReschedulePeerRequestMultiError is an error wrapping multiple validation errors returned by ReschedulePeerRequest.ValidateAll() if the designated constraints aren't met.
func (ReschedulePeerRequestMultiError) AllErrors ¶ added in v2.0.121
func (m ReschedulePeerRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ReschedulePeerRequestMultiError) Error ¶ added in v2.0.121
func (m ReschedulePeerRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ReschedulePeerRequestValidationError ¶ added in v2.0.121
type ReschedulePeerRequestValidationError struct {
// contains filtered or unexported fields
}
ReschedulePeerRequestValidationError is the validation error returned by ReschedulePeerRequest.Validate if the designated constraints aren't met.
func (ReschedulePeerRequestValidationError) Cause ¶ added in v2.0.121
func (e ReschedulePeerRequestValidationError) Cause() error
Cause function returns cause value.
func (ReschedulePeerRequestValidationError) Error ¶ added in v2.0.121
func (e ReschedulePeerRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ReschedulePeerRequestValidationError) ErrorName ¶ added in v2.0.121
func (e ReschedulePeerRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ReschedulePeerRequestValidationError) Field ¶ added in v2.0.121
func (e ReschedulePeerRequestValidationError) Field() string
Field function returns field value.
func (ReschedulePeerRequestValidationError) Key ¶ added in v2.0.121
func (e ReschedulePeerRequestValidationError) Key() bool
Key function returns key value.
func (ReschedulePeerRequestValidationError) Reason ¶ added in v2.0.121
func (e ReschedulePeerRequestValidationError) 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) // DeletePeer releases peer in scheduler. DeletePeer(ctx context.Context, in *DeletePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Checks information of task. StatTask(ctx context.Context, in *StatTaskRequest, opts ...grpc.CallOption) (*v2.Task, error) // DeleteTask releases task in scheduler. DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // AnnounceHost announces host to scheduler. AnnounceHost(ctx context.Context, in *AnnounceHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // DeleteHost releases host in scheduler. DeleteHost(ctx context.Context, in *DeleteHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // SyncProbes sync probes of the host. SyncProbes(ctx context.Context, opts ...grpc.CallOption) (Scheduler_SyncProbesClient, error) // AnnounceCachePeer announces cache peer to scheduler. AnnounceCachePeer(ctx context.Context, opts ...grpc.CallOption) (Scheduler_AnnounceCachePeerClient, error) // Checks information of cache peer. StatCachePeer(ctx context.Context, in *StatCachePeerRequest, opts ...grpc.CallOption) (*v2.CachePeer, error) // DeleteCachePeer releases cache peer in scheduler. DeleteCachePeer(ctx context.Context, in *DeleteCachePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // UploadCacheTask uploads cache task to scheduler. UploadCacheTask(ctx context.Context, in *UploadCacheTaskRequest, opts ...grpc.CallOption) (*v2.CacheTask, error) // Checks information of cache task. StatCacheTask(ctx context.Context, in *StatCacheTaskRequest, opts ...grpc.CallOption) (*v2.CacheTask, error) // DeleteCacheTask releases cache task in scheduler. DeleteCacheTask(ctx context.Context, in *DeleteCacheTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) }
SchedulerClient is the client API for Scheduler service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://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) // DeletePeer releases peer in scheduler. DeletePeer(context.Context, *DeletePeerRequest) (*emptypb.Empty, error) // Checks information of task. StatTask(context.Context, *StatTaskRequest) (*v2.Task, error) // DeleteTask releases task in scheduler. DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error) // AnnounceHost announces host to scheduler. AnnounceHost(context.Context, *AnnounceHostRequest) (*emptypb.Empty, error) // DeleteHost releases host in scheduler. DeleteHost(context.Context, *DeleteHostRequest) (*emptypb.Empty, error) // SyncProbes sync probes of the host. SyncProbes(Scheduler_SyncProbesServer) error // AnnounceCachePeer announces cache peer to scheduler. AnnounceCachePeer(Scheduler_AnnounceCachePeerServer) error // Checks information of cache peer. StatCachePeer(context.Context, *StatCachePeerRequest) (*v2.CachePeer, error) // DeleteCachePeer releases cache peer in scheduler. DeleteCachePeer(context.Context, *DeleteCachePeerRequest) (*emptypb.Empty, error) // UploadCacheTask uploads cache task to scheduler. UploadCacheTask(context.Context, *UploadCacheTaskRequest) (*v2.CacheTask, error) // Checks information of cache task. StatCacheTask(context.Context, *StatCacheTaskRequest) (*v2.CacheTask, error) // DeleteCacheTask releases cache task in scheduler. DeleteCacheTask(context.Context, *DeleteCacheTaskRequest) (*emptypb.Empty, error) }
SchedulerServer is the server API for Scheduler service. All implementations should embed UnimplementedSchedulerServer for forward compatibility
type Scheduler_AnnounceCachePeerClient ¶ added in v2.0.121
type Scheduler_AnnounceCachePeerClient interface { Send(*AnnounceCachePeerRequest) error Recv() (*AnnounceCachePeerResponse, error) grpc.ClientStream }
type Scheduler_AnnounceCachePeerServer ¶ added in v2.0.121
type Scheduler_AnnounceCachePeerServer interface { Send(*AnnounceCachePeerResponse) error Recv() (*AnnounceCachePeerRequest, error) grpc.ServerStream }
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 StatCachePeerRequest ¶ added in v2.0.121
type StatCachePeerRequest 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 }
StatCachePeerRequest represents request of StatCachePeer.
func (*StatCachePeerRequest) Descriptor
deprecated
added in
v2.0.121
func (*StatCachePeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatCachePeerRequest.ProtoReflect.Descriptor instead.
func (*StatCachePeerRequest) GetHostId ¶ added in v2.0.121
func (x *StatCachePeerRequest) GetHostId() string
func (*StatCachePeerRequest) GetPeerId ¶ added in v2.0.121
func (x *StatCachePeerRequest) GetPeerId() string
func (*StatCachePeerRequest) GetTaskId ¶ added in v2.0.121
func (x *StatCachePeerRequest) GetTaskId() string
func (*StatCachePeerRequest) ProtoMessage ¶ added in v2.0.121
func (*StatCachePeerRequest) ProtoMessage()
func (*StatCachePeerRequest) ProtoReflect ¶ added in v2.0.121
func (x *StatCachePeerRequest) ProtoReflect() protoreflect.Message
func (*StatCachePeerRequest) Reset ¶ added in v2.0.121
func (x *StatCachePeerRequest) Reset()
func (*StatCachePeerRequest) String ¶ added in v2.0.121
func (x *StatCachePeerRequest) String() string
func (*StatCachePeerRequest) Validate ¶ added in v2.0.121
func (m *StatCachePeerRequest) Validate() error
Validate checks the field values on StatCachePeerRequest 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 (*StatCachePeerRequest) ValidateAll ¶ added in v2.0.121
func (m *StatCachePeerRequest) ValidateAll() error
ValidateAll checks the field values on StatCachePeerRequest 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 StatCachePeerRequestMultiError, or nil if none found.
type StatCachePeerRequestMultiError ¶ added in v2.0.121
type StatCachePeerRequestMultiError []error
StatCachePeerRequestMultiError is an error wrapping multiple validation errors returned by StatCachePeerRequest.ValidateAll() if the designated constraints aren't met.
func (StatCachePeerRequestMultiError) AllErrors ¶ added in v2.0.121
func (m StatCachePeerRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StatCachePeerRequestMultiError) Error ¶ added in v2.0.121
func (m StatCachePeerRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StatCachePeerRequestValidationError ¶ added in v2.0.121
type StatCachePeerRequestValidationError struct {
// contains filtered or unexported fields
}
StatCachePeerRequestValidationError is the validation error returned by StatCachePeerRequest.Validate if the designated constraints aren't met.
func (StatCachePeerRequestValidationError) Cause ¶ added in v2.0.121
func (e StatCachePeerRequestValidationError) Cause() error
Cause function returns cause value.
func (StatCachePeerRequestValidationError) Error ¶ added in v2.0.121
func (e StatCachePeerRequestValidationError) Error() string
Error satisfies the builtin error interface
func (StatCachePeerRequestValidationError) ErrorName ¶ added in v2.0.121
func (e StatCachePeerRequestValidationError) ErrorName() string
ErrorName returns error name.
func (StatCachePeerRequestValidationError) Field ¶ added in v2.0.121
func (e StatCachePeerRequestValidationError) Field() string
Field function returns field value.
func (StatCachePeerRequestValidationError) Key ¶ added in v2.0.121
func (e StatCachePeerRequestValidationError) Key() bool
Key function returns key value.
func (StatCachePeerRequestValidationError) Reason ¶ added in v2.0.121
func (e StatCachePeerRequestValidationError) Reason() string
Reason function returns reason value.
type StatCacheTaskRequest ¶ added in v2.0.121
type StatCacheTaskRequest struct { // Task id. TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // contains filtered or unexported fields }
StatCacheTaskRequest represents request of StatCacheTask.
func (*StatCacheTaskRequest) Descriptor
deprecated
added in
v2.0.121
func (*StatCacheTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatCacheTaskRequest.ProtoReflect.Descriptor instead.
func (*StatCacheTaskRequest) GetTaskId ¶ added in v2.0.121
func (x *StatCacheTaskRequest) GetTaskId() string
func (*StatCacheTaskRequest) ProtoMessage ¶ added in v2.0.121
func (*StatCacheTaskRequest) ProtoMessage()
func (*StatCacheTaskRequest) ProtoReflect ¶ added in v2.0.121
func (x *StatCacheTaskRequest) ProtoReflect() protoreflect.Message
func (*StatCacheTaskRequest) Reset ¶ added in v2.0.121
func (x *StatCacheTaskRequest) Reset()
func (*StatCacheTaskRequest) String ¶ added in v2.0.121
func (x *StatCacheTaskRequest) String() string
func (*StatCacheTaskRequest) Validate ¶ added in v2.0.121
func (m *StatCacheTaskRequest) Validate() error
Validate checks the field values on StatCacheTaskRequest 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 (*StatCacheTaskRequest) ValidateAll ¶ added in v2.0.121
func (m *StatCacheTaskRequest) ValidateAll() error
ValidateAll checks the field values on StatCacheTaskRequest 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 StatCacheTaskRequestMultiError, or nil if none found.
type StatCacheTaskRequestMultiError ¶ added in v2.0.121
type StatCacheTaskRequestMultiError []error
StatCacheTaskRequestMultiError is an error wrapping multiple validation errors returned by StatCacheTaskRequest.ValidateAll() if the designated constraints aren't met.
func (StatCacheTaskRequestMultiError) AllErrors ¶ added in v2.0.121
func (m StatCacheTaskRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StatCacheTaskRequestMultiError) Error ¶ added in v2.0.121
func (m StatCacheTaskRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StatCacheTaskRequestValidationError ¶ added in v2.0.121
type StatCacheTaskRequestValidationError struct {
// contains filtered or unexported fields
}
StatCacheTaskRequestValidationError is the validation error returned by StatCacheTaskRequest.Validate if the designated constraints aren't met.
func (StatCacheTaskRequestValidationError) Cause ¶ added in v2.0.121
func (e StatCacheTaskRequestValidationError) Cause() error
Cause function returns cause value.
func (StatCacheTaskRequestValidationError) Error ¶ added in v2.0.121
func (e StatCacheTaskRequestValidationError) Error() string
Error satisfies the builtin error interface
func (StatCacheTaskRequestValidationError) ErrorName ¶ added in v2.0.121
func (e StatCacheTaskRequestValidationError) ErrorName() string
ErrorName returns error name.
func (StatCacheTaskRequestValidationError) Field ¶ added in v2.0.121
func (e StatCacheTaskRequestValidationError) Field() string
Field function returns field value.
func (StatCacheTaskRequestValidationError) Key ¶ added in v2.0.121
func (e StatCacheTaskRequestValidationError) Key() bool
Key function returns key value.
func (StatCacheTaskRequestValidationError) Reason ¶ added in v2.0.121
func (e StatCacheTaskRequestValidationError) Reason() string
Reason function returns reason value.
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. TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // contains filtered or unexported fields }
StatTaskRequest represents request of StatTask.
func (*StatTaskRequest) Descriptor
deprecated
func (*StatTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatTaskRequest.ProtoReflect.Descriptor instead.
func (*StatTaskRequest) GetTaskId ¶ added in v2.0.121
func (x *StatTaskRequest) GetTaskId() string
func (*StatTaskRequest) ProtoMessage ¶
func (*StatTaskRequest) ProtoMessage()
func (*StatTaskRequest) ProtoReflect ¶
func (x *StatTaskRequest) ProtoReflect() protoreflect.Message
func (*StatTaskRequest) Reset ¶
func (x *StatTaskRequest) Reset()
func (*StatTaskRequest) String ¶
func (x *StatTaskRequest) String() string
func (*StatTaskRequest) Validate ¶
func (m *StatTaskRequest) Validate() error
Validate checks the field values on StatTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*StatTaskRequest) ValidateAll ¶
func (m *StatTaskRequest) ValidateAll() error
ValidateAll checks the field values on StatTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StatTaskRequestMultiError, or nil if none found.
type StatTaskRequestMultiError ¶
type StatTaskRequestMultiError []error
StatTaskRequestMultiError is an error wrapping multiple validation errors returned by StatTaskRequest.ValidateAll() if the designated constraints aren't met.
func (StatTaskRequestMultiError) AllErrors ¶
func (m StatTaskRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StatTaskRequestMultiError) Error ¶
func (m StatTaskRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StatTaskRequestValidationError ¶
type StatTaskRequestValidationError struct {
// contains filtered or unexported fields
}
StatTaskRequestValidationError is the validation error returned by StatTaskRequest.Validate if the designated constraints aren't met.
func (StatTaskRequestValidationError) Cause ¶
func (e StatTaskRequestValidationError) Cause() error
Cause function returns cause value.
func (StatTaskRequestValidationError) Error ¶
func (e StatTaskRequestValidationError) Error() string
Error satisfies the builtin error interface
func (StatTaskRequestValidationError) ErrorName ¶
func (e StatTaskRequestValidationError) ErrorName() string
ErrorName returns error name.
func (StatTaskRequestValidationError) Field ¶
func (e StatTaskRequestValidationError) Field() string
Field function returns field value.
func (StatTaskRequestValidationError) Key ¶
func (e StatTaskRequestValidationError) Key() bool
Key function returns key value.
func (StatTaskRequestValidationError) Reason ¶
func (e StatTaskRequestValidationError) Reason() string
Reason function returns reason value.
type 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) AnnounceCachePeer ¶ added in v2.0.121
func (UnimplementedSchedulerServer) AnnounceCachePeer(Scheduler_AnnounceCachePeerServer) error
func (UnimplementedSchedulerServer) AnnounceHost ¶
func (UnimplementedSchedulerServer) AnnounceHost(context.Context, *AnnounceHostRequest) (*emptypb.Empty, error)
func (UnimplementedSchedulerServer) AnnouncePeer ¶
func (UnimplementedSchedulerServer) AnnouncePeer(Scheduler_AnnouncePeerServer) error
func (UnimplementedSchedulerServer) DeleteCachePeer ¶ added in v2.0.121
func (UnimplementedSchedulerServer) DeleteCachePeer(context.Context, *DeleteCachePeerRequest) (*emptypb.Empty, error)
func (UnimplementedSchedulerServer) DeleteCacheTask ¶ added in v2.0.121
func (UnimplementedSchedulerServer) DeleteCacheTask(context.Context, *DeleteCacheTaskRequest) (*emptypb.Empty, error)
func (UnimplementedSchedulerServer) DeleteHost ¶ added in v2.0.118
func (UnimplementedSchedulerServer) DeleteHost(context.Context, *DeleteHostRequest) (*emptypb.Empty, error)
func (UnimplementedSchedulerServer) DeletePeer ¶ added in v2.0.118
func (UnimplementedSchedulerServer) DeletePeer(context.Context, *DeletePeerRequest) (*emptypb.Empty, error)
func (UnimplementedSchedulerServer) DeleteTask ¶ added in v2.0.118
func (UnimplementedSchedulerServer) DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)
func (UnimplementedSchedulerServer) StatCachePeer ¶ added in v2.0.121
func (UnimplementedSchedulerServer) StatCachePeer(context.Context, *StatCachePeerRequest) (*v2.CachePeer, error)
func (UnimplementedSchedulerServer) StatCacheTask ¶ added in v2.0.121
func (UnimplementedSchedulerServer) StatCacheTask(context.Context, *StatCacheTaskRequest) (*v2.CacheTask, 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
func (UnimplementedSchedulerServer) UploadCacheTask ¶ added in v2.0.123
func (UnimplementedSchedulerServer) UploadCacheTask(context.Context, *UploadCacheTaskRequest) (*v2.CacheTask, 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.
type UploadCacheTaskRequest ¶ added in v2.0.123
type UploadCacheTaskRequest 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"` // Replica count of the persistent cache task. PersistentReplicaCount uint64 `` /* 130-byte string literal not displayed */ // Tag is used to distinguish different cache tasks. Tag *string `protobuf:"bytes,5,opt,name=tag,proto3,oneof" json:"tag,omitempty"` // Application of task. Application *string `protobuf:"bytes,6,opt,name=application,proto3,oneof" json:"application,omitempty"` // Task piece length. PieceLength uint64 `protobuf:"varint,7,opt,name=piece_length,json=pieceLength,proto3" json:"piece_length,omitempty"` // TTL of the cache task. Ttl *durationpb.Duration `protobuf:"bytes,8,opt,name=ttl,proto3" json:"ttl,omitempty"` // Upload timeout. Timeout *durationpb.Duration `protobuf:"bytes,9,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"` // contains filtered or unexported fields }
UploadCacheTaskRequest represents request of UploadCacheTask.
func (*UploadCacheTaskRequest) Descriptor
deprecated
added in
v2.0.123
func (*UploadCacheTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use UploadCacheTaskRequest.ProtoReflect.Descriptor instead.
func (*UploadCacheTaskRequest) GetApplication ¶ added in v2.0.123
func (x *UploadCacheTaskRequest) GetApplication() string
func (*UploadCacheTaskRequest) GetHostId ¶ added in v2.0.123
func (x *UploadCacheTaskRequest) GetHostId() string
func (*UploadCacheTaskRequest) GetPeerId ¶ added in v2.0.123
func (x *UploadCacheTaskRequest) GetPeerId() string
func (*UploadCacheTaskRequest) GetPersistentReplicaCount ¶ added in v2.0.123
func (x *UploadCacheTaskRequest) GetPersistentReplicaCount() uint64
func (*UploadCacheTaskRequest) GetPieceLength ¶ added in v2.0.123
func (x *UploadCacheTaskRequest) GetPieceLength() uint64
func (*UploadCacheTaskRequest) GetTag ¶ added in v2.0.123
func (x *UploadCacheTaskRequest) GetTag() string
func (*UploadCacheTaskRequest) GetTaskId ¶ added in v2.0.123
func (x *UploadCacheTaskRequest) GetTaskId() string
func (*UploadCacheTaskRequest) GetTimeout ¶ added in v2.0.123
func (x *UploadCacheTaskRequest) GetTimeout() *durationpb.Duration
func (*UploadCacheTaskRequest) GetTtl ¶ added in v2.0.123
func (x *UploadCacheTaskRequest) GetTtl() *durationpb.Duration
func (*UploadCacheTaskRequest) ProtoMessage ¶ added in v2.0.123
func (*UploadCacheTaskRequest) ProtoMessage()
func (*UploadCacheTaskRequest) ProtoReflect ¶ added in v2.0.123
func (x *UploadCacheTaskRequest) ProtoReflect() protoreflect.Message
func (*UploadCacheTaskRequest) Reset ¶ added in v2.0.123
func (x *UploadCacheTaskRequest) Reset()
func (*UploadCacheTaskRequest) String ¶ added in v2.0.123
func (x *UploadCacheTaskRequest) String() string
func (*UploadCacheTaskRequest) Validate ¶ added in v2.0.123
func (m *UploadCacheTaskRequest) Validate() error
Validate checks the field values on UploadCacheTaskRequest 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 (*UploadCacheTaskRequest) ValidateAll ¶ added in v2.0.123
func (m *UploadCacheTaskRequest) ValidateAll() error
ValidateAll checks the field values on UploadCacheTaskRequest 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 UploadCacheTaskRequestMultiError, or nil if none found.
type UploadCacheTaskRequestMultiError ¶ added in v2.0.123
type UploadCacheTaskRequestMultiError []error
UploadCacheTaskRequestMultiError is an error wrapping multiple validation errors returned by UploadCacheTaskRequest.ValidateAll() if the designated constraints aren't met.
func (UploadCacheTaskRequestMultiError) AllErrors ¶ added in v2.0.123
func (m UploadCacheTaskRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (UploadCacheTaskRequestMultiError) Error ¶ added in v2.0.123
func (m UploadCacheTaskRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type UploadCacheTaskRequestValidationError ¶ added in v2.0.123
type UploadCacheTaskRequestValidationError struct {
// contains filtered or unexported fields
}
UploadCacheTaskRequestValidationError is the validation error returned by UploadCacheTaskRequest.Validate if the designated constraints aren't met.
func (UploadCacheTaskRequestValidationError) Cause ¶ added in v2.0.123
func (e UploadCacheTaskRequestValidationError) Cause() error
Cause function returns cause value.
func (UploadCacheTaskRequestValidationError) Error ¶ added in v2.0.123
func (e UploadCacheTaskRequestValidationError) Error() string
Error satisfies the builtin error interface
func (UploadCacheTaskRequestValidationError) ErrorName ¶ added in v2.0.123
func (e UploadCacheTaskRequestValidationError) ErrorName() string
ErrorName returns error name.
func (UploadCacheTaskRequestValidationError) Field ¶ added in v2.0.123
func (e UploadCacheTaskRequestValidationError) Field() string
Field function returns field value.
func (UploadCacheTaskRequestValidationError) Key ¶ added in v2.0.123
func (e UploadCacheTaskRequestValidationError) Key() bool
Key function returns key value.
func (UploadCacheTaskRequestValidationError) Reason ¶ added in v2.0.123
func (e UploadCacheTaskRequestValidationError) Reason() string
Reason function returns reason value.