scheduler

package
v2.0.150 Latest Latest
Warning

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

Go to latest
Published: Aug 19, 2024 License: Apache-2.0 Imports: 26 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: "DeletePeer",
			Handler:    _Scheduler_DeletePeer_Handler,
		},
		{
			MethodName: "StatTask",
			Handler:    _Scheduler_StatTask_Handler,
		},
		{
			MethodName: "DeleteTask",
			Handler:    _Scheduler_DeleteTask_Handler,
		},
		{
			MethodName: "AnnounceHost",
			Handler:    _Scheduler_AnnounceHost_Handler,
		},
		{
			MethodName: "DeleteHost",
			Handler:    _Scheduler_DeleteHost_Handler,
		},
		{
			MethodName: "StatCachePeer",
			Handler:    _Scheduler_StatCachePeer_Handler,
		},
		{
			MethodName: "DeleteCachePeer",
			Handler:    _Scheduler_DeleteCachePeer_Handler,
		},
		{
			MethodName: "UploadCacheTaskStarted",
			Handler:    _Scheduler_UploadCacheTaskStarted_Handler,
		},
		{
			MethodName: "UploadCacheTaskFinished",
			Handler:    _Scheduler_UploadCacheTaskFinished_Handler,
		},
		{
			MethodName: "UploadCacheTaskFailed",
			Handler:    _Scheduler_UploadCacheTaskFailed_Handler,
		},
		{
			MethodName: "StatCacheTask",
			Handler:    _Scheduler_StatCacheTask_Handler,
		},
		{
			MethodName: "DeleteCacheTask",
			Handler:    _Scheduler_DeleteCacheTask_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "AnnouncePeer",
			Handler:       _Scheduler_AnnouncePeer_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "AnnouncePeers",
			Handler:       _Scheduler_AnnouncePeers_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SyncProbes",
			Handler:       _Scheduler_SyncProbes_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "AnnounceCachePeer",
			Handler:       _Scheduler_AnnounceCachePeer_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/apis/scheduler/v2/scheduler.proto",
}

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

Functions

func RegisterSchedulerServer

func RegisterSchedulerServer(s grpc.ServiceRegistrar, srv SchedulerServer)

Types

type AnnounceCachePeerRequest added in v2.0.121

type AnnounceCachePeerRequest struct {

	// Host id.
	HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// Task id.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Peer id.
	PeerId string `protobuf:"bytes,3,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// Types that are assignable to Request:
	//
	//	*AnnounceCachePeerRequest_RegisterCachePeerRequest
	//	*AnnounceCachePeerRequest_DownloadCachePeerStartedRequest
	//	*AnnounceCachePeerRequest_RescheduleCachePeerRequest
	//	*AnnounceCachePeerRequest_DownloadCachePeerFinishedRequest
	//	*AnnounceCachePeerRequest_DownloadCachePeerFailedRequest
	//	*AnnounceCachePeerRequest_DownloadPieceFinishedRequest
	//	*AnnounceCachePeerRequest_DownloadPieceFailedRequest
	Request isAnnounceCachePeerRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

AnnounceCachePeerRequest represents request of AnnounceCachePeer.

func (*AnnounceCachePeerRequest) Descriptor deprecated added in v2.0.121

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

Deprecated: Use AnnounceCachePeerRequest.ProtoReflect.Descriptor instead.

func (*AnnounceCachePeerRequest) GetDownloadCachePeerFailedRequest added in v2.0.121

func (x *AnnounceCachePeerRequest) GetDownloadCachePeerFailedRequest() *DownloadCachePeerFailedRequest

func (*AnnounceCachePeerRequest) GetDownloadCachePeerFinishedRequest added in v2.0.121

func (x *AnnounceCachePeerRequest) GetDownloadCachePeerFinishedRequest() *DownloadCachePeerFinishedRequest

func (*AnnounceCachePeerRequest) GetDownloadCachePeerStartedRequest added in v2.0.121

func (x *AnnounceCachePeerRequest) GetDownloadCachePeerStartedRequest() *DownloadCachePeerStartedRequest

func (*AnnounceCachePeerRequest) GetDownloadPieceFailedRequest added in v2.0.121

func (x *AnnounceCachePeerRequest) GetDownloadPieceFailedRequest() *DownloadPieceFailedRequest

func (*AnnounceCachePeerRequest) GetDownloadPieceFinishedRequest added in v2.0.121

func (x *AnnounceCachePeerRequest) GetDownloadPieceFinishedRequest() *DownloadPieceFinishedRequest

func (*AnnounceCachePeerRequest) GetHostId added in v2.0.121

func (x *AnnounceCachePeerRequest) GetHostId() string

func (*AnnounceCachePeerRequest) GetPeerId added in v2.0.121

func (x *AnnounceCachePeerRequest) GetPeerId() string

func (*AnnounceCachePeerRequest) GetRegisterCachePeerRequest added in v2.0.121

func (x *AnnounceCachePeerRequest) GetRegisterCachePeerRequest() *RegisterCachePeerRequest

func (*AnnounceCachePeerRequest) GetRequest added in v2.0.121

func (m *AnnounceCachePeerRequest) GetRequest() isAnnounceCachePeerRequest_Request

func (*AnnounceCachePeerRequest) GetRescheduleCachePeerRequest added in v2.0.121

func (x *AnnounceCachePeerRequest) GetRescheduleCachePeerRequest() *RescheduleCachePeerRequest

func (*AnnounceCachePeerRequest) GetTaskId added in v2.0.121

func (x *AnnounceCachePeerRequest) GetTaskId() string

func (*AnnounceCachePeerRequest) ProtoMessage added in v2.0.121

func (*AnnounceCachePeerRequest) ProtoMessage()

func (*AnnounceCachePeerRequest) ProtoReflect added in v2.0.121

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

func (*AnnounceCachePeerRequest) Reset added in v2.0.121

func (x *AnnounceCachePeerRequest) Reset()

func (*AnnounceCachePeerRequest) String added in v2.0.121

func (x *AnnounceCachePeerRequest) String() string

func (*AnnounceCachePeerRequest) Validate added in v2.0.121

func (m *AnnounceCachePeerRequest) Validate() error

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

func (*AnnounceCachePeerRequest) ValidateAll added in v2.0.121

func (m *AnnounceCachePeerRequest) ValidateAll() error

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

type AnnounceCachePeerRequestMultiError added in v2.0.121

type AnnounceCachePeerRequestMultiError []error

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

func (AnnounceCachePeerRequestMultiError) AllErrors added in v2.0.121

func (m AnnounceCachePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnounceCachePeerRequestMultiError) Error added in v2.0.121

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

type AnnounceCachePeerRequestValidationError added in v2.0.121

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

AnnounceCachePeerRequestValidationError is the validation error returned by AnnounceCachePeerRequest.Validate if the designated constraints aren't met.

func (AnnounceCachePeerRequestValidationError) Cause added in v2.0.121

Cause function returns cause value.

func (AnnounceCachePeerRequestValidationError) Error added in v2.0.121

Error satisfies the builtin error interface

func (AnnounceCachePeerRequestValidationError) ErrorName added in v2.0.121

ErrorName returns error name.

func (AnnounceCachePeerRequestValidationError) Field added in v2.0.121

Field function returns field value.

func (AnnounceCachePeerRequestValidationError) Key added in v2.0.121

Key function returns key value.

func (AnnounceCachePeerRequestValidationError) Reason added in v2.0.121

Reason function returns reason value.

type AnnounceCachePeerRequest_DownloadCachePeerFailedRequest added in v2.0.121

type AnnounceCachePeerRequest_DownloadCachePeerFailedRequest struct {
	DownloadCachePeerFailedRequest *DownloadCachePeerFailedRequest `protobuf:"bytes,8,opt,name=download_cache_peer_failed_request,json=downloadCachePeerFailedRequest,proto3,oneof"`
}

type AnnounceCachePeerRequest_DownloadCachePeerFinishedRequest added in v2.0.121

type AnnounceCachePeerRequest_DownloadCachePeerFinishedRequest struct {
	DownloadCachePeerFinishedRequest *DownloadCachePeerFinishedRequest `protobuf:"bytes,7,opt,name=download_cache_peer_finished_request,json=downloadCachePeerFinishedRequest,proto3,oneof"`
}

type AnnounceCachePeerRequest_DownloadCachePeerStartedRequest added in v2.0.121

type AnnounceCachePeerRequest_DownloadCachePeerStartedRequest struct {
	DownloadCachePeerStartedRequest *DownloadCachePeerStartedRequest `protobuf:"bytes,5,opt,name=download_cache_peer_started_request,json=downloadCachePeerStartedRequest,proto3,oneof"`
}

type AnnounceCachePeerRequest_DownloadPieceFailedRequest added in v2.0.121

type AnnounceCachePeerRequest_DownloadPieceFailedRequest struct {
	DownloadPieceFailedRequest *DownloadPieceFailedRequest `protobuf:"bytes,10,opt,name=download_piece_failed_request,json=downloadPieceFailedRequest,proto3,oneof"`
}

type AnnounceCachePeerRequest_DownloadPieceFinishedRequest added in v2.0.121

type AnnounceCachePeerRequest_DownloadPieceFinishedRequest struct {
	DownloadPieceFinishedRequest *DownloadPieceFinishedRequest `protobuf:"bytes,9,opt,name=download_piece_finished_request,json=downloadPieceFinishedRequest,proto3,oneof"`
}

type AnnounceCachePeerRequest_RegisterCachePeerRequest added in v2.0.121

type AnnounceCachePeerRequest_RegisterCachePeerRequest struct {
	RegisterCachePeerRequest *RegisterCachePeerRequest `protobuf:"bytes,4,opt,name=register_cache_peer_request,json=registerCachePeerRequest,proto3,oneof"`
}

type AnnounceCachePeerRequest_RescheduleCachePeerRequest added in v2.0.121

type AnnounceCachePeerRequest_RescheduleCachePeerRequest struct {
	RescheduleCachePeerRequest *RescheduleCachePeerRequest `protobuf:"bytes,6,opt,name=reschedule_cache_peer_request,json=rescheduleCachePeerRequest,proto3,oneof"`
}

type AnnounceCachePeerResponse added in v2.0.121

type AnnounceCachePeerResponse struct {

	// Types that are assignable to Response:
	//
	//	*AnnounceCachePeerResponse_EmptyCacheTaskResponse
	//	*AnnounceCachePeerResponse_NormalCacheTaskResponse
	Response isAnnounceCachePeerResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

AnnounceCachePeerResponse represents response of AnnounceCachePeer.

func (*AnnounceCachePeerResponse) Descriptor deprecated added in v2.0.121

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

Deprecated: Use AnnounceCachePeerResponse.ProtoReflect.Descriptor instead.

func (*AnnounceCachePeerResponse) GetEmptyCacheTaskResponse added in v2.0.139

func (x *AnnounceCachePeerResponse) GetEmptyCacheTaskResponse() *EmptyCacheTaskResponse

func (*AnnounceCachePeerResponse) GetNormalCacheTaskResponse added in v2.0.139

func (x *AnnounceCachePeerResponse) GetNormalCacheTaskResponse() *NormalCacheTaskResponse

func (*AnnounceCachePeerResponse) GetResponse added in v2.0.121

func (m *AnnounceCachePeerResponse) GetResponse() isAnnounceCachePeerResponse_Response

func (*AnnounceCachePeerResponse) ProtoMessage added in v2.0.121

func (*AnnounceCachePeerResponse) ProtoMessage()

func (*AnnounceCachePeerResponse) ProtoReflect added in v2.0.121

func (*AnnounceCachePeerResponse) Reset added in v2.0.121

func (x *AnnounceCachePeerResponse) Reset()

func (*AnnounceCachePeerResponse) String added in v2.0.121

func (x *AnnounceCachePeerResponse) String() string

func (*AnnounceCachePeerResponse) Validate added in v2.0.121

func (m *AnnounceCachePeerResponse) Validate() error

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

func (*AnnounceCachePeerResponse) ValidateAll added in v2.0.121

func (m *AnnounceCachePeerResponse) ValidateAll() error

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

type AnnounceCachePeerResponseMultiError added in v2.0.121

type AnnounceCachePeerResponseMultiError []error

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

func (AnnounceCachePeerResponseMultiError) AllErrors added in v2.0.121

AllErrors returns a list of validation violation errors.

func (AnnounceCachePeerResponseMultiError) Error added in v2.0.121

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

type AnnounceCachePeerResponseValidationError added in v2.0.121

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

AnnounceCachePeerResponseValidationError is the validation error returned by AnnounceCachePeerResponse.Validate if the designated constraints aren't met.

func (AnnounceCachePeerResponseValidationError) Cause added in v2.0.121

Cause function returns cause value.

func (AnnounceCachePeerResponseValidationError) Error added in v2.0.121

Error satisfies the builtin error interface

func (AnnounceCachePeerResponseValidationError) ErrorName added in v2.0.121

ErrorName returns error name.

func (AnnounceCachePeerResponseValidationError) Field added in v2.0.121

Field function returns field value.

func (AnnounceCachePeerResponseValidationError) Key added in v2.0.121

Key function returns key value.

func (AnnounceCachePeerResponseValidationError) Reason added in v2.0.121

Reason function returns reason value.

type AnnounceCachePeerResponse_EmptyCacheTaskResponse added in v2.0.139

type AnnounceCachePeerResponse_EmptyCacheTaskResponse struct {
	EmptyCacheTaskResponse *EmptyCacheTaskResponse `protobuf:"bytes,1,opt,name=empty_cache_task_response,json=emptyCacheTaskResponse,proto3,oneof"`
}

type AnnounceCachePeerResponse_NormalCacheTaskResponse added in v2.0.139

type AnnounceCachePeerResponse_NormalCacheTaskResponse struct {
	NormalCacheTaskResponse *NormalCacheTaskResponse `protobuf:"bytes,2,opt,name=normal_cache_task_response,json=normalCacheTaskResponse,proto3,oneof"`
}

type AnnounceHostRequest

type AnnounceHostRequest struct {

	// Host info.
	Host *v2.Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// The interval between dfdaemon announces to scheduler.
	Interval *durationpb.Duration `protobuf:"bytes,2,opt,name=interval,proto3,oneof" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

AnnounceHostRequest represents request of AnnounceHost.

func (*AnnounceHostRequest) Descriptor deprecated

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

Deprecated: Use AnnounceHostRequest.ProtoReflect.Descriptor instead.

func (*AnnounceHostRequest) GetHost

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

func (*AnnounceHostRequest) GetInterval added in v2.0.125

func (x *AnnounceHostRequest) GetInterval() *durationpb.Duration

func (*AnnounceHostRequest) ProtoMessage

func (*AnnounceHostRequest) ProtoMessage()

func (*AnnounceHostRequest) ProtoReflect

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

func (*AnnounceHostRequest) Reset

func (x *AnnounceHostRequest) Reset()

func (*AnnounceHostRequest) String

func (x *AnnounceHostRequest) String() string

func (*AnnounceHostRequest) Validate

func (m *AnnounceHostRequest) Validate() error

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

func (*AnnounceHostRequest) ValidateAll

func (m *AnnounceHostRequest) ValidateAll() error

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

type AnnounceHostRequestMultiError

type AnnounceHostRequestMultiError []error

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

func (AnnounceHostRequestMultiError) AllErrors

func (m AnnounceHostRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnounceHostRequestMultiError) Error

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

Cause function returns cause value.

func (AnnounceHostRequestValidationError) Error

Error satisfies the builtin error interface

func (AnnounceHostRequestValidationError) ErrorName

ErrorName returns error name.

func (AnnounceHostRequestValidationError) Field

Field function returns field value.

func (AnnounceHostRequestValidationError) Key

Key function returns key value.

func (AnnounceHostRequestValidationError) Reason

Reason function returns reason value.

type AnnouncePeerRequest

type AnnouncePeerRequest struct {

	// Host id.
	HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// Task id.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Peer id.
	PeerId string `protobuf:"bytes,3,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// Types that are assignable to Request:
	//
	//	*AnnouncePeerRequest_RegisterPeerRequest
	//	*AnnouncePeerRequest_DownloadPeerStartedRequest
	//	*AnnouncePeerRequest_DownloadPeerBackToSourceStartedRequest
	//	*AnnouncePeerRequest_ReschedulePeerRequest
	//	*AnnouncePeerRequest_DownloadPeerFinishedRequest
	//	*AnnouncePeerRequest_DownloadPeerBackToSourceFinishedRequest
	//	*AnnouncePeerRequest_DownloadPeerFailedRequest
	//	*AnnouncePeerRequest_DownloadPeerBackToSourceFailedRequest
	//	*AnnouncePeerRequest_DownloadPieceFinishedRequest
	//	*AnnouncePeerRequest_DownloadPieceBackToSourceFinishedRequest
	//	*AnnouncePeerRequest_DownloadPieceFailedRequest
	//	*AnnouncePeerRequest_DownloadPieceBackToSourceFailedRequest
	Request isAnnouncePeerRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

AnnouncePeerRequest represents request of AnnouncePeer.

func (*AnnouncePeerRequest) Descriptor deprecated

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

Deprecated: Use AnnouncePeerRequest.ProtoReflect.Descriptor instead.

func (*AnnouncePeerRequest) GetDownloadPeerBackToSourceFailedRequest

func (x *AnnouncePeerRequest) GetDownloadPeerBackToSourceFailedRequest() *DownloadPeerBackToSourceFailedRequest

func (*AnnouncePeerRequest) GetDownloadPeerBackToSourceFinishedRequest

func (x *AnnouncePeerRequest) GetDownloadPeerBackToSourceFinishedRequest() *DownloadPeerBackToSourceFinishedRequest

func (*AnnouncePeerRequest) GetDownloadPeerBackToSourceStartedRequest

func (x *AnnouncePeerRequest) GetDownloadPeerBackToSourceStartedRequest() *DownloadPeerBackToSourceStartedRequest

func (*AnnouncePeerRequest) GetDownloadPeerFailedRequest

func (x *AnnouncePeerRequest) GetDownloadPeerFailedRequest() *DownloadPeerFailedRequest

func (*AnnouncePeerRequest) GetDownloadPeerFinishedRequest

func (x *AnnouncePeerRequest) GetDownloadPeerFinishedRequest() *DownloadPeerFinishedRequest

func (*AnnouncePeerRequest) GetDownloadPeerStartedRequest

func (x *AnnouncePeerRequest) GetDownloadPeerStartedRequest() *DownloadPeerStartedRequest

func (*AnnouncePeerRequest) GetDownloadPieceBackToSourceFailedRequest

func (x *AnnouncePeerRequest) GetDownloadPieceBackToSourceFailedRequest() *DownloadPieceBackToSourceFailedRequest

func (*AnnouncePeerRequest) GetDownloadPieceBackToSourceFinishedRequest

func (x *AnnouncePeerRequest) GetDownloadPieceBackToSourceFinishedRequest() *DownloadPieceBackToSourceFinishedRequest

func (*AnnouncePeerRequest) GetDownloadPieceFailedRequest

func (x *AnnouncePeerRequest) GetDownloadPieceFailedRequest() *DownloadPieceFailedRequest

func (*AnnouncePeerRequest) GetDownloadPieceFinishedRequest

func (x *AnnouncePeerRequest) GetDownloadPieceFinishedRequest() *DownloadPieceFinishedRequest

func (*AnnouncePeerRequest) GetHostId

func (x *AnnouncePeerRequest) GetHostId() string

func (*AnnouncePeerRequest) GetPeerId

func (x *AnnouncePeerRequest) GetPeerId() string

func (*AnnouncePeerRequest) GetRegisterPeerRequest

func (x *AnnouncePeerRequest) GetRegisterPeerRequest() *RegisterPeerRequest

func (*AnnouncePeerRequest) GetRequest

func (m *AnnouncePeerRequest) GetRequest() isAnnouncePeerRequest_Request

func (*AnnouncePeerRequest) GetReschedulePeerRequest added in v2.0.121

func (x *AnnouncePeerRequest) GetReschedulePeerRequest() *ReschedulePeerRequest

func (*AnnouncePeerRequest) GetTaskId

func (x *AnnouncePeerRequest) GetTaskId() string

func (*AnnouncePeerRequest) ProtoMessage

func (*AnnouncePeerRequest) ProtoMessage()

func (*AnnouncePeerRequest) ProtoReflect

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

func (*AnnouncePeerRequest) Reset

func (x *AnnouncePeerRequest) Reset()

func (*AnnouncePeerRequest) String

func (x *AnnouncePeerRequest) String() string

func (*AnnouncePeerRequest) Validate

func (m *AnnouncePeerRequest) Validate() error

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

func (*AnnouncePeerRequest) ValidateAll

func (m *AnnouncePeerRequest) ValidateAll() error

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

type AnnouncePeerRequestMultiError

type AnnouncePeerRequestMultiError []error

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

func (AnnouncePeerRequestMultiError) AllErrors

func (m AnnouncePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnouncePeerRequestMultiError) Error

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

Cause function returns cause value.

func (AnnouncePeerRequestValidationError) Error

Error satisfies the builtin error interface

func (AnnouncePeerRequestValidationError) ErrorName

ErrorName returns error name.

func (AnnouncePeerRequestValidationError) Field

Field function returns field value.

func (AnnouncePeerRequestValidationError) Key

Key function returns key value.

func (AnnouncePeerRequestValidationError) Reason

Reason function returns reason value.

type AnnouncePeerRequest_DownloadPeerBackToSourceFailedRequest

type AnnouncePeerRequest_DownloadPeerBackToSourceFailedRequest struct {
	DownloadPeerBackToSourceFailedRequest *DownloadPeerBackToSourceFailedRequest `` /* 128-byte string literal not displayed */
}

type AnnouncePeerRequest_DownloadPeerBackToSourceFinishedRequest

type AnnouncePeerRequest_DownloadPeerBackToSourceFinishedRequest struct {
	DownloadPeerBackToSourceFinishedRequest *DownloadPeerBackToSourceFinishedRequest `` /* 131-byte string literal not displayed */
}

type AnnouncePeerRequest_DownloadPeerBackToSourceStartedRequest

type AnnouncePeerRequest_DownloadPeerBackToSourceStartedRequest struct {
	DownloadPeerBackToSourceStartedRequest *DownloadPeerBackToSourceStartedRequest `` /* 129-byte string literal not displayed */
}

type AnnouncePeerRequest_DownloadPeerFailedRequest

type AnnouncePeerRequest_DownloadPeerFailedRequest struct {
	DownloadPeerFailedRequest *DownloadPeerFailedRequest `protobuf:"bytes,10,opt,name=download_peer_failed_request,json=downloadPeerFailedRequest,proto3,oneof"`
}

type AnnouncePeerRequest_DownloadPeerFinishedRequest

type AnnouncePeerRequest_DownloadPeerFinishedRequest struct {
	DownloadPeerFinishedRequest *DownloadPeerFinishedRequest `protobuf:"bytes,8,opt,name=download_peer_finished_request,json=downloadPeerFinishedRequest,proto3,oneof"`
}

type AnnouncePeerRequest_DownloadPeerStartedRequest

type AnnouncePeerRequest_DownloadPeerStartedRequest struct {
	DownloadPeerStartedRequest *DownloadPeerStartedRequest `protobuf:"bytes,5,opt,name=download_peer_started_request,json=downloadPeerStartedRequest,proto3,oneof"`
}

type AnnouncePeerRequest_DownloadPieceBackToSourceFailedRequest

type AnnouncePeerRequest_DownloadPieceBackToSourceFailedRequest struct {
	DownloadPieceBackToSourceFailedRequest *DownloadPieceBackToSourceFailedRequest `` /* 130-byte string literal not displayed */
}

type AnnouncePeerRequest_DownloadPieceBackToSourceFinishedRequest

type AnnouncePeerRequest_DownloadPieceBackToSourceFinishedRequest struct {
	DownloadPieceBackToSourceFinishedRequest *DownloadPieceBackToSourceFinishedRequest `` /* 134-byte string literal not displayed */
}

type AnnouncePeerRequest_DownloadPieceFailedRequest

type AnnouncePeerRequest_DownloadPieceFailedRequest struct {
	DownloadPieceFailedRequest *DownloadPieceFailedRequest `protobuf:"bytes,14,opt,name=download_piece_failed_request,json=downloadPieceFailedRequest,proto3,oneof"`
}

type AnnouncePeerRequest_DownloadPieceFinishedRequest

type AnnouncePeerRequest_DownloadPieceFinishedRequest struct {
	DownloadPieceFinishedRequest *DownloadPieceFinishedRequest `protobuf:"bytes,12,opt,name=download_piece_finished_request,json=downloadPieceFinishedRequest,proto3,oneof"`
}

type AnnouncePeerRequest_RegisterPeerRequest

type AnnouncePeerRequest_RegisterPeerRequest struct {
	RegisterPeerRequest *RegisterPeerRequest `protobuf:"bytes,4,opt,name=register_peer_request,json=registerPeerRequest,proto3,oneof"`
}

type AnnouncePeerRequest_ReschedulePeerRequest added in v2.0.121

type AnnouncePeerRequest_ReschedulePeerRequest struct {
	ReschedulePeerRequest *ReschedulePeerRequest `protobuf:"bytes,7,opt,name=reschedule_peer_request,json=reschedulePeerRequest,proto3,oneof"`
}

type AnnouncePeerResponse

type AnnouncePeerResponse struct {

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

AnnouncePeerResponse represents response of AnnouncePeer.

func (*AnnouncePeerResponse) Descriptor deprecated

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

Deprecated: Use AnnouncePeerResponse.ProtoReflect.Descriptor instead.

func (*AnnouncePeerResponse) GetEmptyTaskResponse

func (x *AnnouncePeerResponse) GetEmptyTaskResponse() *EmptyTaskResponse

func (*AnnouncePeerResponse) GetNeedBackToSourceResponse

func (x *AnnouncePeerResponse) GetNeedBackToSourceResponse() *NeedBackToSourceResponse

func (*AnnouncePeerResponse) GetNormalTaskResponse

func (x *AnnouncePeerResponse) GetNormalTaskResponse() *NormalTaskResponse

func (*AnnouncePeerResponse) GetResponse

func (m *AnnouncePeerResponse) GetResponse() isAnnouncePeerResponse_Response

func (*AnnouncePeerResponse) ProtoMessage

func (*AnnouncePeerResponse) ProtoMessage()

func (*AnnouncePeerResponse) ProtoReflect

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

func (*AnnouncePeerResponse) Reset

func (x *AnnouncePeerResponse) Reset()

func (*AnnouncePeerResponse) String

func (x *AnnouncePeerResponse) String() string

func (*AnnouncePeerResponse) Validate

func (m *AnnouncePeerResponse) Validate() error

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

func (*AnnouncePeerResponse) ValidateAll

func (m *AnnouncePeerResponse) ValidateAll() error

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

type AnnouncePeerResponseMultiError

type AnnouncePeerResponseMultiError []error

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

func (AnnouncePeerResponseMultiError) AllErrors

func (m AnnouncePeerResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnouncePeerResponseMultiError) Error

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

Cause function returns cause value.

func (AnnouncePeerResponseValidationError) Error

Error satisfies the builtin error interface

func (AnnouncePeerResponseValidationError) ErrorName

ErrorName returns error name.

func (AnnouncePeerResponseValidationError) Field

Field function returns field value.

func (AnnouncePeerResponseValidationError) Key

Key function returns key value.

func (AnnouncePeerResponseValidationError) Reason

Reason function returns reason value.

type AnnouncePeerResponse_EmptyTaskResponse

type AnnouncePeerResponse_EmptyTaskResponse struct {
	EmptyTaskResponse *EmptyTaskResponse `protobuf:"bytes,1,opt,name=empty_task_response,json=emptyTaskResponse,proto3,oneof"`
}

type AnnouncePeerResponse_NeedBackToSourceResponse

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

type AnnouncePeerResponse_NormalTaskResponse

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

type AnnouncePeersRequest added in v2.0.133

type AnnouncePeersRequest struct {

	// Peers information.
	Peers []*v2.Peer `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

AnnouncePeersRequest represents request of AnnouncePeers.

func (*AnnouncePeersRequest) Descriptor deprecated added in v2.0.133

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

Deprecated: Use AnnouncePeersRequest.ProtoReflect.Descriptor instead.

func (*AnnouncePeersRequest) GetPeers added in v2.0.133

func (x *AnnouncePeersRequest) GetPeers() []*v2.Peer

func (*AnnouncePeersRequest) ProtoMessage added in v2.0.133

func (*AnnouncePeersRequest) ProtoMessage()

func (*AnnouncePeersRequest) ProtoReflect added in v2.0.133

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

func (*AnnouncePeersRequest) Reset added in v2.0.133

func (x *AnnouncePeersRequest) Reset()

func (*AnnouncePeersRequest) String added in v2.0.133

func (x *AnnouncePeersRequest) String() string

func (*AnnouncePeersRequest) Validate added in v2.0.133

func (m *AnnouncePeersRequest) Validate() error

Validate checks the field values on AnnouncePeersRequest 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 (*AnnouncePeersRequest) ValidateAll added in v2.0.133

func (m *AnnouncePeersRequest) ValidateAll() error

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

type AnnouncePeersRequestMultiError added in v2.0.133

type AnnouncePeersRequestMultiError []error

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

func (AnnouncePeersRequestMultiError) AllErrors added in v2.0.133

func (m AnnouncePeersRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnouncePeersRequestMultiError) Error added in v2.0.133

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

type AnnouncePeersRequestValidationError added in v2.0.133

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

AnnouncePeersRequestValidationError is the validation error returned by AnnouncePeersRequest.Validate if the designated constraints aren't met.

func (AnnouncePeersRequestValidationError) Cause added in v2.0.133

Cause function returns cause value.

func (AnnouncePeersRequestValidationError) Error added in v2.0.133

Error satisfies the builtin error interface

func (AnnouncePeersRequestValidationError) ErrorName added in v2.0.133

ErrorName returns error name.

func (AnnouncePeersRequestValidationError) Field added in v2.0.133

Field function returns field value.

func (AnnouncePeersRequestValidationError) Key added in v2.0.133

Key function returns key value.

func (AnnouncePeersRequestValidationError) Reason added in v2.0.133

Reason function returns reason value.

type DeleteCachePeerRequest added in v2.0.121

type DeleteCachePeerRequest struct {

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

DeleteCachePeerRequest represents request of DeleteCachePeer.

func (*DeleteCachePeerRequest) Descriptor deprecated added in v2.0.121

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

Deprecated: Use DeleteCachePeerRequest.ProtoReflect.Descriptor instead.

func (*DeleteCachePeerRequest) GetHostId added in v2.0.121

func (x *DeleteCachePeerRequest) GetHostId() string

func (*DeleteCachePeerRequest) GetPeerId added in v2.0.121

func (x *DeleteCachePeerRequest) GetPeerId() string

func (*DeleteCachePeerRequest) GetTaskId added in v2.0.121

func (x *DeleteCachePeerRequest) GetTaskId() string

func (*DeleteCachePeerRequest) ProtoMessage added in v2.0.121

func (*DeleteCachePeerRequest) ProtoMessage()

func (*DeleteCachePeerRequest) ProtoReflect added in v2.0.121

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

func (*DeleteCachePeerRequest) Reset added in v2.0.121

func (x *DeleteCachePeerRequest) Reset()

func (*DeleteCachePeerRequest) String added in v2.0.121

func (x *DeleteCachePeerRequest) String() string

func (*DeleteCachePeerRequest) Validate added in v2.0.121

func (m *DeleteCachePeerRequest) Validate() error

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

func (*DeleteCachePeerRequest) ValidateAll added in v2.0.121

func (m *DeleteCachePeerRequest) ValidateAll() error

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

type DeleteCachePeerRequestMultiError added in v2.0.121

type DeleteCachePeerRequestMultiError []error

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

func (DeleteCachePeerRequestMultiError) AllErrors added in v2.0.121

func (m DeleteCachePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteCachePeerRequestMultiError) Error added in v2.0.121

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

type DeleteCachePeerRequestValidationError added in v2.0.121

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

DeleteCachePeerRequestValidationError is the validation error returned by DeleteCachePeerRequest.Validate if the designated constraints aren't met.

func (DeleteCachePeerRequestValidationError) Cause added in v2.0.121

Cause function returns cause value.

func (DeleteCachePeerRequestValidationError) Error added in v2.0.121

Error satisfies the builtin error interface

func (DeleteCachePeerRequestValidationError) ErrorName added in v2.0.121

ErrorName returns error name.

func (DeleteCachePeerRequestValidationError) Field added in v2.0.121

Field function returns field value.

func (DeleteCachePeerRequestValidationError) Key added in v2.0.121

Key function returns key value.

func (DeleteCachePeerRequestValidationError) Reason added in v2.0.121

Reason function returns reason value.

type DeleteCacheTaskRequest added in v2.0.121

type DeleteCacheTaskRequest struct {

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

DeleteCacheTaskRequest represents request of DeleteCacheTask.

func (*DeleteCacheTaskRequest) Descriptor deprecated added in v2.0.121

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

Deprecated: Use DeleteCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteCacheTaskRequest) GetHostId added in v2.0.121

func (x *DeleteCacheTaskRequest) GetHostId() string

func (*DeleteCacheTaskRequest) GetTaskId added in v2.0.121

func (x *DeleteCacheTaskRequest) GetTaskId() string

func (*DeleteCacheTaskRequest) ProtoMessage added in v2.0.121

func (*DeleteCacheTaskRequest) ProtoMessage()

func (*DeleteCacheTaskRequest) ProtoReflect added in v2.0.121

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

func (*DeleteCacheTaskRequest) Reset added in v2.0.121

func (x *DeleteCacheTaskRequest) Reset()

func (*DeleteCacheTaskRequest) String added in v2.0.121

func (x *DeleteCacheTaskRequest) String() string

func (*DeleteCacheTaskRequest) Validate added in v2.0.121

func (m *DeleteCacheTaskRequest) Validate() error

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

func (*DeleteCacheTaskRequest) ValidateAll added in v2.0.121

func (m *DeleteCacheTaskRequest) ValidateAll() error

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

type DeleteCacheTaskRequestMultiError added in v2.0.121

type DeleteCacheTaskRequestMultiError []error

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

func (DeleteCacheTaskRequestMultiError) AllErrors added in v2.0.121

func (m DeleteCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteCacheTaskRequestMultiError) Error added in v2.0.121

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

type DeleteCacheTaskRequestValidationError added in v2.0.121

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

DeleteCacheTaskRequestValidationError is the validation error returned by DeleteCacheTaskRequest.Validate if the designated constraints aren't met.

func (DeleteCacheTaskRequestValidationError) Cause added in v2.0.121

Cause function returns cause value.

func (DeleteCacheTaskRequestValidationError) Error added in v2.0.121

Error satisfies the builtin error interface

func (DeleteCacheTaskRequestValidationError) ErrorName added in v2.0.121

ErrorName returns error name.

func (DeleteCacheTaskRequestValidationError) Field added in v2.0.121

Field function returns field value.

func (DeleteCacheTaskRequestValidationError) Key added in v2.0.121

Key function returns key value.

func (DeleteCacheTaskRequestValidationError) Reason added in v2.0.121

Reason function returns reason value.

type DeleteHostRequest added in v2.0.118

type DeleteHostRequest struct {

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

DeleteHostRequest represents request of DeleteHost.

func (*DeleteHostRequest) Descriptor deprecated added in v2.0.118

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

Deprecated: Use DeleteHostRequest.ProtoReflect.Descriptor instead.

func (*DeleteHostRequest) GetHostId added in v2.0.121

func (x *DeleteHostRequest) GetHostId() string

func (*DeleteHostRequest) ProtoMessage added in v2.0.118

func (*DeleteHostRequest) ProtoMessage()

func (*DeleteHostRequest) ProtoReflect added in v2.0.118

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

func (*DeleteHostRequest) Reset added in v2.0.118

func (x *DeleteHostRequest) Reset()

func (*DeleteHostRequest) String added in v2.0.118

func (x *DeleteHostRequest) String() string

func (*DeleteHostRequest) Validate added in v2.0.118

func (m *DeleteHostRequest) Validate() error

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

func (*DeleteHostRequest) ValidateAll added in v2.0.118

func (m *DeleteHostRequest) ValidateAll() error

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

type DeleteHostRequestMultiError added in v2.0.118

type DeleteHostRequestMultiError []error

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

func (DeleteHostRequestMultiError) AllErrors added in v2.0.118

func (m DeleteHostRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteHostRequestMultiError) Error added in v2.0.118

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

type DeleteHostRequestValidationError added in v2.0.118

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

DeleteHostRequestValidationError is the validation error returned by DeleteHostRequest.Validate if the designated constraints aren't met.

func (DeleteHostRequestValidationError) Cause added in v2.0.118

Cause function returns cause value.

func (DeleteHostRequestValidationError) Error added in v2.0.118

Error satisfies the builtin error interface

func (DeleteHostRequestValidationError) ErrorName added in v2.0.118

ErrorName returns error name.

func (DeleteHostRequestValidationError) Field added in v2.0.118

Field function returns field value.

func (DeleteHostRequestValidationError) Key added in v2.0.118

Key function returns key value.

func (DeleteHostRequestValidationError) Reason added in v2.0.118

Reason function returns reason value.

type DeletePeerRequest added in v2.0.118

type DeletePeerRequest struct {

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

DeletePeerRequest represents request of DeletePeer.

func (*DeletePeerRequest) Descriptor deprecated added in v2.0.118

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

Deprecated: Use DeletePeerRequest.ProtoReflect.Descriptor instead.

func (*DeletePeerRequest) GetHostId added in v2.0.118

func (x *DeletePeerRequest) GetHostId() string

func (*DeletePeerRequest) GetPeerId added in v2.0.118

func (x *DeletePeerRequest) GetPeerId() string

func (*DeletePeerRequest) GetTaskId added in v2.0.118

func (x *DeletePeerRequest) GetTaskId() string

func (*DeletePeerRequest) ProtoMessage added in v2.0.118

func (*DeletePeerRequest) ProtoMessage()

func (*DeletePeerRequest) ProtoReflect added in v2.0.118

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

func (*DeletePeerRequest) Reset added in v2.0.118

func (x *DeletePeerRequest) Reset()

func (*DeletePeerRequest) String added in v2.0.118

func (x *DeletePeerRequest) String() string

func (*DeletePeerRequest) Validate added in v2.0.118

func (m *DeletePeerRequest) Validate() error

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

func (*DeletePeerRequest) ValidateAll added in v2.0.118

func (m *DeletePeerRequest) ValidateAll() error

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

type DeletePeerRequestMultiError added in v2.0.118

type DeletePeerRequestMultiError []error

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

func (DeletePeerRequestMultiError) AllErrors added in v2.0.118

func (m DeletePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeletePeerRequestMultiError) Error added in v2.0.118

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

type DeletePeerRequestValidationError added in v2.0.118

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

DeletePeerRequestValidationError is the validation error returned by DeletePeerRequest.Validate if the designated constraints aren't met.

func (DeletePeerRequestValidationError) Cause added in v2.0.118

Cause function returns cause value.

func (DeletePeerRequestValidationError) Error added in v2.0.118

Error satisfies the builtin error interface

func (DeletePeerRequestValidationError) ErrorName added in v2.0.118

ErrorName returns error name.

func (DeletePeerRequestValidationError) Field added in v2.0.118

Field function returns field value.

func (DeletePeerRequestValidationError) Key added in v2.0.118

Key function returns key value.

func (DeletePeerRequestValidationError) Reason added in v2.0.118

Reason function returns reason value.

type DeleteTaskRequest added in v2.0.118

type DeleteTaskRequest struct {

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

DeleteTaskRequest represents request of DeleteTask.

func (*DeleteTaskRequest) Descriptor deprecated added in v2.0.118

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

Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskRequest) GetHostId added in v2.0.118

func (x *DeleteTaskRequest) GetHostId() string

func (*DeleteTaskRequest) GetTaskId added in v2.0.118

func (x *DeleteTaskRequest) GetTaskId() string

func (*DeleteTaskRequest) ProtoMessage added in v2.0.118

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) ProtoReflect added in v2.0.118

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

func (*DeleteTaskRequest) Reset added in v2.0.118

func (x *DeleteTaskRequest) Reset()

func (*DeleteTaskRequest) String added in v2.0.118

func (x *DeleteTaskRequest) String() string

func (*DeleteTaskRequest) Validate added in v2.0.118

func (m *DeleteTaskRequest) Validate() error

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

func (*DeleteTaskRequest) ValidateAll added in v2.0.118

func (m *DeleteTaskRequest) ValidateAll() error

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

type DeleteTaskRequestMultiError added in v2.0.118

type DeleteTaskRequestMultiError []error

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

func (DeleteTaskRequestMultiError) AllErrors added in v2.0.118

func (m DeleteTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteTaskRequestMultiError) Error added in v2.0.118

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

type DeleteTaskRequestValidationError added in v2.0.118

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

DeleteTaskRequestValidationError is the validation error returned by DeleteTaskRequest.Validate if the designated constraints aren't met.

func (DeleteTaskRequestValidationError) Cause added in v2.0.118

Cause function returns cause value.

func (DeleteTaskRequestValidationError) Error added in v2.0.118

Error satisfies the builtin error interface

func (DeleteTaskRequestValidationError) ErrorName added in v2.0.118

ErrorName returns error name.

func (DeleteTaskRequestValidationError) Field added in v2.0.118

Field function returns field value.

func (DeleteTaskRequestValidationError) Key added in v2.0.118

Key function returns key value.

func (DeleteTaskRequestValidationError) Reason added in v2.0.118

Reason function returns reason value.

type DownloadCachePeerFailedRequest added in v2.0.121

type DownloadCachePeerFailedRequest struct {

	// The description of the download failed.
	Description *string `protobuf:"bytes,1,opt,name=description,proto3,oneof" json:"description,omitempty"`
	// contains filtered or unexported fields
}

DownloadCachePeerFailedRequest represents cache peer download failed request of AnnounceCachePeerRequest.

func (*DownloadCachePeerFailedRequest) Descriptor deprecated added in v2.0.121

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

Deprecated: Use DownloadCachePeerFailedRequest.ProtoReflect.Descriptor instead.

func (*DownloadCachePeerFailedRequest) GetDescription added in v2.0.121

func (x *DownloadCachePeerFailedRequest) GetDescription() string

func (*DownloadCachePeerFailedRequest) ProtoMessage added in v2.0.121

func (*DownloadCachePeerFailedRequest) ProtoMessage()

func (*DownloadCachePeerFailedRequest) ProtoReflect added in v2.0.121

func (*DownloadCachePeerFailedRequest) Reset added in v2.0.121

func (x *DownloadCachePeerFailedRequest) Reset()

func (*DownloadCachePeerFailedRequest) String added in v2.0.121

func (*DownloadCachePeerFailedRequest) Validate added in v2.0.121

func (m *DownloadCachePeerFailedRequest) Validate() error

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

func (*DownloadCachePeerFailedRequest) ValidateAll added in v2.0.121

func (m *DownloadCachePeerFailedRequest) ValidateAll() error

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

type DownloadCachePeerFailedRequestMultiError added in v2.0.121

type DownloadCachePeerFailedRequestMultiError []error

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

func (DownloadCachePeerFailedRequestMultiError) AllErrors added in v2.0.121

AllErrors returns a list of validation violation errors.

func (DownloadCachePeerFailedRequestMultiError) Error added in v2.0.121

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

type DownloadCachePeerFailedRequestValidationError added in v2.0.121

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

DownloadCachePeerFailedRequestValidationError is the validation error returned by DownloadCachePeerFailedRequest.Validate if the designated constraints aren't met.

func (DownloadCachePeerFailedRequestValidationError) Cause added in v2.0.121

Cause function returns cause value.

func (DownloadCachePeerFailedRequestValidationError) Error added in v2.0.121

Error satisfies the builtin error interface

func (DownloadCachePeerFailedRequestValidationError) ErrorName added in v2.0.121

ErrorName returns error name.

func (DownloadCachePeerFailedRequestValidationError) Field added in v2.0.121

Field function returns field value.

func (DownloadCachePeerFailedRequestValidationError) Key added in v2.0.121

Key function returns key value.

func (DownloadCachePeerFailedRequestValidationError) Reason added in v2.0.121

Reason function returns reason value.

type DownloadCachePeerFinishedRequest added in v2.0.121

type DownloadCachePeerFinishedRequest struct {

	// Total piece count.
	PieceCount uint32 `protobuf:"varint,1,opt,name=piece_count,json=pieceCount,proto3" json:"piece_count,omitempty"`
	// contains filtered or unexported fields
}

DownloadCachePeerFinishedRequest represents cache peer download finished request of AnnounceCachePeerRequest.

func (*DownloadCachePeerFinishedRequest) Descriptor deprecated added in v2.0.121

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

Deprecated: Use DownloadCachePeerFinishedRequest.ProtoReflect.Descriptor instead.

func (*DownloadCachePeerFinishedRequest) GetPieceCount added in v2.0.121

func (x *DownloadCachePeerFinishedRequest) GetPieceCount() uint32

func (*DownloadCachePeerFinishedRequest) ProtoMessage added in v2.0.121

func (*DownloadCachePeerFinishedRequest) ProtoMessage()

func (*DownloadCachePeerFinishedRequest) ProtoReflect added in v2.0.121

func (*DownloadCachePeerFinishedRequest) Reset added in v2.0.121

func (*DownloadCachePeerFinishedRequest) String added in v2.0.121

func (*DownloadCachePeerFinishedRequest) Validate added in v2.0.121

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

func (*DownloadCachePeerFinishedRequest) ValidateAll added in v2.0.121

func (m *DownloadCachePeerFinishedRequest) ValidateAll() error

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

type DownloadCachePeerFinishedRequestMultiError added in v2.0.121

type DownloadCachePeerFinishedRequestMultiError []error

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

func (DownloadCachePeerFinishedRequestMultiError) AllErrors added in v2.0.121

AllErrors returns a list of validation violation errors.

func (DownloadCachePeerFinishedRequestMultiError) Error added in v2.0.121

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

type DownloadCachePeerFinishedRequestValidationError added in v2.0.121

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

DownloadCachePeerFinishedRequestValidationError is the validation error returned by DownloadCachePeerFinishedRequest.Validate if the designated constraints aren't met.

func (DownloadCachePeerFinishedRequestValidationError) Cause added in v2.0.121

Cause function returns cause value.

func (DownloadCachePeerFinishedRequestValidationError) Error added in v2.0.121

Error satisfies the builtin error interface

func (DownloadCachePeerFinishedRequestValidationError) ErrorName added in v2.0.121

ErrorName returns error name.

func (DownloadCachePeerFinishedRequestValidationError) Field added in v2.0.121

Field function returns field value.

func (DownloadCachePeerFinishedRequestValidationError) Key added in v2.0.121

Key function returns key value.

func (DownloadCachePeerFinishedRequestValidationError) Reason added in v2.0.121

Reason function returns reason value.

type DownloadCachePeerStartedRequest added in v2.0.121

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

DownloadCachePeerStartedRequest represents cache peer download started request of AnnounceCachePeerRequest.

func (*DownloadCachePeerStartedRequest) Descriptor deprecated added in v2.0.121

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

Deprecated: Use DownloadCachePeerStartedRequest.ProtoReflect.Descriptor instead.

func (*DownloadCachePeerStartedRequest) ProtoMessage added in v2.0.121

func (*DownloadCachePeerStartedRequest) ProtoMessage()

func (*DownloadCachePeerStartedRequest) ProtoReflect added in v2.0.121

func (*DownloadCachePeerStartedRequest) Reset added in v2.0.121

func (*DownloadCachePeerStartedRequest) String added in v2.0.121

func (*DownloadCachePeerStartedRequest) Validate added in v2.0.121

func (m *DownloadCachePeerStartedRequest) Validate() error

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

func (*DownloadCachePeerStartedRequest) ValidateAll added in v2.0.121

func (m *DownloadCachePeerStartedRequest) ValidateAll() error

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

type DownloadCachePeerStartedRequestMultiError added in v2.0.121

type DownloadCachePeerStartedRequestMultiError []error

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

func (DownloadCachePeerStartedRequestMultiError) AllErrors added in v2.0.121

AllErrors returns a list of validation violation errors.

func (DownloadCachePeerStartedRequestMultiError) Error added in v2.0.121

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

type DownloadCachePeerStartedRequestValidationError added in v2.0.121

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

DownloadCachePeerStartedRequestValidationError is the validation error returned by DownloadCachePeerStartedRequest.Validate if the designated constraints aren't met.

func (DownloadCachePeerStartedRequestValidationError) Cause added in v2.0.121

Cause function returns cause value.

func (DownloadCachePeerStartedRequestValidationError) Error added in v2.0.121

Error satisfies the builtin error interface

func (DownloadCachePeerStartedRequestValidationError) ErrorName added in v2.0.121

ErrorName returns error name.

func (DownloadCachePeerStartedRequestValidationError) Field added in v2.0.121

Field function returns field value.

func (DownloadCachePeerStartedRequestValidationError) Key added in v2.0.121

Key function returns key value.

func (DownloadCachePeerStartedRequestValidationError) Reason added in v2.0.121

Reason function returns reason value.

type DownloadPeerBackToSourceFailedRequest

type DownloadPeerBackToSourceFailedRequest struct {

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

DownloadPeerBackToSourceFailedRequest represents peer download back-to-source failed request of AnnouncePeerRequest.

func (*DownloadPeerBackToSourceFailedRequest) Descriptor deprecated

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

Deprecated: Use DownloadPeerBackToSourceFailedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPeerBackToSourceFailedRequest) GetDescription

func (x *DownloadPeerBackToSourceFailedRequest) GetDescription() string

func (*DownloadPeerBackToSourceFailedRequest) ProtoMessage

func (*DownloadPeerBackToSourceFailedRequest) ProtoMessage()

func (*DownloadPeerBackToSourceFailedRequest) ProtoReflect

func (*DownloadPeerBackToSourceFailedRequest) Reset

func (*DownloadPeerBackToSourceFailedRequest) String

func (*DownloadPeerBackToSourceFailedRequest) Validate

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

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

AllErrors returns a list of validation violation errors.

func (DownloadPeerBackToSourceFailedRequestMultiError) Error

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

Cause function returns cause value.

func (DownloadPeerBackToSourceFailedRequestValidationError) Error

Error satisfies the builtin error interface

func (DownloadPeerBackToSourceFailedRequestValidationError) ErrorName

ErrorName returns error name.

func (DownloadPeerBackToSourceFailedRequestValidationError) Field

Field function returns field value.

func (DownloadPeerBackToSourceFailedRequestValidationError) Key

Key function returns key value.

func (DownloadPeerBackToSourceFailedRequestValidationError) Reason

Reason function returns reason value.

type DownloadPeerBackToSourceFinishedRequest

type DownloadPeerBackToSourceFinishedRequest struct {

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

DownloadPeerBackToSourceFinishedRequest represents peer download back-to-source finished request of AnnouncePeerRequest.

func (*DownloadPeerBackToSourceFinishedRequest) Descriptor deprecated

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

Deprecated: Use DownloadPeerBackToSourceFinishedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPeerBackToSourceFinishedRequest) GetContentLength

func (x *DownloadPeerBackToSourceFinishedRequest) GetContentLength() uint64

func (*DownloadPeerBackToSourceFinishedRequest) GetPieceCount

func (*DownloadPeerBackToSourceFinishedRequest) ProtoMessage

func (*DownloadPeerBackToSourceFinishedRequest) ProtoReflect

func (*DownloadPeerBackToSourceFinishedRequest) Reset

func (*DownloadPeerBackToSourceFinishedRequest) String

func (*DownloadPeerBackToSourceFinishedRequest) Validate

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

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

AllErrors returns a list of validation violation errors.

func (DownloadPeerBackToSourceFinishedRequestMultiError) Error

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

Cause function returns cause value.

func (DownloadPeerBackToSourceFinishedRequestValidationError) Error

Error satisfies the builtin error interface

func (DownloadPeerBackToSourceFinishedRequestValidationError) ErrorName

ErrorName returns error name.

func (DownloadPeerBackToSourceFinishedRequestValidationError) Field

Field function returns field value.

func (DownloadPeerBackToSourceFinishedRequestValidationError) Key

Key function returns key value.

func (DownloadPeerBackToSourceFinishedRequestValidationError) Reason

Reason function returns reason value.

type DownloadPeerBackToSourceStartedRequest

type DownloadPeerBackToSourceStartedRequest struct {

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

DownloadPeerBackToSourceStartedRequest represents peer download back-to-source started request of AnnouncePeerRequest.

func (*DownloadPeerBackToSourceStartedRequest) Descriptor deprecated

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

Deprecated: Use DownloadPeerBackToSourceStartedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPeerBackToSourceStartedRequest) GetDescription

func (x *DownloadPeerBackToSourceStartedRequest) GetDescription() string

func (*DownloadPeerBackToSourceStartedRequest) ProtoMessage

func (*DownloadPeerBackToSourceStartedRequest) ProtoReflect

func (*DownloadPeerBackToSourceStartedRequest) Reset

func (*DownloadPeerBackToSourceStartedRequest) String

func (*DownloadPeerBackToSourceStartedRequest) Validate

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

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

AllErrors returns a list of validation violation errors.

func (DownloadPeerBackToSourceStartedRequestMultiError) Error

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

Cause function returns cause value.

func (DownloadPeerBackToSourceStartedRequestValidationError) Error

Error satisfies the builtin error interface

func (DownloadPeerBackToSourceStartedRequestValidationError) ErrorName

ErrorName returns error name.

func (DownloadPeerBackToSourceStartedRequestValidationError) Field

Field function returns field value.

func (DownloadPeerBackToSourceStartedRequestValidationError) Key

Key function returns key value.

func (DownloadPeerBackToSourceStartedRequestValidationError) Reason

Reason function returns reason value.

type DownloadPeerFailedRequest

type DownloadPeerFailedRequest struct {

	// The description of the download failed.
	Description *string `protobuf:"bytes,1,opt,name=description,proto3,oneof" json:"description,omitempty"`
	// contains filtered or unexported fields
}

DownloadPeerFailedRequest represents peer download failed request of AnnouncePeerRequest.

func (*DownloadPeerFailedRequest) Descriptor deprecated

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

Deprecated: Use DownloadPeerFailedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPeerFailedRequest) GetDescription

func (x *DownloadPeerFailedRequest) GetDescription() string

func (*DownloadPeerFailedRequest) ProtoMessage

func (*DownloadPeerFailedRequest) ProtoMessage()

func (*DownloadPeerFailedRequest) ProtoReflect

func (*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

AllErrors returns a list of validation violation errors.

func (DownloadPeerFailedRequestMultiError) Error

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

Cause function returns cause value.

func (DownloadPeerFailedRequestValidationError) Error

Error satisfies the builtin error interface

func (DownloadPeerFailedRequestValidationError) ErrorName

ErrorName returns error name.

func (DownloadPeerFailedRequestValidationError) Field

Field function returns field value.

func (DownloadPeerFailedRequestValidationError) Key

Key function returns key value.

func (DownloadPeerFailedRequestValidationError) Reason

Reason function returns reason value.

type DownloadPeerFinishedRequest

type DownloadPeerFinishedRequest struct {

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

DownloadPeerFinishedRequest represents peer download finished request of AnnouncePeerRequest.

func (*DownloadPeerFinishedRequest) Descriptor deprecated

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

Deprecated: Use DownloadPeerFinishedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPeerFinishedRequest) GetContentLength

func (x *DownloadPeerFinishedRequest) GetContentLength() uint64

func (*DownloadPeerFinishedRequest) GetPieceCount

func (x *DownloadPeerFinishedRequest) GetPieceCount() uint32

func (*DownloadPeerFinishedRequest) ProtoMessage

func (*DownloadPeerFinishedRequest) ProtoMessage()

func (*DownloadPeerFinishedRequest) ProtoReflect

func (*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

AllErrors returns a list of validation violation errors.

func (DownloadPeerFinishedRequestMultiError) Error

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

Cause function returns cause value.

func (DownloadPeerFinishedRequestValidationError) Error

Error satisfies the builtin error interface

func (DownloadPeerFinishedRequestValidationError) ErrorName

ErrorName returns error name.

func (DownloadPeerFinishedRequestValidationError) Field

Field function returns field value.

func (DownloadPeerFinishedRequestValidationError) Key

Key function returns key value.

func (DownloadPeerFinishedRequestValidationError) Reason

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 (*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

AllErrors returns a list of validation violation errors.

func (DownloadPeerStartedRequestMultiError) Error

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

Cause function returns cause value.

func (DownloadPeerStartedRequestValidationError) Error

Error satisfies the builtin error interface

func (DownloadPeerStartedRequestValidationError) ErrorName

ErrorName returns error name.

func (DownloadPeerStartedRequestValidationError) Field

Field function returns field value.

func (DownloadPeerStartedRequestValidationError) Key

Key function returns key value.

func (DownloadPeerStartedRequestValidationError) Reason

Reason function returns reason value.

type DownloadPieceBackToSourceFailedRequest

type DownloadPieceBackToSourceFailedRequest struct {

	// Piece number.
	PieceNumber *uint32 `protobuf:"varint,1,opt,name=piece_number,json=pieceNumber,proto3,oneof" json:"piece_number,omitempty"`
	// Types that are assignable to Response:
	//
	//	*DownloadPieceBackToSourceFailedRequest_Backend
	Response isDownloadPieceBackToSourceFailedRequest_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

DownloadPieceBackToSourceFailedRequest downloads piece back-to-source failed request of AnnouncePeerRequest.

func (*DownloadPieceBackToSourceFailedRequest) Descriptor deprecated

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

Deprecated: Use DownloadPieceBackToSourceFailedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPieceBackToSourceFailedRequest) GetBackend added in v2.0.114

func (*DownloadPieceBackToSourceFailedRequest) GetPieceNumber added in v2.0.47

func (x *DownloadPieceBackToSourceFailedRequest) GetPieceNumber() uint32

func (*DownloadPieceBackToSourceFailedRequest) GetResponse

func (m *DownloadPieceBackToSourceFailedRequest) GetResponse() isDownloadPieceBackToSourceFailedRequest_Response

func (*DownloadPieceBackToSourceFailedRequest) ProtoMessage

func (*DownloadPieceBackToSourceFailedRequest) ProtoReflect

func (*DownloadPieceBackToSourceFailedRequest) Reset

func (*DownloadPieceBackToSourceFailedRequest) String

func (*DownloadPieceBackToSourceFailedRequest) Validate

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

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

AllErrors returns a list of validation violation errors.

func (DownloadPieceBackToSourceFailedRequestMultiError) Error

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

Cause function returns cause value.

func (DownloadPieceBackToSourceFailedRequestValidationError) Error

Error satisfies the builtin error interface

func (DownloadPieceBackToSourceFailedRequestValidationError) ErrorName

ErrorName returns error name.

func (DownloadPieceBackToSourceFailedRequestValidationError) Field

Field function returns field value.

func (DownloadPieceBackToSourceFailedRequestValidationError) Key

Key function returns key value.

func (DownloadPieceBackToSourceFailedRequestValidationError) Reason

Reason function returns reason value.

type DownloadPieceBackToSourceFailedRequest_Backend added in v2.0.114

type DownloadPieceBackToSourceFailedRequest_Backend struct {
	Backend *v21.Backend `protobuf:"bytes,2,opt,name=backend,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 (*DownloadPieceBackToSourceFinishedRequest) ProtoMessage

func (*DownloadPieceBackToSourceFinishedRequest) ProtoReflect

func (*DownloadPieceBackToSourceFinishedRequest) Reset

func (*DownloadPieceBackToSourceFinishedRequest) String

func (*DownloadPieceBackToSourceFinishedRequest) Validate

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

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

AllErrors returns a list of validation violation errors.

func (DownloadPieceBackToSourceFinishedRequestMultiError) Error

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

Cause function returns cause value.

func (DownloadPieceBackToSourceFinishedRequestValidationError) Error

Error satisfies the builtin error interface

func (DownloadPieceBackToSourceFinishedRequestValidationError) ErrorName

ErrorName returns error name.

func (DownloadPieceBackToSourceFinishedRequestValidationError) Field

Field function returns field value.

func (DownloadPieceBackToSourceFinishedRequestValidationError) Key

Key function returns key value.

func (DownloadPieceBackToSourceFinishedRequestValidationError) Reason

Reason function returns reason value.

type DownloadPieceFailedRequest

type DownloadPieceFailedRequest struct {

	// Piece number.
	PieceNumber *uint32 `protobuf:"varint,1,opt,name=piece_number,json=pieceNumber,proto3,oneof" json:"piece_number,omitempty"`
	// Parent id.
	ParentId string `protobuf:"bytes,2,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	// Temporary indicates whether the error is temporary.
	Temporary bool `protobuf:"varint,3,opt,name=temporary,proto3" json:"temporary,omitempty"`
	// contains filtered or unexported fields
}

DownloadPieceFailedRequest downloads piece failed request of AnnouncePeerRequest.

func (*DownloadPieceFailedRequest) Descriptor deprecated

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

Deprecated: Use DownloadPieceFailedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPieceFailedRequest) GetParentId added in v2.0.47

func (x *DownloadPieceFailedRequest) GetParentId() string

func (*DownloadPieceFailedRequest) GetPieceNumber added in v2.0.47

func (x *DownloadPieceFailedRequest) GetPieceNumber() uint32

func (*DownloadPieceFailedRequest) GetTemporary

func (x *DownloadPieceFailedRequest) GetTemporary() bool

func (*DownloadPieceFailedRequest) ProtoMessage

func (*DownloadPieceFailedRequest) ProtoMessage()

func (*DownloadPieceFailedRequest) ProtoReflect

func (*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

AllErrors returns a list of validation violation errors.

func (DownloadPieceFailedRequestMultiError) Error

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

Cause function returns cause value.

func (DownloadPieceFailedRequestValidationError) Error

Error satisfies the builtin error interface

func (DownloadPieceFailedRequestValidationError) ErrorName

ErrorName returns error name.

func (DownloadPieceFailedRequestValidationError) Field

Field function returns field value.

func (DownloadPieceFailedRequestValidationError) Key

Key function returns key value.

func (DownloadPieceFailedRequestValidationError) Reason

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 (*DownloadPieceFinishedRequest) Reset

func (x *DownloadPieceFinishedRequest) Reset()

func (*DownloadPieceFinishedRequest) 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

AllErrors returns a list of validation violation errors.

func (DownloadPieceFinishedRequestMultiError) Error

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

Cause function returns cause value.

func (DownloadPieceFinishedRequestValidationError) Error

Error satisfies the builtin error interface

func (DownloadPieceFinishedRequestValidationError) ErrorName

ErrorName returns error name.

func (DownloadPieceFinishedRequestValidationError) Field

Field function returns field value.

func (DownloadPieceFinishedRequestValidationError) Key

Key function returns key value.

func (DownloadPieceFinishedRequestValidationError) Reason

Reason function returns reason value.

type EmptyCacheTaskResponse added in v2.0.121

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

EmptyCacheTaskResponse represents empty cache task response of AnnounceCachePeerResponse.

func (*EmptyCacheTaskResponse) Descriptor deprecated added in v2.0.121

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

Deprecated: Use EmptyCacheTaskResponse.ProtoReflect.Descriptor instead.

func (*EmptyCacheTaskResponse) ProtoMessage added in v2.0.121

func (*EmptyCacheTaskResponse) ProtoMessage()

func (*EmptyCacheTaskResponse) ProtoReflect added in v2.0.121

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

func (*EmptyCacheTaskResponse) Reset added in v2.0.121

func (x *EmptyCacheTaskResponse) Reset()

func (*EmptyCacheTaskResponse) String added in v2.0.121

func (x *EmptyCacheTaskResponse) String() string

func (*EmptyCacheTaskResponse) Validate added in v2.0.121

func (m *EmptyCacheTaskResponse) Validate() error

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

func (*EmptyCacheTaskResponse) ValidateAll added in v2.0.121

func (m *EmptyCacheTaskResponse) ValidateAll() error

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

type EmptyCacheTaskResponseMultiError added in v2.0.121

type EmptyCacheTaskResponseMultiError []error

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

func (EmptyCacheTaskResponseMultiError) AllErrors added in v2.0.121

func (m EmptyCacheTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EmptyCacheTaskResponseMultiError) Error added in v2.0.121

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

type EmptyCacheTaskResponseValidationError added in v2.0.121

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

EmptyCacheTaskResponseValidationError is the validation error returned by EmptyCacheTaskResponse.Validate if the designated constraints aren't met.

func (EmptyCacheTaskResponseValidationError) Cause added in v2.0.121

Cause function returns cause value.

func (EmptyCacheTaskResponseValidationError) Error added in v2.0.121

Error satisfies the builtin error interface

func (EmptyCacheTaskResponseValidationError) ErrorName added in v2.0.121

ErrorName returns error name.

func (EmptyCacheTaskResponseValidationError) Field added in v2.0.121

Field function returns field value.

func (EmptyCacheTaskResponseValidationError) Key added in v2.0.121

Key function returns key value.

func (EmptyCacheTaskResponseValidationError) Reason added in v2.0.121

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

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

Cause function returns cause value.

func (EmptyTaskResponseValidationError) Error

Error satisfies the builtin error interface

func (EmptyTaskResponseValidationError) ErrorName

ErrorName returns error name.

func (EmptyTaskResponseValidationError) Field

Field function returns field value.

func (EmptyTaskResponseValidationError) Key

Key function returns key value.

func (EmptyTaskResponseValidationError) Reason

Reason function returns reason value.

type FailedProbe

type FailedProbe struct {

	// Destination host metadata.
	Host *v2.Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// The description of probing failed.
	Description *string `protobuf:"bytes,2,opt,name=description,proto3,oneof" json:"description,omitempty"`
	// contains filtered or unexported fields
}

FailedProbe information.

func (*FailedProbe) Descriptor deprecated

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

Deprecated: Use FailedProbe.ProtoReflect.Descriptor instead.

func (*FailedProbe) GetDescription

func (x *FailedProbe) GetDescription() string

func (*FailedProbe) GetHost

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

func (*FailedProbe) ProtoMessage

func (*FailedProbe) ProtoMessage()

func (*FailedProbe) ProtoReflect

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

func (*FailedProbe) Reset

func (x *FailedProbe) Reset()

func (*FailedProbe) String

func (x *FailedProbe) String() string

func (*FailedProbe) Validate

func (m *FailedProbe) Validate() error

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

func (*FailedProbe) ValidateAll

func (m *FailedProbe) ValidateAll() error

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

type FailedProbeMultiError

type FailedProbeMultiError []error

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

func (FailedProbeMultiError) AllErrors

func (m FailedProbeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (FailedProbeMultiError) Error

func (m FailedProbeMultiError) Error() string

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

type FailedProbeValidationError

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

FailedProbeValidationError is the validation error returned by FailedProbe.Validate if the designated constraints aren't met.

func (FailedProbeValidationError) Cause

Cause function returns cause value.

func (FailedProbeValidationError) Error

Error satisfies the builtin error interface

func (FailedProbeValidationError) ErrorName

func (e FailedProbeValidationError) ErrorName() string

ErrorName returns error name.

func (FailedProbeValidationError) Field

Field function returns field value.

func (FailedProbeValidationError) Key

Key function returns key value.

func (FailedProbeValidationError) Reason

Reason function returns reason value.

type NeedBackToSourceResponse

type NeedBackToSourceResponse struct {

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

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

func (*NeedBackToSourceResponse) Descriptor deprecated

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

Deprecated: Use NeedBackToSourceResponse.ProtoReflect.Descriptor instead.

func (*NeedBackToSourceResponse) GetDescription

func (x *NeedBackToSourceResponse) GetDescription() string

func (*NeedBackToSourceResponse) ProtoMessage

func (*NeedBackToSourceResponse) ProtoMessage()

func (*NeedBackToSourceResponse) ProtoReflect

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

func (*NeedBackToSourceResponse) Reset

func (x *NeedBackToSourceResponse) Reset()

func (*NeedBackToSourceResponse) String

func (x *NeedBackToSourceResponse) String() string

func (*NeedBackToSourceResponse) Validate

func (m *NeedBackToSourceResponse) Validate() error

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

func (*NeedBackToSourceResponse) ValidateAll

func (m *NeedBackToSourceResponse) ValidateAll() error

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

type NeedBackToSourceResponseMultiError

type NeedBackToSourceResponseMultiError []error

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

func (NeedBackToSourceResponseMultiError) AllErrors

func (m NeedBackToSourceResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NeedBackToSourceResponseMultiError) Error

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

Cause function returns cause value.

func (NeedBackToSourceResponseValidationError) Error

Error satisfies the builtin error interface

func (NeedBackToSourceResponseValidationError) ErrorName

ErrorName returns error name.

func (NeedBackToSourceResponseValidationError) Field

Field function returns field value.

func (NeedBackToSourceResponseValidationError) Key

Key function returns key value.

func (NeedBackToSourceResponseValidationError) Reason

Reason function returns reason value.

type NormalCacheTaskResponse added in v2.0.121

type NormalCacheTaskResponse struct {

	// Candidate parents.
	CandidateParents []*v2.CachePeer `protobuf:"bytes,1,rep,name=candidate_parents,json=candidateParents,proto3" json:"candidate_parents,omitempty"`
	// contains filtered or unexported fields
}

NormalCacheTaskResponse represents normal cache task response of AnnounceCachePeerResponse.

func (*NormalCacheTaskResponse) Descriptor deprecated added in v2.0.121

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

Deprecated: Use NormalCacheTaskResponse.ProtoReflect.Descriptor instead.

func (*NormalCacheTaskResponse) GetCandidateParents added in v2.0.121

func (x *NormalCacheTaskResponse) GetCandidateParents() []*v2.CachePeer

func (*NormalCacheTaskResponse) ProtoMessage added in v2.0.121

func (*NormalCacheTaskResponse) ProtoMessage()

func (*NormalCacheTaskResponse) ProtoReflect added in v2.0.121

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

func (*NormalCacheTaskResponse) Reset added in v2.0.121

func (x *NormalCacheTaskResponse) Reset()

func (*NormalCacheTaskResponse) String added in v2.0.121

func (x *NormalCacheTaskResponse) String() string

func (*NormalCacheTaskResponse) Validate added in v2.0.121

func (m *NormalCacheTaskResponse) Validate() error

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

func (*NormalCacheTaskResponse) ValidateAll added in v2.0.121

func (m *NormalCacheTaskResponse) ValidateAll() error

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

type NormalCacheTaskResponseMultiError added in v2.0.121

type NormalCacheTaskResponseMultiError []error

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

func (NormalCacheTaskResponseMultiError) AllErrors added in v2.0.121

func (m NormalCacheTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NormalCacheTaskResponseMultiError) Error added in v2.0.121

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

type NormalCacheTaskResponseValidationError added in v2.0.121

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

NormalCacheTaskResponseValidationError is the validation error returned by NormalCacheTaskResponse.Validate if the designated constraints aren't met.

func (NormalCacheTaskResponseValidationError) Cause added in v2.0.121

Cause function returns cause value.

func (NormalCacheTaskResponseValidationError) Error added in v2.0.121

Error satisfies the builtin error interface

func (NormalCacheTaskResponseValidationError) ErrorName added in v2.0.121

ErrorName returns error name.

func (NormalCacheTaskResponseValidationError) Field added in v2.0.121

Field function returns field value.

func (NormalCacheTaskResponseValidationError) Key added in v2.0.121

Key function returns key value.

func (NormalCacheTaskResponseValidationError) Reason added in v2.0.121

Reason function returns reason value.

type NormalTaskResponse

type NormalTaskResponse struct {

	// Candidate parents.
	CandidateParents []*v2.Peer `protobuf:"bytes,1,rep,name=candidate_parents,json=candidateParents,proto3" json:"candidate_parents,omitempty"`
	// contains filtered or unexported fields
}

NormalTaskResponse represents normal task response of AnnouncePeerResponse.

func (*NormalTaskResponse) Descriptor deprecated

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

Deprecated: Use NormalTaskResponse.ProtoReflect.Descriptor instead.

func (*NormalTaskResponse) GetCandidateParents

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

func (*NormalTaskResponse) ProtoMessage

func (*NormalTaskResponse) ProtoMessage()

func (*NormalTaskResponse) ProtoReflect

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

func (*NormalTaskResponse) Reset

func (x *NormalTaskResponse) Reset()

func (*NormalTaskResponse) String

func (x *NormalTaskResponse) String() string

func (*NormalTaskResponse) Validate

func (m *NormalTaskResponse) Validate() error

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

func (*NormalTaskResponse) ValidateAll

func (m *NormalTaskResponse) ValidateAll() error

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

type NormalTaskResponseMultiError

type NormalTaskResponseMultiError []error

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

func (NormalTaskResponseMultiError) AllErrors

func (m NormalTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NormalTaskResponseMultiError) Error

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

Cause function returns cause value.

func (NormalTaskResponseValidationError) Error

Error satisfies the builtin error interface

func (NormalTaskResponseValidationError) ErrorName

ErrorName returns error name.

func (NormalTaskResponseValidationError) Field

Field function returns field value.

func (NormalTaskResponseValidationError) Key

Key function returns key value.

func (NormalTaskResponseValidationError) Reason

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

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

Cause function returns cause value.

func (ProbeFailedRequestValidationError) Error

Error satisfies the builtin error interface

func (ProbeFailedRequestValidationError) ErrorName

ErrorName returns error name.

func (ProbeFailedRequestValidationError) Field

Field function returns field value.

func (ProbeFailedRequestValidationError) Key

Key function returns key value.

func (ProbeFailedRequestValidationError) Reason

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

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

Cause function returns cause value.

func (ProbeFinishedRequestValidationError) Error

Error satisfies the builtin error interface

func (ProbeFinishedRequestValidationError) ErrorName

ErrorName returns error name.

func (ProbeFinishedRequestValidationError) Field

Field function returns field value.

func (ProbeFinishedRequestValidationError) Key

Key function returns key value.

func (ProbeFinishedRequestValidationError) Reason

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

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

Cause function returns cause value.

func (ProbeStartedRequestValidationError) Error

Error satisfies the builtin error interface

func (ProbeStartedRequestValidationError) ErrorName

ErrorName returns error name.

func (ProbeStartedRequestValidationError) Field

Field function returns field value.

func (ProbeStartedRequestValidationError) Key

Key function returns key value.

func (ProbeStartedRequestValidationError) Reason

Reason function returns reason value.

type ProbeValidationError

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

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

func (ProbeValidationError) Cause

func (e ProbeValidationError) Cause() error

Cause function returns cause value.

func (ProbeValidationError) Error

func (e ProbeValidationError) Error() string

Error satisfies the builtin error interface

func (ProbeValidationError) ErrorName

func (e ProbeValidationError) ErrorName() string

ErrorName returns error name.

func (ProbeValidationError) Field

func (e ProbeValidationError) Field() string

Field function returns field value.

func (ProbeValidationError) Key

func (e ProbeValidationError) Key() bool

Key function returns key value.

func (ProbeValidationError) Reason

func (e ProbeValidationError) Reason() string

Reason function returns reason value.

type RegisterCachePeerRequest added in v2.0.121

type RegisterCachePeerRequest struct {

	// Host id.
	HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// Task id.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Tag is used to distinguish different cache tasks.
	Tag *string `protobuf:"bytes,3,opt,name=tag,proto3,oneof" json:"tag,omitempty"`
	// Application of task.
	Application *string `protobuf:"bytes,4,opt,name=application,proto3,oneof" json:"application,omitempty"`
	// Task piece length.
	PieceLength uint64 `protobuf:"varint,5,opt,name=piece_length,json=pieceLength,proto3" json:"piece_length,omitempty"`
	// File path to be exported.
	OutputPath string `protobuf:"bytes,6,opt,name=output_path,json=outputPath,proto3" json:"output_path,omitempty"`
	// Download timeout.
	Timeout *durationpb.Duration `protobuf:"bytes,7,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

RegisterCachePeerRequest represents cache peer registered request of AnnounceCachePeerRequest.

func (*RegisterCachePeerRequest) Descriptor deprecated added in v2.0.121

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

Deprecated: Use RegisterCachePeerRequest.ProtoReflect.Descriptor instead.

func (*RegisterCachePeerRequest) GetApplication added in v2.0.121

func (x *RegisterCachePeerRequest) GetApplication() string

func (*RegisterCachePeerRequest) GetHostId added in v2.0.121

func (x *RegisterCachePeerRequest) GetHostId() string

func (*RegisterCachePeerRequest) GetOutputPath added in v2.0.121

func (x *RegisterCachePeerRequest) GetOutputPath() string

func (*RegisterCachePeerRequest) GetPieceLength added in v2.0.121

func (x *RegisterCachePeerRequest) GetPieceLength() uint64

func (*RegisterCachePeerRequest) GetTag added in v2.0.121

func (x *RegisterCachePeerRequest) GetTag() string

func (*RegisterCachePeerRequest) GetTaskId added in v2.0.121

func (x *RegisterCachePeerRequest) GetTaskId() string

func (*RegisterCachePeerRequest) GetTimeout added in v2.0.121

func (x *RegisterCachePeerRequest) GetTimeout() *durationpb.Duration

func (*RegisterCachePeerRequest) ProtoMessage added in v2.0.121

func (*RegisterCachePeerRequest) ProtoMessage()

func (*RegisterCachePeerRequest) ProtoReflect added in v2.0.121

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

func (*RegisterCachePeerRequest) Reset added in v2.0.121

func (x *RegisterCachePeerRequest) Reset()

func (*RegisterCachePeerRequest) String added in v2.0.121

func (x *RegisterCachePeerRequest) String() string

func (*RegisterCachePeerRequest) Validate added in v2.0.121

func (m *RegisterCachePeerRequest) Validate() error

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

func (*RegisterCachePeerRequest) ValidateAll added in v2.0.121

func (m *RegisterCachePeerRequest) ValidateAll() error

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

type RegisterCachePeerRequestMultiError added in v2.0.121

type RegisterCachePeerRequestMultiError []error

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

func (RegisterCachePeerRequestMultiError) AllErrors added in v2.0.121

func (m RegisterCachePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RegisterCachePeerRequestMultiError) Error added in v2.0.121

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

type RegisterCachePeerRequestValidationError added in v2.0.121

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

RegisterCachePeerRequestValidationError is the validation error returned by RegisterCachePeerRequest.Validate if the designated constraints aren't met.

func (RegisterCachePeerRequestValidationError) Cause added in v2.0.121

Cause function returns cause value.

func (RegisterCachePeerRequestValidationError) Error added in v2.0.121

Error satisfies the builtin error interface

func (RegisterCachePeerRequestValidationError) ErrorName added in v2.0.121

ErrorName returns error name.

func (RegisterCachePeerRequestValidationError) Field added in v2.0.121

Field function returns field value.

func (RegisterCachePeerRequestValidationError) Key added in v2.0.121

Key function returns key value.

func (RegisterCachePeerRequestValidationError) Reason added in v2.0.121

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

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

Cause function returns cause value.

func (RegisterPeerRequestValidationError) Error

Error satisfies the builtin error interface

func (RegisterPeerRequestValidationError) ErrorName

ErrorName returns error name.

func (RegisterPeerRequestValidationError) Field

Field function returns field value.

func (RegisterPeerRequestValidationError) Key

Key function returns key value.

func (RegisterPeerRequestValidationError) Reason

Reason function returns reason value.

type RescheduleCachePeerRequest added in v2.0.121

type RescheduleCachePeerRequest struct {

	// Candidate parent ids.
	CandidateParents []*v2.CachePeer `protobuf:"bytes,1,rep,name=candidate_parents,json=candidateParents,proto3" json:"candidate_parents,omitempty"`
	// The description of the reschedule reason.
	Description *string `protobuf:"bytes,2,opt,name=description,proto3,oneof" json:"description,omitempty"`
	// contains filtered or unexported fields
}

RescheduleCachePeerRequest represents reschedule request of AnnounceCachePeerRequest.

func (*RescheduleCachePeerRequest) Descriptor deprecated added in v2.0.121

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

Deprecated: Use RescheduleCachePeerRequest.ProtoReflect.Descriptor instead.

func (*RescheduleCachePeerRequest) GetCandidateParents added in v2.0.121

func (x *RescheduleCachePeerRequest) GetCandidateParents() []*v2.CachePeer

func (*RescheduleCachePeerRequest) GetDescription added in v2.0.121

func (x *RescheduleCachePeerRequest) GetDescription() string

func (*RescheduleCachePeerRequest) ProtoMessage added in v2.0.121

func (*RescheduleCachePeerRequest) ProtoMessage()

func (*RescheduleCachePeerRequest) ProtoReflect added in v2.0.121

func (*RescheduleCachePeerRequest) Reset added in v2.0.121

func (x *RescheduleCachePeerRequest) Reset()

func (*RescheduleCachePeerRequest) String added in v2.0.121

func (x *RescheduleCachePeerRequest) String() string

func (*RescheduleCachePeerRequest) Validate added in v2.0.121

func (m *RescheduleCachePeerRequest) Validate() error

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

func (*RescheduleCachePeerRequest) ValidateAll added in v2.0.121

func (m *RescheduleCachePeerRequest) ValidateAll() error

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

type RescheduleCachePeerRequestMultiError added in v2.0.121

type RescheduleCachePeerRequestMultiError []error

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

func (RescheduleCachePeerRequestMultiError) AllErrors added in v2.0.121

AllErrors returns a list of validation violation errors.

func (RescheduleCachePeerRequestMultiError) Error added in v2.0.121

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

type RescheduleCachePeerRequestValidationError added in v2.0.121

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

RescheduleCachePeerRequestValidationError is the validation error returned by RescheduleCachePeerRequest.Validate if the designated constraints aren't met.

func (RescheduleCachePeerRequestValidationError) Cause added in v2.0.121

Cause function returns cause value.

func (RescheduleCachePeerRequestValidationError) Error added in v2.0.121

Error satisfies the builtin error interface

func (RescheduleCachePeerRequestValidationError) ErrorName added in v2.0.121

ErrorName returns error name.

func (RescheduleCachePeerRequestValidationError) Field added in v2.0.121

Field function returns field value.

func (RescheduleCachePeerRequestValidationError) Key added in v2.0.121

Key function returns key value.

func (RescheduleCachePeerRequestValidationError) Reason added in v2.0.121

Reason function returns reason value.

type ReschedulePeerRequest added in v2.0.121

type ReschedulePeerRequest struct {

	// Candidate parent ids.
	CandidateParents []*v2.Peer `protobuf:"bytes,1,rep,name=candidate_parents,json=candidateParents,proto3" json:"candidate_parents,omitempty"`
	// The description of the reschedule reason.
	Description *string `protobuf:"bytes,2,opt,name=description,proto3,oneof" json:"description,omitempty"`
	// contains filtered or unexported fields
}

ReschedulePeerRequest represents reschedule request of AnnouncePeerRequest.

func (*ReschedulePeerRequest) Descriptor deprecated added in v2.0.121

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

Deprecated: Use ReschedulePeerRequest.ProtoReflect.Descriptor instead.

func (*ReschedulePeerRequest) GetCandidateParents added in v2.0.121

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

func (*ReschedulePeerRequest) GetDescription added in v2.0.121

func (x *ReschedulePeerRequest) GetDescription() string

func (*ReschedulePeerRequest) ProtoMessage added in v2.0.121

func (*ReschedulePeerRequest) ProtoMessage()

func (*ReschedulePeerRequest) ProtoReflect added in v2.0.121

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

func (*ReschedulePeerRequest) Reset added in v2.0.121

func (x *ReschedulePeerRequest) Reset()

func (*ReschedulePeerRequest) String added in v2.0.121

func (x *ReschedulePeerRequest) String() string

func (*ReschedulePeerRequest) Validate added in v2.0.121

func (m *ReschedulePeerRequest) Validate() error

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

func (*ReschedulePeerRequest) ValidateAll added in v2.0.121

func (m *ReschedulePeerRequest) ValidateAll() error

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

type ReschedulePeerRequestMultiError added in v2.0.121

type ReschedulePeerRequestMultiError []error

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

func (ReschedulePeerRequestMultiError) AllErrors added in v2.0.121

func (m ReschedulePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ReschedulePeerRequestMultiError) Error added in v2.0.121

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

type ReschedulePeerRequestValidationError added in v2.0.121

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

ReschedulePeerRequestValidationError is the validation error returned by ReschedulePeerRequest.Validate if the designated constraints aren't met.

func (ReschedulePeerRequestValidationError) Cause added in v2.0.121

Cause function returns cause value.

func (ReschedulePeerRequestValidationError) Error added in v2.0.121

Error satisfies the builtin error interface

func (ReschedulePeerRequestValidationError) ErrorName added in v2.0.121

ErrorName returns error name.

func (ReschedulePeerRequestValidationError) Field added in v2.0.121

Field function returns field value.

func (ReschedulePeerRequestValidationError) Key added in v2.0.121

Key function returns key value.

func (ReschedulePeerRequestValidationError) Reason added in v2.0.121

Reason function returns reason value.

type SchedulerClient

type SchedulerClient interface {
	// AnnouncePeer announces peer to scheduler.
	AnnouncePeer(ctx context.Context, opts ...grpc.CallOption) (Scheduler_AnnouncePeerClient, error)
	// Checks information of peer.
	StatPeer(ctx context.Context, in *StatPeerRequest, opts ...grpc.CallOption) (*v2.Peer, error)
	// DeletePeer releases peer in scheduler.
	DeletePeer(ctx context.Context, in *DeletePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// A host announces that it has the announced peers to scheduler at startup.
	AnnouncePeers(ctx context.Context, opts ...grpc.CallOption) (Scheduler_AnnouncePeersClient, error)
	// Checks information of task.
	StatTask(ctx context.Context, in *StatTaskRequest, opts ...grpc.CallOption) (*v2.Task, error)
	// DeleteTask releases task in scheduler.
	DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// AnnounceHost announces host to scheduler.
	AnnounceHost(ctx context.Context, in *AnnounceHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// DeleteHost releases host in scheduler.
	DeleteHost(ctx context.Context, in *DeleteHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// SyncProbes sync probes of the host.
	SyncProbes(ctx context.Context, opts ...grpc.CallOption) (Scheduler_SyncProbesClient, error)
	// AnnounceCachePeer announces cache peer to scheduler.
	AnnounceCachePeer(ctx context.Context, opts ...grpc.CallOption) (Scheduler_AnnounceCachePeerClient, error)
	// Checks information of cache peer.
	StatCachePeer(ctx context.Context, in *StatCachePeerRequest, opts ...grpc.CallOption) (*v2.CachePeer, error)
	// DeleteCachePeer releases cache peer in scheduler.
	DeleteCachePeer(ctx context.Context, in *DeleteCachePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// UploadCacheTaskStarted uploads cache task started to scheduler.
	UploadCacheTaskStarted(ctx context.Context, in *UploadCacheTaskStartedRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// UploadCacheTaskFinished uploads cache task finished to scheduler.
	UploadCacheTaskFinished(ctx context.Context, in *UploadCacheTaskFinishedRequest, opts ...grpc.CallOption) (*v2.CacheTask, error)
	// UploadCacheTaskFailed uploads cache task failed to scheduler.
	UploadCacheTaskFailed(ctx context.Context, in *UploadCacheTaskFailedRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Checks information of cache task.
	StatCacheTask(ctx context.Context, in *StatCacheTaskRequest, opts ...grpc.CallOption) (*v2.CacheTask, error)
	// DeleteCacheTask releases cache task in scheduler.
	DeleteCacheTask(ctx context.Context, in *DeleteCacheTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

SchedulerClient is the client API for Scheduler service.

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

func NewSchedulerClient

func NewSchedulerClient(cc grpc.ClientConnInterface) SchedulerClient

type SchedulerServer

type SchedulerServer interface {
	// AnnouncePeer announces peer to scheduler.
	AnnouncePeer(Scheduler_AnnouncePeerServer) error
	// Checks information of peer.
	StatPeer(context.Context, *StatPeerRequest) (*v2.Peer, error)
	// DeletePeer releases peer in scheduler.
	DeletePeer(context.Context, *DeletePeerRequest) (*emptypb.Empty, error)
	// A host announces that it has the announced peers to scheduler at startup.
	AnnouncePeers(Scheduler_AnnouncePeersServer) error
	// Checks information of task.
	StatTask(context.Context, *StatTaskRequest) (*v2.Task, error)
	// DeleteTask releases task in scheduler.
	DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)
	// AnnounceHost announces host to scheduler.
	AnnounceHost(context.Context, *AnnounceHostRequest) (*emptypb.Empty, error)
	// DeleteHost releases host in scheduler.
	DeleteHost(context.Context, *DeleteHostRequest) (*emptypb.Empty, error)
	// SyncProbes sync probes of the host.
	SyncProbes(Scheduler_SyncProbesServer) error
	// AnnounceCachePeer announces cache peer to scheduler.
	AnnounceCachePeer(Scheduler_AnnounceCachePeerServer) error
	// Checks information of cache peer.
	StatCachePeer(context.Context, *StatCachePeerRequest) (*v2.CachePeer, error)
	// DeleteCachePeer releases cache peer in scheduler.
	DeleteCachePeer(context.Context, *DeleteCachePeerRequest) (*emptypb.Empty, error)
	// UploadCacheTaskStarted uploads cache task started to scheduler.
	UploadCacheTaskStarted(context.Context, *UploadCacheTaskStartedRequest) (*emptypb.Empty, error)
	// UploadCacheTaskFinished uploads cache task finished to scheduler.
	UploadCacheTaskFinished(context.Context, *UploadCacheTaskFinishedRequest) (*v2.CacheTask, error)
	// UploadCacheTaskFailed uploads cache task failed to scheduler.
	UploadCacheTaskFailed(context.Context, *UploadCacheTaskFailedRequest) (*emptypb.Empty, error)
	// Checks information of cache task.
	StatCacheTask(context.Context, *StatCacheTaskRequest) (*v2.CacheTask, error)
	// DeleteCacheTask releases cache task in scheduler.
	DeleteCacheTask(context.Context, *DeleteCacheTaskRequest) (*emptypb.Empty, error)
}

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

type Scheduler_AnnounceCachePeerClient added in v2.0.121

type Scheduler_AnnounceCachePeerClient interface {
	Send(*AnnounceCachePeerRequest) error
	Recv() (*AnnounceCachePeerResponse, error)
	grpc.ClientStream
}

type Scheduler_AnnounceCachePeerServer added in v2.0.121

type Scheduler_AnnounceCachePeerServer interface {
	Send(*AnnounceCachePeerResponse) error
	Recv() (*AnnounceCachePeerRequest, error)
	grpc.ServerStream
}

type Scheduler_AnnouncePeerClient

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

type Scheduler_AnnouncePeerServer

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

type Scheduler_AnnouncePeersClient added in v2.0.133

type Scheduler_AnnouncePeersClient interface {
	Send(*AnnouncePeersRequest) error
	Recv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type Scheduler_AnnouncePeersServer added in v2.0.133

type Scheduler_AnnouncePeersServer interface {
	Send(*emptypb.Empty) error
	Recv() (*AnnouncePeersRequest, error)
	grpc.ServerStream
}

type Scheduler_SyncProbesClient

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

type Scheduler_SyncProbesServer

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

type StatCachePeerRequest added in v2.0.121

type StatCachePeerRequest struct {

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

StatCachePeerRequest represents request of StatCachePeer.

func (*StatCachePeerRequest) Descriptor deprecated added in v2.0.121

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

Deprecated: Use StatCachePeerRequest.ProtoReflect.Descriptor instead.

func (*StatCachePeerRequest) GetHostId added in v2.0.121

func (x *StatCachePeerRequest) GetHostId() string

func (*StatCachePeerRequest) GetPeerId added in v2.0.121

func (x *StatCachePeerRequest) GetPeerId() string

func (*StatCachePeerRequest) GetTaskId added in v2.0.121

func (x *StatCachePeerRequest) GetTaskId() string

func (*StatCachePeerRequest) ProtoMessage added in v2.0.121

func (*StatCachePeerRequest) ProtoMessage()

func (*StatCachePeerRequest) ProtoReflect added in v2.0.121

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

func (*StatCachePeerRequest) Reset added in v2.0.121

func (x *StatCachePeerRequest) Reset()

func (*StatCachePeerRequest) String added in v2.0.121

func (x *StatCachePeerRequest) String() string

func (*StatCachePeerRequest) Validate added in v2.0.121

func (m *StatCachePeerRequest) Validate() error

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

func (*StatCachePeerRequest) ValidateAll added in v2.0.121

func (m *StatCachePeerRequest) ValidateAll() error

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

type StatCachePeerRequestMultiError added in v2.0.121

type StatCachePeerRequestMultiError []error

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

func (StatCachePeerRequestMultiError) AllErrors added in v2.0.121

func (m StatCachePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatCachePeerRequestMultiError) Error added in v2.0.121

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

type StatCachePeerRequestValidationError added in v2.0.121

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

StatCachePeerRequestValidationError is the validation error returned by StatCachePeerRequest.Validate if the designated constraints aren't met.

func (StatCachePeerRequestValidationError) Cause added in v2.0.121

Cause function returns cause value.

func (StatCachePeerRequestValidationError) Error added in v2.0.121

Error satisfies the builtin error interface

func (StatCachePeerRequestValidationError) ErrorName added in v2.0.121

ErrorName returns error name.

func (StatCachePeerRequestValidationError) Field added in v2.0.121

Field function returns field value.

func (StatCachePeerRequestValidationError) Key added in v2.0.121

Key function returns key value.

func (StatCachePeerRequestValidationError) Reason added in v2.0.121

Reason function returns reason value.

type StatCacheTaskRequest added in v2.0.121

type StatCacheTaskRequest struct {

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

StatCacheTaskRequest represents request of StatCacheTask.

func (*StatCacheTaskRequest) Descriptor deprecated added in v2.0.121

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

Deprecated: Use StatCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*StatCacheTaskRequest) GetHostId added in v2.0.131

func (x *StatCacheTaskRequest) GetHostId() string

func (*StatCacheTaskRequest) GetTaskId added in v2.0.121

func (x *StatCacheTaskRequest) GetTaskId() string

func (*StatCacheTaskRequest) ProtoMessage added in v2.0.121

func (*StatCacheTaskRequest) ProtoMessage()

func (*StatCacheTaskRequest) ProtoReflect added in v2.0.121

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

func (*StatCacheTaskRequest) Reset added in v2.0.121

func (x *StatCacheTaskRequest) Reset()

func (*StatCacheTaskRequest) String added in v2.0.121

func (x *StatCacheTaskRequest) String() string

func (*StatCacheTaskRequest) Validate added in v2.0.121

func (m *StatCacheTaskRequest) Validate() error

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

func (*StatCacheTaskRequest) ValidateAll added in v2.0.121

func (m *StatCacheTaskRequest) ValidateAll() error

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

type StatCacheTaskRequestMultiError added in v2.0.121

type StatCacheTaskRequestMultiError []error

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

func (StatCacheTaskRequestMultiError) AllErrors added in v2.0.121

func (m StatCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatCacheTaskRequestMultiError) Error added in v2.0.121

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

type StatCacheTaskRequestValidationError added in v2.0.121

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

StatCacheTaskRequestValidationError is the validation error returned by StatCacheTaskRequest.Validate if the designated constraints aren't met.

func (StatCacheTaskRequestValidationError) Cause added in v2.0.121

Cause function returns cause value.

func (StatCacheTaskRequestValidationError) Error added in v2.0.121

Error satisfies the builtin error interface

func (StatCacheTaskRequestValidationError) ErrorName added in v2.0.121

ErrorName returns error name.

func (StatCacheTaskRequestValidationError) Field added in v2.0.121

Field function returns field value.

func (StatCacheTaskRequestValidationError) Key added in v2.0.121

Key function returns key value.

func (StatCacheTaskRequestValidationError) Reason added in v2.0.121

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

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

Cause function returns cause value.

func (StatPeerRequestValidationError) Error

Error satisfies the builtin error interface

func (StatPeerRequestValidationError) ErrorName

func (e StatPeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatPeerRequestValidationError) Field

Field function returns field value.

func (StatPeerRequestValidationError) Key

Key function returns key value.

func (StatPeerRequestValidationError) Reason

Reason function returns reason value.

type StatTaskRequest

type StatTaskRequest struct {

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

StatTaskRequest represents request of StatTask.

func (*StatTaskRequest) Descriptor deprecated

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

Deprecated: Use StatTaskRequest.ProtoReflect.Descriptor instead.

func (*StatTaskRequest) GetHostId added in v2.0.131

func (x *StatTaskRequest) GetHostId() string

func (*StatTaskRequest) GetTaskId added in v2.0.121

func (x *StatTaskRequest) GetTaskId() string

func (*StatTaskRequest) ProtoMessage

func (*StatTaskRequest) ProtoMessage()

func (*StatTaskRequest) ProtoReflect

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

func (*StatTaskRequest) Reset

func (x *StatTaskRequest) Reset()

func (*StatTaskRequest) String

func (x *StatTaskRequest) String() string

func (*StatTaskRequest) Validate

func (m *StatTaskRequest) Validate() error

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

func (*StatTaskRequest) ValidateAll

func (m *StatTaskRequest) ValidateAll() error

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

type StatTaskRequestMultiError

type StatTaskRequestMultiError []error

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

func (StatTaskRequestMultiError) AllErrors

func (m StatTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatTaskRequestMultiError) Error

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

Cause function returns cause value.

func (StatTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (StatTaskRequestValidationError) ErrorName

func (e StatTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatTaskRequestValidationError) Field

Field function returns field value.

func (StatTaskRequestValidationError) Key

Key function returns key value.

func (StatTaskRequestValidationError) Reason

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

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

Cause function returns cause value.

func (SyncProbesRequestValidationError) Error

Error satisfies the builtin error interface

func (SyncProbesRequestValidationError) ErrorName

ErrorName returns error name.

func (SyncProbesRequestValidationError) Field

Field function returns field value.

func (SyncProbesRequestValidationError) Key

Key function returns key value.

func (SyncProbesRequestValidationError) Reason

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

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

Cause function returns cause value.

func (SyncProbesResponseValidationError) Error

Error satisfies the builtin error interface

func (SyncProbesResponseValidationError) ErrorName

ErrorName returns error name.

func (SyncProbesResponseValidationError) Field

Field function returns field value.

func (SyncProbesResponseValidationError) Key

Key function returns key value.

func (SyncProbesResponseValidationError) Reason

Reason function returns reason value.

type UnimplementedSchedulerServer

type UnimplementedSchedulerServer struct {
}

UnimplementedSchedulerServer should be embedded to have forward compatible implementations.

func (UnimplementedSchedulerServer) AnnounceCachePeer added in v2.0.121

func (UnimplementedSchedulerServer) AnnounceHost

func (UnimplementedSchedulerServer) AnnouncePeer

func (UnimplementedSchedulerServer) AnnouncePeers added in v2.0.133

func (UnimplementedSchedulerServer) DeleteCachePeer added in v2.0.121

func (UnimplementedSchedulerServer) DeleteCacheTask added in v2.0.121

func (UnimplementedSchedulerServer) DeleteHost added in v2.0.118

func (UnimplementedSchedulerServer) DeletePeer added in v2.0.118

func (UnimplementedSchedulerServer) DeleteTask added in v2.0.118

func (UnimplementedSchedulerServer) StatCachePeer added in v2.0.121

func (UnimplementedSchedulerServer) StatCacheTask added in v2.0.121

func (UnimplementedSchedulerServer) StatPeer

func (UnimplementedSchedulerServer) StatTask

func (UnimplementedSchedulerServer) SyncProbes

func (UnimplementedSchedulerServer) UploadCacheTaskFailed added in v2.0.129

func (UnimplementedSchedulerServer) UploadCacheTaskFinished added in v2.0.129

func (UnimplementedSchedulerServer) UploadCacheTaskStarted added in v2.0.129

type UnsafeSchedulerServer

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

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

type UploadCacheTaskFailedRequest added in v2.0.128

type UploadCacheTaskFailedRequest 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"`
	// The description of the upload failed.
	Description *string `protobuf:"bytes,4,opt,name=description,proto3,oneof" json:"description,omitempty"`
	// contains filtered or unexported fields
}

UploadCacheTaskFailedRequest represents upload cache task failed request of UploadCacheTaskFailedRequest.

func (*UploadCacheTaskFailedRequest) Descriptor deprecated added in v2.0.128

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

Deprecated: Use UploadCacheTaskFailedRequest.ProtoReflect.Descriptor instead.

func (*UploadCacheTaskFailedRequest) GetDescription added in v2.0.128

func (x *UploadCacheTaskFailedRequest) GetDescription() string

func (*UploadCacheTaskFailedRequest) GetHostId added in v2.0.130

func (x *UploadCacheTaskFailedRequest) GetHostId() string

func (*UploadCacheTaskFailedRequest) GetPeerId added in v2.0.130

func (x *UploadCacheTaskFailedRequest) GetPeerId() string

func (*UploadCacheTaskFailedRequest) GetTaskId added in v2.0.130

func (x *UploadCacheTaskFailedRequest) GetTaskId() string

func (*UploadCacheTaskFailedRequest) ProtoMessage added in v2.0.128

func (*UploadCacheTaskFailedRequest) ProtoMessage()

func (*UploadCacheTaskFailedRequest) ProtoReflect added in v2.0.128

func (*UploadCacheTaskFailedRequest) Reset added in v2.0.128

func (x *UploadCacheTaskFailedRequest) Reset()

func (*UploadCacheTaskFailedRequest) String added in v2.0.128

func (*UploadCacheTaskFailedRequest) Validate added in v2.0.128

func (m *UploadCacheTaskFailedRequest) Validate() error

Validate checks the field values on UploadCacheTaskFailedRequest 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 (*UploadCacheTaskFailedRequest) ValidateAll added in v2.0.128

func (m *UploadCacheTaskFailedRequest) ValidateAll() error

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

type UploadCacheTaskFailedRequestMultiError added in v2.0.128

type UploadCacheTaskFailedRequestMultiError []error

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

func (UploadCacheTaskFailedRequestMultiError) AllErrors added in v2.0.128

AllErrors returns a list of validation violation errors.

func (UploadCacheTaskFailedRequestMultiError) Error added in v2.0.128

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

type UploadCacheTaskFailedRequestValidationError added in v2.0.128

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

UploadCacheTaskFailedRequestValidationError is the validation error returned by UploadCacheTaskFailedRequest.Validate if the designated constraints aren't met.

func (UploadCacheTaskFailedRequestValidationError) Cause added in v2.0.128

Cause function returns cause value.

func (UploadCacheTaskFailedRequestValidationError) Error added in v2.0.128

Error satisfies the builtin error interface

func (UploadCacheTaskFailedRequestValidationError) ErrorName added in v2.0.128

ErrorName returns error name.

func (UploadCacheTaskFailedRequestValidationError) Field added in v2.0.128

Field function returns field value.

func (UploadCacheTaskFailedRequestValidationError) Key added in v2.0.128

Key function returns key value.

func (UploadCacheTaskFailedRequestValidationError) Reason added in v2.0.128

Reason function returns reason value.

type UploadCacheTaskFinishedRequest added in v2.0.128

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

UploadCacheTaskFinishedRequest represents upload cache task finished request of UploadCacheTaskFinishedRequest.

func (*UploadCacheTaskFinishedRequest) Descriptor deprecated added in v2.0.128

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

Deprecated: Use UploadCacheTaskFinishedRequest.ProtoReflect.Descriptor instead.

func (*UploadCacheTaskFinishedRequest) GetHostId added in v2.0.130

func (x *UploadCacheTaskFinishedRequest) GetHostId() string

func (*UploadCacheTaskFinishedRequest) GetPeerId added in v2.0.130

func (x *UploadCacheTaskFinishedRequest) GetPeerId() string

func (*UploadCacheTaskFinishedRequest) GetTaskId added in v2.0.130

func (x *UploadCacheTaskFinishedRequest) GetTaskId() string

func (*UploadCacheTaskFinishedRequest) ProtoMessage added in v2.0.128

func (*UploadCacheTaskFinishedRequest) ProtoMessage()

func (*UploadCacheTaskFinishedRequest) ProtoReflect added in v2.0.128

func (*UploadCacheTaskFinishedRequest) Reset added in v2.0.128

func (x *UploadCacheTaskFinishedRequest) Reset()

func (*UploadCacheTaskFinishedRequest) String added in v2.0.128

func (*UploadCacheTaskFinishedRequest) Validate added in v2.0.128

func (m *UploadCacheTaskFinishedRequest) Validate() error

Validate checks the field values on UploadCacheTaskFinishedRequest 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 (*UploadCacheTaskFinishedRequest) ValidateAll added in v2.0.128

func (m *UploadCacheTaskFinishedRequest) ValidateAll() error

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

type UploadCacheTaskFinishedRequestMultiError added in v2.0.128

type UploadCacheTaskFinishedRequestMultiError []error

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

func (UploadCacheTaskFinishedRequestMultiError) AllErrors added in v2.0.128

AllErrors returns a list of validation violation errors.

func (UploadCacheTaskFinishedRequestMultiError) Error added in v2.0.128

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

type UploadCacheTaskFinishedRequestValidationError added in v2.0.128

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

UploadCacheTaskFinishedRequestValidationError is the validation error returned by UploadCacheTaskFinishedRequest.Validate if the designated constraints aren't met.

func (UploadCacheTaskFinishedRequestValidationError) Cause added in v2.0.128

Cause function returns cause value.

func (UploadCacheTaskFinishedRequestValidationError) Error added in v2.0.128

Error satisfies the builtin error interface

func (UploadCacheTaskFinishedRequestValidationError) ErrorName added in v2.0.128

ErrorName returns error name.

func (UploadCacheTaskFinishedRequestValidationError) Field added in v2.0.128

Field function returns field value.

func (UploadCacheTaskFinishedRequestValidationError) Key added in v2.0.128

Key function returns key value.

func (UploadCacheTaskFinishedRequestValidationError) Reason added in v2.0.128

Reason function returns reason value.

type UploadCacheTaskStartedRequest added in v2.0.128

type UploadCacheTaskStartedRequest struct {

	// Host id.
	HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// Task id.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Peer id.
	PeerId string `protobuf:"bytes,3,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// Replica count of the persistent cache task.
	PersistentReplicaCount uint64 `` /* 130-byte string literal not displayed */
	// Tag is used to distinguish different cache tasks.
	Tag *string `protobuf:"bytes,5,opt,name=tag,proto3,oneof" json:"tag,omitempty"`
	// Application of task.
	Application *string `protobuf:"bytes,6,opt,name=application,proto3,oneof" json:"application,omitempty"`
	// Task piece length.
	PieceLength uint64 `protobuf:"varint,7,opt,name=piece_length,json=pieceLength,proto3" json:"piece_length,omitempty"`
	// TTL of the cache task.
	Ttl *durationpb.Duration `protobuf:"bytes,8,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// Upload timeout.
	Timeout *durationpb.Duration `protobuf:"bytes,9,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

UploadCacheTaskStartedRequest represents upload cache task started request of UploadCacheTaskStartedRequest.

func (*UploadCacheTaskStartedRequest) Descriptor deprecated added in v2.0.128

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

Deprecated: Use UploadCacheTaskStartedRequest.ProtoReflect.Descriptor instead.

func (*UploadCacheTaskStartedRequest) GetApplication added in v2.0.128

func (x *UploadCacheTaskStartedRequest) GetApplication() string

func (*UploadCacheTaskStartedRequest) GetHostId added in v2.0.129

func (x *UploadCacheTaskStartedRequest) GetHostId() string

func (*UploadCacheTaskStartedRequest) GetPeerId added in v2.0.129

func (x *UploadCacheTaskStartedRequest) GetPeerId() string

func (*UploadCacheTaskStartedRequest) GetPersistentReplicaCount added in v2.0.128

func (x *UploadCacheTaskStartedRequest) GetPersistentReplicaCount() uint64

func (*UploadCacheTaskStartedRequest) GetPieceLength added in v2.0.128

func (x *UploadCacheTaskStartedRequest) GetPieceLength() uint64

func (*UploadCacheTaskStartedRequest) GetTag added in v2.0.128

func (*UploadCacheTaskStartedRequest) GetTaskId added in v2.0.129

func (x *UploadCacheTaskStartedRequest) GetTaskId() string

func (*UploadCacheTaskStartedRequest) GetTimeout added in v2.0.128

func (*UploadCacheTaskStartedRequest) GetTtl added in v2.0.128

func (*UploadCacheTaskStartedRequest) ProtoMessage added in v2.0.128

func (*UploadCacheTaskStartedRequest) ProtoMessage()

func (*UploadCacheTaskStartedRequest) ProtoReflect added in v2.0.128

func (*UploadCacheTaskStartedRequest) Reset added in v2.0.128

func (x *UploadCacheTaskStartedRequest) Reset()

func (*UploadCacheTaskStartedRequest) String added in v2.0.128

func (*UploadCacheTaskStartedRequest) Validate added in v2.0.128

func (m *UploadCacheTaskStartedRequest) Validate() error

Validate checks the field values on UploadCacheTaskStartedRequest 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 (*UploadCacheTaskStartedRequest) ValidateAll added in v2.0.128

func (m *UploadCacheTaskStartedRequest) ValidateAll() error

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

type UploadCacheTaskStartedRequestMultiError added in v2.0.128

type UploadCacheTaskStartedRequestMultiError []error

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

func (UploadCacheTaskStartedRequestMultiError) AllErrors added in v2.0.128

AllErrors returns a list of validation violation errors.

func (UploadCacheTaskStartedRequestMultiError) Error added in v2.0.128

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

type UploadCacheTaskStartedRequestValidationError added in v2.0.128

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

UploadCacheTaskStartedRequestValidationError is the validation error returned by UploadCacheTaskStartedRequest.Validate if the designated constraints aren't met.

func (UploadCacheTaskStartedRequestValidationError) Cause added in v2.0.128

Cause function returns cause value.

func (UploadCacheTaskStartedRequestValidationError) Error added in v2.0.128

Error satisfies the builtin error interface

func (UploadCacheTaskStartedRequestValidationError) ErrorName added in v2.0.128

ErrorName returns error name.

func (UploadCacheTaskStartedRequestValidationError) Field added in v2.0.128

Field function returns field value.

func (UploadCacheTaskStartedRequestValidationError) Key added in v2.0.128

Key function returns key value.

func (UploadCacheTaskStartedRequestValidationError) Reason added in v2.0.128

Reason function returns reason value.

Directories

Path Synopsis
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL