scheduler

package
v2.0.166 Latest Latest
Warning

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

 Go to latest Published: Sep 30, 2024 License: Apache-2.0 Imports: 25 Imported by: 15

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_apis_scheduler_v2_scheduler_proto protoreflect.FileDescriptor
View Source 
var Scheduler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "scheduler.v2.Scheduler",
	HandlerType: (*SchedulerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StatPeer",
			Handler:    _Scheduler_StatPeer_Handler,
		},
		{
			MethodName: "DeletePeer",
			Handler:    _Scheduler_DeletePeer_Handler,
		},
		{
			MethodName: "StatTask",
			Handler:    _Scheduler_StatTask_Handler,
		},
		{
			MethodName: "DeleteTask",
			Handler:    _Scheduler_DeleteTask_Handler,
		},
		{
			MethodName: "AnnounceHost",
			Handler:    _Scheduler_AnnounceHost_Handler,
		},
		{
			MethodName: "ListHosts",
			Handler:    _Scheduler_ListHosts_Handler,
		},
		{
			MethodName: "DeleteHost",
			Handler:    _Scheduler_DeleteHost_Handler,
		},
		{
			MethodName: "StatPersistentCachePeer",
			Handler:    _Scheduler_StatPersistentCachePeer_Handler,
		},
		{
			MethodName: "DeletePersistentCachePeer",
			Handler:    _Scheduler_DeletePersistentCachePeer_Handler,
		},
		{
			MethodName: "UploadPersistentCacheTaskStarted",
			Handler:    _Scheduler_UploadPersistentCacheTaskStarted_Handler,
		},
		{
			MethodName: "UploadPersistentCacheTaskFinished",
			Handler:    _Scheduler_UploadPersistentCacheTaskFinished_Handler,
		},
		{
			MethodName: "UploadPersistentCacheTaskFailed",
			Handler:    _Scheduler_UploadPersistentCacheTaskFailed_Handler,
		},
		{
			MethodName: "StatPersistentCacheTask",
			Handler:    _Scheduler_StatPersistentCacheTask_Handler,
		},
		{
			MethodName: "DeletePersistentCacheTask",
			Handler:    _Scheduler_DeletePersistentCacheTask_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "AnnouncePeer",
			Handler:       _Scheduler_AnnouncePeer_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "AnnouncePersistentCachePeer",
			Handler:       _Scheduler_AnnouncePersistentCachePeer_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/apis/scheduler/v2/scheduler.proto",
}

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

Functions

func RegisterSchedulerServer 

func RegisterSchedulerServer(s grpc.ServiceRegistrar, srv SchedulerServer)

Types

type AnnounceHostRequest 

type AnnounceHostRequest struct {

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

AnnounceHostRequest represents request of AnnounceHost.

func (*AnnounceHostRequest) Descriptor deprecated 

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

Deprecated: Use AnnounceHostRequest.ProtoReflect.Descriptor instead.

func (*AnnounceHostRequest) GetHost 

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

func (*AnnounceHostRequest) GetInterval added in v2.0.125 

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

func (*AnnounceHostRequest) ProtoMessage 

func (*AnnounceHostRequest) ProtoMessage()

func (*AnnounceHostRequest) ProtoReflect 

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

func (*AnnounceHostRequest) Reset 

func (x *AnnounceHostRequest) Reset()

func (*AnnounceHostRequest) String 

func (x *AnnounceHostRequest) String() string

func (*AnnounceHostRequest) Validate 

func (m *AnnounceHostRequest) Validate() error

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

func (*AnnounceHostRequest) ValidateAll 

func (m *AnnounceHostRequest) ValidateAll() error

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

type AnnounceHostRequestMultiError 

type AnnounceHostRequestMultiError []error

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

func (AnnounceHostRequestMultiError) AllErrors 

func (m AnnounceHostRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnounceHostRequestMultiError) Error 

func (m AnnounceHostRequestMultiError) Error() string

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

type AnnounceHostRequestValidationError 

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

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

func (AnnounceHostRequestValidationError) Cause 

func (e AnnounceHostRequestValidationError) Cause() error

Cause function returns cause value.

func (AnnounceHostRequestValidationError) Error 

func (e AnnounceHostRequestValidationError) Error() string

Error satisfies the builtin error interface

func (AnnounceHostRequestValidationError) ErrorName 

func (e AnnounceHostRequestValidationError) ErrorName() string

ErrorName returns error name.

func (AnnounceHostRequestValidationError) Field 

func (e AnnounceHostRequestValidationError) Field() string

Field function returns field value.

func (AnnounceHostRequestValidationError) Key 

func (e AnnounceHostRequestValidationError) Key() bool

Key function returns key value.

func (AnnounceHostRequestValidationError) Reason 

func (e AnnounceHostRequestValidationError) Reason() string

Reason function returns reason value.

type AnnouncePeerRequest 

type AnnouncePeerRequest struct {

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

AnnouncePeerRequest represents request of AnnouncePeer.

func (*AnnouncePeerRequest) Descriptor deprecated 

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

Deprecated: Use AnnouncePeerRequest.ProtoReflect.Descriptor instead.

func (*AnnouncePeerRequest) GetDownloadPeerBackToSourceFailedRequest 

func (x *AnnouncePeerRequest) GetDownloadPeerBackToSourceFailedRequest() *DownloadPeerBackToSourceFailedRequest

func (*AnnouncePeerRequest) GetDownloadPeerBackToSourceFinishedRequest 

func (x *AnnouncePeerRequest) GetDownloadPeerBackToSourceFinishedRequest() *DownloadPeerBackToSourceFinishedRequest

func (*AnnouncePeerRequest) GetDownloadPeerBackToSourceStartedRequest 

func (x *AnnouncePeerRequest) GetDownloadPeerBackToSourceStartedRequest() *DownloadPeerBackToSourceStartedRequest

func (*AnnouncePeerRequest) GetDownloadPeerFailedRequest 

func (x *AnnouncePeerRequest) GetDownloadPeerFailedRequest() *DownloadPeerFailedRequest

func (*AnnouncePeerRequest) GetDownloadPeerFinishedRequest 

func (x *AnnouncePeerRequest) GetDownloadPeerFinishedRequest() *DownloadPeerFinishedRequest

func (*AnnouncePeerRequest) GetDownloadPeerStartedRequest 

func (x *AnnouncePeerRequest) GetDownloadPeerStartedRequest() *DownloadPeerStartedRequest

func (*AnnouncePeerRequest) GetDownloadPieceBackToSourceFailedRequest 

func (x *AnnouncePeerRequest) GetDownloadPieceBackToSourceFailedRequest() *DownloadPieceBackToSourceFailedRequest

func (*AnnouncePeerRequest) GetDownloadPieceBackToSourceFinishedRequest 

func (x *AnnouncePeerRequest) GetDownloadPieceBackToSourceFinishedRequest() *DownloadPieceBackToSourceFinishedRequest

func (*AnnouncePeerRequest) GetDownloadPieceFailedRequest 

func (x *AnnouncePeerRequest) GetDownloadPieceFailedRequest() *DownloadPieceFailedRequest

func (*AnnouncePeerRequest) GetDownloadPieceFinishedRequest 

func (x *AnnouncePeerRequest) GetDownloadPieceFinishedRequest() *DownloadPieceFinishedRequest

func (*AnnouncePeerRequest) GetHostId 

func (x *AnnouncePeerRequest) GetHostId() string

func (*AnnouncePeerRequest) GetPeerId 

func (x *AnnouncePeerRequest) GetPeerId() string

func (*AnnouncePeerRequest) GetRegisterPeerRequest 

func (x *AnnouncePeerRequest) GetRegisterPeerRequest() *RegisterPeerRequest

func (*AnnouncePeerRequest) GetRequest 

func (m *AnnouncePeerRequest) GetRequest() isAnnouncePeerRequest_Request

func (*AnnouncePeerRequest) GetReschedulePeerRequest added in v2.0.121 

func (x *AnnouncePeerRequest) GetReschedulePeerRequest() *ReschedulePeerRequest

func (*AnnouncePeerRequest) GetTaskId 

func (x *AnnouncePeerRequest) GetTaskId() string

func (*AnnouncePeerRequest) ProtoMessage 

func (*AnnouncePeerRequest) ProtoMessage()

func (*AnnouncePeerRequest) ProtoReflect 

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

func (*AnnouncePeerRequest) Reset 

func (x *AnnouncePeerRequest) Reset()

func (*AnnouncePeerRequest) String 

func (x *AnnouncePeerRequest) String() string

func (*AnnouncePeerRequest) Validate 

func (m *AnnouncePeerRequest) Validate() error

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

func (*AnnouncePeerRequest) ValidateAll 

func (m *AnnouncePeerRequest) ValidateAll() error

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

type AnnouncePeerRequestMultiError 

type AnnouncePeerRequestMultiError []error

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

func (AnnouncePeerRequestMultiError) AllErrors 

func (m AnnouncePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnouncePeerRequestMultiError) Error 

func (m AnnouncePeerRequestMultiError) Error() string

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

type AnnouncePeerRequestValidationError 

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

AnnouncePeerRequestValidationError is the validation error returned by AnnouncePeerRequest.Validate if the designated constraints aren't met.

func (AnnouncePeerRequestValidationError) Cause 

func (e AnnouncePeerRequestValidationError) Cause() error

Cause function returns cause value.

func (AnnouncePeerRequestValidationError) Error 

func (e AnnouncePeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (AnnouncePeerRequestValidationError) ErrorName 

func (e AnnouncePeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (AnnouncePeerRequestValidationError) Field 

func (e AnnouncePeerRequestValidationError) Field() string

Field function returns field value.

func (AnnouncePeerRequestValidationError) Key 

func (e AnnouncePeerRequestValidationError) Key() bool

Key function returns key value.

func (AnnouncePeerRequestValidationError) Reason 

func (e AnnouncePeerRequestValidationError) Reason() string

Reason function returns reason value.

type AnnouncePeerRequest_DownloadPeerBackToSourceFailedRequest 

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

type AnnouncePeerRequest_DownloadPeerBackToSourceFinishedRequest 

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

type AnnouncePeerRequest_DownloadPeerBackToSourceStartedRequest 

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

type AnnouncePeerRequest_DownloadPeerFailedRequest 

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

type AnnouncePeerRequest_DownloadPeerFinishedRequest 

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

type AnnouncePeerRequest_DownloadPeerStartedRequest 

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

type AnnouncePeerRequest_DownloadPieceBackToSourceFailedRequest 

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

type AnnouncePeerRequest_DownloadPieceBackToSourceFinishedRequest 

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

type AnnouncePeerRequest_DownloadPieceFailedRequest 

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

type AnnouncePeerRequest_DownloadPieceFinishedRequest 

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

type AnnouncePeerRequest_RegisterPeerRequest 

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

type AnnouncePeerRequest_ReschedulePeerRequest added in v2.0.121 

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

type AnnouncePeerResponse 

type AnnouncePeerResponse struct {

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

AnnouncePeerResponse represents response of AnnouncePeer.

func (*AnnouncePeerResponse) Descriptor deprecated 

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

Deprecated: Use AnnouncePeerResponse.ProtoReflect.Descriptor instead.

func (*AnnouncePeerResponse) GetEmptyTaskResponse 

func (x *AnnouncePeerResponse) GetEmptyTaskResponse() *EmptyTaskResponse

func (*AnnouncePeerResponse) GetNeedBackToSourceResponse 

func (x *AnnouncePeerResponse) GetNeedBackToSourceResponse() *NeedBackToSourceResponse

func (*AnnouncePeerResponse) GetNormalTaskResponse 

func (x *AnnouncePeerResponse) GetNormalTaskResponse() *NormalTaskResponse

func (*AnnouncePeerResponse) GetResponse 

func (m *AnnouncePeerResponse) GetResponse() isAnnouncePeerResponse_Response

func (*AnnouncePeerResponse) ProtoMessage 

func (*AnnouncePeerResponse) ProtoMessage()

func (*AnnouncePeerResponse) ProtoReflect 

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

func (*AnnouncePeerResponse) Reset 

func (x *AnnouncePeerResponse) Reset()

func (*AnnouncePeerResponse) String 

func (x *AnnouncePeerResponse) String() string

func (*AnnouncePeerResponse) Validate 

func (m *AnnouncePeerResponse) Validate() error

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

func (*AnnouncePeerResponse) ValidateAll 

func (m *AnnouncePeerResponse) ValidateAll() error

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

type AnnouncePeerResponseMultiError 

type AnnouncePeerResponseMultiError []error

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

func (AnnouncePeerResponseMultiError) AllErrors 

func (m AnnouncePeerResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnouncePeerResponseMultiError) Error 

func (m AnnouncePeerResponseMultiError) Error() string

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

type AnnouncePeerResponseValidationError 

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

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

func (AnnouncePeerResponseValidationError) Cause 

func (e AnnouncePeerResponseValidationError) Cause() error

Cause function returns cause value.

func (AnnouncePeerResponseValidationError) Error 

func (e AnnouncePeerResponseValidationError) Error() string

Error satisfies the builtin error interface

func (AnnouncePeerResponseValidationError) ErrorName 

func (e AnnouncePeerResponseValidationError) ErrorName() string

ErrorName returns error name.

func (AnnouncePeerResponseValidationError) Field 

func (e AnnouncePeerResponseValidationError) Field() string

Field function returns field value.

func (AnnouncePeerResponseValidationError) Key 

func (e AnnouncePeerResponseValidationError) Key() bool

Key function returns key value.

func (AnnouncePeerResponseValidationError) Reason 

func (e AnnouncePeerResponseValidationError) Reason() string

Reason function returns reason value.

type AnnouncePeerResponse_EmptyTaskResponse 

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

type AnnouncePeerResponse_NeedBackToSourceResponse 

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

type AnnouncePeerResponse_NormalTaskResponse 

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

type AnnouncePersistentCachePeerRequest added in v2.0.161 

type AnnouncePersistentCachePeerRequest 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:
	//
	//	*AnnouncePersistentCachePeerRequest_RegisterPersistentCachePeerRequest
	//	*AnnouncePersistentCachePeerRequest_DownloadPersistentCachePeerStartedRequest
	//	*AnnouncePersistentCachePeerRequest_ReschedulePersistentCachePeerRequest
	//	*AnnouncePersistentCachePeerRequest_DownloadPersistentCachePeerFinishedRequest
	//	*AnnouncePersistentCachePeerRequest_DownloadPersistentCachePeerFailedRequest
	//	*AnnouncePersistentCachePeerRequest_DownloadPieceFinishedRequest
	//	*AnnouncePersistentCachePeerRequest_DownloadPieceFailedRequest
	Request isAnnouncePersistentCachePeerRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

AnnouncePersistentCachePeerRequest represents request of AnnouncePersistentCachePeer.

func (*AnnouncePersistentCachePeerRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use AnnouncePersistentCachePeerRequest.ProtoReflect.Descriptor instead.

func (*AnnouncePersistentCachePeerRequest) GetDownloadPersistentCachePeerFailedRequest added in v2.0.161 

func (x *AnnouncePersistentCachePeerRequest) GetDownloadPersistentCachePeerFailedRequest() *DownloadPersistentCachePeerFailedRequest

func (*AnnouncePersistentCachePeerRequest) GetDownloadPersistentCachePeerFinishedRequest added in v2.0.161 

func (x *AnnouncePersistentCachePeerRequest) GetDownloadPersistentCachePeerFinishedRequest() *DownloadPersistentCachePeerFinishedRequest

func (*AnnouncePersistentCachePeerRequest) GetDownloadPersistentCachePeerStartedRequest added in v2.0.161 

func (x *AnnouncePersistentCachePeerRequest) GetDownloadPersistentCachePeerStartedRequest() *DownloadPersistentCachePeerStartedRequest

func (*AnnouncePersistentCachePeerRequest) GetDownloadPieceFailedRequest added in v2.0.161 

func (x *AnnouncePersistentCachePeerRequest) GetDownloadPieceFailedRequest() *DownloadPieceFailedRequest

func (*AnnouncePersistentCachePeerRequest) GetDownloadPieceFinishedRequest added in v2.0.161 

func (x *AnnouncePersistentCachePeerRequest) GetDownloadPieceFinishedRequest() *DownloadPieceFinishedRequest

func (*AnnouncePersistentCachePeerRequest) GetHostId added in v2.0.161 

func (x *AnnouncePersistentCachePeerRequest) GetHostId() string

func (*AnnouncePersistentCachePeerRequest) GetPeerId added in v2.0.161 

func (x *AnnouncePersistentCachePeerRequest) GetPeerId() string

func (*AnnouncePersistentCachePeerRequest) GetRegisterPersistentCachePeerRequest added in v2.0.161 

func (x *AnnouncePersistentCachePeerRequest) GetRegisterPersistentCachePeerRequest() *RegisterPersistentCachePeerRequest

func (*AnnouncePersistentCachePeerRequest) GetRequest added in v2.0.161 

func (m *AnnouncePersistentCachePeerRequest) GetRequest() isAnnouncePersistentCachePeerRequest_Request

func (*AnnouncePersistentCachePeerRequest) GetReschedulePersistentCachePeerRequest added in v2.0.161 

func (x *AnnouncePersistentCachePeerRequest) GetReschedulePersistentCachePeerRequest() *ReschedulePersistentCachePeerRequest

func (*AnnouncePersistentCachePeerRequest) GetTaskId added in v2.0.161 

func (x *AnnouncePersistentCachePeerRequest) GetTaskId() string

func (*AnnouncePersistentCachePeerRequest) ProtoMessage added in v2.0.161 

func (*AnnouncePersistentCachePeerRequest) ProtoMessage()

func (*AnnouncePersistentCachePeerRequest) ProtoReflect added in v2.0.161 

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

func (*AnnouncePersistentCachePeerRequest) Reset added in v2.0.161 

func (x *AnnouncePersistentCachePeerRequest) Reset()

func (*AnnouncePersistentCachePeerRequest) String added in v2.0.161 

func (x *AnnouncePersistentCachePeerRequest) String() string

func (*AnnouncePersistentCachePeerRequest) Validate added in v2.0.161 

func (m *AnnouncePersistentCachePeerRequest) Validate() error

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

func (m *AnnouncePersistentCachePeerRequest) ValidateAll() error

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

type AnnouncePersistentCachePeerRequestMultiError added in v2.0.161 

type AnnouncePersistentCachePeerRequestMultiError []error

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

func (AnnouncePersistentCachePeerRequestMultiError) AllErrors added in v2.0.161 

func (m AnnouncePersistentCachePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnouncePersistentCachePeerRequestMultiError) Error added in v2.0.161 

func (m AnnouncePersistentCachePeerRequestMultiError) Error() string

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

type AnnouncePersistentCachePeerRequestValidationError added in v2.0.161 

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

AnnouncePersistentCachePeerRequestValidationError is the validation error returned by AnnouncePersistentCachePeerRequest.Validate if the designated constraints aren't met.

func (AnnouncePersistentCachePeerRequestValidationError) Cause added in v2.0.161 

func (e AnnouncePersistentCachePeerRequestValidationError) Cause() error

Cause function returns cause value.

func (AnnouncePersistentCachePeerRequestValidationError) Error added in v2.0.161 

func (e AnnouncePersistentCachePeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (AnnouncePersistentCachePeerRequestValidationError) ErrorName added in v2.0.161 

func (e AnnouncePersistentCachePeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (AnnouncePersistentCachePeerRequestValidationError) Field added in v2.0.161 

func (e AnnouncePersistentCachePeerRequestValidationError) Field() string

Field function returns field value.

func (AnnouncePersistentCachePeerRequestValidationError) Key added in v2.0.161 

func (e AnnouncePersistentCachePeerRequestValidationError) Key() bool

Key function returns key value.

func (AnnouncePersistentCachePeerRequestValidationError) Reason added in v2.0.161 

func (e AnnouncePersistentCachePeerRequestValidationError) Reason() string

Reason function returns reason value.

type AnnouncePersistentCachePeerRequest_DownloadPersistentCachePeerFailedRequest added in v2.0.161 

type AnnouncePersistentCachePeerRequest_DownloadPersistentCachePeerFailedRequest struct {
	DownloadPersistentCachePeerFailedRequest *DownloadPersistentCachePeerFailedRequest `` /* 132-byte string literal not displayed */
}

type AnnouncePersistentCachePeerRequest_DownloadPersistentCachePeerFinishedRequest added in v2.0.161 

type AnnouncePersistentCachePeerRequest_DownloadPersistentCachePeerFinishedRequest struct {
	DownloadPersistentCachePeerFinishedRequest *DownloadPersistentCachePeerFinishedRequest `` /* 136-byte string literal not displayed */
}

type AnnouncePersistentCachePeerRequest_DownloadPersistentCachePeerStartedRequest added in v2.0.161 

type AnnouncePersistentCachePeerRequest_DownloadPersistentCachePeerStartedRequest struct {
	DownloadPersistentCachePeerStartedRequest *DownloadPersistentCachePeerStartedRequest `` /* 134-byte string literal not displayed */
}

type AnnouncePersistentCachePeerRequest_DownloadPieceFailedRequest added in v2.0.161 

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

type AnnouncePersistentCachePeerRequest_DownloadPieceFinishedRequest added in v2.0.161 

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

type AnnouncePersistentCachePeerRequest_RegisterPersistentCachePeerRequest added in v2.0.161 

type AnnouncePersistentCachePeerRequest_RegisterPersistentCachePeerRequest struct {
	RegisterPersistentCachePeerRequest *RegisterPersistentCachePeerRequest `protobuf:"bytes,4,opt,name=register_persistent_cache_peer_request,json=registerPersistentCachePeerRequest,proto3,oneof"`
}

type AnnouncePersistentCachePeerRequest_ReschedulePersistentCachePeerRequest added in v2.0.161 

type AnnouncePersistentCachePeerRequest_ReschedulePersistentCachePeerRequest struct {
	ReschedulePersistentCachePeerRequest *ReschedulePersistentCachePeerRequest `protobuf:"bytes,6,opt,name=reschedule_persistent_cache_peer_request,json=reschedulePersistentCachePeerRequest,proto3,oneof"`
}

type AnnouncePersistentCachePeerResponse added in v2.0.161 

type AnnouncePersistentCachePeerResponse struct {

	// Types that are assignable to Response:
	//
	//	*AnnouncePersistentCachePeerResponse_EmptyPersistentCacheTaskResponse
	//	*AnnouncePersistentCachePeerResponse_NormalPersistentCacheTaskResponse
	Response isAnnouncePersistentCachePeerResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

AnnouncePersistentCachePeerResponse represents response of AnnouncePersistentCachePeer.

func (*AnnouncePersistentCachePeerResponse) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use AnnouncePersistentCachePeerResponse.ProtoReflect.Descriptor instead.

func (*AnnouncePersistentCachePeerResponse) GetEmptyPersistentCacheTaskResponse added in v2.0.161 

func (x *AnnouncePersistentCachePeerResponse) GetEmptyPersistentCacheTaskResponse() *EmptyPersistentCacheTaskResponse

func (*AnnouncePersistentCachePeerResponse) GetNormalPersistentCacheTaskResponse added in v2.0.161 

func (x *AnnouncePersistentCachePeerResponse) GetNormalPersistentCacheTaskResponse() *NormalPersistentCacheTaskResponse

func (*AnnouncePersistentCachePeerResponse) GetResponse added in v2.0.161 

func (m *AnnouncePersistentCachePeerResponse) GetResponse() isAnnouncePersistentCachePeerResponse_Response

func (*AnnouncePersistentCachePeerResponse) ProtoMessage added in v2.0.161 

func (*AnnouncePersistentCachePeerResponse) ProtoMessage()

func (*AnnouncePersistentCachePeerResponse) ProtoReflect added in v2.0.161 

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

func (*AnnouncePersistentCachePeerResponse) Reset added in v2.0.161 

func (x *AnnouncePersistentCachePeerResponse) Reset()

func (*AnnouncePersistentCachePeerResponse) String added in v2.0.161 

func (x *AnnouncePersistentCachePeerResponse) String() string

func (*AnnouncePersistentCachePeerResponse) Validate added in v2.0.161 

func (m *AnnouncePersistentCachePeerResponse) Validate() error

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

func (m *AnnouncePersistentCachePeerResponse) ValidateAll() error

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

type AnnouncePersistentCachePeerResponseMultiError added in v2.0.161 

type AnnouncePersistentCachePeerResponseMultiError []error

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

func (AnnouncePersistentCachePeerResponseMultiError) AllErrors added in v2.0.161 

func (m AnnouncePersistentCachePeerResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnouncePersistentCachePeerResponseMultiError) Error added in v2.0.161 

func (m AnnouncePersistentCachePeerResponseMultiError) Error() string

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

type AnnouncePersistentCachePeerResponseValidationError added in v2.0.161 

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

AnnouncePersistentCachePeerResponseValidationError is the validation error returned by AnnouncePersistentCachePeerResponse.Validate if the designated constraints aren't met.

func (AnnouncePersistentCachePeerResponseValidationError) Cause added in v2.0.161 

func (e AnnouncePersistentCachePeerResponseValidationError) Cause() error

Cause function returns cause value.

func (AnnouncePersistentCachePeerResponseValidationError) Error added in v2.0.161 

func (e AnnouncePersistentCachePeerResponseValidationError) Error() string

Error satisfies the builtin error interface

func (AnnouncePersistentCachePeerResponseValidationError) ErrorName added in v2.0.161 

func (e AnnouncePersistentCachePeerResponseValidationError) ErrorName() string

ErrorName returns error name.

func (AnnouncePersistentCachePeerResponseValidationError) Field added in v2.0.161 

func (e AnnouncePersistentCachePeerResponseValidationError) Field() string

Field function returns field value.

func (AnnouncePersistentCachePeerResponseValidationError) Key added in v2.0.161 

func (e AnnouncePersistentCachePeerResponseValidationError) Key() bool

Key function returns key value.

func (AnnouncePersistentCachePeerResponseValidationError) Reason added in v2.0.161 

func (e AnnouncePersistentCachePeerResponseValidationError) Reason() string

Reason function returns reason value.

type AnnouncePersistentCachePeerResponse_EmptyPersistentCacheTaskResponse added in v2.0.161 

type AnnouncePersistentCachePeerResponse_EmptyPersistentCacheTaskResponse struct {
	EmptyPersistentCacheTaskResponse *EmptyPersistentCacheTaskResponse `protobuf:"bytes,1,opt,name=empty_persistent_cache_task_response,json=emptyPersistentCacheTaskResponse,proto3,oneof"`
}

type AnnouncePersistentCachePeerResponse_NormalPersistentCacheTaskResponse added in v2.0.161 

type AnnouncePersistentCachePeerResponse_NormalPersistentCacheTaskResponse struct {
	NormalPersistentCacheTaskResponse *NormalPersistentCacheTaskResponse `protobuf:"bytes,2,opt,name=normal_persistent_cache_task_response,json=normalPersistentCacheTaskResponse,proto3,oneof"`
}

type DeleteHostRequest added in v2.0.118 

type DeleteHostRequest struct {

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

DeleteHostRequest represents request of DeleteHost.

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

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

Deprecated: Use DeleteHostRequest.ProtoReflect.Descriptor instead.

func (*DeleteHostRequest) GetHostId added in v2.0.121 

func (x *DeleteHostRequest) GetHostId() string

func (*DeleteHostRequest) ProtoMessage added in v2.0.118 

func (*DeleteHostRequest) ProtoMessage()

func (*DeleteHostRequest) ProtoReflect added in v2.0.118 

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

func (*DeleteHostRequest) Reset added in v2.0.118 

func (x *DeleteHostRequest) Reset()

func (*DeleteHostRequest) String added in v2.0.118 

func (x *DeleteHostRequest) String() string

func (*DeleteHostRequest) Validate added in v2.0.118 

func (m *DeleteHostRequest) Validate() error

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

func (*DeleteHostRequest) ValidateAll added in v2.0.118 

func (m *DeleteHostRequest) ValidateAll() error

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

type DeleteHostRequestMultiError added in v2.0.118 

type DeleteHostRequestMultiError []error

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

func (DeleteHostRequestMultiError) AllErrors added in v2.0.118 

func (m DeleteHostRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteHostRequestMultiError) Error added in v2.0.118 

func (m DeleteHostRequestMultiError) Error() string

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

type DeleteHostRequestValidationError added in v2.0.118 

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

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

func (DeleteHostRequestValidationError) Cause added in v2.0.118 

func (e DeleteHostRequestValidationError) Cause() error

Cause function returns cause value.

func (DeleteHostRequestValidationError) Error added in v2.0.118 

func (e DeleteHostRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DeleteHostRequestValidationError) ErrorName added in v2.0.118 

func (e DeleteHostRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DeleteHostRequestValidationError) Field added in v2.0.118 

func (e DeleteHostRequestValidationError) Field() string

Field function returns field value.

func (DeleteHostRequestValidationError) Key added in v2.0.118 

func (e DeleteHostRequestValidationError) Key() bool

Key function returns key value.

func (DeleteHostRequestValidationError) Reason added in v2.0.118 

func (e DeleteHostRequestValidationError) Reason() string

Reason function returns reason value.

type DeletePeerRequest added in v2.0.118 

type DeletePeerRequest struct {

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

DeletePeerRequest represents request of DeletePeer.

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

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

Deprecated: Use DeletePeerRequest.ProtoReflect.Descriptor instead.

func (*DeletePeerRequest) GetHostId added in v2.0.118 

func (x *DeletePeerRequest) GetHostId() string

func (*DeletePeerRequest) GetPeerId added in v2.0.118 

func (x *DeletePeerRequest) GetPeerId() string

func (*DeletePeerRequest) GetTaskId added in v2.0.118 

func (x *DeletePeerRequest) GetTaskId() string

func (*DeletePeerRequest) ProtoMessage added in v2.0.118 

func (*DeletePeerRequest) ProtoMessage()

func (*DeletePeerRequest) ProtoReflect added in v2.0.118 

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

func (*DeletePeerRequest) Reset added in v2.0.118 

func (x *DeletePeerRequest) Reset()

func (*DeletePeerRequest) String added in v2.0.118 

func (x *DeletePeerRequest) String() string

func (*DeletePeerRequest) Validate added in v2.0.118 

func (m *DeletePeerRequest) Validate() error

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

func (*DeletePeerRequest) ValidateAll added in v2.0.118 

func (m *DeletePeerRequest) ValidateAll() error

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

type DeletePeerRequestMultiError added in v2.0.118 

type DeletePeerRequestMultiError []error

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

func (DeletePeerRequestMultiError) AllErrors added in v2.0.118 

func (m DeletePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeletePeerRequestMultiError) Error added in v2.0.118 

func (m DeletePeerRequestMultiError) Error() string

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

type DeletePeerRequestValidationError added in v2.0.118 

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

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

func (DeletePeerRequestValidationError) Cause added in v2.0.118 

func (e DeletePeerRequestValidationError) Cause() error

Cause function returns cause value.

func (DeletePeerRequestValidationError) Error added in v2.0.118 

func (e DeletePeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DeletePeerRequestValidationError) ErrorName added in v2.0.118 

func (e DeletePeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DeletePeerRequestValidationError) Field added in v2.0.118 

func (e DeletePeerRequestValidationError) Field() string

Field function returns field value.

func (DeletePeerRequestValidationError) Key added in v2.0.118 

func (e DeletePeerRequestValidationError) Key() bool

Key function returns key value.

func (DeletePeerRequestValidationError) Reason added in v2.0.118 

func (e DeletePeerRequestValidationError) Reason() string

Reason function returns reason value.

type DeletePersistentCachePeerRequest added in v2.0.161 

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

DeletePersistentCachePeerRequest represents request of DeletePersistentCachePeer.

func (*DeletePersistentCachePeerRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use DeletePersistentCachePeerRequest.ProtoReflect.Descriptor instead.

func (*DeletePersistentCachePeerRequest) GetHostId added in v2.0.161 

func (x *DeletePersistentCachePeerRequest) GetHostId() string

func (*DeletePersistentCachePeerRequest) GetPeerId added in v2.0.161 

func (x *DeletePersistentCachePeerRequest) GetPeerId() string

func (*DeletePersistentCachePeerRequest) GetTaskId added in v2.0.161 

func (x *DeletePersistentCachePeerRequest) GetTaskId() string

func (*DeletePersistentCachePeerRequest) ProtoMessage added in v2.0.161 

func (*DeletePersistentCachePeerRequest) ProtoMessage()

func (*DeletePersistentCachePeerRequest) ProtoReflect added in v2.0.161 

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

func (*DeletePersistentCachePeerRequest) Reset added in v2.0.161 

func (x *DeletePersistentCachePeerRequest) Reset()

func (*DeletePersistentCachePeerRequest) String added in v2.0.161 

func (x *DeletePersistentCachePeerRequest) String() string

func (*DeletePersistentCachePeerRequest) Validate added in v2.0.161 

func (m *DeletePersistentCachePeerRequest) Validate() error

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

func (m *DeletePersistentCachePeerRequest) ValidateAll() error

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

type DeletePersistentCachePeerRequestMultiError added in v2.0.161 

type DeletePersistentCachePeerRequestMultiError []error

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

func (DeletePersistentCachePeerRequestMultiError) AllErrors added in v2.0.161 

func (m DeletePersistentCachePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeletePersistentCachePeerRequestMultiError) Error added in v2.0.161 

func (m DeletePersistentCachePeerRequestMultiError) Error() string

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

type DeletePersistentCachePeerRequestValidationError added in v2.0.161 

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

DeletePersistentCachePeerRequestValidationError is the validation error returned by DeletePersistentCachePeerRequest.Validate if the designated constraints aren't met.

func (DeletePersistentCachePeerRequestValidationError) Cause added in v2.0.161 

func (e DeletePersistentCachePeerRequestValidationError) Cause() error

Cause function returns cause value.

func (DeletePersistentCachePeerRequestValidationError) Error added in v2.0.161 

func (e DeletePersistentCachePeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DeletePersistentCachePeerRequestValidationError) ErrorName added in v2.0.161 

func (e DeletePersistentCachePeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DeletePersistentCachePeerRequestValidationError) Field added in v2.0.161 

func (e DeletePersistentCachePeerRequestValidationError) Field() string

Field function returns field value.

func (DeletePersistentCachePeerRequestValidationError) Key added in v2.0.161 

func (e DeletePersistentCachePeerRequestValidationError) Key() bool

Key function returns key value.

func (DeletePersistentCachePeerRequestValidationError) Reason added in v2.0.161 

func (e DeletePersistentCachePeerRequestValidationError) Reason() string

Reason function returns reason value.

type DeletePersistentCacheTaskRequest added in v2.0.161 

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

DeletePersistentCacheTaskRequest represents request of DeletePersistentCacheTask.

func (*DeletePersistentCacheTaskRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use DeletePersistentCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*DeletePersistentCacheTaskRequest) GetHostId added in v2.0.161 

func (x *DeletePersistentCacheTaskRequest) GetHostId() string

func (*DeletePersistentCacheTaskRequest) GetTaskId added in v2.0.161 

func (x *DeletePersistentCacheTaskRequest) GetTaskId() string

func (*DeletePersistentCacheTaskRequest) ProtoMessage added in v2.0.161 

func (*DeletePersistentCacheTaskRequest) ProtoMessage()

func (*DeletePersistentCacheTaskRequest) ProtoReflect added in v2.0.161 

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

func (*DeletePersistentCacheTaskRequest) Reset added in v2.0.161 

func (x *DeletePersistentCacheTaskRequest) Reset()

func (*DeletePersistentCacheTaskRequest) String added in v2.0.161 

func (x *DeletePersistentCacheTaskRequest) String() string

func (*DeletePersistentCacheTaskRequest) Validate added in v2.0.161 

func (m *DeletePersistentCacheTaskRequest) Validate() error

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

func (m *DeletePersistentCacheTaskRequest) ValidateAll() error

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

type DeletePersistentCacheTaskRequestMultiError added in v2.0.161 

type DeletePersistentCacheTaskRequestMultiError []error

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

func (DeletePersistentCacheTaskRequestMultiError) AllErrors added in v2.0.161 

func (m DeletePersistentCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeletePersistentCacheTaskRequestMultiError) Error added in v2.0.161 

func (m DeletePersistentCacheTaskRequestMultiError) Error() string

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

type DeletePersistentCacheTaskRequestValidationError added in v2.0.161 

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

DeletePersistentCacheTaskRequestValidationError is the validation error returned by DeletePersistentCacheTaskRequest.Validate if the designated constraints aren't met.

func (DeletePersistentCacheTaskRequestValidationError) Cause added in v2.0.161 

func (e DeletePersistentCacheTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (DeletePersistentCacheTaskRequestValidationError) Error added in v2.0.161 

func (e DeletePersistentCacheTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DeletePersistentCacheTaskRequestValidationError) ErrorName added in v2.0.161 

func (e DeletePersistentCacheTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DeletePersistentCacheTaskRequestValidationError) Field added in v2.0.161 

func (e DeletePersistentCacheTaskRequestValidationError) Field() string

Field function returns field value.

func (DeletePersistentCacheTaskRequestValidationError) Key added in v2.0.161 

func (e DeletePersistentCacheTaskRequestValidationError) Key() bool

Key function returns key value.

func (DeletePersistentCacheTaskRequestValidationError) Reason added in v2.0.161 

func (e DeletePersistentCacheTaskRequestValidationError) Reason() string

Reason function returns reason value.

type DeleteTaskRequest added in v2.0.118 

type DeleteTaskRequest struct {

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

DeleteTaskRequest represents request of DeleteTask.

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

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

Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskRequest) GetHostId added in v2.0.118 

func (x *DeleteTaskRequest) GetHostId() string

func (*DeleteTaskRequest) GetTaskId added in v2.0.118 

func (x *DeleteTaskRequest) GetTaskId() string

func (*DeleteTaskRequest) ProtoMessage added in v2.0.118 

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) ProtoReflect added in v2.0.118 

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

func (*DeleteTaskRequest) Reset added in v2.0.118 

func (x *DeleteTaskRequest) Reset()

func (*DeleteTaskRequest) String added in v2.0.118 

func (x *DeleteTaskRequest) String() string

func (*DeleteTaskRequest) Validate added in v2.0.118 

func (m *DeleteTaskRequest) Validate() error

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

func (*DeleteTaskRequest) ValidateAll added in v2.0.118 

func (m *DeleteTaskRequest) ValidateAll() error

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

type DeleteTaskRequestMultiError added in v2.0.118 

type DeleteTaskRequestMultiError []error

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

func (DeleteTaskRequestMultiError) AllErrors added in v2.0.118 

func (m DeleteTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteTaskRequestMultiError) Error added in v2.0.118 

func (m DeleteTaskRequestMultiError) Error() string

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

type DeleteTaskRequestValidationError added in v2.0.118 

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

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

func (DeleteTaskRequestValidationError) Cause added in v2.0.118 

func (e DeleteTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (DeleteTaskRequestValidationError) Error added in v2.0.118 

func (e DeleteTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DeleteTaskRequestValidationError) ErrorName added in v2.0.118 

func (e DeleteTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DeleteTaskRequestValidationError) Field added in v2.0.118 

func (e DeleteTaskRequestValidationError) Field() string

Field function returns field value.

func (DeleteTaskRequestValidationError) Key added in v2.0.118 

func (e DeleteTaskRequestValidationError) Key() bool

Key function returns key value.

func (DeleteTaskRequestValidationError) Reason added in v2.0.118 

func (e DeleteTaskRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPeerBackToSourceFailedRequest 

type DownloadPeerBackToSourceFailedRequest struct {

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

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

func (*DownloadPeerBackToSourceFailedRequest) Descriptor deprecated 

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

Deprecated: Use DownloadPeerBackToSourceFailedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPeerBackToSourceFailedRequest) GetDescription 

func (x *DownloadPeerBackToSourceFailedRequest) GetDescription() string

func (*DownloadPeerBackToSourceFailedRequest) ProtoMessage 

func (*DownloadPeerBackToSourceFailedRequest) ProtoMessage()

func (*DownloadPeerBackToSourceFailedRequest) ProtoReflect 

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

func (*DownloadPeerBackToSourceFailedRequest) Reset 

func (x *DownloadPeerBackToSourceFailedRequest) Reset()

func (*DownloadPeerBackToSourceFailedRequest) String 

func (x *DownloadPeerBackToSourceFailedRequest) String() string

func (*DownloadPeerBackToSourceFailedRequest) Validate 

func (m *DownloadPeerBackToSourceFailedRequest) Validate() error

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

func (*DownloadPeerBackToSourceFailedRequest) ValidateAll 

func (m *DownloadPeerBackToSourceFailedRequest) ValidateAll() error

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

type DownloadPeerBackToSourceFailedRequestMultiError 

type DownloadPeerBackToSourceFailedRequestMultiError []error

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

func (DownloadPeerBackToSourceFailedRequestMultiError) AllErrors 

func (m DownloadPeerBackToSourceFailedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPeerBackToSourceFailedRequestMultiError) Error 

func (m DownloadPeerBackToSourceFailedRequestMultiError) Error() string

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

type DownloadPeerBackToSourceFailedRequestValidationError 

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

DownloadPeerBackToSourceFailedRequestValidationError is the validation error returned by DownloadPeerBackToSourceFailedRequest.Validate if the designated constraints aren't met.

func (DownloadPeerBackToSourceFailedRequestValidationError) Cause 

func (e DownloadPeerBackToSourceFailedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPeerBackToSourceFailedRequestValidationError) Error 

func (e DownloadPeerBackToSourceFailedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPeerBackToSourceFailedRequestValidationError) ErrorName 

func (e DownloadPeerBackToSourceFailedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPeerBackToSourceFailedRequestValidationError) Field 

func (e DownloadPeerBackToSourceFailedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPeerBackToSourceFailedRequestValidationError) Key 

func (e DownloadPeerBackToSourceFailedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPeerBackToSourceFailedRequestValidationError) Reason 

func (e DownloadPeerBackToSourceFailedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPeerBackToSourceFinishedRequest 

type DownloadPeerBackToSourceFinishedRequest struct {

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

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

func (*DownloadPeerBackToSourceFinishedRequest) Descriptor deprecated 

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

Deprecated: Use DownloadPeerBackToSourceFinishedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPeerBackToSourceFinishedRequest) GetContentLength 

func (x *DownloadPeerBackToSourceFinishedRequest) GetContentLength() uint64

func (*DownloadPeerBackToSourceFinishedRequest) GetPieceCount 

func (x *DownloadPeerBackToSourceFinishedRequest) GetPieceCount() uint32

func (*DownloadPeerBackToSourceFinishedRequest) ProtoMessage 

func (*DownloadPeerBackToSourceFinishedRequest) ProtoMessage()

func (*DownloadPeerBackToSourceFinishedRequest) ProtoReflect 

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

func (*DownloadPeerBackToSourceFinishedRequest) Reset 

func (x *DownloadPeerBackToSourceFinishedRequest) Reset()

func (*DownloadPeerBackToSourceFinishedRequest) String 

func (x *DownloadPeerBackToSourceFinishedRequest) String() string

func (*DownloadPeerBackToSourceFinishedRequest) Validate 

func (m *DownloadPeerBackToSourceFinishedRequest) Validate() error

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

func (*DownloadPeerBackToSourceFinishedRequest) ValidateAll 

func (m *DownloadPeerBackToSourceFinishedRequest) ValidateAll() error

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

type DownloadPeerBackToSourceFinishedRequestMultiError 

type DownloadPeerBackToSourceFinishedRequestMultiError []error

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

func (DownloadPeerBackToSourceFinishedRequestMultiError) AllErrors 

func (m DownloadPeerBackToSourceFinishedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPeerBackToSourceFinishedRequestMultiError) Error 

func (m DownloadPeerBackToSourceFinishedRequestMultiError) Error() string

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

type DownloadPeerBackToSourceFinishedRequestValidationError 

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

DownloadPeerBackToSourceFinishedRequestValidationError is the validation error returned by DownloadPeerBackToSourceFinishedRequest.Validate if the designated constraints aren't met.

func (DownloadPeerBackToSourceFinishedRequestValidationError) Cause 

func (e DownloadPeerBackToSourceFinishedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPeerBackToSourceFinishedRequestValidationError) Error 

func (e DownloadPeerBackToSourceFinishedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPeerBackToSourceFinishedRequestValidationError) ErrorName 

func (e DownloadPeerBackToSourceFinishedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPeerBackToSourceFinishedRequestValidationError) Field 

func (e DownloadPeerBackToSourceFinishedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPeerBackToSourceFinishedRequestValidationError) Key 

func (e DownloadPeerBackToSourceFinishedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPeerBackToSourceFinishedRequestValidationError) Reason 

func (e DownloadPeerBackToSourceFinishedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPeerBackToSourceStartedRequest 

type DownloadPeerBackToSourceStartedRequest struct {

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

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

func (*DownloadPeerBackToSourceStartedRequest) Descriptor deprecated 

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

Deprecated: Use DownloadPeerBackToSourceStartedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPeerBackToSourceStartedRequest) GetDescription 

func (x *DownloadPeerBackToSourceStartedRequest) GetDescription() string

func (*DownloadPeerBackToSourceStartedRequest) ProtoMessage 

func (*DownloadPeerBackToSourceStartedRequest) ProtoMessage()

func (*DownloadPeerBackToSourceStartedRequest) ProtoReflect 

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

func (*DownloadPeerBackToSourceStartedRequest) Reset 

func (x *DownloadPeerBackToSourceStartedRequest) Reset()

func (*DownloadPeerBackToSourceStartedRequest) String 

func (x *DownloadPeerBackToSourceStartedRequest) String() string

func (*DownloadPeerBackToSourceStartedRequest) Validate 

func (m *DownloadPeerBackToSourceStartedRequest) Validate() error

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

func (*DownloadPeerBackToSourceStartedRequest) ValidateAll 

func (m *DownloadPeerBackToSourceStartedRequest) ValidateAll() error

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

type DownloadPeerBackToSourceStartedRequestMultiError 

type DownloadPeerBackToSourceStartedRequestMultiError []error

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

func (DownloadPeerBackToSourceStartedRequestMultiError) AllErrors 

func (m DownloadPeerBackToSourceStartedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPeerBackToSourceStartedRequestMultiError) Error 

func (m DownloadPeerBackToSourceStartedRequestMultiError) Error() string

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

type DownloadPeerBackToSourceStartedRequestValidationError 

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

DownloadPeerBackToSourceStartedRequestValidationError is the validation error returned by DownloadPeerBackToSourceStartedRequest.Validate if the designated constraints aren't met.

func (DownloadPeerBackToSourceStartedRequestValidationError) Cause 

func (e DownloadPeerBackToSourceStartedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPeerBackToSourceStartedRequestValidationError) Error 

func (e DownloadPeerBackToSourceStartedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPeerBackToSourceStartedRequestValidationError) ErrorName 

func (e DownloadPeerBackToSourceStartedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPeerBackToSourceStartedRequestValidationError) Field 

func (e DownloadPeerBackToSourceStartedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPeerBackToSourceStartedRequestValidationError) Key 

func (e DownloadPeerBackToSourceStartedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPeerBackToSourceStartedRequestValidationError) Reason 

func (e DownloadPeerBackToSourceStartedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPeerFailedRequest 

type DownloadPeerFailedRequest struct {

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

DownloadPeerFailedRequest represents peer download failed request of AnnouncePeerRequest.

func (*DownloadPeerFailedRequest) Descriptor deprecated 

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

Deprecated: Use DownloadPeerFailedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPeerFailedRequest) GetDescription 

func (x *DownloadPeerFailedRequest) GetDescription() string

func (*DownloadPeerFailedRequest) ProtoMessage 

func (*DownloadPeerFailedRequest) ProtoMessage()

func (*DownloadPeerFailedRequest) ProtoReflect 

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

func (*DownloadPeerFailedRequest) Reset 

func (x *DownloadPeerFailedRequest) Reset()

func (*DownloadPeerFailedRequest) String 

func (x *DownloadPeerFailedRequest) String() string

func (*DownloadPeerFailedRequest) Validate 

func (m *DownloadPeerFailedRequest) Validate() error

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

func (*DownloadPeerFailedRequest) ValidateAll 

func (m *DownloadPeerFailedRequest) ValidateAll() error

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

type DownloadPeerFailedRequestMultiError 

type DownloadPeerFailedRequestMultiError []error

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

func (DownloadPeerFailedRequestMultiError) AllErrors 

func (m DownloadPeerFailedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPeerFailedRequestMultiError) Error 

func (m DownloadPeerFailedRequestMultiError) Error() string

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

type DownloadPeerFailedRequestValidationError 

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

DownloadPeerFailedRequestValidationError is the validation error returned by DownloadPeerFailedRequest.Validate if the designated constraints aren't met.

func (DownloadPeerFailedRequestValidationError) Cause 

func (e DownloadPeerFailedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPeerFailedRequestValidationError) Error 

func (e DownloadPeerFailedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPeerFailedRequestValidationError) ErrorName 

func (e DownloadPeerFailedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPeerFailedRequestValidationError) Field 

func (e DownloadPeerFailedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPeerFailedRequestValidationError) Key 

func (e DownloadPeerFailedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPeerFailedRequestValidationError) Reason 

func (e DownloadPeerFailedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPeerFinishedRequest 

type DownloadPeerFinishedRequest struct {

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

DownloadPeerFinishedRequest represents peer download finished request of AnnouncePeerRequest.

func (*DownloadPeerFinishedRequest) Descriptor deprecated 

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

Deprecated: Use DownloadPeerFinishedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPeerFinishedRequest) GetContentLength 

func (x *DownloadPeerFinishedRequest) GetContentLength() uint64

func (*DownloadPeerFinishedRequest) GetPieceCount 

func (x *DownloadPeerFinishedRequest) GetPieceCount() uint32

func (*DownloadPeerFinishedRequest) ProtoMessage 

func (*DownloadPeerFinishedRequest) ProtoMessage()

func (*DownloadPeerFinishedRequest) ProtoReflect 

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

func (*DownloadPeerFinishedRequest) Reset 

func (x *DownloadPeerFinishedRequest) Reset()

func (*DownloadPeerFinishedRequest) String 

func (x *DownloadPeerFinishedRequest) String() string

func (*DownloadPeerFinishedRequest) Validate 

func (m *DownloadPeerFinishedRequest) Validate() error

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

func (*DownloadPeerFinishedRequest) ValidateAll 

func (m *DownloadPeerFinishedRequest) ValidateAll() error

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

type DownloadPeerFinishedRequestMultiError 

type DownloadPeerFinishedRequestMultiError []error

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

func (DownloadPeerFinishedRequestMultiError) AllErrors 

func (m DownloadPeerFinishedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPeerFinishedRequestMultiError) Error 

func (m DownloadPeerFinishedRequestMultiError) Error() string

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

type DownloadPeerFinishedRequestValidationError 

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

DownloadPeerFinishedRequestValidationError is the validation error returned by DownloadPeerFinishedRequest.Validate if the designated constraints aren't met.

func (DownloadPeerFinishedRequestValidationError) Cause 

func (e DownloadPeerFinishedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPeerFinishedRequestValidationError) Error 

func (e DownloadPeerFinishedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPeerFinishedRequestValidationError) ErrorName 

func (e DownloadPeerFinishedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPeerFinishedRequestValidationError) Field 

func (e DownloadPeerFinishedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPeerFinishedRequestValidationError) Key 

func (e DownloadPeerFinishedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPeerFinishedRequestValidationError) Reason 

func (e DownloadPeerFinishedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPeerStartedRequest 

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

DownloadPeerStartedRequest represents peer download started request of AnnouncePeerRequest.

func (*DownloadPeerStartedRequest) Descriptor deprecated 

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

Deprecated: Use DownloadPeerStartedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPeerStartedRequest) ProtoMessage 

func (*DownloadPeerStartedRequest) ProtoMessage()

func (*DownloadPeerStartedRequest) ProtoReflect 

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

func (*DownloadPeerStartedRequest) Reset 

func (x *DownloadPeerStartedRequest) Reset()

func (*DownloadPeerStartedRequest) String 

func (x *DownloadPeerStartedRequest) String() string

func (*DownloadPeerStartedRequest) Validate 

func (m *DownloadPeerStartedRequest) Validate() error

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

func (*DownloadPeerStartedRequest) ValidateAll 

func (m *DownloadPeerStartedRequest) ValidateAll() error

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

type DownloadPeerStartedRequestMultiError 

type DownloadPeerStartedRequestMultiError []error

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

func (DownloadPeerStartedRequestMultiError) AllErrors 

func (m DownloadPeerStartedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPeerStartedRequestMultiError) Error 

func (m DownloadPeerStartedRequestMultiError) Error() string

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

type DownloadPeerStartedRequestValidationError 

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

DownloadPeerStartedRequestValidationError is the validation error returned by DownloadPeerStartedRequest.Validate if the designated constraints aren't met.

func (DownloadPeerStartedRequestValidationError) Cause 

func (e DownloadPeerStartedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPeerStartedRequestValidationError) Error 

func (e DownloadPeerStartedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPeerStartedRequestValidationError) ErrorName 

func (e DownloadPeerStartedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPeerStartedRequestValidationError) Field 

func (e DownloadPeerStartedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPeerStartedRequestValidationError) Key 

func (e DownloadPeerStartedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPeerStartedRequestValidationError) Reason 

func (e DownloadPeerStartedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPersistentCachePeerFailedRequest added in v2.0.161 

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

DownloadPersistentCachePeerFailedRequest represents persistent cache peer download failed request of AnnouncePersistentCachePeerRequest.

func (*DownloadPersistentCachePeerFailedRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use DownloadPersistentCachePeerFailedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPersistentCachePeerFailedRequest) GetDescription added in v2.0.161 

func (x *DownloadPersistentCachePeerFailedRequest) GetDescription() string

func (*DownloadPersistentCachePeerFailedRequest) ProtoMessage added in v2.0.161 

func (*DownloadPersistentCachePeerFailedRequest) ProtoMessage()

func (*DownloadPersistentCachePeerFailedRequest) ProtoReflect added in v2.0.161 

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

func (*DownloadPersistentCachePeerFailedRequest) Reset added in v2.0.161 

func (x *DownloadPersistentCachePeerFailedRequest) Reset()

func (*DownloadPersistentCachePeerFailedRequest) String added in v2.0.161 

func (x *DownloadPersistentCachePeerFailedRequest) String() string

func (*DownloadPersistentCachePeerFailedRequest) Validate added in v2.0.161 

func (m *DownloadPersistentCachePeerFailedRequest) Validate() error

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

func (m *DownloadPersistentCachePeerFailedRequest) ValidateAll() error

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

type DownloadPersistentCachePeerFailedRequestMultiError added in v2.0.161 

type DownloadPersistentCachePeerFailedRequestMultiError []error

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

func (DownloadPersistentCachePeerFailedRequestMultiError) AllErrors added in v2.0.161 

func (m DownloadPersistentCachePeerFailedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPersistentCachePeerFailedRequestMultiError) Error added in v2.0.161 

func (m DownloadPersistentCachePeerFailedRequestMultiError) Error() string

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

type DownloadPersistentCachePeerFailedRequestValidationError added in v2.0.161 

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

DownloadPersistentCachePeerFailedRequestValidationError is the validation error returned by DownloadPersistentCachePeerFailedRequest.Validate if the designated constraints aren't met.

func (DownloadPersistentCachePeerFailedRequestValidationError) Cause added in v2.0.161 

func (e DownloadPersistentCachePeerFailedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPersistentCachePeerFailedRequestValidationError) Error added in v2.0.161 

func (e DownloadPersistentCachePeerFailedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPersistentCachePeerFailedRequestValidationError) ErrorName added in v2.0.161 

func (e DownloadPersistentCachePeerFailedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPersistentCachePeerFailedRequestValidationError) Field added in v2.0.161 

func (e DownloadPersistentCachePeerFailedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPersistentCachePeerFailedRequestValidationError) Key added in v2.0.161 

func (e DownloadPersistentCachePeerFailedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPersistentCachePeerFailedRequestValidationError) Reason added in v2.0.161 

func (e DownloadPersistentCachePeerFailedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPersistentCachePeerFinishedRequest added in v2.0.161 

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

DownloadPersistentCachePeerFinishedRequest represents persistent cache peer download finished request of AnnouncePersistentCachePeerRequest.

func (*DownloadPersistentCachePeerFinishedRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use DownloadPersistentCachePeerFinishedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPersistentCachePeerFinishedRequest) GetPieceCount added in v2.0.161 

func (x *DownloadPersistentCachePeerFinishedRequest) GetPieceCount() uint32

func (*DownloadPersistentCachePeerFinishedRequest) ProtoMessage added in v2.0.161 

func (*DownloadPersistentCachePeerFinishedRequest) ProtoMessage()

func (*DownloadPersistentCachePeerFinishedRequest) ProtoReflect added in v2.0.161 

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

func (*DownloadPersistentCachePeerFinishedRequest) Reset added in v2.0.161 

func (x *DownloadPersistentCachePeerFinishedRequest) Reset()

func (*DownloadPersistentCachePeerFinishedRequest) String added in v2.0.161 

func (x *DownloadPersistentCachePeerFinishedRequest) String() string

func (*DownloadPersistentCachePeerFinishedRequest) Validate added in v2.0.161 

func (m *DownloadPersistentCachePeerFinishedRequest) Validate() error

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

func (m *DownloadPersistentCachePeerFinishedRequest) ValidateAll() error

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

type DownloadPersistentCachePeerFinishedRequestMultiError added in v2.0.161 

type DownloadPersistentCachePeerFinishedRequestMultiError []error

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

func (DownloadPersistentCachePeerFinishedRequestMultiError) AllErrors added in v2.0.161 

func (m DownloadPersistentCachePeerFinishedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPersistentCachePeerFinishedRequestMultiError) Error added in v2.0.161 

func (m DownloadPersistentCachePeerFinishedRequestMultiError) Error() string

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

type DownloadPersistentCachePeerFinishedRequestValidationError added in v2.0.161 

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

DownloadPersistentCachePeerFinishedRequestValidationError is the validation error returned by DownloadPersistentCachePeerFinishedRequest.Validate if the designated constraints aren't met.

func (DownloadPersistentCachePeerFinishedRequestValidationError) Cause added in v2.0.161 

func (e DownloadPersistentCachePeerFinishedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPersistentCachePeerFinishedRequestValidationError) Error added in v2.0.161 

func (e DownloadPersistentCachePeerFinishedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPersistentCachePeerFinishedRequestValidationError) ErrorName added in v2.0.161 

func (e DownloadPersistentCachePeerFinishedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPersistentCachePeerFinishedRequestValidationError) Field added in v2.0.161 

func (e DownloadPersistentCachePeerFinishedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPersistentCachePeerFinishedRequestValidationError) Key added in v2.0.161 

func (e DownloadPersistentCachePeerFinishedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPersistentCachePeerFinishedRequestValidationError) Reason added in v2.0.161 

func (e DownloadPersistentCachePeerFinishedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPersistentCachePeerStartedRequest added in v2.0.161 

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

DownloadPersistentCachePeerStartedRequest represents persistent cache peer download started request of AnnouncePersistentCachePeerRequest.

func (*DownloadPersistentCachePeerStartedRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use DownloadPersistentCachePeerStartedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPersistentCachePeerStartedRequest) ProtoMessage added in v2.0.161 

func (*DownloadPersistentCachePeerStartedRequest) ProtoMessage()

func (*DownloadPersistentCachePeerStartedRequest) ProtoReflect added in v2.0.161 

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

func (*DownloadPersistentCachePeerStartedRequest) Reset added in v2.0.161 

func (x *DownloadPersistentCachePeerStartedRequest) Reset()

func (*DownloadPersistentCachePeerStartedRequest) String added in v2.0.161 

func (x *DownloadPersistentCachePeerStartedRequest) String() string

func (*DownloadPersistentCachePeerStartedRequest) Validate added in v2.0.161 

func (m *DownloadPersistentCachePeerStartedRequest) Validate() error

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

func (m *DownloadPersistentCachePeerStartedRequest) ValidateAll() error

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

type DownloadPersistentCachePeerStartedRequestMultiError added in v2.0.161 

type DownloadPersistentCachePeerStartedRequestMultiError []error

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

func (DownloadPersistentCachePeerStartedRequestMultiError) AllErrors added in v2.0.161 

func (m DownloadPersistentCachePeerStartedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPersistentCachePeerStartedRequestMultiError) Error added in v2.0.161 

func (m DownloadPersistentCachePeerStartedRequestMultiError) Error() string

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

type DownloadPersistentCachePeerStartedRequestValidationError added in v2.0.161 

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

DownloadPersistentCachePeerStartedRequestValidationError is the validation error returned by DownloadPersistentCachePeerStartedRequest.Validate if the designated constraints aren't met.

func (DownloadPersistentCachePeerStartedRequestValidationError) Cause added in v2.0.161 

func (e DownloadPersistentCachePeerStartedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPersistentCachePeerStartedRequestValidationError) Error added in v2.0.161 

func (e DownloadPersistentCachePeerStartedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPersistentCachePeerStartedRequestValidationError) ErrorName added in v2.0.161 

func (e DownloadPersistentCachePeerStartedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPersistentCachePeerStartedRequestValidationError) Field added in v2.0.161 

func (e DownloadPersistentCachePeerStartedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPersistentCachePeerStartedRequestValidationError) Key added in v2.0.161 

func (e DownloadPersistentCachePeerStartedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPersistentCachePeerStartedRequestValidationError) Reason added in v2.0.161 

func (e DownloadPersistentCachePeerStartedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPieceBackToSourceFailedRequest 

type DownloadPieceBackToSourceFailedRequest struct {

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

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

func (*DownloadPieceBackToSourceFailedRequest) Descriptor deprecated 

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

Deprecated: Use DownloadPieceBackToSourceFailedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPieceBackToSourceFailedRequest) GetBackend added in v2.0.114 

func (x *DownloadPieceBackToSourceFailedRequest) GetBackend() *v21.Backend

func (*DownloadPieceBackToSourceFailedRequest) GetPieceNumber added in v2.0.47 

func (x *DownloadPieceBackToSourceFailedRequest) GetPieceNumber() uint32

func (*DownloadPieceBackToSourceFailedRequest) GetResponse 

func (m *DownloadPieceBackToSourceFailedRequest) GetResponse() isDownloadPieceBackToSourceFailedRequest_Response

func (*DownloadPieceBackToSourceFailedRequest) ProtoMessage 

func (*DownloadPieceBackToSourceFailedRequest) ProtoMessage()

func (*DownloadPieceBackToSourceFailedRequest) ProtoReflect 

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

func (*DownloadPieceBackToSourceFailedRequest) Reset 

func (x *DownloadPieceBackToSourceFailedRequest) Reset()

func (*DownloadPieceBackToSourceFailedRequest) String 

func (x *DownloadPieceBackToSourceFailedRequest) String() string

func (*DownloadPieceBackToSourceFailedRequest) Validate 

func (m *DownloadPieceBackToSourceFailedRequest) Validate() error

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

func (*DownloadPieceBackToSourceFailedRequest) ValidateAll 

func (m *DownloadPieceBackToSourceFailedRequest) ValidateAll() error

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

type DownloadPieceBackToSourceFailedRequestMultiError 

type DownloadPieceBackToSourceFailedRequestMultiError []error

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

func (DownloadPieceBackToSourceFailedRequestMultiError) AllErrors 

func (m DownloadPieceBackToSourceFailedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPieceBackToSourceFailedRequestMultiError) Error 

func (m DownloadPieceBackToSourceFailedRequestMultiError) Error() string

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

type DownloadPieceBackToSourceFailedRequestValidationError 

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

DownloadPieceBackToSourceFailedRequestValidationError is the validation error returned by DownloadPieceBackToSourceFailedRequest.Validate if the designated constraints aren't met.

func (DownloadPieceBackToSourceFailedRequestValidationError) Cause 

func (e DownloadPieceBackToSourceFailedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPieceBackToSourceFailedRequestValidationError) Error 

func (e DownloadPieceBackToSourceFailedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPieceBackToSourceFailedRequestValidationError) ErrorName 

func (e DownloadPieceBackToSourceFailedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPieceBackToSourceFailedRequestValidationError) Field 

func (e DownloadPieceBackToSourceFailedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPieceBackToSourceFailedRequestValidationError) Key 

func (e DownloadPieceBackToSourceFailedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPieceBackToSourceFailedRequestValidationError) Reason 

func (e DownloadPieceBackToSourceFailedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPieceBackToSourceFailedRequest_Backend added in v2.0.114 

type 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 (x *DownloadPieceBackToSourceFinishedRequest) GetPiece() *v2.Piece

func (*DownloadPieceBackToSourceFinishedRequest) ProtoMessage 

func (*DownloadPieceBackToSourceFinishedRequest) ProtoMessage()

func (*DownloadPieceBackToSourceFinishedRequest) ProtoReflect 

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

func (*DownloadPieceBackToSourceFinishedRequest) Reset 

func (x *DownloadPieceBackToSourceFinishedRequest) Reset()

func (*DownloadPieceBackToSourceFinishedRequest) String 

func (x *DownloadPieceBackToSourceFinishedRequest) String() string

func (*DownloadPieceBackToSourceFinishedRequest) Validate 

func (m *DownloadPieceBackToSourceFinishedRequest) Validate() error

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

func (*DownloadPieceBackToSourceFinishedRequest) ValidateAll 

func (m *DownloadPieceBackToSourceFinishedRequest) ValidateAll() error

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

type DownloadPieceBackToSourceFinishedRequestMultiError 

type DownloadPieceBackToSourceFinishedRequestMultiError []error

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

func (DownloadPieceBackToSourceFinishedRequestMultiError) AllErrors 

func (m DownloadPieceBackToSourceFinishedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPieceBackToSourceFinishedRequestMultiError) Error 

func (m DownloadPieceBackToSourceFinishedRequestMultiError) Error() string

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

type DownloadPieceBackToSourceFinishedRequestValidationError 

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

DownloadPieceBackToSourceFinishedRequestValidationError is the validation error returned by DownloadPieceBackToSourceFinishedRequest.Validate if the designated constraints aren't met.

func (DownloadPieceBackToSourceFinishedRequestValidationError) Cause 

func (e DownloadPieceBackToSourceFinishedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPieceBackToSourceFinishedRequestValidationError) Error 

func (e DownloadPieceBackToSourceFinishedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPieceBackToSourceFinishedRequestValidationError) ErrorName 

func (e DownloadPieceBackToSourceFinishedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPieceBackToSourceFinishedRequestValidationError) Field 

func (e DownloadPieceBackToSourceFinishedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPieceBackToSourceFinishedRequestValidationError) Key 

func (e DownloadPieceBackToSourceFinishedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPieceBackToSourceFinishedRequestValidationError) Reason 

func (e DownloadPieceBackToSourceFinishedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPieceFailedRequest 

type DownloadPieceFailedRequest struct {

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

DownloadPieceFailedRequest downloads piece failed request of AnnouncePeerRequest.

func (*DownloadPieceFailedRequest) Descriptor deprecated 

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

Deprecated: Use DownloadPieceFailedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPieceFailedRequest) GetParentId added in v2.0.47 

func (x *DownloadPieceFailedRequest) GetParentId() string

func (*DownloadPieceFailedRequest) GetPieceNumber added in v2.0.47 

func (x *DownloadPieceFailedRequest) GetPieceNumber() uint32

func (*DownloadPieceFailedRequest) GetTemporary 

func (x *DownloadPieceFailedRequest) GetTemporary() bool

func (*DownloadPieceFailedRequest) ProtoMessage 

func (*DownloadPieceFailedRequest) ProtoMessage()

func (*DownloadPieceFailedRequest) ProtoReflect 

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

func (*DownloadPieceFailedRequest) Reset 

func (x *DownloadPieceFailedRequest) Reset()

func (*DownloadPieceFailedRequest) String 

func (x *DownloadPieceFailedRequest) String() string

func (*DownloadPieceFailedRequest) Validate 

func (m *DownloadPieceFailedRequest) Validate() error

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

func (*DownloadPieceFailedRequest) ValidateAll 

func (m *DownloadPieceFailedRequest) ValidateAll() error

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

type DownloadPieceFailedRequestMultiError 

type DownloadPieceFailedRequestMultiError []error

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

func (DownloadPieceFailedRequestMultiError) AllErrors 

func (m DownloadPieceFailedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPieceFailedRequestMultiError) Error 

func (m DownloadPieceFailedRequestMultiError) Error() string

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

type DownloadPieceFailedRequestValidationError 

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

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

func (DownloadPieceFailedRequestValidationError) Cause 

func (e DownloadPieceFailedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPieceFailedRequestValidationError) Error 

func (e DownloadPieceFailedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPieceFailedRequestValidationError) ErrorName 

func (e DownloadPieceFailedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPieceFailedRequestValidationError) Field 

func (e DownloadPieceFailedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPieceFailedRequestValidationError) Key 

func (e DownloadPieceFailedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPieceFailedRequestValidationError) Reason 

func (e DownloadPieceFailedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPieceFinishedRequest 

type DownloadPieceFinishedRequest struct {

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

DownloadPieceFinishedRequest represents piece download finished request of AnnouncePeerRequest.

func (*DownloadPieceFinishedRequest) Descriptor deprecated 

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

Deprecated: Use DownloadPieceFinishedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPieceFinishedRequest) GetPiece 

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

func (*DownloadPieceFinishedRequest) ProtoMessage 

func (*DownloadPieceFinishedRequest) ProtoMessage()

func (*DownloadPieceFinishedRequest) ProtoReflect 

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

func (*DownloadPieceFinishedRequest) Reset 

func (x *DownloadPieceFinishedRequest) Reset()

func (*DownloadPieceFinishedRequest) String 

func (x *DownloadPieceFinishedRequest) String() string

func (*DownloadPieceFinishedRequest) Validate 

func (m *DownloadPieceFinishedRequest) Validate() error

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

func (*DownloadPieceFinishedRequest) ValidateAll 

func (m *DownloadPieceFinishedRequest) ValidateAll() error

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

type DownloadPieceFinishedRequestMultiError 

type DownloadPieceFinishedRequestMultiError []error

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

func (DownloadPieceFinishedRequestMultiError) AllErrors 

func (m DownloadPieceFinishedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPieceFinishedRequestMultiError) Error 

func (m DownloadPieceFinishedRequestMultiError) Error() string

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

type DownloadPieceFinishedRequestValidationError 

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

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

func (DownloadPieceFinishedRequestValidationError) Cause 

func (e DownloadPieceFinishedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPieceFinishedRequestValidationError) Error 

func (e DownloadPieceFinishedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPieceFinishedRequestValidationError) ErrorName 

func (e DownloadPieceFinishedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPieceFinishedRequestValidationError) Field 

func (e DownloadPieceFinishedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPieceFinishedRequestValidationError) Key 

func (e DownloadPieceFinishedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPieceFinishedRequestValidationError) Reason 

func (e DownloadPieceFinishedRequestValidationError) Reason() string

Reason function returns reason value.

type EmptyPersistentCacheTaskResponse added in v2.0.161 

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

EmptyPersistentCacheTaskResponse represents empty persistent cache task response of AnnouncePersistentCachePeerResponse.

func (*EmptyPersistentCacheTaskResponse) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use EmptyPersistentCacheTaskResponse.ProtoReflect.Descriptor instead.

func (*EmptyPersistentCacheTaskResponse) ProtoMessage added in v2.0.161 

func (*EmptyPersistentCacheTaskResponse) ProtoMessage()

func (*EmptyPersistentCacheTaskResponse) ProtoReflect added in v2.0.161 

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

func (*EmptyPersistentCacheTaskResponse) Reset added in v2.0.161 

func (x *EmptyPersistentCacheTaskResponse) Reset()

func (*EmptyPersistentCacheTaskResponse) String added in v2.0.161 

func (x *EmptyPersistentCacheTaskResponse) String() string

func (*EmptyPersistentCacheTaskResponse) Validate added in v2.0.161 

func (m *EmptyPersistentCacheTaskResponse) Validate() error

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

func (m *EmptyPersistentCacheTaskResponse) ValidateAll() error

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

type EmptyPersistentCacheTaskResponseMultiError added in v2.0.161 

type EmptyPersistentCacheTaskResponseMultiError []error

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

func (EmptyPersistentCacheTaskResponseMultiError) AllErrors added in v2.0.161 

func (m EmptyPersistentCacheTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EmptyPersistentCacheTaskResponseMultiError) Error added in v2.0.161 

func (m EmptyPersistentCacheTaskResponseMultiError) Error() string

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

type EmptyPersistentCacheTaskResponseValidationError added in v2.0.161 

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

EmptyPersistentCacheTaskResponseValidationError is the validation error returned by EmptyPersistentCacheTaskResponse.Validate if the designated constraints aren't met.

func (EmptyPersistentCacheTaskResponseValidationError) Cause added in v2.0.161 

func (e EmptyPersistentCacheTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (EmptyPersistentCacheTaskResponseValidationError) Error added in v2.0.161 

func (e EmptyPersistentCacheTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (EmptyPersistentCacheTaskResponseValidationError) ErrorName added in v2.0.161 

func (e EmptyPersistentCacheTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (EmptyPersistentCacheTaskResponseValidationError) Field added in v2.0.161 

func (e EmptyPersistentCacheTaskResponseValidationError) Field() string

Field function returns field value.

func (EmptyPersistentCacheTaskResponseValidationError) Key added in v2.0.161 

func (e EmptyPersistentCacheTaskResponseValidationError) Key() bool

Key function returns key value.

func (EmptyPersistentCacheTaskResponseValidationError) Reason added in v2.0.161 

func (e EmptyPersistentCacheTaskResponseValidationError) Reason() string

Reason function returns reason value.

type EmptyTaskResponse 

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

EmptyTaskResponse represents empty task response of AnnouncePeerResponse.

func (*EmptyTaskResponse) Descriptor deprecated 

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

Deprecated: Use EmptyTaskResponse.ProtoReflect.Descriptor instead.

func (*EmptyTaskResponse) ProtoMessage 

func (*EmptyTaskResponse) ProtoMessage()

func (*EmptyTaskResponse) ProtoReflect 

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

func (*EmptyTaskResponse) Reset 

func (x *EmptyTaskResponse) Reset()

func (*EmptyTaskResponse) String 

func (x *EmptyTaskResponse) String() string

func (*EmptyTaskResponse) Validate 

func (m *EmptyTaskResponse) Validate() error

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

func (*EmptyTaskResponse) ValidateAll 

func (m *EmptyTaskResponse) ValidateAll() error

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

type EmptyTaskResponseMultiError 

type EmptyTaskResponseMultiError []error

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

func (EmptyTaskResponseMultiError) AllErrors 

func (m EmptyTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EmptyTaskResponseMultiError) Error 

func (m EmptyTaskResponseMultiError) Error() string

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

type EmptyTaskResponseValidationError 

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

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

func (EmptyTaskResponseValidationError) Cause 

func (e EmptyTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (EmptyTaskResponseValidationError) Error 

func (e EmptyTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (EmptyTaskResponseValidationError) ErrorName 

func (e EmptyTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (EmptyTaskResponseValidationError) Field 

func (e EmptyTaskResponseValidationError) Field() string

Field function returns field value.

func (EmptyTaskResponseValidationError) Key 

func (e EmptyTaskResponseValidationError) Key() bool

Key function returns key value.

func (EmptyTaskResponseValidationError) Reason 

func (e EmptyTaskResponseValidationError) Reason() string

Reason function returns reason value.

type ListHostsResponse added in v2.0.158 

type ListHostsResponse struct {

	// Hosts info.
	Hosts []*v2.Host `protobuf:"bytes,1,rep,name=hosts,proto3" json:"hosts,omitempty"`
	// contains filtered or unexported fields
}

ListHostsResponse represents response of ListHosts.

func (*ListHostsResponse) Descriptor deprecated added in v2.0.158 

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

Deprecated: Use ListHostsResponse.ProtoReflect.Descriptor instead.

func (*ListHostsResponse) GetHosts added in v2.0.158 

func (x *ListHostsResponse) GetHosts() []*v2.Host

func (*ListHostsResponse) ProtoMessage added in v2.0.158 

func (*ListHostsResponse) ProtoMessage()

func (*ListHostsResponse) ProtoReflect added in v2.0.158 

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

func (*ListHostsResponse) Reset added in v2.0.158 

func (x *ListHostsResponse) Reset()

func (*ListHostsResponse) String added in v2.0.158 

func (x *ListHostsResponse) String() string

func (*ListHostsResponse) Validate added in v2.0.158 

func (m *ListHostsResponse) Validate() error

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

func (m *ListHostsResponse) ValidateAll() error

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

type ListHostsResponseMultiError added in v2.0.158 

type ListHostsResponseMultiError []error

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

func (ListHostsResponseMultiError) AllErrors added in v2.0.158 

func (m ListHostsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListHostsResponseMultiError) Error added in v2.0.158 

func (m ListHostsResponseMultiError) Error() string

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

type ListHostsResponseValidationError added in v2.0.158 

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

ListHostsResponseValidationError is the validation error returned by ListHostsResponse.Validate if the designated constraints aren't met.

func (ListHostsResponseValidationError) Cause added in v2.0.158 

func (e ListHostsResponseValidationError) Cause() error

Cause function returns cause value.

func (ListHostsResponseValidationError) Error added in v2.0.158 

func (e ListHostsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ListHostsResponseValidationError) ErrorName added in v2.0.158 

func (e ListHostsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ListHostsResponseValidationError) Field added in v2.0.158 

func (e ListHostsResponseValidationError) Field() string

Field function returns field value.

func (ListHostsResponseValidationError) Key added in v2.0.158 

func (e ListHostsResponseValidationError) Key() bool

Key function returns key value.

func (ListHostsResponseValidationError) Reason added in v2.0.158 

func (e ListHostsResponseValidationError) Reason() string

Reason function returns reason value.

type NeedBackToSourceResponse 

type NeedBackToSourceResponse struct {

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

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

func (*NeedBackToSourceResponse) Descriptor deprecated 

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

Deprecated: Use NeedBackToSourceResponse.ProtoReflect.Descriptor instead.

func (*NeedBackToSourceResponse) GetDescription 

func (x *NeedBackToSourceResponse) GetDescription() string

func (*NeedBackToSourceResponse) ProtoMessage 

func (*NeedBackToSourceResponse) ProtoMessage()

func (*NeedBackToSourceResponse) ProtoReflect 

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

func (*NeedBackToSourceResponse) Reset 

func (x *NeedBackToSourceResponse) Reset()

func (*NeedBackToSourceResponse) String 

func (x *NeedBackToSourceResponse) String() string

func (*NeedBackToSourceResponse) Validate 

func (m *NeedBackToSourceResponse) Validate() error

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

func (*NeedBackToSourceResponse) ValidateAll 

func (m *NeedBackToSourceResponse) ValidateAll() error

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

type NeedBackToSourceResponseMultiError 

type NeedBackToSourceResponseMultiError []error

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

func (NeedBackToSourceResponseMultiError) AllErrors 

func (m NeedBackToSourceResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NeedBackToSourceResponseMultiError) Error 

func (m NeedBackToSourceResponseMultiError) Error() string

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

type NeedBackToSourceResponseValidationError 

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

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

func (NeedBackToSourceResponseValidationError) Cause 

func (e NeedBackToSourceResponseValidationError) Cause() error

Cause function returns cause value.

func (NeedBackToSourceResponseValidationError) Error 

func (e NeedBackToSourceResponseValidationError) Error() string

Error satisfies the builtin error interface

func (NeedBackToSourceResponseValidationError) ErrorName 

func (e NeedBackToSourceResponseValidationError) ErrorName() string

ErrorName returns error name.

func (NeedBackToSourceResponseValidationError) Field 

func (e NeedBackToSourceResponseValidationError) Field() string

Field function returns field value.

func (NeedBackToSourceResponseValidationError) Key 

func (e NeedBackToSourceResponseValidationError) Key() bool

Key function returns key value.

func (NeedBackToSourceResponseValidationError) Reason 

func (e NeedBackToSourceResponseValidationError) Reason() string

Reason function returns reason value.

type NormalPersistentCacheTaskResponse added in v2.0.161 

type NormalPersistentCacheTaskResponse struct {

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

NormalPersistentCacheTaskResponse represents normal persistent cache task response of AnnouncePersistentCachePeerResponse.

func (*NormalPersistentCacheTaskResponse) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use NormalPersistentCacheTaskResponse.ProtoReflect.Descriptor instead.

func (*NormalPersistentCacheTaskResponse) GetCandidateParents added in v2.0.161 

func (x *NormalPersistentCacheTaskResponse) GetCandidateParents() []*v2.PersistentCachePeer

func (*NormalPersistentCacheTaskResponse) ProtoMessage added in v2.0.161 

func (*NormalPersistentCacheTaskResponse) ProtoMessage()

func (*NormalPersistentCacheTaskResponse) ProtoReflect added in v2.0.161 

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

func (*NormalPersistentCacheTaskResponse) Reset added in v2.0.161 

func (x *NormalPersistentCacheTaskResponse) Reset()

func (*NormalPersistentCacheTaskResponse) String added in v2.0.161 

func (x *NormalPersistentCacheTaskResponse) String() string

func (*NormalPersistentCacheTaskResponse) Validate added in v2.0.161 

func (m *NormalPersistentCacheTaskResponse) Validate() error

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

func (m *NormalPersistentCacheTaskResponse) ValidateAll() error

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

type NormalPersistentCacheTaskResponseMultiError added in v2.0.161 

type NormalPersistentCacheTaskResponseMultiError []error

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

func (NormalPersistentCacheTaskResponseMultiError) AllErrors added in v2.0.161 

func (m NormalPersistentCacheTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NormalPersistentCacheTaskResponseMultiError) Error added in v2.0.161 

func (m NormalPersistentCacheTaskResponseMultiError) Error() string

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

type NormalPersistentCacheTaskResponseValidationError added in v2.0.161 

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

NormalPersistentCacheTaskResponseValidationError is the validation error returned by NormalPersistentCacheTaskResponse.Validate if the designated constraints aren't met.

func (NormalPersistentCacheTaskResponseValidationError) Cause added in v2.0.161 

func (e NormalPersistentCacheTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (NormalPersistentCacheTaskResponseValidationError) Error added in v2.0.161 

func (e NormalPersistentCacheTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (NormalPersistentCacheTaskResponseValidationError) ErrorName added in v2.0.161 

func (e NormalPersistentCacheTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (NormalPersistentCacheTaskResponseValidationError) Field added in v2.0.161 

func (e NormalPersistentCacheTaskResponseValidationError) Field() string

Field function returns field value.

func (NormalPersistentCacheTaskResponseValidationError) Key added in v2.0.161 

func (e NormalPersistentCacheTaskResponseValidationError) Key() bool

Key function returns key value.

func (NormalPersistentCacheTaskResponseValidationError) Reason added in v2.0.161 

func (e NormalPersistentCacheTaskResponseValidationError) Reason() string

Reason function returns reason value.

type NormalTaskResponse 

type NormalTaskResponse struct {

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

NormalTaskResponse represents normal task response of AnnouncePeerResponse.

func (*NormalTaskResponse) Descriptor deprecated 

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

Deprecated: Use NormalTaskResponse.ProtoReflect.Descriptor instead.

func (*NormalTaskResponse) GetCandidateParents 

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

func (*NormalTaskResponse) ProtoMessage 

func (*NormalTaskResponse) ProtoMessage()

func (*NormalTaskResponse) ProtoReflect 

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

func (*NormalTaskResponse) Reset 

func (x *NormalTaskResponse) Reset()

func (*NormalTaskResponse) String 

func (x *NormalTaskResponse) String() string

func (*NormalTaskResponse) Validate 

func (m *NormalTaskResponse) Validate() error

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

func (*NormalTaskResponse) ValidateAll 

func (m *NormalTaskResponse) ValidateAll() error

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

type NormalTaskResponseMultiError 

type NormalTaskResponseMultiError []error

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

func (NormalTaskResponseMultiError) AllErrors 

func (m NormalTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NormalTaskResponseMultiError) Error 

func (m NormalTaskResponseMultiError) Error() string

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

type NormalTaskResponseValidationError 

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

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

func (NormalTaskResponseValidationError) Cause 

func (e NormalTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (NormalTaskResponseValidationError) Error 

func (e NormalTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (NormalTaskResponseValidationError) ErrorName 

func (e NormalTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (NormalTaskResponseValidationError) Field 

func (e NormalTaskResponseValidationError) Field() string

Field function returns field value.

func (NormalTaskResponseValidationError) Key 

func (e NormalTaskResponseValidationError) Key() bool

Key function returns key value.

func (NormalTaskResponseValidationError) Reason 

func (e NormalTaskResponseValidationError) Reason() string

Reason function returns reason value.

type RegisterPeerRequest 

type RegisterPeerRequest struct {

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

RegisterPeerRequest represents peer registered request of AnnouncePeerRequest.

func (*RegisterPeerRequest) Descriptor deprecated 

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

Deprecated: Use RegisterPeerRequest.ProtoReflect.Descriptor instead.

func (*RegisterPeerRequest) GetDownload 

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

func (*RegisterPeerRequest) ProtoMessage 

func (*RegisterPeerRequest) ProtoMessage()

func (*RegisterPeerRequest) ProtoReflect 

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

func (*RegisterPeerRequest) Reset 

func (x *RegisterPeerRequest) Reset()

func (*RegisterPeerRequest) String 

func (x *RegisterPeerRequest) String() string

func (*RegisterPeerRequest) Validate 

func (m *RegisterPeerRequest) Validate() error

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

func (*RegisterPeerRequest) ValidateAll 

func (m *RegisterPeerRequest) ValidateAll() error

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

type RegisterPeerRequestMultiError 

type RegisterPeerRequestMultiError []error

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

func (RegisterPeerRequestMultiError) AllErrors 

func (m RegisterPeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RegisterPeerRequestMultiError) Error 

func (m RegisterPeerRequestMultiError) Error() string

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

type RegisterPeerRequestValidationError 

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

RegisterPeerRequestValidationError is the validation error returned by RegisterPeerRequest.Validate if the designated constraints aren't met.

func (RegisterPeerRequestValidationError) Cause 

func (e RegisterPeerRequestValidationError) Cause() error

Cause function returns cause value.

func (RegisterPeerRequestValidationError) Error 

func (e RegisterPeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (RegisterPeerRequestValidationError) ErrorName 

func (e RegisterPeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (RegisterPeerRequestValidationError) Field 

func (e RegisterPeerRequestValidationError) Field() string

Field function returns field value.

func (RegisterPeerRequestValidationError) Key 

func (e RegisterPeerRequestValidationError) Key() bool

Key function returns key value.

func (RegisterPeerRequestValidationError) Reason 

func (e RegisterPeerRequestValidationError) Reason() string

Reason function returns reason value.

type RegisterPersistentCachePeerRequest added in v2.0.161 

type RegisterPersistentCachePeerRequest 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 persistent 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
}

RegisterPersistentCachePeerRequest represents persistent cache peer registered request of AnnouncePersistentCachePeerRequest.

func (*RegisterPersistentCachePeerRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use RegisterPersistentCachePeerRequest.ProtoReflect.Descriptor instead.

func (*RegisterPersistentCachePeerRequest) GetApplication added in v2.0.161 

func (x *RegisterPersistentCachePeerRequest) GetApplication() string

func (*RegisterPersistentCachePeerRequest) GetHostId added in v2.0.161 

func (x *RegisterPersistentCachePeerRequest) GetHostId() string

func (*RegisterPersistentCachePeerRequest) GetOutputPath added in v2.0.161 

func (x *RegisterPersistentCachePeerRequest) GetOutputPath() string

func (*RegisterPersistentCachePeerRequest) GetPieceLength added in v2.0.161 

func (x *RegisterPersistentCachePeerRequest) GetPieceLength() uint64

func (*RegisterPersistentCachePeerRequest) GetTag added in v2.0.161 

func (x *RegisterPersistentCachePeerRequest) GetTag() string

func (*RegisterPersistentCachePeerRequest) GetTaskId added in v2.0.161 

func (x *RegisterPersistentCachePeerRequest) GetTaskId() string

func (*RegisterPersistentCachePeerRequest) GetTimeout added in v2.0.161 

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

func (*RegisterPersistentCachePeerRequest) ProtoMessage added in v2.0.161 

func (*RegisterPersistentCachePeerRequest) ProtoMessage()

func (*RegisterPersistentCachePeerRequest) ProtoReflect added in v2.0.161 

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

func (*RegisterPersistentCachePeerRequest) Reset added in v2.0.161 

func (x *RegisterPersistentCachePeerRequest) Reset()

func (*RegisterPersistentCachePeerRequest) String added in v2.0.161 

func (x *RegisterPersistentCachePeerRequest) String() string

func (*RegisterPersistentCachePeerRequest) Validate added in v2.0.161 

func (m *RegisterPersistentCachePeerRequest) Validate() error

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

func (m *RegisterPersistentCachePeerRequest) ValidateAll() error

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

type RegisterPersistentCachePeerRequestMultiError added in v2.0.161 

type RegisterPersistentCachePeerRequestMultiError []error

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

func (RegisterPersistentCachePeerRequestMultiError) AllErrors added in v2.0.161 

func (m RegisterPersistentCachePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RegisterPersistentCachePeerRequestMultiError) Error added in v2.0.161 

func (m RegisterPersistentCachePeerRequestMultiError) Error() string

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

type RegisterPersistentCachePeerRequestValidationError added in v2.0.161 

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

RegisterPersistentCachePeerRequestValidationError is the validation error returned by RegisterPersistentCachePeerRequest.Validate if the designated constraints aren't met.

func (RegisterPersistentCachePeerRequestValidationError) Cause added in v2.0.161 

func (e RegisterPersistentCachePeerRequestValidationError) Cause() error

Cause function returns cause value.

func (RegisterPersistentCachePeerRequestValidationError) Error added in v2.0.161 

func (e RegisterPersistentCachePeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (RegisterPersistentCachePeerRequestValidationError) ErrorName added in v2.0.161 

func (e RegisterPersistentCachePeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (RegisterPersistentCachePeerRequestValidationError) Field added in v2.0.161 

func (e RegisterPersistentCachePeerRequestValidationError) Field() string

Field function returns field value.

func (RegisterPersistentCachePeerRequestValidationError) Key added in v2.0.161 

func (e RegisterPersistentCachePeerRequestValidationError) Key() bool

Key function returns key value.

func (RegisterPersistentCachePeerRequestValidationError) Reason added in v2.0.161 

func (e RegisterPersistentCachePeerRequestValidationError) Reason() string

Reason function returns reason value.

type ReschedulePeerRequest added in v2.0.121 

type ReschedulePeerRequest struct {

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

ReschedulePeerRequest represents reschedule request of AnnouncePeerRequest.

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

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

Deprecated: Use ReschedulePeerRequest.ProtoReflect.Descriptor instead.

func (*ReschedulePeerRequest) GetCandidateParents added in v2.0.121 

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

func (*ReschedulePeerRequest) GetDescription added in v2.0.121 

func (x *ReschedulePeerRequest) GetDescription() string

func (*ReschedulePeerRequest) ProtoMessage added in v2.0.121 

func (*ReschedulePeerRequest) ProtoMessage()

func (*ReschedulePeerRequest) ProtoReflect added in v2.0.121 

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

func (*ReschedulePeerRequest) Reset added in v2.0.121 

func (x *ReschedulePeerRequest) Reset()

func (*ReschedulePeerRequest) String added in v2.0.121 

func (x *ReschedulePeerRequest) String() string

func (*ReschedulePeerRequest) Validate added in v2.0.121 

func (m *ReschedulePeerRequest) Validate() error

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

func (*ReschedulePeerRequest) ValidateAll added in v2.0.121 

func (m *ReschedulePeerRequest) ValidateAll() error

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

type ReschedulePeerRequestMultiError added in v2.0.121 

type ReschedulePeerRequestMultiError []error

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

func (ReschedulePeerRequestMultiError) AllErrors added in v2.0.121 

func (m ReschedulePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ReschedulePeerRequestMultiError) Error added in v2.0.121 

func (m ReschedulePeerRequestMultiError) Error() string

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

type ReschedulePeerRequestValidationError added in v2.0.121 

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

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

func (ReschedulePeerRequestValidationError) Cause added in v2.0.121 

func (e ReschedulePeerRequestValidationError) Cause() error

Cause function returns cause value.

func (ReschedulePeerRequestValidationError) Error added in v2.0.121 

func (e ReschedulePeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ReschedulePeerRequestValidationError) ErrorName added in v2.0.121 

func (e ReschedulePeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ReschedulePeerRequestValidationError) Field added in v2.0.121 

func (e ReschedulePeerRequestValidationError) Field() string

Field function returns field value.

func (ReschedulePeerRequestValidationError) Key added in v2.0.121 

func (e ReschedulePeerRequestValidationError) Key() bool

Key function returns key value.

func (ReschedulePeerRequestValidationError) Reason added in v2.0.121 

func (e ReschedulePeerRequestValidationError) Reason() string

Reason function returns reason value.

type ReschedulePersistentCachePeerRequest added in v2.0.161 

type ReschedulePersistentCachePeerRequest struct {

	// Candidate parent ids.
	CandidateParents []*v2.PersistentCachePeer `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
}

ReschedulePersistentCachePeerRequest represents reschedule request of AnnouncePersistentCachePeerRequest.

func (*ReschedulePersistentCachePeerRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use ReschedulePersistentCachePeerRequest.ProtoReflect.Descriptor instead.

func (*ReschedulePersistentCachePeerRequest) GetCandidateParents added in v2.0.161 

func (x *ReschedulePersistentCachePeerRequest) GetCandidateParents() []*v2.PersistentCachePeer

func (*ReschedulePersistentCachePeerRequest) GetDescription added in v2.0.161 

func (x *ReschedulePersistentCachePeerRequest) GetDescription() string

func (*ReschedulePersistentCachePeerRequest) ProtoMessage added in v2.0.161 

func (*ReschedulePersistentCachePeerRequest) ProtoMessage()

func (*ReschedulePersistentCachePeerRequest) ProtoReflect added in v2.0.161 

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

func (*ReschedulePersistentCachePeerRequest) Reset added in v2.0.161 

func (x *ReschedulePersistentCachePeerRequest) Reset()

func (*ReschedulePersistentCachePeerRequest) String added in v2.0.161 

func (x *ReschedulePersistentCachePeerRequest) String() string

func (*ReschedulePersistentCachePeerRequest) Validate added in v2.0.161 

func (m *ReschedulePersistentCachePeerRequest) Validate() error

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

func (m *ReschedulePersistentCachePeerRequest) ValidateAll() error

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

type ReschedulePersistentCachePeerRequestMultiError added in v2.0.161 

type ReschedulePersistentCachePeerRequestMultiError []error

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

func (ReschedulePersistentCachePeerRequestMultiError) AllErrors added in v2.0.161 

func (m ReschedulePersistentCachePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ReschedulePersistentCachePeerRequestMultiError) Error added in v2.0.161 

func (m ReschedulePersistentCachePeerRequestMultiError) Error() string

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

type ReschedulePersistentCachePeerRequestValidationError added in v2.0.161 

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

ReschedulePersistentCachePeerRequestValidationError is the validation error returned by ReschedulePersistentCachePeerRequest.Validate if the designated constraints aren't met.

func (ReschedulePersistentCachePeerRequestValidationError) Cause added in v2.0.161 

func (e ReschedulePersistentCachePeerRequestValidationError) Cause() error

Cause function returns cause value.

func (ReschedulePersistentCachePeerRequestValidationError) Error added in v2.0.161 

func (e ReschedulePersistentCachePeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ReschedulePersistentCachePeerRequestValidationError) ErrorName added in v2.0.161 

func (e ReschedulePersistentCachePeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ReschedulePersistentCachePeerRequestValidationError) Field added in v2.0.161 

func (e ReschedulePersistentCachePeerRequestValidationError) Field() string

Field function returns field value.

func (ReschedulePersistentCachePeerRequestValidationError) Key added in v2.0.161 

func (e ReschedulePersistentCachePeerRequestValidationError) Key() bool

Key function returns key value.

func (ReschedulePersistentCachePeerRequestValidationError) Reason added in v2.0.161 

func (e ReschedulePersistentCachePeerRequestValidationError) Reason() string

Reason function returns reason value.

type SchedulerClient 

type SchedulerClient interface {
	// AnnouncePeer announces peer to scheduler.
	AnnouncePeer(ctx context.Context, opts ...grpc.CallOption) (Scheduler_AnnouncePeerClient, error)
	// Checks information of peer.
	StatPeer(ctx context.Context, in *StatPeerRequest, opts ...grpc.CallOption) (*v2.Peer, error)
	// DeletePeer releases peer in scheduler.
	DeletePeer(ctx context.Context, in *DeletePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Checks information of task.
	StatTask(ctx context.Context, in *StatTaskRequest, opts ...grpc.CallOption) (*v2.Task, error)
	// DeleteTask releases task in scheduler.
	DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// AnnounceHost announces host to scheduler.
	AnnounceHost(ctx context.Context, in *AnnounceHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// ListHosts lists hosts in scheduler.
	ListHosts(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListHostsResponse, error)
	// DeleteHost releases host in scheduler.
	DeleteHost(ctx context.Context, in *DeleteHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// AnnouncePersistentCachePeer announces persistent cache peer to scheduler.
	AnnouncePersistentCachePeer(ctx context.Context, opts ...grpc.CallOption) (Scheduler_AnnouncePersistentCachePeerClient, error)
	// Checks information of persistent cache peer.
	StatPersistentCachePeer(ctx context.Context, in *StatPersistentCachePeerRequest, opts ...grpc.CallOption) (*v2.PersistentCachePeer, error)
	// DeletePersistentCachePeer releases persistent cache peer in scheduler.
	DeletePersistentCachePeer(ctx context.Context, in *DeletePersistentCachePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// UploadPersistentCacheTaskStarted uploads persistent cache task started to scheduler.
	UploadPersistentCacheTaskStarted(ctx context.Context, in *UploadPersistentCacheTaskStartedRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// UploadPersistentCacheTaskFinished uploads persistent cache task finished to scheduler.
	UploadPersistentCacheTaskFinished(ctx context.Context, in *UploadPersistentCacheTaskFinishedRequest, opts ...grpc.CallOption) (*v2.PersistentCacheTask, error)
	// UploadPersistentCacheTaskFailed uploads persistent cache task failed to scheduler.
	UploadPersistentCacheTaskFailed(ctx context.Context, in *UploadPersistentCacheTaskFailedRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Checks information of persistent cache task.
	StatPersistentCacheTask(ctx context.Context, in *StatPersistentCacheTaskRequest, opts ...grpc.CallOption) (*v2.PersistentCacheTask, error)
	// DeletePersistentCacheTask releases persistent cache task in scheduler.
	DeletePersistentCacheTask(ctx context.Context, in *DeletePersistentCacheTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

SchedulerClient is the client API for Scheduler service.

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

func NewSchedulerClient 

func NewSchedulerClient(cc grpc.ClientConnInterface) SchedulerClient

type SchedulerServer 

type SchedulerServer interface {
	// AnnouncePeer announces peer to scheduler.
	AnnouncePeer(Scheduler_AnnouncePeerServer) error
	// Checks information of peer.
	StatPeer(context.Context, *StatPeerRequest) (*v2.Peer, error)
	// DeletePeer releases peer in scheduler.
	DeletePeer(context.Context, *DeletePeerRequest) (*emptypb.Empty, error)
	// Checks information of task.
	StatTask(context.Context, *StatTaskRequest) (*v2.Task, error)
	// DeleteTask releases task in scheduler.
	DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)
	// AnnounceHost announces host to scheduler.
	AnnounceHost(context.Context, *AnnounceHostRequest) (*emptypb.Empty, error)
	// ListHosts lists hosts in scheduler.
	ListHosts(context.Context, *emptypb.Empty) (*ListHostsResponse, error)
	// DeleteHost releases host in scheduler.
	DeleteHost(context.Context, *DeleteHostRequest) (*emptypb.Empty, error)
	// AnnouncePersistentCachePeer announces persistent cache peer to scheduler.
	AnnouncePersistentCachePeer(Scheduler_AnnouncePersistentCachePeerServer) error
	// Checks information of persistent cache peer.
	StatPersistentCachePeer(context.Context, *StatPersistentCachePeerRequest) (*v2.PersistentCachePeer, error)
	// DeletePersistentCachePeer releases persistent cache peer in scheduler.
	DeletePersistentCachePeer(context.Context, *DeletePersistentCachePeerRequest) (*emptypb.Empty, error)
	// UploadPersistentCacheTaskStarted uploads persistent cache task started to scheduler.
	UploadPersistentCacheTaskStarted(context.Context, *UploadPersistentCacheTaskStartedRequest) (*emptypb.Empty, error)
	// UploadPersistentCacheTaskFinished uploads persistent cache task finished to scheduler.
	UploadPersistentCacheTaskFinished(context.Context, *UploadPersistentCacheTaskFinishedRequest) (*v2.PersistentCacheTask, error)
	// UploadPersistentCacheTaskFailed uploads persistent cache task failed to scheduler.
	UploadPersistentCacheTaskFailed(context.Context, *UploadPersistentCacheTaskFailedRequest) (*emptypb.Empty, error)
	// Checks information of persistent cache task.
	StatPersistentCacheTask(context.Context, *StatPersistentCacheTaskRequest) (*v2.PersistentCacheTask, error)
	// DeletePersistentCacheTask releases persistent cache task in scheduler.
	DeletePersistentCacheTask(context.Context, *DeletePersistentCacheTaskRequest) (*emptypb.Empty, error)
}

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

type Scheduler_AnnouncePeerClient 

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

type Scheduler_AnnouncePeerServer 

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

type Scheduler_AnnouncePersistentCachePeerClient added in v2.0.161 

type Scheduler_AnnouncePersistentCachePeerClient interface {
	Send(*AnnouncePersistentCachePeerRequest) error
	Recv() (*AnnouncePersistentCachePeerResponse, error)
	grpc.ClientStream
}

type Scheduler_AnnouncePersistentCachePeerServer added in v2.0.161 

type Scheduler_AnnouncePersistentCachePeerServer interface {
	Send(*AnnouncePersistentCachePeerResponse) error
	Recv() (*AnnouncePersistentCachePeerRequest, error)
	grpc.ServerStream
}

type StatPeerRequest 

type StatPeerRequest struct {

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

StatPeerRequest represents request of StatPeer.

func (*StatPeerRequest) Descriptor deprecated 

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

Deprecated: Use StatPeerRequest.ProtoReflect.Descriptor instead.

func (*StatPeerRequest) GetHostId 

func (x *StatPeerRequest) GetHostId() string

func (*StatPeerRequest) GetPeerId 

func (x *StatPeerRequest) GetPeerId() string

func (*StatPeerRequest) GetTaskId 

func (x *StatPeerRequest) GetTaskId() string

func (*StatPeerRequest) ProtoMessage 

func (*StatPeerRequest) ProtoMessage()

func (*StatPeerRequest) ProtoReflect 

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

func (*StatPeerRequest) Reset 

func (x *StatPeerRequest) Reset()

func (*StatPeerRequest) String 

func (x *StatPeerRequest) String() string

func (*StatPeerRequest) Validate 

func (m *StatPeerRequest) Validate() error

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

func (*StatPeerRequest) ValidateAll 

func (m *StatPeerRequest) ValidateAll() error

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

type StatPeerRequestMultiError 

type StatPeerRequestMultiError []error

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

func (StatPeerRequestMultiError) AllErrors 

func (m StatPeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatPeerRequestMultiError) Error 

func (m StatPeerRequestMultiError) Error() string

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

type StatPeerRequestValidationError 

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

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

func (StatPeerRequestValidationError) Cause 

func (e StatPeerRequestValidationError) Cause() error

Cause function returns cause value.

func (StatPeerRequestValidationError) Error 

func (e StatPeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatPeerRequestValidationError) ErrorName 

func (e StatPeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatPeerRequestValidationError) Field 

func (e StatPeerRequestValidationError) Field() string

Field function returns field value.

func (StatPeerRequestValidationError) Key 

func (e StatPeerRequestValidationError) Key() bool

Key function returns key value.

func (StatPeerRequestValidationError) Reason 

func (e StatPeerRequestValidationError) Reason() string

Reason function returns reason value.

type StatPersistentCachePeerRequest added in v2.0.161 

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

StatPersistentCachePeerRequest represents request of StatPersistentCachePeer.

func (*StatPersistentCachePeerRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use StatPersistentCachePeerRequest.ProtoReflect.Descriptor instead.

func (*StatPersistentCachePeerRequest) GetHostId added in v2.0.161 

func (x *StatPersistentCachePeerRequest) GetHostId() string

func (*StatPersistentCachePeerRequest) GetPeerId added in v2.0.161 

func (x *StatPersistentCachePeerRequest) GetPeerId() string

func (*StatPersistentCachePeerRequest) GetTaskId added in v2.0.161 

func (x *StatPersistentCachePeerRequest) GetTaskId() string

func (*StatPersistentCachePeerRequest) ProtoMessage added in v2.0.161 

func (*StatPersistentCachePeerRequest) ProtoMessage()

func (*StatPersistentCachePeerRequest) ProtoReflect added in v2.0.161 

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

func (*StatPersistentCachePeerRequest) Reset added in v2.0.161 

func (x *StatPersistentCachePeerRequest) Reset()

func (*StatPersistentCachePeerRequest) String added in v2.0.161 

func (x *StatPersistentCachePeerRequest) String() string

func (*StatPersistentCachePeerRequest) Validate added in v2.0.161 

func (m *StatPersistentCachePeerRequest) Validate() error

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

func (m *StatPersistentCachePeerRequest) ValidateAll() error

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

type StatPersistentCachePeerRequestMultiError added in v2.0.161 

type StatPersistentCachePeerRequestMultiError []error

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

func (StatPersistentCachePeerRequestMultiError) AllErrors added in v2.0.161 

func (m StatPersistentCachePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatPersistentCachePeerRequestMultiError) Error added in v2.0.161 

func (m StatPersistentCachePeerRequestMultiError) Error() string

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

type StatPersistentCachePeerRequestValidationError added in v2.0.161 

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

StatPersistentCachePeerRequestValidationError is the validation error returned by StatPersistentCachePeerRequest.Validate if the designated constraints aren't met.

func (StatPersistentCachePeerRequestValidationError) Cause added in v2.0.161 

func (e StatPersistentCachePeerRequestValidationError) Cause() error

Cause function returns cause value.

func (StatPersistentCachePeerRequestValidationError) Error added in v2.0.161 

func (e StatPersistentCachePeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatPersistentCachePeerRequestValidationError) ErrorName added in v2.0.161 

func (e StatPersistentCachePeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatPersistentCachePeerRequestValidationError) Field added in v2.0.161 

func (e StatPersistentCachePeerRequestValidationError) Field() string

Field function returns field value.

func (StatPersistentCachePeerRequestValidationError) Key added in v2.0.161 

func (e StatPersistentCachePeerRequestValidationError) Key() bool

Key function returns key value.

func (StatPersistentCachePeerRequestValidationError) Reason added in v2.0.161 

func (e StatPersistentCachePeerRequestValidationError) Reason() string

Reason function returns reason value.

type StatPersistentCacheTaskRequest added in v2.0.161 

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

StatPersistentCacheTaskRequest represents request of StatPersistentCacheTask.

func (*StatPersistentCacheTaskRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use StatPersistentCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*StatPersistentCacheTaskRequest) GetHostId added in v2.0.161 

func (x *StatPersistentCacheTaskRequest) GetHostId() string

func (*StatPersistentCacheTaskRequest) GetTaskId added in v2.0.161 

func (x *StatPersistentCacheTaskRequest) GetTaskId() string

func (*StatPersistentCacheTaskRequest) ProtoMessage added in v2.0.161 

func (*StatPersistentCacheTaskRequest) ProtoMessage()

func (*StatPersistentCacheTaskRequest) ProtoReflect added in v2.0.161 

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

func (*StatPersistentCacheTaskRequest) Reset added in v2.0.161 

func (x *StatPersistentCacheTaskRequest) Reset()

func (*StatPersistentCacheTaskRequest) String added in v2.0.161 

func (x *StatPersistentCacheTaskRequest) String() string

func (*StatPersistentCacheTaskRequest) Validate added in v2.0.161 

func (m *StatPersistentCacheTaskRequest) Validate() error

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

func (m *StatPersistentCacheTaskRequest) ValidateAll() error

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

type StatPersistentCacheTaskRequestMultiError added in v2.0.161 

type StatPersistentCacheTaskRequestMultiError []error

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

func (StatPersistentCacheTaskRequestMultiError) AllErrors added in v2.0.161 

func (m StatPersistentCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatPersistentCacheTaskRequestMultiError) Error added in v2.0.161 

func (m StatPersistentCacheTaskRequestMultiError) Error() string

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

type StatPersistentCacheTaskRequestValidationError added in v2.0.161 

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

StatPersistentCacheTaskRequestValidationError is the validation error returned by StatPersistentCacheTaskRequest.Validate if the designated constraints aren't met.

func (StatPersistentCacheTaskRequestValidationError) Cause added in v2.0.161 

func (e StatPersistentCacheTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (StatPersistentCacheTaskRequestValidationError) Error added in v2.0.161 

func (e StatPersistentCacheTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatPersistentCacheTaskRequestValidationError) ErrorName added in v2.0.161 

func (e StatPersistentCacheTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatPersistentCacheTaskRequestValidationError) Field added in v2.0.161 

func (e StatPersistentCacheTaskRequestValidationError) Field() string

Field function returns field value.

func (StatPersistentCacheTaskRequestValidationError) Key added in v2.0.161 

func (e StatPersistentCacheTaskRequestValidationError) Key() bool

Key function returns key value.

func (StatPersistentCacheTaskRequestValidationError) Reason added in v2.0.161 

func (e StatPersistentCacheTaskRequestValidationError) Reason() string

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 

func (m StatTaskRequestMultiError) Error() string

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

type StatTaskRequestValidationError 

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

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

func (StatTaskRequestValidationError) Cause 

func (e StatTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (StatTaskRequestValidationError) Error 

func (e StatTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatTaskRequestValidationError) ErrorName 

func (e StatTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatTaskRequestValidationError) Field 

func (e StatTaskRequestValidationError) Field() string

Field function returns field value.

func (StatTaskRequestValidationError) Key 

func (e StatTaskRequestValidationError) Key() bool

Key function returns key value.

func (StatTaskRequestValidationError) Reason 

func (e StatTaskRequestValidationError) Reason() string

Reason function returns reason value.

type UnimplementedSchedulerServer 

type UnimplementedSchedulerServer struct {
}

UnimplementedSchedulerServer should be embedded to have forward compatible implementations.

func (UnimplementedSchedulerServer) AnnounceHost 

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

func (UnimplementedSchedulerServer) AnnouncePeer 

func (UnimplementedSchedulerServer) AnnouncePeer(Scheduler_AnnouncePeerServer) error

func (UnimplementedSchedulerServer) AnnouncePersistentCachePeer added in v2.0.161 

func (UnimplementedSchedulerServer) AnnouncePersistentCachePeer(Scheduler_AnnouncePersistentCachePeerServer) error

func (UnimplementedSchedulerServer) DeleteHost added in v2.0.118 

func (UnimplementedSchedulerServer) DeleteHost(context.Context, *DeleteHostRequest) (*emptypb.Empty, error)

func (UnimplementedSchedulerServer) DeletePeer added in v2.0.118 

func (UnimplementedSchedulerServer) DeletePeer(context.Context, *DeletePeerRequest) (*emptypb.Empty, error)

func (UnimplementedSchedulerServer) DeletePersistentCachePeer added in v2.0.161 

func (UnimplementedSchedulerServer) DeletePersistentCachePeer(context.Context, *DeletePersistentCachePeerRequest) (*emptypb.Empty, error)

func (UnimplementedSchedulerServer) DeletePersistentCacheTask added in v2.0.161 

func (UnimplementedSchedulerServer) DeletePersistentCacheTask(context.Context, *DeletePersistentCacheTaskRequest) (*emptypb.Empty, error)

func (UnimplementedSchedulerServer) DeleteTask added in v2.0.118 

func (UnimplementedSchedulerServer) DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)

func (UnimplementedSchedulerServer) ListHosts added in v2.0.158 

func (UnimplementedSchedulerServer) ListHosts(context.Context, *emptypb.Empty) (*ListHostsResponse, error)

func (UnimplementedSchedulerServer) StatPeer 

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

func (UnimplementedSchedulerServer) StatPersistentCachePeer added in v2.0.161 

func (UnimplementedSchedulerServer) StatPersistentCachePeer(context.Context, *StatPersistentCachePeerRequest) (*v2.PersistentCachePeer, error)

func (UnimplementedSchedulerServer) StatPersistentCacheTask added in v2.0.161 

func (UnimplementedSchedulerServer) StatPersistentCacheTask(context.Context, *StatPersistentCacheTaskRequest) (*v2.PersistentCacheTask, error)

func (UnimplementedSchedulerServer) StatTask 

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

func (UnimplementedSchedulerServer) UploadPersistentCacheTaskFailed added in v2.0.161 

func (UnimplementedSchedulerServer) UploadPersistentCacheTaskFailed(context.Context, *UploadPersistentCacheTaskFailedRequest) (*emptypb.Empty, error)

func (UnimplementedSchedulerServer) UploadPersistentCacheTaskFinished added in v2.0.161 

func (UnimplementedSchedulerServer) UploadPersistentCacheTaskFinished(context.Context, *UploadPersistentCacheTaskFinishedRequest) (*v2.PersistentCacheTask, error)

func (UnimplementedSchedulerServer) UploadPersistentCacheTaskStarted added in v2.0.161 

func (UnimplementedSchedulerServer) UploadPersistentCacheTaskStarted(context.Context, *UploadPersistentCacheTaskStartedRequest) (*emptypb.Empty, error)

type UnsafeSchedulerServer 

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

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

type UploadPersistentCacheTaskFailedRequest added in v2.0.161 

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

UploadPersistentCacheTaskFailedRequest represents upload persistent cache task failed request of UploadPersistentCacheTaskFailedRequest.

func (*UploadPersistentCacheTaskFailedRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use UploadPersistentCacheTaskFailedRequest.ProtoReflect.Descriptor instead.

func (*UploadPersistentCacheTaskFailedRequest) GetDescription added in v2.0.161 

func (x *UploadPersistentCacheTaskFailedRequest) GetDescription() string

func (*UploadPersistentCacheTaskFailedRequest) GetHostId added in v2.0.161 

func (x *UploadPersistentCacheTaskFailedRequest) GetHostId() string

func (*UploadPersistentCacheTaskFailedRequest) GetPeerId added in v2.0.161 

func (x *UploadPersistentCacheTaskFailedRequest) GetPeerId() string

func (*UploadPersistentCacheTaskFailedRequest) GetTaskId added in v2.0.161 

func (x *UploadPersistentCacheTaskFailedRequest) GetTaskId() string

func (*UploadPersistentCacheTaskFailedRequest) ProtoMessage added in v2.0.161 

func (*UploadPersistentCacheTaskFailedRequest) ProtoMessage()

func (*UploadPersistentCacheTaskFailedRequest) ProtoReflect added in v2.0.161 

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

func (*UploadPersistentCacheTaskFailedRequest) Reset added in v2.0.161 

func (x *UploadPersistentCacheTaskFailedRequest) Reset()

func (*UploadPersistentCacheTaskFailedRequest) String added in v2.0.161 

func (x *UploadPersistentCacheTaskFailedRequest) String() string

func (*UploadPersistentCacheTaskFailedRequest) Validate added in v2.0.161 

func (m *UploadPersistentCacheTaskFailedRequest) Validate() error

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

func (m *UploadPersistentCacheTaskFailedRequest) ValidateAll() error

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

type UploadPersistentCacheTaskFailedRequestMultiError added in v2.0.161 

type UploadPersistentCacheTaskFailedRequestMultiError []error

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

func (UploadPersistentCacheTaskFailedRequestMultiError) AllErrors added in v2.0.161 

func (m UploadPersistentCacheTaskFailedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UploadPersistentCacheTaskFailedRequestMultiError) Error added in v2.0.161 

func (m UploadPersistentCacheTaskFailedRequestMultiError) Error() string

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

type UploadPersistentCacheTaskFailedRequestValidationError added in v2.0.161 

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

UploadPersistentCacheTaskFailedRequestValidationError is the validation error returned by UploadPersistentCacheTaskFailedRequest.Validate if the designated constraints aren't met.

func (UploadPersistentCacheTaskFailedRequestValidationError) Cause added in v2.0.161 

func (e UploadPersistentCacheTaskFailedRequestValidationError) Cause() error

Cause function returns cause value.

func (UploadPersistentCacheTaskFailedRequestValidationError) Error added in v2.0.161 

func (e UploadPersistentCacheTaskFailedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (UploadPersistentCacheTaskFailedRequestValidationError) ErrorName added in v2.0.161 

func (e UploadPersistentCacheTaskFailedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (UploadPersistentCacheTaskFailedRequestValidationError) Field added in v2.0.161 

func (e UploadPersistentCacheTaskFailedRequestValidationError) Field() string

Field function returns field value.

func (UploadPersistentCacheTaskFailedRequestValidationError) Key added in v2.0.161 

func (e UploadPersistentCacheTaskFailedRequestValidationError) Key() bool

Key function returns key value.

func (UploadPersistentCacheTaskFailedRequestValidationError) Reason added in v2.0.161 

func (e UploadPersistentCacheTaskFailedRequestValidationError) Reason() string

Reason function returns reason value.

type UploadPersistentCacheTaskFinishedRequest added in v2.0.161 

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

UploadPersistentCacheTaskFinishedRequest represents upload persistent cache task finished request of UploadPersistentCacheTaskFinishedRequest.

func (*UploadPersistentCacheTaskFinishedRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use UploadPersistentCacheTaskFinishedRequest.ProtoReflect.Descriptor instead.

func (*UploadPersistentCacheTaskFinishedRequest) GetHostId added in v2.0.161 

func (x *UploadPersistentCacheTaskFinishedRequest) GetHostId() string

func (*UploadPersistentCacheTaskFinishedRequest) GetPeerId added in v2.0.161 

func (x *UploadPersistentCacheTaskFinishedRequest) GetPeerId() string

func (*UploadPersistentCacheTaskFinishedRequest) GetTaskId added in v2.0.161 

func (x *UploadPersistentCacheTaskFinishedRequest) GetTaskId() string

func (*UploadPersistentCacheTaskFinishedRequest) ProtoMessage added in v2.0.161 

func (*UploadPersistentCacheTaskFinishedRequest) ProtoMessage()

func (*UploadPersistentCacheTaskFinishedRequest) ProtoReflect added in v2.0.161 

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

func (*UploadPersistentCacheTaskFinishedRequest) Reset added in v2.0.161 

func (x *UploadPersistentCacheTaskFinishedRequest) Reset()

func (*UploadPersistentCacheTaskFinishedRequest) String added in v2.0.161 

func (x *UploadPersistentCacheTaskFinishedRequest) String() string

func (*UploadPersistentCacheTaskFinishedRequest) Validate added in v2.0.161 

func (m *UploadPersistentCacheTaskFinishedRequest) Validate() error

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

func (m *UploadPersistentCacheTaskFinishedRequest) ValidateAll() error

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

type UploadPersistentCacheTaskFinishedRequestMultiError added in v2.0.161 

type UploadPersistentCacheTaskFinishedRequestMultiError []error

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

func (UploadPersistentCacheTaskFinishedRequestMultiError) AllErrors added in v2.0.161 

func (m UploadPersistentCacheTaskFinishedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UploadPersistentCacheTaskFinishedRequestMultiError) Error added in v2.0.161 

func (m UploadPersistentCacheTaskFinishedRequestMultiError) Error() string

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

type UploadPersistentCacheTaskFinishedRequestValidationError added in v2.0.161 

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

UploadPersistentCacheTaskFinishedRequestValidationError is the validation error returned by UploadPersistentCacheTaskFinishedRequest.Validate if the designated constraints aren't met.

func (UploadPersistentCacheTaskFinishedRequestValidationError) Cause added in v2.0.161 

func (e UploadPersistentCacheTaskFinishedRequestValidationError) Cause() error

Cause function returns cause value.

func (UploadPersistentCacheTaskFinishedRequestValidationError) Error added in v2.0.161 

func (e UploadPersistentCacheTaskFinishedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (UploadPersistentCacheTaskFinishedRequestValidationError) ErrorName added in v2.0.161 

func (e UploadPersistentCacheTaskFinishedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (UploadPersistentCacheTaskFinishedRequestValidationError) Field added in v2.0.161 

func (e UploadPersistentCacheTaskFinishedRequestValidationError) Field() string

Field function returns field value.

func (UploadPersistentCacheTaskFinishedRequestValidationError) Key added in v2.0.161 

func (e UploadPersistentCacheTaskFinishedRequestValidationError) Key() bool

Key function returns key value.

func (UploadPersistentCacheTaskFinishedRequestValidationError) Reason added in v2.0.161 

func (e UploadPersistentCacheTaskFinishedRequestValidationError) Reason() string

Reason function returns reason value.

type UploadPersistentCacheTaskStartedRequest added in v2.0.161 

type UploadPersistentCacheTaskStartedRequest 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 persistent 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 persistent 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
}

UploadPersistentCacheTaskStartedRequest represents upload persistent cache task started request of UploadPersistentCacheTaskStartedRequest.

func (*UploadPersistentCacheTaskStartedRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use UploadPersistentCacheTaskStartedRequest.ProtoReflect.Descriptor instead.

func (*UploadPersistentCacheTaskStartedRequest) GetApplication added in v2.0.161 

func (x *UploadPersistentCacheTaskStartedRequest) GetApplication() string

func (*UploadPersistentCacheTaskStartedRequest) GetHostId added in v2.0.161 

func (x *UploadPersistentCacheTaskStartedRequest) GetHostId() string

func (*UploadPersistentCacheTaskStartedRequest) GetPeerId added in v2.0.161 

func (x *UploadPersistentCacheTaskStartedRequest) GetPeerId() string

func (*UploadPersistentCacheTaskStartedRequest) GetPersistentReplicaCount added in v2.0.161 

func (x *UploadPersistentCacheTaskStartedRequest) GetPersistentReplicaCount() uint64

func (*UploadPersistentCacheTaskStartedRequest) GetPieceLength added in v2.0.161 

func (x *UploadPersistentCacheTaskStartedRequest) GetPieceLength() uint64

func (*UploadPersistentCacheTaskStartedRequest) GetTag added in v2.0.161 

func (x *UploadPersistentCacheTaskStartedRequest) GetTag() string

func (*UploadPersistentCacheTaskStartedRequest) GetTaskId added in v2.0.161 

func (x *UploadPersistentCacheTaskStartedRequest) GetTaskId() string

func (*UploadPersistentCacheTaskStartedRequest) GetTimeout added in v2.0.161 

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

func (*UploadPersistentCacheTaskStartedRequest) GetTtl added in v2.0.161 

func (x *UploadPersistentCacheTaskStartedRequest) GetTtl() *durationpb.Duration

func (*UploadPersistentCacheTaskStartedRequest) ProtoMessage added in v2.0.161 

func (*UploadPersistentCacheTaskStartedRequest) ProtoMessage()

func (*UploadPersistentCacheTaskStartedRequest) ProtoReflect added in v2.0.161 

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

func (*UploadPersistentCacheTaskStartedRequest) Reset added in v2.0.161 

func (x *UploadPersistentCacheTaskStartedRequest) Reset()

func (*UploadPersistentCacheTaskStartedRequest) String added in v2.0.161 

func (x *UploadPersistentCacheTaskStartedRequest) String() string

func (*UploadPersistentCacheTaskStartedRequest) Validate added in v2.0.161 

func (m *UploadPersistentCacheTaskStartedRequest) Validate() error

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

func (m *UploadPersistentCacheTaskStartedRequest) ValidateAll() error

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

type UploadPersistentCacheTaskStartedRequestMultiError added in v2.0.161 

type UploadPersistentCacheTaskStartedRequestMultiError []error

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

func (UploadPersistentCacheTaskStartedRequestMultiError) AllErrors added in v2.0.161 

func (m UploadPersistentCacheTaskStartedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UploadPersistentCacheTaskStartedRequestMultiError) Error added in v2.0.161 

func (m UploadPersistentCacheTaskStartedRequestMultiError) Error() string

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

type UploadPersistentCacheTaskStartedRequestValidationError added in v2.0.161 

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

UploadPersistentCacheTaskStartedRequestValidationError is the validation error returned by UploadPersistentCacheTaskStartedRequest.Validate if the designated constraints aren't met.

func (UploadPersistentCacheTaskStartedRequestValidationError) Cause added in v2.0.161 

func (e UploadPersistentCacheTaskStartedRequestValidationError) Cause() error

Cause function returns cause value.

func (UploadPersistentCacheTaskStartedRequestValidationError) Error added in v2.0.161 

func (e UploadPersistentCacheTaskStartedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (UploadPersistentCacheTaskStartedRequestValidationError) ErrorName added in v2.0.161 

func (e UploadPersistentCacheTaskStartedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (UploadPersistentCacheTaskStartedRequestValidationError) Field added in v2.0.161 

func (e UploadPersistentCacheTaskStartedRequestValidationError) Field() string

Field function returns field value.

func (UploadPersistentCacheTaskStartedRequestValidationError) Key added in v2.0.161 

func (e UploadPersistentCacheTaskStartedRequestValidationError) Key() bool

Key function returns key value.

func (UploadPersistentCacheTaskStartedRequestValidationError) Reason added in v2.0.161 

func (e UploadPersistentCacheTaskStartedRequestValidationError) Reason() string

Reason function returns reason value.

Source Files

View all Source files

Directories

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

Jump to

Keyboard shortcuts

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