scheduler

package
v2.0.41 Latest Latest
Warning

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

 Go to latest Published: Nov 6, 2023 License: Apache-2.0 Imports: 25 Imported by: 15

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_apis_scheduler_v2_scheduler_proto protoreflect.FileDescriptor
View Source 
var Scheduler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "scheduler.v2.Scheduler",
	HandlerType: (*SchedulerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StatPeer",
			Handler:    _Scheduler_StatPeer_Handler,
		},
		{
			MethodName: "LeavePeer",
			Handler:    _Scheduler_LeavePeer_Handler,
		},
		{
			MethodName: "ExchangePeer",
			Handler:    _Scheduler_ExchangePeer_Handler,
		},
		{
			MethodName: "StatTask",
			Handler:    _Scheduler_StatTask_Handler,
		},
		{
			MethodName: "AnnounceHost",
			Handler:    _Scheduler_AnnounceHost_Handler,
		},
		{
			MethodName: "LeaveHost",
			Handler:    _Scheduler_LeaveHost_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "AnnouncePeer",
			Handler:       _Scheduler_AnnouncePeer_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SyncProbes",
			Handler:       _Scheduler_SyncProbes_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/apis/scheduler/v2/scheduler.proto",
}

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

Functions

func RegisterSchedulerServer 

func RegisterSchedulerServer(s grpc.ServiceRegistrar, srv SchedulerServer)

Types

type AnnounceHostRequest 

type AnnounceHostRequest struct {

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

AnnounceHostRequest represents request of AnnounceHost.

func (*AnnounceHostRequest) Descriptor deprecated 

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

Deprecated: Use AnnounceHostRequest.ProtoReflect.Descriptor instead.

func (*AnnounceHostRequest) GetHost 

func (x *AnnounceHostRequest) GetHost() *v2.Host

func (*AnnounceHostRequest) ProtoMessage 

func (*AnnounceHostRequest) ProtoMessage()

func (*AnnounceHostRequest) ProtoReflect 

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

func (*AnnounceHostRequest) Reset 

func (x *AnnounceHostRequest) Reset()

func (*AnnounceHostRequest) String 

func (x *AnnounceHostRequest) String() string

func (*AnnounceHostRequest) Validate 

func (m *AnnounceHostRequest) Validate() error

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

func (*AnnounceHostRequest) ValidateAll 

func (m *AnnounceHostRequest) ValidateAll() error

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

type AnnounceHostRequestMultiError 

type AnnounceHostRequestMultiError []error

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

func (AnnounceHostRequestMultiError) AllErrors 

func (m AnnounceHostRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnounceHostRequestMultiError) Error 

func (m AnnounceHostRequestMultiError) Error() string

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

type AnnounceHostRequestValidationError 

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

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

func (AnnounceHostRequestValidationError) Cause 

func (e AnnounceHostRequestValidationError) Cause() error

Cause function returns cause value.

func (AnnounceHostRequestValidationError) Error 

func (e AnnounceHostRequestValidationError) Error() string

Error satisfies the builtin error interface

func (AnnounceHostRequestValidationError) ErrorName 

func (e AnnounceHostRequestValidationError) ErrorName() string

ErrorName returns error name.

func (AnnounceHostRequestValidationError) Field 

func (e AnnounceHostRequestValidationError) Field() string

Field function returns field value.

func (AnnounceHostRequestValidationError) Key 

func (e AnnounceHostRequestValidationError) Key() bool

Key function returns key value.

func (AnnounceHostRequestValidationError) Reason 

func (e AnnounceHostRequestValidationError) Reason() string

Reason function returns reason value.

type AnnouncePeerRequest 

type AnnouncePeerRequest struct {

	// Host id.
	HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// Task id.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Peer id.
	PeerId string `protobuf:"bytes,3,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// Types that are assignable to Request:
	//
	//	*AnnouncePeerRequest_RegisterPeerRequest
	//	*AnnouncePeerRequest_RegisterSeedPeerRequest
	//	*AnnouncePeerRequest_DownloadPeerStartedRequest
	//	*AnnouncePeerRequest_DownloadPeerBackToSourceStartedRequest
	//	*AnnouncePeerRequest_DownloadPeerFinishedRequest
	//	*AnnouncePeerRequest_DownloadPeerBackToSourceFinishedRequest
	//	*AnnouncePeerRequest_DownloadPeerFailedRequest
	//	*AnnouncePeerRequest_DownloadPeerBackToSourceFailedRequest
	//	*AnnouncePeerRequest_DownloadPieceFinishedRequest
	//	*AnnouncePeerRequest_DownloadPieceBackToSourceFinishedRequest
	//	*AnnouncePeerRequest_DownloadPieceFailedRequest
	//	*AnnouncePeerRequest_DownloadPieceBackToSourceFailedRequest
	//	*AnnouncePeerRequest_SyncPiecesFailedRequest
	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) GetRegisterSeedPeerRequest 

func (x *AnnouncePeerRequest) GetRegisterSeedPeerRequest() *RegisterSeedPeerRequest

func (*AnnouncePeerRequest) GetRequest 

func (m *AnnouncePeerRequest) GetRequest() isAnnouncePeerRequest_Request

func (*AnnouncePeerRequest) GetSyncPiecesFailedRequest 

func (x *AnnouncePeerRequest) GetSyncPiecesFailedRequest() *SyncPiecesFailedRequest

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,6,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_RegisterSeedPeerRequest 

type AnnouncePeerRequest_RegisterSeedPeerRequest struct {
	RegisterSeedPeerRequest *RegisterSeedPeerRequest `protobuf:"bytes,5,opt,name=register_seed_peer_request,json=registerSeedPeerRequest,proto3,oneof"`
}

type AnnouncePeerRequest_SyncPiecesFailedRequest 

type AnnouncePeerRequest_SyncPiecesFailedRequest struct {
	SyncPiecesFailedRequest *SyncPiecesFailedRequest `protobuf:"bytes,16,opt,name=sync_pieces_failed_request,json=syncPiecesFailedRequest,proto3,oneof"`
}

type AnnouncePeerResponse 

type AnnouncePeerResponse struct {

	// Types that are assignable to Response:
	//
	//	*AnnouncePeerResponse_EmptyTaskResponse
	//	*AnnouncePeerResponse_TinyTaskResponse
	//	*AnnouncePeerResponse_SmallTaskResponse
	//	*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) GetSmallTaskResponse 

func (x *AnnouncePeerResponse) GetSmallTaskResponse() *SmallTaskResponse

func (*AnnouncePeerResponse) GetTinyTaskResponse 

func (x *AnnouncePeerResponse) GetTinyTaskResponse() *TinyTaskResponse

func (*AnnouncePeerResponse) ProtoMessage 

func (*AnnouncePeerResponse) ProtoMessage()

func (*AnnouncePeerResponse) ProtoReflect 

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

func (*AnnouncePeerResponse) Reset 

func (x *AnnouncePeerResponse) Reset()

func (*AnnouncePeerResponse) String 

func (x *AnnouncePeerResponse) String() string

func (*AnnouncePeerResponse) Validate 

func (m *AnnouncePeerResponse) Validate() error

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

func (*AnnouncePeerResponse) ValidateAll 

func (m *AnnouncePeerResponse) ValidateAll() error

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

type AnnouncePeerResponseMultiError 

type AnnouncePeerResponseMultiError []error

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

func (AnnouncePeerResponseMultiError) AllErrors 

func (m AnnouncePeerResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnouncePeerResponseMultiError) Error 

func (m AnnouncePeerResponseMultiError) Error() string

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

type AnnouncePeerResponseValidationError 

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

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

func (AnnouncePeerResponseValidationError) Cause 

func (e AnnouncePeerResponseValidationError) Cause() error

Cause function returns cause value.

func (AnnouncePeerResponseValidationError) Error 

func (e AnnouncePeerResponseValidationError) Error() string

Error satisfies the builtin error interface

func (AnnouncePeerResponseValidationError) ErrorName 

func (e AnnouncePeerResponseValidationError) ErrorName() string

ErrorName returns error name.

func (AnnouncePeerResponseValidationError) Field 

func (e AnnouncePeerResponseValidationError) Field() string

Field function returns field value.

func (AnnouncePeerResponseValidationError) Key 

func (e AnnouncePeerResponseValidationError) Key() bool

Key function returns key value.

func (AnnouncePeerResponseValidationError) Reason 

func (e AnnouncePeerResponseValidationError) Reason() string

Reason function returns reason value.

type AnnouncePeerResponse_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,5,opt,name=need_back_to_source_response,json=needBackToSourceResponse,proto3,oneof"`
}

type AnnouncePeerResponse_NormalTaskResponse 

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

type AnnouncePeerResponse_SmallTaskResponse 

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

type AnnouncePeerResponse_TinyTaskResponse 

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

type DownloadPeerBackToSourceFailedRequest 

type DownloadPeerBackToSourceFailedRequest struct {

	// The description of the download back-to-source failed.
	Description string `protobuf:"bytes,1,opt,name=description,proto3" 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 int64 `protobuf:"varint,1,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// Total piece count.
	PieceCount int32 `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() int64

func (*DownloadPeerBackToSourceFinishedRequest) GetPieceCount 

func (x *DownloadPeerBackToSourceFinishedRequest) GetPieceCount() int32

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" 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" 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 int64 `protobuf:"varint,1,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// Total piece count.
	PieceCount int32 `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() int64

func (*DownloadPeerFinishedRequest) GetPieceCount 

func (x *DownloadPeerFinishedRequest) GetPieceCount() int32

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 info.
	Piece *v2.Piece `protobuf:"bytes,1,opt,name=piece,proto3" json:"piece,omitempty"`
	// Types that are assignable to Response:
	//
	//	*DownloadPieceBackToSourceFailedRequest_HttpResponse
	//	*DownloadPieceBackToSourceFailedRequest_HdfsResponse
	//	*DownloadPieceBackToSourceFailedRequest_S3Response
	//	*DownloadPieceBackToSourceFailedRequest_OssResponse
	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) GetHdfsResponse 

func (x *DownloadPieceBackToSourceFailedRequest) GetHdfsResponse() *HDFSResponse

func (*DownloadPieceBackToSourceFailedRequest) GetHttpResponse 

func (x *DownloadPieceBackToSourceFailedRequest) GetHttpResponse() *HTTPResponse

func (*DownloadPieceBackToSourceFailedRequest) GetOssResponse 

func (x *DownloadPieceBackToSourceFailedRequest) GetOssResponse() *OSSResponse

func (*DownloadPieceBackToSourceFailedRequest) GetPiece 

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

func (*DownloadPieceBackToSourceFailedRequest) GetResponse 

func (m *DownloadPieceBackToSourceFailedRequest) GetResponse() isDownloadPieceBackToSourceFailedRequest_Response

func (*DownloadPieceBackToSourceFailedRequest) GetS3Response 

func (x *DownloadPieceBackToSourceFailedRequest) GetS3Response() *S3Response

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_HdfsResponse 

type DownloadPieceBackToSourceFailedRequest_HdfsResponse struct {
	HdfsResponse *HDFSResponse `protobuf:"bytes,3,opt,name=hdfs_response,json=hdfsResponse,proto3,oneof"`
}

type DownloadPieceBackToSourceFailedRequest_HttpResponse 

type DownloadPieceBackToSourceFailedRequest_HttpResponse struct {
	HttpResponse *HTTPResponse `protobuf:"bytes,2,opt,name=http_response,json=httpResponse,proto3,oneof"`
}

type DownloadPieceBackToSourceFailedRequest_OssResponse 

type DownloadPieceBackToSourceFailedRequest_OssResponse struct {
	OssResponse *OSSResponse `protobuf:"bytes,5,opt,name=oss_response,json=ossResponse,proto3,oneof"`
}

type DownloadPieceBackToSourceFailedRequest_S3Response 

type DownloadPieceBackToSourceFailedRequest_S3Response struct {
	S3Response *S3Response `protobuf:"bytes,4,opt,name=s3_response,json=s3Response,proto3,oneof"`
}

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 info.
	Piece *v2.Piece `protobuf:"bytes,1,opt,name=piece,proto3" json:"piece,omitempty"`
	// Temporary indicates whether the error is temporary.
	Temporary bool `protobuf:"varint,2,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) GetPiece 

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

func (*DownloadPieceFailedRequest) GetTemporary 

func (x *DownloadPieceFailedRequest) GetTemporary() bool

func (*DownloadPieceFailedRequest) ProtoMessage 

func (*DownloadPieceFailedRequest) ProtoMessage()

func (*DownloadPieceFailedRequest) ProtoReflect 

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

func (*DownloadPieceFailedRequest) Reset 

func (x *DownloadPieceFailedRequest) Reset()

func (*DownloadPieceFailedRequest) String 

func (x *DownloadPieceFailedRequest) String() string

func (*DownloadPieceFailedRequest) Validate 

func (m *DownloadPieceFailedRequest) Validate() error

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

func (*DownloadPieceFailedRequest) ValidateAll 

func (m *DownloadPieceFailedRequest) ValidateAll() error

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

type DownloadPieceFailedRequestMultiError 

type DownloadPieceFailedRequestMultiError []error

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

func (DownloadPieceFailedRequestMultiError) AllErrors 

func (m DownloadPieceFailedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPieceFailedRequestMultiError) Error 

func (m DownloadPieceFailedRequestMultiError) Error() string

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

type DownloadPieceFailedRequestValidationError 

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

DownloadPieceFailedRequestValidationError is the validation error returned by DownloadPieceFailedRequest.Validate if the designated constraints aren't met.

func (DownloadPieceFailedRequestValidationError) Cause 

func (e DownloadPieceFailedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPieceFailedRequestValidationError) Error 

func (e DownloadPieceFailedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPieceFailedRequestValidationError) ErrorName 

func (e DownloadPieceFailedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPieceFailedRequestValidationError) Field 

func (e DownloadPieceFailedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPieceFailedRequestValidationError) Key 

func (e DownloadPieceFailedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPieceFailedRequestValidationError) Reason 

func (e DownloadPieceFailedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPieceFinishedRequest 

type DownloadPieceFinishedRequest struct {

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

DownloadPieceFinishedRequest represents piece download finished request of AnnouncePeerRequest.

func (*DownloadPieceFinishedRequest) Descriptor deprecated 

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

Deprecated: Use DownloadPieceFinishedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPieceFinishedRequest) GetPiece 

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

func (*DownloadPieceFinishedRequest) ProtoMessage 

func (*DownloadPieceFinishedRequest) ProtoMessage()

func (*DownloadPieceFinishedRequest) ProtoReflect 

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

func (*DownloadPieceFinishedRequest) Reset 

func (x *DownloadPieceFinishedRequest) Reset()

func (*DownloadPieceFinishedRequest) String 

func (x *DownloadPieceFinishedRequest) String() string

func (*DownloadPieceFinishedRequest) Validate 

func (m *DownloadPieceFinishedRequest) Validate() error

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

func (*DownloadPieceFinishedRequest) ValidateAll 

func (m *DownloadPieceFinishedRequest) ValidateAll() error

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

type DownloadPieceFinishedRequestMultiError 

type DownloadPieceFinishedRequestMultiError []error

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

func (DownloadPieceFinishedRequestMultiError) AllErrors 

func (m DownloadPieceFinishedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPieceFinishedRequestMultiError) Error 

func (m DownloadPieceFinishedRequestMultiError) Error() string

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

type DownloadPieceFinishedRequestValidationError 

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

DownloadPieceFinishedRequestValidationError is the validation error returned by DownloadPieceFinishedRequest.Validate if the designated constraints aren't met.

func (DownloadPieceFinishedRequestValidationError) Cause 

func (e DownloadPieceFinishedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPieceFinishedRequestValidationError) Error 

func (e DownloadPieceFinishedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPieceFinishedRequestValidationError) ErrorName 

func (e DownloadPieceFinishedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPieceFinishedRequestValidationError) Field 

func (e DownloadPieceFinishedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPieceFinishedRequestValidationError) Key 

func (e DownloadPieceFinishedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPieceFinishedRequestValidationError) Reason 

func (e DownloadPieceFinishedRequestValidationError) Reason() string

Reason function returns reason value.

type EmptyTaskResponse 

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

EmptyTaskResponse represents empty task response of AnnouncePeerResponse.

func (*EmptyTaskResponse) Descriptor deprecated 

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

Deprecated: Use EmptyTaskResponse.ProtoReflect.Descriptor instead.

func (*EmptyTaskResponse) ProtoMessage 

func (*EmptyTaskResponse) ProtoMessage()

func (*EmptyTaskResponse) ProtoReflect 

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

func (*EmptyTaskResponse) Reset 

func (x *EmptyTaskResponse) Reset()

func (*EmptyTaskResponse) String 

func (x *EmptyTaskResponse) String() string

func (*EmptyTaskResponse) Validate 

func (m *EmptyTaskResponse) Validate() error

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

func (*EmptyTaskResponse) ValidateAll 

func (m *EmptyTaskResponse) ValidateAll() error

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

type EmptyTaskResponseMultiError 

type EmptyTaskResponseMultiError []error

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

func (EmptyTaskResponseMultiError) AllErrors 

func (m EmptyTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EmptyTaskResponseMultiError) Error 

func (m EmptyTaskResponseMultiError) Error() string

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

type EmptyTaskResponseValidationError 

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

EmptyTaskResponseValidationError is the validation error returned by EmptyTaskResponse.Validate if the designated constraints aren't met.

func (EmptyTaskResponseValidationError) Cause 

func (e EmptyTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (EmptyTaskResponseValidationError) Error 

func (e EmptyTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (EmptyTaskResponseValidationError) ErrorName 

func (e EmptyTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (EmptyTaskResponseValidationError) Field 

func (e EmptyTaskResponseValidationError) Field() string

Field function returns field value.

func (EmptyTaskResponseValidationError) Key 

func (e EmptyTaskResponseValidationError) Key() bool

Key function returns key value.

func (EmptyTaskResponseValidationError) Reason 

func (e EmptyTaskResponseValidationError) Reason() string

Reason function returns reason value.

type ExchangePeerRequest 

type ExchangePeerRequest struct {

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

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

func (*ExchangePeerRequest) Descriptor deprecated 

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

Deprecated: Use ExchangePeerRequest.ProtoReflect.Descriptor instead.

func (*ExchangePeerRequest) GetHostId 

func (x *ExchangePeerRequest) GetHostId() string

func (*ExchangePeerRequest) GetPeerId 

func (x *ExchangePeerRequest) GetPeerId() string

func (*ExchangePeerRequest) GetTaskId 

func (x *ExchangePeerRequest) GetTaskId() string

func (*ExchangePeerRequest) ProtoMessage 

func (*ExchangePeerRequest) ProtoMessage()

func (*ExchangePeerRequest) ProtoReflect 

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

func (*ExchangePeerRequest) Reset 

func (x *ExchangePeerRequest) Reset()

func (*ExchangePeerRequest) String 

func (x *ExchangePeerRequest) String() string

func (*ExchangePeerRequest) Validate 

func (m *ExchangePeerRequest) Validate() error

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

func (*ExchangePeerRequest) ValidateAll 

func (m *ExchangePeerRequest) ValidateAll() error

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

type ExchangePeerRequestMultiError 

type ExchangePeerRequestMultiError []error

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

func (ExchangePeerRequestMultiError) AllErrors 

func (m ExchangePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExchangePeerRequestMultiError) Error 

func (m ExchangePeerRequestMultiError) Error() string

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

type ExchangePeerRequestValidationError 

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

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

func (ExchangePeerRequestValidationError) Cause 

func (e ExchangePeerRequestValidationError) Cause() error

Cause function returns cause value.

func (ExchangePeerRequestValidationError) Error 

func (e ExchangePeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ExchangePeerRequestValidationError) ErrorName 

func (e ExchangePeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ExchangePeerRequestValidationError) Field 

func (e ExchangePeerRequestValidationError) Field() string

Field function returns field value.

func (ExchangePeerRequestValidationError) Key 

func (e ExchangePeerRequestValidationError) Key() bool

Key function returns key value.

func (ExchangePeerRequestValidationError) Reason 

func (e ExchangePeerRequestValidationError) Reason() string

Reason function returns reason value.

type ExchangePeerResponse 

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

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

func (*ExchangePeerResponse) Descriptor deprecated 

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

Deprecated: Use ExchangePeerResponse.ProtoReflect.Descriptor instead.

func (*ExchangePeerResponse) ProtoMessage 

func (*ExchangePeerResponse) ProtoMessage()

func (*ExchangePeerResponse) ProtoReflect 

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

func (*ExchangePeerResponse) Reset 

func (x *ExchangePeerResponse) Reset()

func (*ExchangePeerResponse) String 

func (x *ExchangePeerResponse) String() string

func (*ExchangePeerResponse) Validate 

func (m *ExchangePeerResponse) Validate() error

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

func (*ExchangePeerResponse) ValidateAll 

func (m *ExchangePeerResponse) ValidateAll() error

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

type ExchangePeerResponseMultiError 

type ExchangePeerResponseMultiError []error

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

func (ExchangePeerResponseMultiError) AllErrors 

func (m ExchangePeerResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExchangePeerResponseMultiError) Error 

func (m ExchangePeerResponseMultiError) Error() string

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

type ExchangePeerResponseValidationError 

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

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

func (ExchangePeerResponseValidationError) Cause 

func (e ExchangePeerResponseValidationError) Cause() error

Cause function returns cause value.

func (ExchangePeerResponseValidationError) Error 

func (e ExchangePeerResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ExchangePeerResponseValidationError) ErrorName 

func (e ExchangePeerResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ExchangePeerResponseValidationError) Field 

func (e ExchangePeerResponseValidationError) Field() string

Field function returns field value.

func (ExchangePeerResponseValidationError) Key 

func (e ExchangePeerResponseValidationError) Key() bool

Key function returns key value.

func (ExchangePeerResponseValidationError) Reason 

func (e ExchangePeerResponseValidationError) Reason() string

Reason function returns reason value.

type FailedProbe 

type FailedProbe struct {

	// Destination host metadata.
	Host *v2.Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// The description of probing failed.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" 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 HDFSResponse 

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

HDFSResponse represents hdfs protocol response of DownloadPieceBackToSourceFailedRequest.

func (*HDFSResponse) Descriptor deprecated 

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

Deprecated: Use HDFSResponse.ProtoReflect.Descriptor instead.

func (*HDFSResponse) ProtoMessage 

func (*HDFSResponse) ProtoMessage()

func (*HDFSResponse) ProtoReflect 

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

func (*HDFSResponse) Reset 

func (x *HDFSResponse) Reset()

func (*HDFSResponse) String 

func (x *HDFSResponse) String() string

func (*HDFSResponse) Validate 

func (m *HDFSResponse) Validate() error

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

func (m *HDFSResponse) ValidateAll() error

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

type HDFSResponseMultiError 

type HDFSResponseMultiError []error

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

func (HDFSResponseMultiError) AllErrors 

func (m HDFSResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (HDFSResponseMultiError) Error 

func (m HDFSResponseMultiError) Error() string

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

type HDFSResponseValidationError 

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

HDFSResponseValidationError is the validation error returned by HDFSResponse.Validate if the designated constraints aren't met.

func (HDFSResponseValidationError) Cause 

func (e HDFSResponseValidationError) Cause() error

Cause function returns cause value.

func (HDFSResponseValidationError) Error 

func (e HDFSResponseValidationError) Error() string

Error satisfies the builtin error interface

func (HDFSResponseValidationError) ErrorName 

func (e HDFSResponseValidationError) ErrorName() string

ErrorName returns error name.

func (HDFSResponseValidationError) Field 

func (e HDFSResponseValidationError) Field() string

Field function returns field value.

func (HDFSResponseValidationError) Key 

func (e HDFSResponseValidationError) Key() bool

Key function returns key value.

func (HDFSResponseValidationError) Reason 

func (e HDFSResponseValidationError) Reason() string

Reason function returns reason value.

type HTTPResponse 

type HTTPResponse struct {

	// HTTP Response Header.
	Header map[string]string `` /* 153-byte string literal not displayed */
	// HTTP Status Code.
	StatusCode int32 `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	// HTTP Status.
	Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

HTTPResponse represents http protocol response of DownloadPieceBackToSourceFailedRequest.

func (*HTTPResponse) Descriptor deprecated 

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

Deprecated: Use HTTPResponse.ProtoReflect.Descriptor instead.

func (*HTTPResponse) GetHeader 

func (x *HTTPResponse) GetHeader() map[string]string

func (*HTTPResponse) GetStatus 

func (x *HTTPResponse) GetStatus() string

func (*HTTPResponse) GetStatusCode 

func (x *HTTPResponse) GetStatusCode() int32

func (*HTTPResponse) ProtoMessage 

func (*HTTPResponse) ProtoMessage()

func (*HTTPResponse) ProtoReflect 

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

func (*HTTPResponse) Reset 

func (x *HTTPResponse) Reset()

func (*HTTPResponse) String 

func (x *HTTPResponse) String() string

func (*HTTPResponse) Validate 

func (m *HTTPResponse) Validate() error

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

func (m *HTTPResponse) ValidateAll() error

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

type HTTPResponseMultiError 

type HTTPResponseMultiError []error

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

func (HTTPResponseMultiError) AllErrors 

func (m HTTPResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (HTTPResponseMultiError) Error 

func (m HTTPResponseMultiError) Error() string

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

type HTTPResponseValidationError 

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

HTTPResponseValidationError is the validation error returned by HTTPResponse.Validate if the designated constraints aren't met.

func (HTTPResponseValidationError) Cause 

func (e HTTPResponseValidationError) Cause() error

Cause function returns cause value.

func (HTTPResponseValidationError) Error 

func (e HTTPResponseValidationError) Error() string

Error satisfies the builtin error interface

func (HTTPResponseValidationError) ErrorName 

func (e HTTPResponseValidationError) ErrorName() string

ErrorName returns error name.

func (HTTPResponseValidationError) Field 

func (e HTTPResponseValidationError) Field() string

Field function returns field value.

func (HTTPResponseValidationError) Key 

func (e HTTPResponseValidationError) Key() bool

Key function returns key value.

func (HTTPResponseValidationError) Reason 

func (e HTTPResponseValidationError) Reason() string

Reason function returns reason value.

type LeaveHostRequest 

type LeaveHostRequest struct {

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

LeaveHostRequest represents request of LeaveHost.

func (*LeaveHostRequest) Descriptor deprecated 

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

Deprecated: Use LeaveHostRequest.ProtoReflect.Descriptor instead.

func (*LeaveHostRequest) GetId 

func (x *LeaveHostRequest) GetId() string

func (*LeaveHostRequest) ProtoMessage 

func (*LeaveHostRequest) ProtoMessage()

func (*LeaveHostRequest) ProtoReflect 

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

func (*LeaveHostRequest) Reset 

func (x *LeaveHostRequest) Reset()

func (*LeaveHostRequest) String 

func (x *LeaveHostRequest) String() string

func (*LeaveHostRequest) Validate 

func (m *LeaveHostRequest) Validate() error

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

func (*LeaveHostRequest) ValidateAll 

func (m *LeaveHostRequest) ValidateAll() error

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

type LeaveHostRequestMultiError 

type LeaveHostRequestMultiError []error

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

func (LeaveHostRequestMultiError) AllErrors 

func (m LeaveHostRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LeaveHostRequestMultiError) Error 

func (m LeaveHostRequestMultiError) Error() string

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

type LeaveHostRequestValidationError 

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

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

func (LeaveHostRequestValidationError) Cause 

func (e LeaveHostRequestValidationError) Cause() error

Cause function returns cause value.

func (LeaveHostRequestValidationError) Error 

func (e LeaveHostRequestValidationError) Error() string

Error satisfies the builtin error interface

func (LeaveHostRequestValidationError) ErrorName 

func (e LeaveHostRequestValidationError) ErrorName() string

ErrorName returns error name.

func (LeaveHostRequestValidationError) Field 

func (e LeaveHostRequestValidationError) Field() string

Field function returns field value.

func (LeaveHostRequestValidationError) Key 

func (e LeaveHostRequestValidationError) Key() bool

Key function returns key value.

func (LeaveHostRequestValidationError) Reason 

func (e LeaveHostRequestValidationError) Reason() string

Reason function returns reason value.

type LeavePeerRequest 

type LeavePeerRequest struct {

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

LeavePeerRequest represents request of LeavePeer.

func (*LeavePeerRequest) Descriptor deprecated 

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

Deprecated: Use LeavePeerRequest.ProtoReflect.Descriptor instead.

func (*LeavePeerRequest) GetHostId 

func (x *LeavePeerRequest) GetHostId() string

func (*LeavePeerRequest) GetPeerId 

func (x *LeavePeerRequest) GetPeerId() string

func (*LeavePeerRequest) GetTaskId 

func (x *LeavePeerRequest) GetTaskId() string

func (*LeavePeerRequest) ProtoMessage 

func (*LeavePeerRequest) ProtoMessage()

func (*LeavePeerRequest) ProtoReflect 

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

func (*LeavePeerRequest) Reset 

func (x *LeavePeerRequest) Reset()

func (*LeavePeerRequest) String 

func (x *LeavePeerRequest) String() string

func (*LeavePeerRequest) Validate 

func (m *LeavePeerRequest) Validate() error

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

func (*LeavePeerRequest) ValidateAll 

func (m *LeavePeerRequest) ValidateAll() error

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

type LeavePeerRequestMultiError 

type LeavePeerRequestMultiError []error

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

func (LeavePeerRequestMultiError) AllErrors 

func (m LeavePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LeavePeerRequestMultiError) Error 

func (m LeavePeerRequestMultiError) Error() string

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

type LeavePeerRequestValidationError 

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

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

func (LeavePeerRequestValidationError) Cause 

func (e LeavePeerRequestValidationError) Cause() error

Cause function returns cause value.

func (LeavePeerRequestValidationError) Error 

func (e LeavePeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (LeavePeerRequestValidationError) ErrorName 

func (e LeavePeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (LeavePeerRequestValidationError) Field 

func (e LeavePeerRequestValidationError) Field() string

Field function returns field value.

func (LeavePeerRequestValidationError) Key 

func (e LeavePeerRequestValidationError) Key() bool

Key function returns key value.

func (LeavePeerRequestValidationError) Reason 

func (e LeavePeerRequestValidationError) Reason() string

Reason function returns reason value.

type NeedBackToSourceResponse 

type NeedBackToSourceResponse struct {

	// The description of the back-to-source reason.
	Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

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

func (*NeedBackToSourceResponse) Descriptor deprecated 

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

Deprecated: Use NeedBackToSourceResponse.ProtoReflect.Descriptor instead.

func (*NeedBackToSourceResponse) GetDescription 

func (x *NeedBackToSourceResponse) GetDescription() string

func (*NeedBackToSourceResponse) ProtoMessage 

func (*NeedBackToSourceResponse) ProtoMessage()

func (*NeedBackToSourceResponse) ProtoReflect 

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

func (*NeedBackToSourceResponse) Reset 

func (x *NeedBackToSourceResponse) Reset()

func (*NeedBackToSourceResponse) String 

func (x *NeedBackToSourceResponse) String() string

func (*NeedBackToSourceResponse) Validate 

func (m *NeedBackToSourceResponse) Validate() error

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

func (*NeedBackToSourceResponse) ValidateAll 

func (m *NeedBackToSourceResponse) ValidateAll() error

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

type NeedBackToSourceResponseMultiError 

type NeedBackToSourceResponseMultiError []error

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

func (NeedBackToSourceResponseMultiError) AllErrors 

func (m NeedBackToSourceResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NeedBackToSourceResponseMultiError) Error 

func (m NeedBackToSourceResponseMultiError) Error() string

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

type NeedBackToSourceResponseValidationError 

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

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

func (NeedBackToSourceResponseValidationError) Cause 

func (e NeedBackToSourceResponseValidationError) Cause() error

Cause function returns cause value.

func (NeedBackToSourceResponseValidationError) Error 

func (e NeedBackToSourceResponseValidationError) Error() string

Error satisfies the builtin error interface

func (NeedBackToSourceResponseValidationError) ErrorName 

func (e NeedBackToSourceResponseValidationError) ErrorName() string

ErrorName returns error name.

func (NeedBackToSourceResponseValidationError) Field 

func (e NeedBackToSourceResponseValidationError) Field() string

Field function returns field value.

func (NeedBackToSourceResponseValidationError) Key 

func (e NeedBackToSourceResponseValidationError) Key() bool

Key function returns key value.

func (NeedBackToSourceResponseValidationError) Reason 

func (e NeedBackToSourceResponseValidationError) Reason() string

Reason function returns reason value.

type NormalTaskResponse 

type NormalTaskResponse struct {

	// Candidate parents.
	CandidateParents []*v2.Peer `protobuf:"bytes,1,rep,name=candidate_parents,json=candidateParents,proto3" json:"candidate_parents,omitempty"`
	// Concurrent downloading piece count from the peers.
	ConcurrentPieceCount int32 `protobuf:"varint,2,opt,name=concurrent_piece_count,json=concurrentPieceCount,proto3" json:"concurrent_piece_count,omitempty"`
	// contains filtered or unexported fields
}

NormalTaskResponse represents normal task response of AnnouncePeerResponse.

func (*NormalTaskResponse) Descriptor deprecated 

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

Deprecated: Use NormalTaskResponse.ProtoReflect.Descriptor instead.

func (*NormalTaskResponse) GetCandidateParents 

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

func (*NormalTaskResponse) GetConcurrentPieceCount 

func (x *NormalTaskResponse) GetConcurrentPieceCount() int32

func (*NormalTaskResponse) ProtoMessage 

func (*NormalTaskResponse) ProtoMessage()

func (*NormalTaskResponse) ProtoReflect 

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

func (*NormalTaskResponse) Reset 

func (x *NormalTaskResponse) Reset()

func (*NormalTaskResponse) String 

func (x *NormalTaskResponse) String() string

func (*NormalTaskResponse) Validate 

func (m *NormalTaskResponse) Validate() error

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

func (*NormalTaskResponse) ValidateAll 

func (m *NormalTaskResponse) ValidateAll() error

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

type NormalTaskResponseMultiError 

type NormalTaskResponseMultiError []error

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

func (NormalTaskResponseMultiError) AllErrors 

func (m NormalTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NormalTaskResponseMultiError) Error 

func (m NormalTaskResponseMultiError) Error() string

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

type NormalTaskResponseValidationError 

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

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

func (NormalTaskResponseValidationError) Cause 

func (e NormalTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (NormalTaskResponseValidationError) Error 

func (e NormalTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (NormalTaskResponseValidationError) ErrorName 

func (e NormalTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (NormalTaskResponseValidationError) Field 

func (e NormalTaskResponseValidationError) Field() string

Field function returns field value.

func (NormalTaskResponseValidationError) Key 

func (e NormalTaskResponseValidationError) Key() bool

Key function returns key value.

func (NormalTaskResponseValidationError) Reason 

func (e NormalTaskResponseValidationError) Reason() string

Reason function returns reason value.

type OSSResponse 

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

OSSResponse represents oss protocol response of DownloadPieceBackToSourceFailedRequest.

func (*OSSResponse) Descriptor deprecated 

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

Deprecated: Use OSSResponse.ProtoReflect.Descriptor instead.

func (*OSSResponse) ProtoMessage 

func (*OSSResponse) ProtoMessage()

func (*OSSResponse) ProtoReflect 

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

func (*OSSResponse) Reset 

func (x *OSSResponse) Reset()

func (*OSSResponse) String 

func (x *OSSResponse) String() string

func (*OSSResponse) Validate 

func (m *OSSResponse) Validate() error

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

func (m *OSSResponse) ValidateAll() error

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

type OSSResponseMultiError 

type OSSResponseMultiError []error

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

func (OSSResponseMultiError) AllErrors 

func (m OSSResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OSSResponseMultiError) Error 

func (m OSSResponseMultiError) Error() string

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

type OSSResponseValidationError 

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

OSSResponseValidationError is the validation error returned by OSSResponse.Validate if the designated constraints aren't met.

func (OSSResponseValidationError) Cause 

func (e OSSResponseValidationError) Cause() error

Cause function returns cause value.

func (OSSResponseValidationError) Error 

func (e OSSResponseValidationError) Error() string

Error satisfies the builtin error interface

func (OSSResponseValidationError) ErrorName 

func (e OSSResponseValidationError) ErrorName() string

ErrorName returns error name.

func (OSSResponseValidationError) Field 

func (e OSSResponseValidationError) Field() string

Field function returns field value.

func (OSSResponseValidationError) Key 

func (e OSSResponseValidationError) Key() bool

Key function returns key value.

func (OSSResponseValidationError) Reason 

func (e OSSResponseValidationError) 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) Descriptor() ([]byte, []int)

Deprecated: Use Probe.ProtoReflect.Descriptor instead.

func (*Probe) GetCreatedAt 

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

func (*Probe) GetHost 

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

func (*Probe) GetRtt 

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

func (*Probe) ProtoMessage 

func (*Probe) ProtoMessage()

func (*Probe) ProtoReflect 

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

func (*Probe) Reset 

func (x *Probe) Reset()

func (*Probe) String 

func (x *Probe) String() string

func (*Probe) Validate 

func (m *Probe) Validate() error

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

func (*Probe) ValidateAll 

func (m *Probe) ValidateAll() error

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

type ProbeFailedRequest 

type ProbeFailedRequest struct {

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

ProbeFailedRequest represents failed request of SyncProbesRequest.

func (*ProbeFailedRequest) Descriptor deprecated 

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

Deprecated: Use ProbeFailedRequest.ProtoReflect.Descriptor instead.

func (*ProbeFailedRequest) GetProbes 

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

func (*ProbeFailedRequest) ProtoMessage 

func (*ProbeFailedRequest) ProtoMessage()

func (*ProbeFailedRequest) ProtoReflect 

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

func (*ProbeFailedRequest) Reset 

func (x *ProbeFailedRequest) Reset()

func (*ProbeFailedRequest) String 

func (x *ProbeFailedRequest) String() string

func (*ProbeFailedRequest) Validate 

func (m *ProbeFailedRequest) Validate() error

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

func (*ProbeFailedRequest) ValidateAll 

func (m *ProbeFailedRequest) ValidateAll() error

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

type ProbeFailedRequestMultiError 

type ProbeFailedRequestMultiError []error

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

func (ProbeFailedRequestMultiError) AllErrors 

func (m ProbeFailedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ProbeFailedRequestMultiError) Error 

func (m ProbeFailedRequestMultiError) Error() string

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

type ProbeFailedRequestValidationError 

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

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

func (ProbeFailedRequestValidationError) Cause 

func (e ProbeFailedRequestValidationError) Cause() error

Cause function returns cause value.

func (ProbeFailedRequestValidationError) Error 

func (e ProbeFailedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ProbeFailedRequestValidationError) ErrorName 

func (e ProbeFailedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ProbeFailedRequestValidationError) Field 

func (e ProbeFailedRequestValidationError) Field() string

Field function returns field value.

func (ProbeFailedRequestValidationError) Key 

func (e ProbeFailedRequestValidationError) Key() bool

Key function returns key value.

func (ProbeFailedRequestValidationError) Reason 

func (e ProbeFailedRequestValidationError) Reason() string

Reason function returns reason value.

type ProbeFinishedRequest 

type ProbeFinishedRequest struct {

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

ProbeFinishedRequest represents finished request of SyncProbesRequest.

func (*ProbeFinishedRequest) Descriptor deprecated 

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

Deprecated: Use ProbeFinishedRequest.ProtoReflect.Descriptor instead.

func (*ProbeFinishedRequest) GetProbes 

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

func (*ProbeFinishedRequest) ProtoMessage 

func (*ProbeFinishedRequest) ProtoMessage()

func (*ProbeFinishedRequest) ProtoReflect 

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

func (*ProbeFinishedRequest) Reset 

func (x *ProbeFinishedRequest) Reset()

func (*ProbeFinishedRequest) String 

func (x *ProbeFinishedRequest) String() string

func (*ProbeFinishedRequest) Validate 

func (m *ProbeFinishedRequest) Validate() error

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

func (*ProbeFinishedRequest) ValidateAll 

func (m *ProbeFinishedRequest) ValidateAll() error

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

type ProbeFinishedRequestMultiError 

type ProbeFinishedRequestMultiError []error

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

func (ProbeFinishedRequestMultiError) AllErrors 

func (m ProbeFinishedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ProbeFinishedRequestMultiError) Error 

func (m ProbeFinishedRequestMultiError) Error() string

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

type ProbeFinishedRequestValidationError 

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

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

func (ProbeFinishedRequestValidationError) Cause 

func (e ProbeFinishedRequestValidationError) Cause() error

Cause function returns cause value.

func (ProbeFinishedRequestValidationError) Error 

func (e ProbeFinishedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ProbeFinishedRequestValidationError) ErrorName 

func (e ProbeFinishedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ProbeFinishedRequestValidationError) Field 

func (e ProbeFinishedRequestValidationError) Field() string

Field function returns field value.

func (ProbeFinishedRequestValidationError) Key 

func (e ProbeFinishedRequestValidationError) Key() bool

Key function returns key value.

func (ProbeFinishedRequestValidationError) Reason 

func (e ProbeFinishedRequestValidationError) Reason() string

Reason function returns reason value.

type ProbeMultiError 

type ProbeMultiError []error

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

func (ProbeMultiError) AllErrors 

func (m ProbeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ProbeMultiError) Error 

func (m ProbeMultiError) Error() string

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

type ProbeStartedRequest 

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

ProbeStartedRequest represents started request of SyncProbesRequest.

func (*ProbeStartedRequest) Descriptor deprecated 

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

Deprecated: Use ProbeStartedRequest.ProtoReflect.Descriptor instead.

func (*ProbeStartedRequest) ProtoMessage 

func (*ProbeStartedRequest) ProtoMessage()

func (*ProbeStartedRequest) ProtoReflect 

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

func (*ProbeStartedRequest) Reset 

func (x *ProbeStartedRequest) Reset()

func (*ProbeStartedRequest) String 

func (x *ProbeStartedRequest) String() string

func (*ProbeStartedRequest) Validate 

func (m *ProbeStartedRequest) Validate() error

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

func (*ProbeStartedRequest) ValidateAll 

func (m *ProbeStartedRequest) ValidateAll() error

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

type ProbeStartedRequestMultiError 

type ProbeStartedRequestMultiError []error

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

func (ProbeStartedRequestMultiError) AllErrors 

func (m ProbeStartedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ProbeStartedRequestMultiError) Error 

func (m ProbeStartedRequestMultiError) Error() string

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

type ProbeStartedRequestValidationError 

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

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

func (ProbeStartedRequestValidationError) Cause 

func (e ProbeStartedRequestValidationError) Cause() error

Cause function returns cause value.

func (ProbeStartedRequestValidationError) Error 

func (e ProbeStartedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ProbeStartedRequestValidationError) ErrorName 

func (e ProbeStartedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ProbeStartedRequestValidationError) Field 

func (e ProbeStartedRequestValidationError) Field() string

Field function returns field value.

func (ProbeStartedRequestValidationError) Key 

func (e ProbeStartedRequestValidationError) Key() bool

Key function returns key value.

func (ProbeStartedRequestValidationError) Reason 

func (e ProbeStartedRequestValidationError) Reason() string

Reason function returns reason value.

type ProbeValidationError 

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

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

func (ProbeValidationError) Cause 

func (e ProbeValidationError) Cause() error

Cause function returns cause value.

func (ProbeValidationError) Error 

func (e ProbeValidationError) Error() string

Error satisfies the builtin error interface

func (ProbeValidationError) ErrorName 

func (e ProbeValidationError) ErrorName() string

ErrorName returns error name.

func (ProbeValidationError) Field 

func (e ProbeValidationError) Field() string

Field function returns field value.

func (ProbeValidationError) Key 

func (e ProbeValidationError) Key() bool

Key function returns key value.

func (ProbeValidationError) Reason 

func (e ProbeValidationError) Reason() string

Reason function returns reason value.

type RegisterPeerRequest 

type RegisterPeerRequest struct {

	// Download information.
	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 RegisterSeedPeerRequest 

type RegisterSeedPeerRequest struct {

	// Download information.
	Download *v2.Download `protobuf:"bytes,1,opt,name=download,proto3" json:"download,omitempty"`
	// contains filtered or unexported fields
}

RegisterSeedPeerRequest represents seed peer registered request of AnnouncePeerRequest.

func (*RegisterSeedPeerRequest) Descriptor deprecated 

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

Deprecated: Use RegisterSeedPeerRequest.ProtoReflect.Descriptor instead.

func (*RegisterSeedPeerRequest) GetDownload 

func (x *RegisterSeedPeerRequest) GetDownload() *v2.Download

func (*RegisterSeedPeerRequest) ProtoMessage 

func (*RegisterSeedPeerRequest) ProtoMessage()

func (*RegisterSeedPeerRequest) ProtoReflect 

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

func (*RegisterSeedPeerRequest) Reset 

func (x *RegisterSeedPeerRequest) Reset()

func (*RegisterSeedPeerRequest) String 

func (x *RegisterSeedPeerRequest) String() string

func (*RegisterSeedPeerRequest) Validate 

func (m *RegisterSeedPeerRequest) Validate() error

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

func (m *RegisterSeedPeerRequest) ValidateAll() error

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

type RegisterSeedPeerRequestMultiError 

type RegisterSeedPeerRequestMultiError []error

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

func (RegisterSeedPeerRequestMultiError) AllErrors 

func (m RegisterSeedPeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RegisterSeedPeerRequestMultiError) Error 

func (m RegisterSeedPeerRequestMultiError) Error() string

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

type RegisterSeedPeerRequestValidationError 

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

RegisterSeedPeerRequestValidationError is the validation error returned by RegisterSeedPeerRequest.Validate if the designated constraints aren't met.

func (RegisterSeedPeerRequestValidationError) Cause 

func (e RegisterSeedPeerRequestValidationError) Cause() error

Cause function returns cause value.

func (RegisterSeedPeerRequestValidationError) Error 

func (e RegisterSeedPeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (RegisterSeedPeerRequestValidationError) ErrorName 

func (e RegisterSeedPeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (RegisterSeedPeerRequestValidationError) Field 

func (e RegisterSeedPeerRequestValidationError) Field() string

Field function returns field value.

func (RegisterSeedPeerRequestValidationError) Key 

func (e RegisterSeedPeerRequestValidationError) Key() bool

Key function returns key value.

func (RegisterSeedPeerRequestValidationError) Reason 

func (e RegisterSeedPeerRequestValidationError) Reason() string

Reason function returns reason value.

type S3Response 

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

S3Response represents s3 protocol response of DownloadPieceBackToSourceFailedRequest.

func (*S3Response) Descriptor deprecated 

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

Deprecated: Use S3Response.ProtoReflect.Descriptor instead.

func (*S3Response) ProtoMessage 

func (*S3Response) ProtoMessage()

func (*S3Response) ProtoReflect 

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

func (*S3Response) Reset 

func (x *S3Response) Reset()

func (*S3Response) String 

func (x *S3Response) String() string

func (*S3Response) Validate 

func (m *S3Response) Validate() error

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

func (m *S3Response) ValidateAll() error

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

type S3ResponseMultiError 

type S3ResponseMultiError []error

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

func (S3ResponseMultiError) AllErrors 

func (m S3ResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (S3ResponseMultiError) Error 

func (m S3ResponseMultiError) Error() string

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

type S3ResponseValidationError 

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

S3ResponseValidationError is the validation error returned by S3Response.Validate if the designated constraints aren't met.

func (S3ResponseValidationError) Cause 

func (e S3ResponseValidationError) Cause() error

Cause function returns cause value.

func (S3ResponseValidationError) Error 

func (e S3ResponseValidationError) Error() string

Error satisfies the builtin error interface

func (S3ResponseValidationError) ErrorName 

func (e S3ResponseValidationError) ErrorName() string

ErrorName returns error name.

func (S3ResponseValidationError) Field 

func (e S3ResponseValidationError) Field() string

Field function returns field value.

func (S3ResponseValidationError) Key 

func (e S3ResponseValidationError) Key() bool

Key function returns key value.

func (S3ResponseValidationError) Reason 

func (e S3ResponseValidationError) Reason() string

Reason function returns reason value.

type SchedulerClient 

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

SchedulerClient is the client API for Scheduler service.

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

func NewSchedulerClient 

func NewSchedulerClient(cc grpc.ClientConnInterface) SchedulerClient

type SchedulerServer 

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

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

type Scheduler_AnnouncePeerClient 

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

type Scheduler_AnnouncePeerServer 

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

type Scheduler_SyncProbesClient 

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

type Scheduler_SyncProbesServer 

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

type SmallTaskResponse 

type SmallTaskResponse struct {

	// Candidate parent.
	CandidateParent *v2.Peer `protobuf:"bytes,1,opt,name=candidate_parent,json=candidateParent,proto3" json:"candidate_parent,omitempty"`
	// contains filtered or unexported fields
}

SmallTaskResponse represents small task response of AnnouncePeerResponse.

func (*SmallTaskResponse) Descriptor deprecated 

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

Deprecated: Use SmallTaskResponse.ProtoReflect.Descriptor instead.

func (*SmallTaskResponse) GetCandidateParent 

func (x *SmallTaskResponse) GetCandidateParent() *v2.Peer

func (*SmallTaskResponse) ProtoMessage 

func (*SmallTaskResponse) ProtoMessage()

func (*SmallTaskResponse) ProtoReflect 

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

func (*SmallTaskResponse) Reset 

func (x *SmallTaskResponse) Reset()

func (*SmallTaskResponse) String 

func (x *SmallTaskResponse) String() string

func (*SmallTaskResponse) Validate 

func (m *SmallTaskResponse) Validate() error

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

func (*SmallTaskResponse) ValidateAll 

func (m *SmallTaskResponse) ValidateAll() error

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

type SmallTaskResponseMultiError 

type SmallTaskResponseMultiError []error

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

func (SmallTaskResponseMultiError) AllErrors 

func (m SmallTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SmallTaskResponseMultiError) Error 

func (m SmallTaskResponseMultiError) Error() string

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

type SmallTaskResponseValidationError 

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

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

func (SmallTaskResponseValidationError) Cause 

func (e SmallTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (SmallTaskResponseValidationError) Error 

func (e SmallTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (SmallTaskResponseValidationError) ErrorName 

func (e SmallTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (SmallTaskResponseValidationError) Field 

func (e SmallTaskResponseValidationError) Field() string

Field function returns field value.

func (SmallTaskResponseValidationError) Key 

func (e SmallTaskResponseValidationError) Key() bool

Key function returns key value.

func (SmallTaskResponseValidationError) Reason 

func (e SmallTaskResponseValidationError) Reason() string

Reason function returns reason value.

type StatPeerRequest 

type StatPeerRequest struct {

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

StatPeerRequest represents request of StatPeer.

func (*StatPeerRequest) Descriptor deprecated 

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

Deprecated: Use StatPeerRequest.ProtoReflect.Descriptor instead.

func (*StatPeerRequest) GetHostId 

func (x *StatPeerRequest) GetHostId() string

func (*StatPeerRequest) GetPeerId 

func (x *StatPeerRequest) GetPeerId() string

func (*StatPeerRequest) GetTaskId 

func (x *StatPeerRequest) GetTaskId() string

func (*StatPeerRequest) ProtoMessage 

func (*StatPeerRequest) ProtoMessage()

func (*StatPeerRequest) ProtoReflect 

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

func (*StatPeerRequest) Reset 

func (x *StatPeerRequest) Reset()

func (*StatPeerRequest) String 

func (x *StatPeerRequest) String() string

func (*StatPeerRequest) Validate 

func (m *StatPeerRequest) Validate() error

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

func (*StatPeerRequest) ValidateAll 

func (m *StatPeerRequest) ValidateAll() error

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

type StatPeerRequestMultiError 

type StatPeerRequestMultiError []error

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

func (StatPeerRequestMultiError) AllErrors 

func (m StatPeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatPeerRequestMultiError) Error 

func (m StatPeerRequestMultiError) Error() string

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

type StatPeerRequestValidationError 

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

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

func (StatPeerRequestValidationError) Cause 

func (e StatPeerRequestValidationError) Cause() error

Cause function returns cause value.

func (StatPeerRequestValidationError) Error 

func (e StatPeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatPeerRequestValidationError) ErrorName 

func (e StatPeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatPeerRequestValidationError) Field 

func (e StatPeerRequestValidationError) Field() string

Field function returns field value.

func (StatPeerRequestValidationError) Key 

func (e StatPeerRequestValidationError) Key() bool

Key function returns key value.

func (StatPeerRequestValidationError) Reason 

func (e StatPeerRequestValidationError) Reason() string

Reason function returns reason value.

type StatTaskRequest 

type StatTaskRequest struct {

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

StatTaskRequest represents request of StatTask.

func (*StatTaskRequest) Descriptor deprecated 

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

Deprecated: Use StatTaskRequest.ProtoReflect.Descriptor instead.

func (*StatTaskRequest) GetId 

func (x *StatTaskRequest) GetId() string

func (*StatTaskRequest) ProtoMessage 

func (*StatTaskRequest) ProtoMessage()

func (*StatTaskRequest) ProtoReflect 

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

func (*StatTaskRequest) Reset 

func (x *StatTaskRequest) Reset()

func (*StatTaskRequest) String 

func (x *StatTaskRequest) String() string

func (*StatTaskRequest) Validate 

func (m *StatTaskRequest) Validate() error

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

func (*StatTaskRequest) ValidateAll 

func (m *StatTaskRequest) ValidateAll() error

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

type StatTaskRequestMultiError 

type StatTaskRequestMultiError []error

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

func (StatTaskRequestMultiError) AllErrors 

func (m StatTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatTaskRequestMultiError) Error 

func (m StatTaskRequestMultiError) Error() string

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

type StatTaskRequestValidationError 

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

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

func (StatTaskRequestValidationError) Cause 

func (e StatTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (StatTaskRequestValidationError) Error 

func (e StatTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatTaskRequestValidationError) ErrorName 

func (e StatTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatTaskRequestValidationError) Field 

func (e StatTaskRequestValidationError) Field() string

Field function returns field value.

func (StatTaskRequestValidationError) Key 

func (e StatTaskRequestValidationError) Key() bool

Key function returns key value.

func (StatTaskRequestValidationError) Reason 

func (e StatTaskRequestValidationError) Reason() string

Reason function returns reason value.

type SyncPiecesFailedRequest 

type SyncPiecesFailedRequest struct {

	// Parent peer id.
	ParentId string `protobuf:"bytes,1,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	// The description of the error.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

SyncPiecesFailedRequest syncs pieces failed request of AnnouncePeerRequest.

func (*SyncPiecesFailedRequest) Descriptor deprecated 

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

Deprecated: Use SyncPiecesFailedRequest.ProtoReflect.Descriptor instead.

func (*SyncPiecesFailedRequest) GetDescription 

func (x *SyncPiecesFailedRequest) GetDescription() string

func (*SyncPiecesFailedRequest) GetParentId 

func (x *SyncPiecesFailedRequest) GetParentId() string

func (*SyncPiecesFailedRequest) ProtoMessage 

func (*SyncPiecesFailedRequest) ProtoMessage()

func (*SyncPiecesFailedRequest) ProtoReflect 

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

func (*SyncPiecesFailedRequest) Reset 

func (x *SyncPiecesFailedRequest) Reset()

func (*SyncPiecesFailedRequest) String 

func (x *SyncPiecesFailedRequest) String() string

func (*SyncPiecesFailedRequest) Validate 

func (m *SyncPiecesFailedRequest) Validate() error

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

func (m *SyncPiecesFailedRequest) ValidateAll() error

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

type SyncPiecesFailedRequestMultiError 

type SyncPiecesFailedRequestMultiError []error

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

func (SyncPiecesFailedRequestMultiError) AllErrors 

func (m SyncPiecesFailedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncPiecesFailedRequestMultiError) Error 

func (m SyncPiecesFailedRequestMultiError) Error() string

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

type SyncPiecesFailedRequestValidationError 

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

SyncPiecesFailedRequestValidationError is the validation error returned by SyncPiecesFailedRequest.Validate if the designated constraints aren't met.

func (SyncPiecesFailedRequestValidationError) Cause 

func (e SyncPiecesFailedRequestValidationError) Cause() error

Cause function returns cause value.

func (SyncPiecesFailedRequestValidationError) Error 

func (e SyncPiecesFailedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (SyncPiecesFailedRequestValidationError) ErrorName 

func (e SyncPiecesFailedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (SyncPiecesFailedRequestValidationError) Field 

func (e SyncPiecesFailedRequestValidationError) Field() string

Field function returns field value.

func (SyncPiecesFailedRequestValidationError) Key 

func (e SyncPiecesFailedRequestValidationError) Key() bool

Key function returns key value.

func (SyncPiecesFailedRequestValidationError) Reason 

func (e SyncPiecesFailedRequestValidationError) 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 TinyTaskResponse 

type TinyTaskResponse struct {

	// Tiny task content.
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

TinyTaskResponse represents tiny task response of AnnouncePeerResponse.

func (*TinyTaskResponse) Descriptor deprecated 

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

Deprecated: Use TinyTaskResponse.ProtoReflect.Descriptor instead.

func (*TinyTaskResponse) GetContent 

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

func (*TinyTaskResponse) ProtoMessage 

func (*TinyTaskResponse) ProtoMessage()

func (*TinyTaskResponse) ProtoReflect 

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

func (*TinyTaskResponse) Reset 

func (x *TinyTaskResponse) Reset()

func (*TinyTaskResponse) String 

func (x *TinyTaskResponse) String() string

func (*TinyTaskResponse) Validate 

func (m *TinyTaskResponse) Validate() error

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

func (*TinyTaskResponse) ValidateAll 

func (m *TinyTaskResponse) ValidateAll() error

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

type TinyTaskResponseMultiError 

type TinyTaskResponseMultiError []error

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

func (TinyTaskResponseMultiError) AllErrors 

func (m TinyTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TinyTaskResponseMultiError) Error 

func (m TinyTaskResponseMultiError) Error() string

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

type TinyTaskResponseValidationError 

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

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

func (TinyTaskResponseValidationError) Cause 

func (e TinyTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (TinyTaskResponseValidationError) Error 

func (e TinyTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (TinyTaskResponseValidationError) ErrorName 

func (e TinyTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (TinyTaskResponseValidationError) Field 

func (e TinyTaskResponseValidationError) Field() string

Field function returns field value.

func (TinyTaskResponseValidationError) Key 

func (e TinyTaskResponseValidationError) Key() bool

Key function returns key value.

func (TinyTaskResponseValidationError) Reason 

func (e TinyTaskResponseValidationError) Reason() string

Reason function returns reason value.

type UnimplementedSchedulerServer 

type UnimplementedSchedulerServer struct {
}

UnimplementedSchedulerServer should be embedded to have forward compatible implementations.

func (UnimplementedSchedulerServer) AnnounceHost 

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

func (UnimplementedSchedulerServer) AnnouncePeer 

func (UnimplementedSchedulerServer) AnnouncePeer(Scheduler_AnnouncePeerServer) error

func (UnimplementedSchedulerServer) ExchangePeer 

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

func (UnimplementedSchedulerServer) LeaveHost 

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

func (UnimplementedSchedulerServer) LeavePeer 

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

func (UnimplementedSchedulerServer) StatPeer 

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

func (UnimplementedSchedulerServer) StatTask 

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

func (UnimplementedSchedulerServer) SyncProbes 

func (UnimplementedSchedulerServer) SyncProbes(Scheduler_SyncProbesServer) error

type UnsafeSchedulerServer 

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

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

Source Files

View all Source files

Directories

Path Synopsis
Code generated by MockGen.
 Code generated by MockGen.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.