scheduler

package
v1.5.8 Latest Latest
Warning

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

 Go to latest Published: Feb 20, 2023 License: Apache-2.0 Imports: 26 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_apis_scheduler_v2_scheduler_proto protoreflect.FileDescriptor
View Source 
var Scheduler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "scheduler.v2.Scheduler",
	HandlerType: (*SchedulerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StatPeer",
			Handler:    _Scheduler_StatPeer_Handler,
		},
		{
			MethodName: "LeavePeer",
			Handler:    _Scheduler_LeavePeer_Handler,
		},
		{
			MethodName: "ExchangePeer",
			Handler:    _Scheduler_ExchangePeer_Handler,
		},
		{
			MethodName: "StatTask",
			Handler:    _Scheduler_StatTask_Handler,
		},
		{
			MethodName: "AnnounceHost",
			Handler:    _Scheduler_AnnounceHost_Handler,
		},
		{
			MethodName: "LeaveHost",
			Handler:    _Scheduler_LeaveHost_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "AnnouncePeer",
			Handler:       _Scheduler_AnnouncePeer_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SyncProbes",
			Handler:       _Scheduler_SyncProbes_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SyncNetworkTopology",
			Handler:       _Scheduler_SyncNetworkTopology_Handler,
			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 added in v1.2.5 

type AnnounceHostRequest struct {

	// Host id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Host type.
	Type uint32 `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
	// Hostname.
	Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Host ip.
	Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"`
	// Port of grpc service.
	Port int32 `protobuf:"varint,5,opt,name=port,proto3" json:"port,omitempty"`
	// Port of download server.
	DownloadPort int32 `protobuf:"varint,6,opt,name=download_port,json=downloadPort,proto3" json:"download_port,omitempty"`
	// Host OS.
	Os string `protobuf:"bytes,7,opt,name=os,proto3" json:"os,omitempty"`
	// Host platform.
	Platform string `protobuf:"bytes,8,opt,name=platform,proto3" json:"platform,omitempty"`
	// Host platform family.
	PlatformFamily string `protobuf:"bytes,9,opt,name=platform_family,json=platformFamily,proto3" json:"platform_family,omitempty"`
	// Host platform version.
	PlatformVersion string `protobuf:"bytes,10,opt,name=platform_version,json=platformVersion,proto3" json:"platform_version,omitempty"`
	// Host kernel version.
	KernelVersion string `protobuf:"bytes,11,opt,name=kernel_version,json=kernelVersion,proto3" json:"kernel_version,omitempty"`
	// CPU Stat.
	Cpu *CPU `protobuf:"bytes,12,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// Memory Stat.
	Memory *Memory `protobuf:"bytes,13,opt,name=memory,proto3" json:"memory,omitempty"`
	// Network Stat.
	Network *Network `protobuf:"bytes,14,opt,name=network,proto3" json:"network,omitempty"`
	// Disk Stat.
	Disk *Disk `protobuf:"bytes,15,opt,name=disk,proto3" json:"disk,omitempty"`
	// Build information.
	Build *Build `protobuf:"bytes,16,opt,name=build,proto3" json:"build,omitempty"`
	// contains filtered or unexported fields
}

AnnounceHostRequest represents request of AnnounceHost.

func (*AnnounceHostRequest) Descriptor deprecated added in v1.2.5 

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

Deprecated: Use AnnounceHostRequest.ProtoReflect.Descriptor instead.

func (*AnnounceHostRequest) GetBuild added in v1.2.5 

func (x *AnnounceHostRequest) GetBuild() *Build

func (*AnnounceHostRequest) GetCpu added in v1.2.5 

func (x *AnnounceHostRequest) GetCpu() *CPU

func (*AnnounceHostRequest) GetDisk added in v1.2.5 

func (x *AnnounceHostRequest) GetDisk() *Disk

func (*AnnounceHostRequest) GetDownloadPort added in v1.2.5 

func (x *AnnounceHostRequest) GetDownloadPort() int32

func (*AnnounceHostRequest) GetHostname added in v1.2.5 

func (x *AnnounceHostRequest) GetHostname() string

func (*AnnounceHostRequest) GetId added in v1.2.5 

func (x *AnnounceHostRequest) GetId() string

func (*AnnounceHostRequest) GetIp added in v1.2.5 

func (x *AnnounceHostRequest) GetIp() string

func (*AnnounceHostRequest) GetKernelVersion added in v1.2.5 

func (x *AnnounceHostRequest) GetKernelVersion() string

func (*AnnounceHostRequest) GetMemory added in v1.2.5 

func (x *AnnounceHostRequest) GetMemory() *Memory

func (*AnnounceHostRequest) GetNetwork added in v1.2.5 

func (x *AnnounceHostRequest) GetNetwork() *Network

func (*AnnounceHostRequest) GetOs added in v1.2.5 

func (x *AnnounceHostRequest) GetOs() string

func (*AnnounceHostRequest) GetPlatform added in v1.2.5 

func (x *AnnounceHostRequest) GetPlatform() string

func (*AnnounceHostRequest) GetPlatformFamily added in v1.2.5 

func (x *AnnounceHostRequest) GetPlatformFamily() string

func (*AnnounceHostRequest) GetPlatformVersion added in v1.2.5 

func (x *AnnounceHostRequest) GetPlatformVersion() string

func (*AnnounceHostRequest) GetPort added in v1.2.5 

func (x *AnnounceHostRequest) GetPort() int32

func (*AnnounceHostRequest) GetType added in v1.2.6 

func (x *AnnounceHostRequest) GetType() uint32

func (*AnnounceHostRequest) ProtoMessage added in v1.2.5 

func (*AnnounceHostRequest) ProtoMessage()

func (*AnnounceHostRequest) ProtoReflect added in v1.2.5 

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

func (*AnnounceHostRequest) Reset added in v1.2.5 

func (x *AnnounceHostRequest) Reset()

func (*AnnounceHostRequest) String added in v1.2.5 

func (x *AnnounceHostRequest) String() string

func (*AnnounceHostRequest) Validate added in v1.2.5 

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 added in v1.2.5 

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 added in v1.2.5 

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 added in v1.2.5 

func (m AnnounceHostRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnounceHostRequestMultiError) Error added in v1.2.5 

func (m AnnounceHostRequestMultiError) Error() string

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

type AnnounceHostRequestValidationError added in v1.2.5 

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 added in v1.2.5 

func (e AnnounceHostRequestValidationError) Cause() error

Cause function returns cause value.

func (AnnounceHostRequestValidationError) Error added in v1.2.5 

func (e AnnounceHostRequestValidationError) Error() string

Error satisfies the builtin error interface

func (AnnounceHostRequestValidationError) ErrorName added in v1.2.5 

func (e AnnounceHostRequestValidationError) ErrorName() string

ErrorName returns error name.

func (AnnounceHostRequestValidationError) Field added in v1.2.5 

func (e AnnounceHostRequestValidationError) Field() string

Field function returns field value.

func (AnnounceHostRequestValidationError) Key added in v1.2.5 

func (e AnnounceHostRequestValidationError) Key() bool

Key function returns key value.

func (AnnounceHostRequestValidationError) Reason added in v1.2.5 

func (e AnnounceHostRequestValidationError) Reason() string

Reason function returns reason value.

type AnnouncePeerRequest 

type AnnouncePeerRequest struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Peer id.
	PeerId string `protobuf:"bytes,2,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// Types that are assignable to Request:
	//
	//	*AnnouncePeerRequest_RegisterPeerRequest
	//	*AnnouncePeerRequest_DownloadPeerStartedRequest
	//	*AnnouncePeerRequest_DownloadPeerBackToSourceStartedRequest
	//	*AnnouncePeerRequest_DownloadPeerFinishedRequest
	//	*AnnouncePeerRequest_DownloadPeerBackToSourceFinishedRequest
	//	*AnnouncePeerRequest_DownloadPieceFinishedRequest
	//	*AnnouncePeerRequest_DownloadPieceBackToSourceFinishedRequest
	Request isAnnouncePeerRequest_Request `protobuf_oneof:"request"`
	// Types that are assignable to Errordetails:
	//
	//	*AnnouncePeerRequest_DownloadPeerBackToSourceFailed
	//	*AnnouncePeerRequest_DownloadPieceBackToSourceFailed
	//	*AnnouncePeerRequest_SyncPiecesFailed
	//	*AnnouncePeerRequest_DownloadPieceFailed
	Errordetails isAnnouncePeerRequest_Errordetails `protobuf_oneof:"errordetails"`
	// 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) GetDownloadPeerBackToSourceFailed added in v1.4.1 

func (x *AnnouncePeerRequest) GetDownloadPeerBackToSourceFailed() *v21.DownloadPeerBackToSourceFailed

func (*AnnouncePeerRequest) GetDownloadPeerBackToSourceFinishedRequest added in v1.4.1 

func (x *AnnouncePeerRequest) GetDownloadPeerBackToSourceFinishedRequest() *DownloadPeerBackToSourceFinishedRequest

func (*AnnouncePeerRequest) GetDownloadPeerBackToSourceStartedRequest added in v1.4.1 

func (x *AnnouncePeerRequest) GetDownloadPeerBackToSourceStartedRequest() *DownloadPeerBackToSourceStartedRequest

func (*AnnouncePeerRequest) GetDownloadPeerFinishedRequest added in v1.4.1 

func (x *AnnouncePeerRequest) GetDownloadPeerFinishedRequest() *DownloadPeerFinishedRequest

func (*AnnouncePeerRequest) GetDownloadPeerStartedRequest added in v1.4.1 

func (x *AnnouncePeerRequest) GetDownloadPeerStartedRequest() *DownloadPeerStartedRequest

func (*AnnouncePeerRequest) GetDownloadPieceBackToSourceFailed added in v1.4.1 

func (x *AnnouncePeerRequest) GetDownloadPieceBackToSourceFailed() *v21.DownloadPieceBackToSourceFailed

func (*AnnouncePeerRequest) GetDownloadPieceBackToSourceFinishedRequest added in v1.4.1 

func (x *AnnouncePeerRequest) GetDownloadPieceBackToSourceFinishedRequest() *DownloadPieceBackToSourceFinishedRequest

func (*AnnouncePeerRequest) GetDownloadPieceFailed added in v1.4.1 

func (x *AnnouncePeerRequest) GetDownloadPieceFailed() *v21.DownloadPieceFailed

func (*AnnouncePeerRequest) GetDownloadPieceFinishedRequest added in v1.4.1 

func (x *AnnouncePeerRequest) GetDownloadPieceFinishedRequest() *DownloadPieceFinishedRequest

func (*AnnouncePeerRequest) GetErrordetails added in v1.4.1 

func (m *AnnouncePeerRequest) GetErrordetails() isAnnouncePeerRequest_Errordetails

func (*AnnouncePeerRequest) GetPeerId added in v1.4.5 

func (x *AnnouncePeerRequest) GetPeerId() string

func (*AnnouncePeerRequest) GetRegisterPeerRequest added in v1.4.1 

func (x *AnnouncePeerRequest) GetRegisterPeerRequest() *RegisterPeerRequest

func (*AnnouncePeerRequest) GetRequest 

func (m *AnnouncePeerRequest) GetRequest() isAnnouncePeerRequest_Request

func (*AnnouncePeerRequest) GetSyncPiecesFailed added in v1.4.1 

func (x *AnnouncePeerRequest) GetSyncPiecesFailed() *v21.SyncPiecesFailed

func (*AnnouncePeerRequest) GetTaskId added in v1.4.5 

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_DownloadPeerBackToSourceFailed added in v1.4.1 

type AnnouncePeerRequest_DownloadPeerBackToSourceFailed struct {
	DownloadPeerBackToSourceFailed *v21.DownloadPeerBackToSourceFailed `protobuf:"bytes,10,opt,name=download_peer_back_to_source_failed,json=downloadPeerBackToSourceFailed,proto3,oneof"`
}

type AnnouncePeerRequest_DownloadPeerBackToSourceFinishedRequest added in v1.4.1 

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

type AnnouncePeerRequest_DownloadPeerBackToSourceStartedRequest added in v1.4.1 

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

type AnnouncePeerRequest_DownloadPeerFinishedRequest added in v1.4.1 

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

type AnnouncePeerRequest_DownloadPeerStartedRequest added in v1.4.1 

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

type AnnouncePeerRequest_DownloadPieceBackToSourceFailed added in v1.4.1 

type AnnouncePeerRequest_DownloadPieceBackToSourceFailed struct {
	DownloadPieceBackToSourceFailed *v21.DownloadPieceBackToSourceFailed `protobuf:"bytes,11,opt,name=download_piece_back_to_source_failed,json=downloadPieceBackToSourceFailed,proto3,oneof"`
}

type AnnouncePeerRequest_DownloadPieceBackToSourceFinishedRequest added in v1.4.1 

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

type AnnouncePeerRequest_DownloadPieceFailed added in v1.4.1 

type AnnouncePeerRequest_DownloadPieceFailed struct {
	DownloadPieceFailed *v21.DownloadPieceFailed `protobuf:"bytes,13,opt,name=download_piece_failed,json=downloadPieceFailed,proto3,oneof"`
}

type AnnouncePeerRequest_DownloadPieceFinishedRequest added in v1.4.1 

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

type AnnouncePeerRequest_RegisterPeerRequest added in v1.4.1 

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

type AnnouncePeerRequest_SyncPiecesFailed added in v1.4.1 

type AnnouncePeerRequest_SyncPiecesFailed struct {
	SyncPiecesFailed *v21.SyncPiecesFailed `protobuf:"bytes,12,opt,name=sync_pieces_failed,json=syncPiecesFailed,proto3,oneof"`
}

type AnnouncePeerResponse 

type AnnouncePeerResponse struct {

	// Types that are assignable to Response:
	//
	//	*AnnouncePeerResponse_TinyTaskResponse
	//	*AnnouncePeerResponse_SmallTaskResponse
	//	*AnnouncePeerResponse_NormalTaskResponse
	//	*AnnouncePeerResponse_NeedBackToSourceResponse
	Response isAnnouncePeerResponse_Response `protobuf_oneof:"response"`
	// Types that are assignable to Errordetails:
	//
	//	*AnnouncePeerResponse_SchedulePeerForbidden
	//	*AnnouncePeerResponse_SchedulePeerFailed
	Errordetails isAnnouncePeerResponse_Errordetails `protobuf_oneof:"errordetails"`
	// 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) GetErrordetails added in v1.4.1 

func (m *AnnouncePeerResponse) GetErrordetails() isAnnouncePeerResponse_Errordetails

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) GetSchedulePeerFailed added in v1.4.1 

func (x *AnnouncePeerResponse) GetSchedulePeerFailed() *v21.SchedulePeerFailed

func (*AnnouncePeerResponse) GetSchedulePeerForbidden added in v1.4.1 

func (x *AnnouncePeerResponse) GetSchedulePeerForbidden() *v21.SchedulePeerForbidden

func (*AnnouncePeerResponse) GetSmallTaskResponse 

func (x *AnnouncePeerResponse) GetSmallTaskResponse() *SmallTaskResponse

func (*AnnouncePeerResponse) GetTinyTaskResponse 

func (x *AnnouncePeerResponse) GetTinyTaskResponse() *TinyTaskResponse

func (*AnnouncePeerResponse) ProtoMessage 

func (*AnnouncePeerResponse) ProtoMessage()

func (*AnnouncePeerResponse) ProtoReflect 

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

func (*AnnouncePeerResponse) Reset 

func (x *AnnouncePeerResponse) Reset()

func (*AnnouncePeerResponse) String 

func (x *AnnouncePeerResponse) String() string

func (*AnnouncePeerResponse) Validate 

func (m *AnnouncePeerResponse) Validate() error

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

func (*AnnouncePeerResponse) ValidateAll 

func (m *AnnouncePeerResponse) ValidateAll() error

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

type AnnouncePeerResponseMultiError 

type AnnouncePeerResponseMultiError []error

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

func (AnnouncePeerResponseMultiError) AllErrors 

func (m AnnouncePeerResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnouncePeerResponseMultiError) Error 

func (m AnnouncePeerResponseMultiError) Error() string

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

type AnnouncePeerResponseValidationError 

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

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

func (AnnouncePeerResponseValidationError) Cause 

func (e AnnouncePeerResponseValidationError) Cause() error

Cause function returns cause value.

func (AnnouncePeerResponseValidationError) Error 

func (e AnnouncePeerResponseValidationError) Error() string

Error satisfies the builtin error interface

func (AnnouncePeerResponseValidationError) ErrorName 

func (e AnnouncePeerResponseValidationError) ErrorName() string

ErrorName returns error name.

func (AnnouncePeerResponseValidationError) Field 

func (e AnnouncePeerResponseValidationError) Field() string

Field function returns field value.

func (AnnouncePeerResponseValidationError) Key 

func (e AnnouncePeerResponseValidationError) Key() bool

Key function returns key value.

func (AnnouncePeerResponseValidationError) Reason 

func (e AnnouncePeerResponseValidationError) Reason() string

Reason function returns reason value.

type AnnouncePeerResponse_NeedBackToSourceResponse 

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

type AnnouncePeerResponse_NormalTaskResponse 

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

type AnnouncePeerResponse_SchedulePeerFailed added in v1.4.1 

type AnnouncePeerResponse_SchedulePeerFailed struct {
	SchedulePeerFailed *v21.SchedulePeerFailed `protobuf:"bytes,6,opt,name=schedule_peer_failed,json=schedulePeerFailed,proto3,oneof"`
}

type AnnouncePeerResponse_SchedulePeerForbidden added in v1.4.1 

type AnnouncePeerResponse_SchedulePeerForbidden struct {
	SchedulePeerForbidden *v21.SchedulePeerForbidden `protobuf:"bytes,5,opt,name=schedule_peer_forbidden,json=schedulePeerForbidden,proto3,oneof"`
}

type AnnouncePeerResponse_SmallTaskResponse 

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

type AnnouncePeerResponse_TinyTaskResponse 

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

type Build added in v1.2.5 

type Build struct {

	// Git version.
	GitVersion string `protobuf:"bytes,1,opt,name=git_version,json=gitVersion,proto3" json:"git_version,omitempty"`
	// Git commit.
	GitCommit string `protobuf:"bytes,2,opt,name=git_commit,json=gitCommit,proto3" json:"git_commit,omitempty"`
	// Golang version.
	GoVersion string `protobuf:"bytes,3,opt,name=go_version,json=goVersion,proto3" json:"go_version,omitempty"`
	// Build platform.
	Platform string `protobuf:"bytes,4,opt,name=platform,proto3" json:"platform,omitempty"`
	// contains filtered or unexported fields
}

Build information.

func (*Build) Descriptor deprecated added in v1.2.5 

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

Deprecated: Use Build.ProtoReflect.Descriptor instead.

func (*Build) GetGitCommit added in v1.2.5 

func (x *Build) GetGitCommit() string

func (*Build) GetGitVersion added in v1.2.5 

func (x *Build) GetGitVersion() string

func (*Build) GetGoVersion added in v1.2.5 

func (x *Build) GetGoVersion() string

func (*Build) GetPlatform added in v1.2.5 

func (x *Build) GetPlatform() string

func (*Build) ProtoMessage added in v1.2.5 

func (*Build) ProtoMessage()

func (*Build) ProtoReflect added in v1.2.5 

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

func (*Build) Reset added in v1.2.5 

func (x *Build) Reset()

func (*Build) String added in v1.2.5 

func (x *Build) String() string

func (*Build) Validate added in v1.2.5 

func (m *Build) Validate() error

Validate checks the field values on Build 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 (*Build) ValidateAll added in v1.2.5 

func (m *Build) ValidateAll() error

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

type BuildMultiError added in v1.2.5 

type BuildMultiError []error

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

func (BuildMultiError) AllErrors added in v1.2.5 

func (m BuildMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (BuildMultiError) Error added in v1.2.5 

func (m BuildMultiError) Error() string

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

type BuildValidationError added in v1.2.5 

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

BuildValidationError is the validation error returned by Build.Validate if the designated constraints aren't met.

func (BuildValidationError) Cause added in v1.2.5 

func (e BuildValidationError) Cause() error

Cause function returns cause value.

func (BuildValidationError) Error added in v1.2.5 

func (e BuildValidationError) Error() string

Error satisfies the builtin error interface

func (BuildValidationError) ErrorName added in v1.2.5 

func (e BuildValidationError) ErrorName() string

ErrorName returns error name.

func (BuildValidationError) Field added in v1.2.5 

func (e BuildValidationError) Field() string

Field function returns field value.

func (BuildValidationError) Key added in v1.2.5 

func (e BuildValidationError) Key() bool

Key function returns key value.

func (BuildValidationError) Reason added in v1.2.5 

func (e BuildValidationError) Reason() string

Reason function returns reason value.

type CPU added in v1.2.5 

type CPU struct {

	// Number of logical cores in the system.
	LogicalCount uint32 `protobuf:"varint,1,opt,name=logical_count,json=logicalCount,proto3" json:"logical_count,omitempty"`
	// Number of physical cores in the system
	PhysicalCount uint32 `protobuf:"varint,2,opt,name=physical_count,json=physicalCount,proto3" json:"physical_count,omitempty"`
	// Percent calculates the percentage of cpu used.
	Percent float64 `protobuf:"fixed64,3,opt,name=percent,proto3" json:"percent,omitempty"`
	// Calculates the percentage of cpu used by process.
	ProcessPercent float64 `protobuf:"fixed64,4,opt,name=process_percent,json=processPercent,proto3" json:"process_percent,omitempty"`
	// CPUTimes contains the amounts of time the CPU has spent performing different kinds of work.
	Times *CPUTimes `protobuf:"bytes,5,opt,name=times,proto3" json:"times,omitempty"`
	// contains filtered or unexported fields
}

CPU Stat.

func (*CPU) Descriptor deprecated added in v1.2.5 

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

Deprecated: Use CPU.ProtoReflect.Descriptor instead.

func (*CPU) GetLogicalCount added in v1.2.5 

func (x *CPU) GetLogicalCount() uint32

func (*CPU) GetPercent added in v1.2.5 

func (x *CPU) GetPercent() float64

func (*CPU) GetPhysicalCount added in v1.2.5 

func (x *CPU) GetPhysicalCount() uint32

func (*CPU) GetProcessPercent added in v1.2.5 

func (x *CPU) GetProcessPercent() float64

func (*CPU) GetTimes added in v1.2.5 

func (x *CPU) GetTimes() *CPUTimes

func (*CPU) ProtoMessage added in v1.2.5 

func (*CPU) ProtoMessage()

func (*CPU) ProtoReflect added in v1.2.5 

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

func (*CPU) Reset added in v1.2.5 

func (x *CPU) Reset()

func (*CPU) String added in v1.2.5 

func (x *CPU) String() string

func (*CPU) Validate added in v1.2.5 

func (m *CPU) Validate() error

Validate checks the field values on CPU 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 (*CPU) ValidateAll added in v1.2.5 

func (m *CPU) ValidateAll() error

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

type CPUMultiError added in v1.2.5 

type CPUMultiError []error

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

func (CPUMultiError) AllErrors added in v1.2.5 

func (m CPUMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CPUMultiError) Error added in v1.2.5 

func (m CPUMultiError) Error() string

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

type CPUTimes added in v1.2.5 

type CPUTimes struct {

	// CPU time of user.
	User float64 `protobuf:"fixed64,1,opt,name=user,proto3" json:"user,omitempty"`
	// CPU time of system.
	System float64 `protobuf:"fixed64,2,opt,name=system,proto3" json:"system,omitempty"`
	// CPU time of idle.
	Idle float64 `protobuf:"fixed64,3,opt,name=idle,proto3" json:"idle,omitempty"`
	// CPU time of nice.
	Nice float64 `protobuf:"fixed64,4,opt,name=nice,proto3" json:"nice,omitempty"`
	// CPU time of iowait.
	Iowait float64 `protobuf:"fixed64,5,opt,name=iowait,proto3" json:"iowait,omitempty"`
	// CPU time of irq.
	Irq float64 `protobuf:"fixed64,6,opt,name=irq,proto3" json:"irq,omitempty"`
	// CPU time of softirq.
	Softirq float64 `protobuf:"fixed64,7,opt,name=softirq,proto3" json:"softirq,omitempty"`
	// CPU time of steal.
	Steal float64 `protobuf:"fixed64,8,opt,name=steal,proto3" json:"steal,omitempty"`
	// CPU time of guest.
	Guest float64 `protobuf:"fixed64,9,opt,name=guest,proto3" json:"guest,omitempty"`
	// CPU time of guest nice.
	GuestNice float64 `protobuf:"fixed64,10,opt,name=guest_nice,json=guestNice,proto3" json:"guest_nice,omitempty"`
	// contains filtered or unexported fields
}

CPUTimes contains the amounts of time the CPU has spent performing different kinds of work. Time units are in seconds.

func (*CPUTimes) Descriptor deprecated added in v1.2.5 

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

Deprecated: Use CPUTimes.ProtoReflect.Descriptor instead.

func (*CPUTimes) GetGuest added in v1.2.5 

func (x *CPUTimes) GetGuest() float64

func (*CPUTimes) GetGuestNice added in v1.2.5 

func (x *CPUTimes) GetGuestNice() float64

func (*CPUTimes) GetIdle added in v1.2.5 

func (x *CPUTimes) GetIdle() float64

func (*CPUTimes) GetIowait added in v1.2.5 

func (x *CPUTimes) GetIowait() float64

func (*CPUTimes) GetIrq added in v1.2.5 

func (x *CPUTimes) GetIrq() float64

func (*CPUTimes) GetNice added in v1.2.5 

func (x *CPUTimes) GetNice() float64

func (*CPUTimes) GetSoftirq added in v1.2.5 

func (x *CPUTimes) GetSoftirq() float64

func (*CPUTimes) GetSteal added in v1.2.5 

func (x *CPUTimes) GetSteal() float64

func (*CPUTimes) GetSystem added in v1.2.5 

func (x *CPUTimes) GetSystem() float64

func (*CPUTimes) GetUser added in v1.2.5 

func (x *CPUTimes) GetUser() float64

func (*CPUTimes) ProtoMessage added in v1.2.5 

func (*CPUTimes) ProtoMessage()

func (*CPUTimes) ProtoReflect added in v1.2.5 

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

func (*CPUTimes) Reset added in v1.2.5 

func (x *CPUTimes) Reset()

func (*CPUTimes) String added in v1.2.5 

func (x *CPUTimes) String() string

func (*CPUTimes) Validate added in v1.2.5 

func (m *CPUTimes) Validate() error

Validate checks the field values on CPUTimes 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 (*CPUTimes) ValidateAll added in v1.2.5 

func (m *CPUTimes) ValidateAll() error

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

type CPUTimesMultiError added in v1.2.5 

type CPUTimesMultiError []error

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

func (CPUTimesMultiError) AllErrors added in v1.2.5 

func (m CPUTimesMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CPUTimesMultiError) Error added in v1.2.5 

func (m CPUTimesMultiError) Error() string

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

type CPUTimesValidationError added in v1.2.5 

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

CPUTimesValidationError is the validation error returned by CPUTimes.Validate if the designated constraints aren't met.

func (CPUTimesValidationError) Cause added in v1.2.5 

func (e CPUTimesValidationError) Cause() error

Cause function returns cause value.

func (CPUTimesValidationError) Error added in v1.2.5 

func (e CPUTimesValidationError) Error() string

Error satisfies the builtin error interface

func (CPUTimesValidationError) ErrorName added in v1.2.5 

func (e CPUTimesValidationError) ErrorName() string

ErrorName returns error name.

func (CPUTimesValidationError) Field added in v1.2.5 

func (e CPUTimesValidationError) Field() string

Field function returns field value.

func (CPUTimesValidationError) Key added in v1.2.5 

func (e CPUTimesValidationError) Key() bool

Key function returns key value.

func (CPUTimesValidationError) Reason added in v1.2.5 

func (e CPUTimesValidationError) Reason() string

Reason function returns reason value.

type CPUValidationError added in v1.2.5 

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

CPUValidationError is the validation error returned by CPU.Validate if the designated constraints aren't met.

func (CPUValidationError) Cause added in v1.2.5 

func (e CPUValidationError) Cause() error

Cause function returns cause value.

func (CPUValidationError) Error added in v1.2.5 

func (e CPUValidationError) Error() string

Error satisfies the builtin error interface

func (CPUValidationError) ErrorName added in v1.2.5 

func (e CPUValidationError) ErrorName() string

ErrorName returns error name.

func (CPUValidationError) Field added in v1.2.5 

func (e CPUValidationError) Field() string

Field function returns field value.

func (CPUValidationError) Key added in v1.2.5 

func (e CPUValidationError) Key() bool

Key function returns key value.

func (CPUValidationError) Reason added in v1.2.5 

func (e CPUValidationError) Reason() string

Reason function returns reason value.

type DeleteHostsRequest added in v1.4.8 

type DeleteHostsRequest struct {

	// Hosts needs to be deleted.
	ProbesOfHosts []*ProbesOfHost `protobuf:"bytes,1,rep,name=probes_of_hosts,json=probesOfHosts,proto3" json:"probes_of_hosts,omitempty"`
	// contains filtered or unexported fields
}

DeleteHostsRequest represents delete hosts request of SyncNetworkTopologyRequest.

func (*DeleteHostsRequest) Descriptor deprecated added in v1.4.8 

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

Deprecated: Use DeleteHostsRequest.ProtoReflect.Descriptor instead.

func (*DeleteHostsRequest) GetProbesOfHosts added in v1.4.8 

func (x *DeleteHostsRequest) GetProbesOfHosts() []*ProbesOfHost

func (*DeleteHostsRequest) ProtoMessage added in v1.4.8 

func (*DeleteHostsRequest) ProtoMessage()

func (*DeleteHostsRequest) ProtoReflect added in v1.4.8 

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

func (*DeleteHostsRequest) Reset added in v1.4.8 

func (x *DeleteHostsRequest) Reset()

func (*DeleteHostsRequest) String added in v1.4.8 

func (x *DeleteHostsRequest) String() string

func (*DeleteHostsRequest) Validate added in v1.4.8 

func (m *DeleteHostsRequest) Validate() error

Validate checks the field values on DeleteHostsRequest 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 (*DeleteHostsRequest) ValidateAll added in v1.4.8 

func (m *DeleteHostsRequest) ValidateAll() error

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

type DeleteHostsRequestMultiError added in v1.4.8 

type DeleteHostsRequestMultiError []error

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

func (DeleteHostsRequestMultiError) AllErrors added in v1.4.8 

func (m DeleteHostsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteHostsRequestMultiError) Error added in v1.4.8 

func (m DeleteHostsRequestMultiError) Error() string

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

type DeleteHostsRequestValidationError added in v1.4.8 

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

DeleteHostsRequestValidationError is the validation error returned by DeleteHostsRequest.Validate if the designated constraints aren't met.

func (DeleteHostsRequestValidationError) Cause added in v1.4.8 

func (e DeleteHostsRequestValidationError) Cause() error

Cause function returns cause value.

func (DeleteHostsRequestValidationError) Error added in v1.4.8 

func (e DeleteHostsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DeleteHostsRequestValidationError) ErrorName added in v1.4.8 

func (e DeleteHostsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DeleteHostsRequestValidationError) Field added in v1.4.8 

func (e DeleteHostsRequestValidationError) Field() string

Field function returns field value.

func (DeleteHostsRequestValidationError) Key added in v1.4.8 

func (e DeleteHostsRequestValidationError) Key() bool

Key function returns key value.

func (DeleteHostsRequestValidationError) Reason added in v1.4.8 

func (e DeleteHostsRequestValidationError) Reason() string

Reason function returns reason value.

type Disk added in v1.2.5 

type Disk struct {

	// Total amount of disk on the data path of dragonfly.
	Total uint64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	// Free amount of disk on the data path of dragonfly.
	Free uint64 `protobuf:"varint,2,opt,name=free,proto3" json:"free,omitempty"`
	// Used amount of disk on the data path of dragonfly.
	Used uint64 `protobuf:"varint,3,opt,name=used,proto3" json:"used,omitempty"`
	// Used percent of disk on the data path of dragonfly directory.
	UsedPercent float64 `protobuf:"fixed64,4,opt,name=used_percent,json=usedPercent,proto3" json:"used_percent,omitempty"`
	// Total amount of indoes on the data path of dragonfly directory.
	InodesTotal uint64 `protobuf:"varint,5,opt,name=inodes_total,json=inodesTotal,proto3" json:"inodes_total,omitempty"`
	// Used amount of indoes on the data path of dragonfly directory.
	InodesUsed uint64 `protobuf:"varint,6,opt,name=inodes_used,json=inodesUsed,proto3" json:"inodes_used,omitempty"`
	// Free amount of indoes on the data path of dragonfly directory.
	InodesFree uint64 `protobuf:"varint,7,opt,name=inodes_free,json=inodesFree,proto3" json:"inodes_free,omitempty"`
	// Used percent of indoes on the data path of dragonfly directory.
	InodesUsedPercent float64 `protobuf:"fixed64,8,opt,name=inodes_used_percent,json=inodesUsedPercent,proto3" json:"inodes_used_percent,omitempty"`
	// contains filtered or unexported fields
}

Disk Stat.

func (*Disk) Descriptor deprecated added in v1.2.5 

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

Deprecated: Use Disk.ProtoReflect.Descriptor instead.

func (*Disk) GetFree added in v1.2.5 

func (x *Disk) GetFree() uint64

func (*Disk) GetInodesFree added in v1.2.5 

func (x *Disk) GetInodesFree() uint64

func (*Disk) GetInodesTotal added in v1.2.5 

func (x *Disk) GetInodesTotal() uint64

func (*Disk) GetInodesUsed added in v1.2.5 

func (x *Disk) GetInodesUsed() uint64

func (*Disk) GetInodesUsedPercent added in v1.2.5 

func (x *Disk) GetInodesUsedPercent() float64

func (*Disk) GetTotal added in v1.2.5 

func (x *Disk) GetTotal() uint64

func (*Disk) GetUsed added in v1.2.5 

func (x *Disk) GetUsed() uint64

func (*Disk) GetUsedPercent added in v1.2.5 

func (x *Disk) GetUsedPercent() float64

func (*Disk) ProtoMessage added in v1.2.5 

func (*Disk) ProtoMessage()

func (*Disk) ProtoReflect added in v1.2.5 

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

func (*Disk) Reset added in v1.2.5 

func (x *Disk) Reset()

func (*Disk) String added in v1.2.5 

func (x *Disk) String() string

func (*Disk) Validate added in v1.2.5 

func (m *Disk) Validate() error

Validate checks the field values on Disk 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 (*Disk) ValidateAll added in v1.2.5 

func (m *Disk) ValidateAll() error

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

type DiskMultiError added in v1.2.5 

type DiskMultiError []error

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

func (DiskMultiError) AllErrors added in v1.2.5 

func (m DiskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DiskMultiError) Error added in v1.2.5 

func (m DiskMultiError) Error() string

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

type DiskValidationError added in v1.2.5 

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

DiskValidationError is the validation error returned by Disk.Validate if the designated constraints aren't met.

func (DiskValidationError) Cause added in v1.2.5 

func (e DiskValidationError) Cause() error

Cause function returns cause value.

func (DiskValidationError) Error added in v1.2.5 

func (e DiskValidationError) Error() string

Error satisfies the builtin error interface

func (DiskValidationError) ErrorName added in v1.2.5 

func (e DiskValidationError) ErrorName() string

ErrorName returns error name.

func (DiskValidationError) Field added in v1.2.5 

func (e DiskValidationError) Field() string

Field function returns field value.

func (DiskValidationError) Key added in v1.2.5 

func (e DiskValidationError) Key() bool

Key function returns key value.

func (DiskValidationError) Reason added in v1.2.5 

func (e DiskValidationError) Reason() string

Reason function returns reason value.

type DownloadPeerBackToSourceFinishedRequest added in v1.4.1 

type DownloadPeerBackToSourceFinishedRequest struct {

	// Total content length.
	ContentLength int64 `protobuf:"varint,1,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// Total piece count.
	PieceCount int64 `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 added in v1.4.1 

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

Deprecated: Use DownloadPeerBackToSourceFinishedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPeerBackToSourceFinishedRequest) GetContentLength added in v1.4.1 

func (x *DownloadPeerBackToSourceFinishedRequest) GetContentLength() int64

func (*DownloadPeerBackToSourceFinishedRequest) GetPieceCount added in v1.4.1 

func (x *DownloadPeerBackToSourceFinishedRequest) GetPieceCount() int64

func (*DownloadPeerBackToSourceFinishedRequest) ProtoMessage added in v1.4.1 

func (*DownloadPeerBackToSourceFinishedRequest) ProtoMessage()

func (*DownloadPeerBackToSourceFinishedRequest) ProtoReflect added in v1.4.1 

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

func (*DownloadPeerBackToSourceFinishedRequest) Reset added in v1.4.1 

func (x *DownloadPeerBackToSourceFinishedRequest) Reset()

func (*DownloadPeerBackToSourceFinishedRequest) String added in v1.4.1 

func (x *DownloadPeerBackToSourceFinishedRequest) String() string

func (*DownloadPeerBackToSourceFinishedRequest) Validate added in v1.4.1 

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 added in v1.4.1 

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 added in v1.4.1 

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 added in v1.4.1 

func (m DownloadPeerBackToSourceFinishedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPeerBackToSourceFinishedRequestMultiError) Error added in v1.4.1 

func (m DownloadPeerBackToSourceFinishedRequestMultiError) Error() string

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

type DownloadPeerBackToSourceFinishedRequestValidationError added in v1.4.1 

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 added in v1.4.1 

func (e DownloadPeerBackToSourceFinishedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPeerBackToSourceFinishedRequestValidationError) Error added in v1.4.1 

func (e DownloadPeerBackToSourceFinishedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPeerBackToSourceFinishedRequestValidationError) ErrorName added in v1.4.1 

func (e DownloadPeerBackToSourceFinishedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPeerBackToSourceFinishedRequestValidationError) Field added in v1.4.1 

func (e DownloadPeerBackToSourceFinishedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPeerBackToSourceFinishedRequestValidationError) Key added in v1.4.1 

func (e DownloadPeerBackToSourceFinishedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPeerBackToSourceFinishedRequestValidationError) Reason added in v1.4.1 

func (e DownloadPeerBackToSourceFinishedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPeerBackToSourceStartedRequest added in v1.4.1 

type DownloadPeerBackToSourceStartedRequest struct {

	// Download back-to-source reason.
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

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

func (*DownloadPeerBackToSourceStartedRequest) Descriptor deprecated added in v1.4.1 

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

Deprecated: Use DownloadPeerBackToSourceStartedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPeerBackToSourceStartedRequest) GetReason added in v1.4.1 

func (x *DownloadPeerBackToSourceStartedRequest) GetReason() string

func (*DownloadPeerBackToSourceStartedRequest) ProtoMessage added in v1.4.1 

func (*DownloadPeerBackToSourceStartedRequest) ProtoMessage()

func (*DownloadPeerBackToSourceStartedRequest) ProtoReflect added in v1.4.1 

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

func (*DownloadPeerBackToSourceStartedRequest) Reset added in v1.4.1 

func (x *DownloadPeerBackToSourceStartedRequest) Reset()

func (*DownloadPeerBackToSourceStartedRequest) String added in v1.4.1 

func (x *DownloadPeerBackToSourceStartedRequest) String() string

func (*DownloadPeerBackToSourceStartedRequest) Validate added in v1.4.1 

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 added in v1.4.1 

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 added in v1.4.1 

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 added in v1.4.1 

func (m DownloadPeerBackToSourceStartedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPeerBackToSourceStartedRequestMultiError) Error added in v1.4.1 

func (m DownloadPeerBackToSourceStartedRequestMultiError) Error() string

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

type DownloadPeerBackToSourceStartedRequestValidationError added in v1.4.1 

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 added in v1.4.1 

func (e DownloadPeerBackToSourceStartedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPeerBackToSourceStartedRequestValidationError) Error added in v1.4.1 

func (e DownloadPeerBackToSourceStartedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPeerBackToSourceStartedRequestValidationError) ErrorName added in v1.4.1 

func (e DownloadPeerBackToSourceStartedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPeerBackToSourceStartedRequestValidationError) Field added in v1.4.1 

func (e DownloadPeerBackToSourceStartedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPeerBackToSourceStartedRequestValidationError) Key added in v1.4.1 

func (e DownloadPeerBackToSourceStartedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPeerBackToSourceStartedRequestValidationError) Reason added in v1.4.1 

func (e DownloadPeerBackToSourceStartedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPeerFinishedRequest added in v1.4.1 

type DownloadPeerFinishedRequest struct {

	// Total content length.
	ContentLength int64 `protobuf:"varint,1,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// Total piece count.
	PieceCount int64 `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 added in v1.4.1 

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

Deprecated: Use DownloadPeerFinishedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPeerFinishedRequest) GetContentLength added in v1.4.1 

func (x *DownloadPeerFinishedRequest) GetContentLength() int64

func (*DownloadPeerFinishedRequest) GetPieceCount added in v1.4.1 

func (x *DownloadPeerFinishedRequest) GetPieceCount() int64

func (*DownloadPeerFinishedRequest) ProtoMessage added in v1.4.1 

func (*DownloadPeerFinishedRequest) ProtoMessage()

func (*DownloadPeerFinishedRequest) ProtoReflect added in v1.4.1 

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

func (*DownloadPeerFinishedRequest) Reset added in v1.4.1 

func (x *DownloadPeerFinishedRequest) Reset()

func (*DownloadPeerFinishedRequest) String added in v1.4.1 

func (x *DownloadPeerFinishedRequest) String() string

func (*DownloadPeerFinishedRequest) Validate added in v1.4.1 

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 added in v1.4.1 

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 added in v1.4.1 

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 added in v1.4.1 

func (m DownloadPeerFinishedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPeerFinishedRequestMultiError) Error added in v1.4.1 

func (m DownloadPeerFinishedRequestMultiError) Error() string

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

type DownloadPeerFinishedRequestValidationError added in v1.4.1 

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 added in v1.4.1 

func (e DownloadPeerFinishedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPeerFinishedRequestValidationError) Error added in v1.4.1 

func (e DownloadPeerFinishedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPeerFinishedRequestValidationError) ErrorName added in v1.4.1 

func (e DownloadPeerFinishedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPeerFinishedRequestValidationError) Field added in v1.4.1 

func (e DownloadPeerFinishedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPeerFinishedRequestValidationError) Key added in v1.4.1 

func (e DownloadPeerFinishedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPeerFinishedRequestValidationError) Reason added in v1.4.1 

func (e DownloadPeerFinishedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPeerStartedRequest added in v1.4.1 

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

DownloadPeerStartedRequest represents peer download started request of AnnouncePeerRequest.

func (*DownloadPeerStartedRequest) Descriptor deprecated added in v1.4.1 

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

Deprecated: Use DownloadPeerStartedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPeerStartedRequest) ProtoMessage added in v1.4.1 

func (*DownloadPeerStartedRequest) ProtoMessage()

func (*DownloadPeerStartedRequest) ProtoReflect added in v1.4.1 

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

func (*DownloadPeerStartedRequest) Reset added in v1.4.1 

func (x *DownloadPeerStartedRequest) Reset()

func (*DownloadPeerStartedRequest) String added in v1.4.1 

func (x *DownloadPeerStartedRequest) String() string

func (*DownloadPeerStartedRequest) Validate added in v1.4.1 

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 added in v1.4.1 

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 added in v1.4.1 

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 added in v1.4.1 

func (m DownloadPeerStartedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPeerStartedRequestMultiError) Error added in v1.4.1 

func (m DownloadPeerStartedRequestMultiError) Error() string

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

type DownloadPeerStartedRequestValidationError added in v1.4.1 

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 added in v1.4.1 

func (e DownloadPeerStartedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPeerStartedRequestValidationError) Error added in v1.4.1 

func (e DownloadPeerStartedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPeerStartedRequestValidationError) ErrorName added in v1.4.1 

func (e DownloadPeerStartedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPeerStartedRequestValidationError) Field added in v1.4.1 

func (e DownloadPeerStartedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPeerStartedRequestValidationError) Key added in v1.4.1 

func (e DownloadPeerStartedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPeerStartedRequestValidationError) Reason added in v1.4.1 

func (e DownloadPeerStartedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPieceBackToSourceFinishedRequest added in v1.4.1 

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 added in v1.4.1 

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

Deprecated: Use DownloadPieceBackToSourceFinishedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPieceBackToSourceFinishedRequest) GetPiece added in v1.4.1 

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

func (*DownloadPieceBackToSourceFinishedRequest) ProtoMessage added in v1.4.1 

func (*DownloadPieceBackToSourceFinishedRequest) ProtoMessage()

func (*DownloadPieceBackToSourceFinishedRequest) ProtoReflect added in v1.4.1 

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

func (*DownloadPieceBackToSourceFinishedRequest) Reset added in v1.4.1 

func (x *DownloadPieceBackToSourceFinishedRequest) Reset()

func (*DownloadPieceBackToSourceFinishedRequest) String added in v1.4.1 

func (x *DownloadPieceBackToSourceFinishedRequest) String() string

func (*DownloadPieceBackToSourceFinishedRequest) Validate added in v1.4.1 

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 added in v1.4.1 

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 added in v1.4.1 

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 added in v1.4.1 

func (m DownloadPieceBackToSourceFinishedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPieceBackToSourceFinishedRequestMultiError) Error added in v1.4.1 

func (m DownloadPieceBackToSourceFinishedRequestMultiError) Error() string

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

type DownloadPieceBackToSourceFinishedRequestValidationError added in v1.4.1 

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 added in v1.4.1 

func (e DownloadPieceBackToSourceFinishedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPieceBackToSourceFinishedRequestValidationError) Error added in v1.4.1 

func (e DownloadPieceBackToSourceFinishedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPieceBackToSourceFinishedRequestValidationError) ErrorName added in v1.4.1 

func (e DownloadPieceBackToSourceFinishedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPieceBackToSourceFinishedRequestValidationError) Field added in v1.4.1 

func (e DownloadPieceBackToSourceFinishedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPieceBackToSourceFinishedRequestValidationError) Key added in v1.4.1 

func (e DownloadPieceBackToSourceFinishedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPieceBackToSourceFinishedRequestValidationError) Reason added in v1.4.1 

func (e DownloadPieceBackToSourceFinishedRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPieceFinishedRequest added in v1.4.1 

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 added in v1.4.1 

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

Deprecated: Use DownloadPieceFinishedRequest.ProtoReflect.Descriptor instead.

func (*DownloadPieceFinishedRequest) GetPiece added in v1.4.1 

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

func (*DownloadPieceFinishedRequest) ProtoMessage added in v1.4.1 

func (*DownloadPieceFinishedRequest) ProtoMessage()

func (*DownloadPieceFinishedRequest) ProtoReflect added in v1.4.1 

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

func (*DownloadPieceFinishedRequest) Reset added in v1.4.1 

func (x *DownloadPieceFinishedRequest) Reset()

func (*DownloadPieceFinishedRequest) String added in v1.4.1 

func (x *DownloadPieceFinishedRequest) String() string

func (*DownloadPieceFinishedRequest) Validate added in v1.4.1 

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 added in v1.4.1 

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 added in v1.4.1 

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 added in v1.4.1 

func (m DownloadPieceFinishedRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPieceFinishedRequestMultiError) Error added in v1.4.1 

func (m DownloadPieceFinishedRequestMultiError) Error() string

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

type DownloadPieceFinishedRequestValidationError added in v1.4.1 

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 added in v1.4.1 

func (e DownloadPieceFinishedRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPieceFinishedRequestValidationError) Error added in v1.4.1 

func (e DownloadPieceFinishedRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPieceFinishedRequestValidationError) ErrorName added in v1.4.1 

func (e DownloadPieceFinishedRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPieceFinishedRequestValidationError) Field added in v1.4.1 

func (e DownloadPieceFinishedRequestValidationError) Field() string

Field function returns field value.

func (DownloadPieceFinishedRequestValidationError) Key added in v1.4.1 

func (e DownloadPieceFinishedRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPieceFinishedRequestValidationError) Reason added in v1.4.1 

func (e DownloadPieceFinishedRequestValidationError) Reason() string

Reason function returns reason value.

type ExchangePeerRequest 

type ExchangePeerRequest struct {

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

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

func (*ExchangePeerRequest) Descriptor deprecated 

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

Deprecated: Use ExchangePeerRequest.ProtoReflect.Descriptor instead.

func (*ExchangePeerRequest) GetPeerId added in v1.1.6 

func (x *ExchangePeerRequest) GetPeerId() string

func (*ExchangePeerRequest) GetTaskId added in v1.1.6 

func (x *ExchangePeerRequest) GetTaskId() string

func (*ExchangePeerRequest) ProtoMessage 

func (*ExchangePeerRequest) ProtoMessage()

func (*ExchangePeerRequest) ProtoReflect 

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

func (*ExchangePeerRequest) Reset 

func (x *ExchangePeerRequest) Reset()

func (*ExchangePeerRequest) String 

func (x *ExchangePeerRequest) String() string

func (*ExchangePeerRequest) Validate 

func (m *ExchangePeerRequest) Validate() error

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

func (*ExchangePeerRequest) ValidateAll 

func (m *ExchangePeerRequest) ValidateAll() error

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

type ExchangePeerRequestMultiError 

type ExchangePeerRequestMultiError []error

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

func (ExchangePeerRequestMultiError) AllErrors 

func (m ExchangePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExchangePeerRequestMultiError) Error 

func (m ExchangePeerRequestMultiError) Error() string

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

type ExchangePeerRequestValidationError 

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

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

func (ExchangePeerRequestValidationError) Cause 

func (e ExchangePeerRequestValidationError) Cause() error

Cause function returns cause value.

func (ExchangePeerRequestValidationError) Error 

func (e ExchangePeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ExchangePeerRequestValidationError) ErrorName 

func (e ExchangePeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ExchangePeerRequestValidationError) Field 

func (e ExchangePeerRequestValidationError) Field() string

Field function returns field value.

func (ExchangePeerRequestValidationError) Key 

func (e ExchangePeerRequestValidationError) Key() bool

Key function returns key value.

func (ExchangePeerRequestValidationError) Reason 

func (e ExchangePeerRequestValidationError) Reason() string

Reason function returns reason value.

type ExchangePeerResponse 

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

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

func (*ExchangePeerResponse) Descriptor deprecated 

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

Deprecated: Use ExchangePeerResponse.ProtoReflect.Descriptor instead.

func (*ExchangePeerResponse) ProtoMessage 

func (*ExchangePeerResponse) ProtoMessage()

func (*ExchangePeerResponse) ProtoReflect 

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

func (*ExchangePeerResponse) Reset 

func (x *ExchangePeerResponse) Reset()

func (*ExchangePeerResponse) String 

func (x *ExchangePeerResponse) String() string

func (*ExchangePeerResponse) Validate 

func (m *ExchangePeerResponse) Validate() error

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

func (*ExchangePeerResponse) ValidateAll 

func (m *ExchangePeerResponse) ValidateAll() error

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

type ExchangePeerResponseMultiError 

type ExchangePeerResponseMultiError []error

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

func (ExchangePeerResponseMultiError) AllErrors 

func (m ExchangePeerResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExchangePeerResponseMultiError) Error 

func (m ExchangePeerResponseMultiError) Error() string

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

type ExchangePeerResponseValidationError 

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

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

func (ExchangePeerResponseValidationError) Cause 

func (e ExchangePeerResponseValidationError) Cause() error

Cause function returns cause value.

func (ExchangePeerResponseValidationError) Error 

func (e ExchangePeerResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ExchangePeerResponseValidationError) ErrorName 

func (e ExchangePeerResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ExchangePeerResponseValidationError) Field 

func (e ExchangePeerResponseValidationError) Field() string

Field function returns field value.

func (ExchangePeerResponseValidationError) Key 

func (e ExchangePeerResponseValidationError) Key() bool

Key function returns key value.

func (ExchangePeerResponseValidationError) Reason 

func (e ExchangePeerResponseValidationError) Reason() string

Reason function returns reason value.

type LeaveHostRequest added in v1.2.2 

type LeaveHostRequest struct {

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

LeaveHostRequest represents request of LeaveHost.

func (*LeaveHostRequest) Descriptor deprecated added in v1.2.2 

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

Deprecated: Use LeaveHostRequest.ProtoReflect.Descriptor instead.

func (*LeaveHostRequest) GetId added in v1.2.2 

func (x *LeaveHostRequest) GetId() string

func (*LeaveHostRequest) ProtoMessage added in v1.2.2 

func (*LeaveHostRequest) ProtoMessage()

func (*LeaveHostRequest) ProtoReflect added in v1.2.2 

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

func (*LeaveHostRequest) Reset added in v1.2.2 

func (x *LeaveHostRequest) Reset()

func (*LeaveHostRequest) String added in v1.2.2 

func (x *LeaveHostRequest) String() string

func (*LeaveHostRequest) Validate added in v1.2.2 

func (m *LeaveHostRequest) Validate() error

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

func (*LeaveHostRequest) ValidateAll added in v1.2.2 

func (m *LeaveHostRequest) ValidateAll() error

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

type LeaveHostRequestMultiError added in v1.2.2 

type LeaveHostRequestMultiError []error

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

func (LeaveHostRequestMultiError) AllErrors added in v1.2.2 

func (m LeaveHostRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LeaveHostRequestMultiError) Error added in v1.2.2 

func (m LeaveHostRequestMultiError) Error() string

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

type LeaveHostRequestValidationError added in v1.2.2 

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

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

func (LeaveHostRequestValidationError) Cause added in v1.2.2 

func (e LeaveHostRequestValidationError) Cause() error

Cause function returns cause value.

func (LeaveHostRequestValidationError) Error added in v1.2.2 

func (e LeaveHostRequestValidationError) Error() string

Error satisfies the builtin error interface

func (LeaveHostRequestValidationError) ErrorName added in v1.2.2 

func (e LeaveHostRequestValidationError) ErrorName() string

ErrorName returns error name.

func (LeaveHostRequestValidationError) Field added in v1.2.2 

func (e LeaveHostRequestValidationError) Field() string

Field function returns field value.

func (LeaveHostRequestValidationError) Key added in v1.2.2 

func (e LeaveHostRequestValidationError) Key() bool

Key function returns key value.

func (LeaveHostRequestValidationError) Reason added in v1.2.2 

func (e LeaveHostRequestValidationError) Reason() string

Reason function returns reason value.

type LeavePeerRequest 

type LeavePeerRequest struct {

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

LeavePeerRequest represents request of LeavePeer.

func (*LeavePeerRequest) Descriptor deprecated 

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

Deprecated: Use LeavePeerRequest.ProtoReflect.Descriptor instead.

func (*LeavePeerRequest) GetPeerId 

func (x *LeavePeerRequest) GetPeerId() string

func (*LeavePeerRequest) GetTaskId added in v1.1.6 

func (x *LeavePeerRequest) GetTaskId() string

func (*LeavePeerRequest) ProtoMessage 

func (*LeavePeerRequest) ProtoMessage()

func (*LeavePeerRequest) ProtoReflect 

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

func (*LeavePeerRequest) Reset 

func (x *LeavePeerRequest) Reset()

func (*LeavePeerRequest) String 

func (x *LeavePeerRequest) String() string

func (*LeavePeerRequest) Validate 

func (m *LeavePeerRequest) Validate() error

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

func (*LeavePeerRequest) ValidateAll 

func (m *LeavePeerRequest) ValidateAll() error

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

type LeavePeerRequestMultiError 

type LeavePeerRequestMultiError []error

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

func (LeavePeerRequestMultiError) AllErrors 

func (m LeavePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LeavePeerRequestMultiError) Error 

func (m LeavePeerRequestMultiError) Error() string

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

type LeavePeerRequestValidationError 

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

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

func (LeavePeerRequestValidationError) Cause 

func (e LeavePeerRequestValidationError) Cause() error

Cause function returns cause value.

func (LeavePeerRequestValidationError) Error 

func (e LeavePeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (LeavePeerRequestValidationError) ErrorName 

func (e LeavePeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (LeavePeerRequestValidationError) Field 

func (e LeavePeerRequestValidationError) Field() string

Field function returns field value.

func (LeavePeerRequestValidationError) Key 

func (e LeavePeerRequestValidationError) Key() bool

Key function returns key value.

func (LeavePeerRequestValidationError) Reason 

func (e LeavePeerRequestValidationError) Reason() string

Reason function returns reason value.

type Memory added in v1.2.5 

type Memory struct {

	// Total amount of RAM on this system.
	Total uint64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	// RAM available for programs to allocate.
	Available uint64 `protobuf:"varint,2,opt,name=available,proto3" json:"available,omitempty"`
	// RAM used by programs.
	Used uint64 `protobuf:"varint,3,opt,name=used,proto3" json:"used,omitempty"`
	// Percentage of RAM used by programs.
	UsedPercent float64 `protobuf:"fixed64,4,opt,name=used_percent,json=usedPercent,proto3" json:"used_percent,omitempty"`
	// Calculates the percentage of memory used by process.
	ProcessUsedPercent float64 `protobuf:"fixed64,5,opt,name=process_used_percent,json=processUsedPercent,proto3" json:"process_used_percent,omitempty"`
	// This is the kernel's notion of free memory.
	Free uint64 `protobuf:"varint,6,opt,name=free,proto3" json:"free,omitempty"`
	// contains filtered or unexported fields
}

Memory Stat.

func (*Memory) Descriptor deprecated added in v1.2.5 

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

Deprecated: Use Memory.ProtoReflect.Descriptor instead.

func (*Memory) GetAvailable added in v1.2.5 

func (x *Memory) GetAvailable() uint64

func (*Memory) GetFree added in v1.2.5 

func (x *Memory) GetFree() uint64

func (*Memory) GetProcessUsedPercent added in v1.2.5 

func (x *Memory) GetProcessUsedPercent() float64

func (*Memory) GetTotal added in v1.2.5 

func (x *Memory) GetTotal() uint64

func (*Memory) GetUsed added in v1.2.5 

func (x *Memory) GetUsed() uint64

func (*Memory) GetUsedPercent added in v1.2.5 

func (x *Memory) GetUsedPercent() float64

func (*Memory) ProtoMessage added in v1.2.5 

func (*Memory) ProtoMessage()

func (*Memory) ProtoReflect added in v1.2.5 

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

func (*Memory) Reset added in v1.2.5 

func (x *Memory) Reset()

func (*Memory) String added in v1.2.5 

func (x *Memory) String() string

func (*Memory) Validate added in v1.2.5 

func (m *Memory) Validate() error

Validate checks the field values on Memory 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 (*Memory) ValidateAll added in v1.2.5 

func (m *Memory) ValidateAll() error

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

type MemoryMultiError added in v1.2.5 

type MemoryMultiError []error

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

func (MemoryMultiError) AllErrors added in v1.2.5 

func (m MemoryMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (MemoryMultiError) Error added in v1.2.5 

func (m MemoryMultiError) Error() string

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

type MemoryValidationError added in v1.2.5 

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

MemoryValidationError is the validation error returned by Memory.Validate if the designated constraints aren't met.

func (MemoryValidationError) Cause added in v1.2.5 

func (e MemoryValidationError) Cause() error

Cause function returns cause value.

func (MemoryValidationError) Error added in v1.2.5 

func (e MemoryValidationError) Error() string

Error satisfies the builtin error interface

func (MemoryValidationError) ErrorName added in v1.2.5 

func (e MemoryValidationError) ErrorName() string

ErrorName returns error name.

func (MemoryValidationError) Field added in v1.2.5 

func (e MemoryValidationError) Field() string

Field function returns field value.

func (MemoryValidationError) Key added in v1.2.5 

func (e MemoryValidationError) Key() bool

Key function returns key value.

func (MemoryValidationError) Reason added in v1.2.5 

func (e MemoryValidationError) Reason() string

Reason function returns reason value.

type NeedBackToSourceResponse 

type NeedBackToSourceResponse struct {

	// Download back-to-source reason.
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,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) GetReason 

func (x *NeedBackToSourceResponse) GetReason() 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 Network added in v1.2.5 

type Network struct {

	// Return count of tcp connections opened and status is ESTABLISHED.
	TcpConnectionCount uint32 `protobuf:"varint,1,opt,name=tcp_connection_count,json=tcpConnectionCount,proto3" json:"tcp_connection_count,omitempty"`
	// Return count of upload tcp connections opened and status is ESTABLISHED.
	UploadTcpConnectionCount uint32 `` /* 138-byte string literal not displayed */
	// Security domain for network.
	SecurityDomain string `protobuf:"bytes,3,opt,name=security_domain,json=securityDomain,proto3" json:"security_domain,omitempty"`
	// Location path(area|country|province|city|...).
	Location string `protobuf:"bytes,4,opt,name=location,proto3" json:"location,omitempty"`
	// IDC where the peer host is located
	Idc string `protobuf:"bytes,5,opt,name=idc,proto3" json:"idc,omitempty"`
	// contains filtered or unexported fields
}

Network Stat.

func (*Network) Descriptor deprecated added in v1.2.5 

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

Deprecated: Use Network.ProtoReflect.Descriptor instead.

func (*Network) GetIdc added in v1.2.5 

func (x *Network) GetIdc() string

func (*Network) GetLocation added in v1.2.5 

func (x *Network) GetLocation() string

func (*Network) GetSecurityDomain added in v1.2.5 

func (x *Network) GetSecurityDomain() string

func (*Network) GetTcpConnectionCount added in v1.2.5 

func (x *Network) GetTcpConnectionCount() uint32

func (*Network) GetUploadTcpConnectionCount added in v1.2.5 

func (x *Network) GetUploadTcpConnectionCount() uint32

func (*Network) ProtoMessage added in v1.2.5 

func (*Network) ProtoMessage()

func (*Network) ProtoReflect added in v1.2.5 

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

func (*Network) Reset added in v1.2.5 

func (x *Network) Reset()

func (*Network) String added in v1.2.5 

func (x *Network) String() string

func (*Network) Validate added in v1.2.5 

func (m *Network) Validate() error

Validate checks the field values on Network 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 (*Network) ValidateAll added in v1.2.5 

func (m *Network) ValidateAll() error

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

type NetworkMultiError added in v1.2.5 

type NetworkMultiError []error

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

func (NetworkMultiError) AllErrors added in v1.2.5 

func (m NetworkMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NetworkMultiError) Error added in v1.2.5 

func (m NetworkMultiError) Error() string

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

type NetworkValidationError added in v1.2.5 

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

NetworkValidationError is the validation error returned by Network.Validate if the designated constraints aren't met.

func (NetworkValidationError) Cause added in v1.2.5 

func (e NetworkValidationError) Cause() error

Cause function returns cause value.

func (NetworkValidationError) Error added in v1.2.5 

func (e NetworkValidationError) Error() string

Error satisfies the builtin error interface

func (NetworkValidationError) ErrorName added in v1.2.5 

func (e NetworkValidationError) ErrorName() string

ErrorName returns error name.

func (NetworkValidationError) Field added in v1.2.5 

func (e NetworkValidationError) Field() string

Field function returns field value.

func (NetworkValidationError) Key added in v1.2.5 

func (e NetworkValidationError) Key() bool

Key function returns key value.

func (NetworkValidationError) Reason added in v1.2.5 

func (e NetworkValidationError) Reason() string

Reason function returns reason value.

type NormalTaskResponse 

type NormalTaskResponse struct {

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

NormalTaskResponse represents normal task response of AnnouncePeerResponse.

func (*NormalTaskResponse) Descriptor deprecated 

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

Deprecated: Use NormalTaskResponse.ProtoReflect.Descriptor instead.

func (*NormalTaskResponse) GetCandidateParents 

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

func (*NormalTaskResponse) GetConcurrentPieceCount added in v1.5.4 

func (x *NormalTaskResponse) GetConcurrentPieceCount() int32

func (*NormalTaskResponse) ProtoMessage 

func (*NormalTaskResponse) ProtoMessage()

func (*NormalTaskResponse) ProtoReflect 

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

func (*NormalTaskResponse) Reset 

func (x *NormalTaskResponse) Reset()

func (*NormalTaskResponse) String 

func (x *NormalTaskResponse) String() string

func (*NormalTaskResponse) Validate 

func (m *NormalTaskResponse) Validate() error

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

func (*NormalTaskResponse) ValidateAll 

func (m *NormalTaskResponse) ValidateAll() error

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

type NormalTaskResponseMultiError 

type NormalTaskResponseMultiError []error

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

func (NormalTaskResponseMultiError) AllErrors 

func (m NormalTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NormalTaskResponseMultiError) Error 

func (m NormalTaskResponseMultiError) Error() string

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

type NormalTaskResponseValidationError 

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

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

func (NormalTaskResponseValidationError) Cause 

func (e NormalTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (NormalTaskResponseValidationError) Error 

func (e NormalTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (NormalTaskResponseValidationError) ErrorName 

func (e NormalTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (NormalTaskResponseValidationError) Field 

func (e NormalTaskResponseValidationError) Field() string

Field function returns field value.

func (NormalTaskResponseValidationError) Key 

func (e NormalTaskResponseValidationError) Key() bool

Key function returns key value.

func (NormalTaskResponseValidationError) Reason 

func (e NormalTaskResponseValidationError) Reason() string

Reason function returns reason value.

type Probe added in v1.4.8 

type Probe struct {

	// Host metadata.
	Host *v2.Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// RTT is the round-trip time sent via this pinger.
	Rtt *durationpb.Duration `protobuf:"bytes,2,opt,name=rtt,proto3" json:"rtt,omitempty"`
	// Task update time.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

Probe information.

func (*Probe) Descriptor deprecated added in v1.4.8 

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

Deprecated: Use Probe.ProtoReflect.Descriptor instead.

func (*Probe) GetHost added in v1.4.8 

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

func (*Probe) GetRtt added in v1.4.8 

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

func (*Probe) GetUpdatedAt added in v1.4.8 

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

func (*Probe) ProtoMessage added in v1.4.8 

func (*Probe) ProtoMessage()

func (*Probe) ProtoReflect added in v1.4.8 

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

func (*Probe) Reset added in v1.4.8 

func (x *Probe) Reset()

func (*Probe) String added in v1.4.8 

func (x *Probe) String() string

func (*Probe) Validate added in v1.4.8 

func (m *Probe) Validate() error

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

func (*Probe) ValidateAll added in v1.4.8 

func (m *Probe) ValidateAll() error

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

type ProbeMultiError added in v1.4.8 

type ProbeMultiError []error

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

func (ProbeMultiError) AllErrors added in v1.4.8 

func (m ProbeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ProbeMultiError) Error added in v1.4.8 

func (m ProbeMultiError) Error() string

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

type ProbeValidationError added in v1.4.8 

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

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

func (ProbeValidationError) Cause added in v1.4.8 

func (e ProbeValidationError) Cause() error

Cause function returns cause value.

func (ProbeValidationError) Error added in v1.4.8 

func (e ProbeValidationError) Error() string

Error satisfies the builtin error interface

func (ProbeValidationError) ErrorName added in v1.4.8 

func (e ProbeValidationError) ErrorName() string

ErrorName returns error name.

func (ProbeValidationError) Field added in v1.4.8 

func (e ProbeValidationError) Field() string

Field function returns field value.

func (ProbeValidationError) Key added in v1.4.8 

func (e ProbeValidationError) Key() bool

Key function returns key value.

func (ProbeValidationError) Reason added in v1.4.8 

func (e ProbeValidationError) Reason() string

Reason function returns reason value.

type ProbesOfHost added in v1.4.8 

type ProbesOfHost struct {

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

ProbesOfHost represents probes information of the host.

func (*ProbesOfHost) Descriptor deprecated added in v1.4.8 

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

Deprecated: Use ProbesOfHost.ProtoReflect.Descriptor instead.

func (*ProbesOfHost) GetHost added in v1.4.8 

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

func (*ProbesOfHost) GetProbes added in v1.4.8 

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

func (*ProbesOfHost) ProtoMessage added in v1.4.8 

func (*ProbesOfHost) ProtoMessage()

func (*ProbesOfHost) ProtoReflect added in v1.4.8 

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

func (*ProbesOfHost) Reset added in v1.4.8 

func (x *ProbesOfHost) Reset()

func (*ProbesOfHost) String added in v1.4.8 

func (x *ProbesOfHost) String() string

func (*ProbesOfHost) Validate added in v1.4.8 

func (m *ProbesOfHost) Validate() error

Validate checks the field values on ProbesOfHost 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 (*ProbesOfHost) ValidateAll added in v1.4.8 

func (m *ProbesOfHost) ValidateAll() error

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

type ProbesOfHostMultiError added in v1.4.8 

type ProbesOfHostMultiError []error

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

func (ProbesOfHostMultiError) AllErrors added in v1.4.8 

func (m ProbesOfHostMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ProbesOfHostMultiError) Error added in v1.4.8 

func (m ProbesOfHostMultiError) Error() string

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

type ProbesOfHostValidationError added in v1.4.8 

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

ProbesOfHostValidationError is the validation error returned by ProbesOfHost.Validate if the designated constraints aren't met.

func (ProbesOfHostValidationError) Cause added in v1.4.8 

func (e ProbesOfHostValidationError) Cause() error

Cause function returns cause value.

func (ProbesOfHostValidationError) Error added in v1.4.8 

func (e ProbesOfHostValidationError) Error() string

Error satisfies the builtin error interface

func (ProbesOfHostValidationError) ErrorName added in v1.4.8 

func (e ProbesOfHostValidationError) ErrorName() string

ErrorName returns error name.

func (ProbesOfHostValidationError) Field added in v1.4.8 

func (e ProbesOfHostValidationError) Field() string

Field function returns field value.

func (ProbesOfHostValidationError) Key added in v1.4.8 

func (e ProbesOfHostValidationError) Key() bool

Key function returns key value.

func (ProbesOfHostValidationError) Reason added in v1.4.8 

func (e ProbesOfHostValidationError) Reason() string

Reason function returns reason value.

type RegisterPeerRequest added in v1.4.1 

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 added in v1.4.1 

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

Deprecated: Use RegisterPeerRequest.ProtoReflect.Descriptor instead.

func (*RegisterPeerRequest) GetDownload added in v1.5.0 

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

func (*RegisterPeerRequest) ProtoMessage added in v1.4.1 

func (*RegisterPeerRequest) ProtoMessage()

func (*RegisterPeerRequest) ProtoReflect added in v1.4.1 

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

func (*RegisterPeerRequest) Reset added in v1.4.1 

func (x *RegisterPeerRequest) Reset()

func (*RegisterPeerRequest) String added in v1.4.1 

func (x *RegisterPeerRequest) String() string

func (*RegisterPeerRequest) Validate added in v1.4.1 

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 added in v1.4.1 

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 added in v1.4.1 

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 added in v1.4.1 

func (m RegisterPeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RegisterPeerRequestMultiError) Error added in v1.4.1 

func (m RegisterPeerRequestMultiError) Error() string

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

type RegisterPeerRequestValidationError added in v1.4.1 

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 added in v1.4.1 

func (e RegisterPeerRequestValidationError) Cause() error

Cause function returns cause value.

func (RegisterPeerRequestValidationError) Error added in v1.4.1 

func (e RegisterPeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (RegisterPeerRequestValidationError) ErrorName added in v1.4.1 

func (e RegisterPeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (RegisterPeerRequestValidationError) Field added in v1.4.1 

func (e RegisterPeerRequestValidationError) Field() string

Field function returns field value.

func (RegisterPeerRequestValidationError) Key added in v1.4.1 

func (e RegisterPeerRequestValidationError) Key() bool

Key function returns key value.

func (RegisterPeerRequestValidationError) Reason added in v1.4.1 

func (e RegisterPeerRequestValidationError) Reason() string

Reason function returns reason value.

type SchedulerClient 

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

SchedulerClient is the client API for Scheduler service.

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

func NewSchedulerClient 

func NewSchedulerClient(cc grpc.ClientConnInterface) SchedulerClient

type SchedulerServer 

type SchedulerServer interface {
	// AnnouncePeer announces peer to scheduler.
	AnnouncePeer(Scheduler_AnnouncePeerServer) error
	// Checks information of peer.
	StatPeer(context.Context, *StatPeerRequest) (*v2.Peer, error)
	// LeavePeer releases peer in scheduler.
	LeavePeer(context.Context, *LeavePeerRequest) (*emptypb.Empty, error)
	// TODO exchange peer api definition.
	// ExchangePeer exchanges peer information.
	ExchangePeer(context.Context, *ExchangePeerRequest) (*ExchangePeerResponse, error)
	// Checks information of task.
	StatTask(context.Context, *StatTaskRequest) (*v2.Task, error)
	// AnnounceHost announces host to scheduler.
	AnnounceHost(context.Context, *AnnounceHostRequest) (*emptypb.Empty, error)
	// LeaveHost releases host in scheduler.
	LeaveHost(context.Context, *LeaveHostRequest) (*emptypb.Empty, error)
	// SyncProbes sync probes of the host.
	SyncProbes(Scheduler_SyncProbesServer) error
	// SyncNetworkTopology sync network topology of the hosts.
	SyncNetworkTopology(Scheduler_SyncNetworkTopologyServer) 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_SyncNetworkTopologyClient added in v1.4.8 

type Scheduler_SyncNetworkTopologyClient interface {
	Send(*SyncNetworkTopologyRequest) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type Scheduler_SyncNetworkTopologyServer added in v1.4.8 

type Scheduler_SyncNetworkTopologyServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*SyncNetworkTopologyRequest, error)
	grpc.ServerStream
}

type Scheduler_SyncProbesClient added in v1.4.8 

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

type Scheduler_SyncProbesServer added in v1.4.8 

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

type SmallTaskResponse 

type SmallTaskResponse struct {

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

SmallTaskResponse represents small task response of AnnouncePeerResponse.

func (*SmallTaskResponse) Descriptor deprecated 

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

Deprecated: Use SmallTaskResponse.ProtoReflect.Descriptor instead.

func (*SmallTaskResponse) GetPiece 

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

func (*SmallTaskResponse) ProtoMessage 

func (*SmallTaskResponse) ProtoMessage()

func (*SmallTaskResponse) ProtoReflect 

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

func (*SmallTaskResponse) Reset 

func (x *SmallTaskResponse) Reset()

func (*SmallTaskResponse) String 

func (x *SmallTaskResponse) String() string

func (*SmallTaskResponse) Validate 

func (m *SmallTaskResponse) Validate() error

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

func (*SmallTaskResponse) ValidateAll 

func (m *SmallTaskResponse) ValidateAll() error

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

type SmallTaskResponseMultiError 

type SmallTaskResponseMultiError []error

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

func (SmallTaskResponseMultiError) AllErrors 

func (m SmallTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SmallTaskResponseMultiError) Error 

func (m SmallTaskResponseMultiError) Error() string

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

type SmallTaskResponseValidationError 

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

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

func (SmallTaskResponseValidationError) Cause 

func (e SmallTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (SmallTaskResponseValidationError) Error 

func (e SmallTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (SmallTaskResponseValidationError) ErrorName 

func (e SmallTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (SmallTaskResponseValidationError) Field 

func (e SmallTaskResponseValidationError) Field() string

Field function returns field value.

func (SmallTaskResponseValidationError) Key 

func (e SmallTaskResponseValidationError) Key() bool

Key function returns key value.

func (SmallTaskResponseValidationError) Reason 

func (e SmallTaskResponseValidationError) Reason() string

Reason function returns reason value.

type StatPeerRequest 

type StatPeerRequest struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Peer id.
	PeerId string `protobuf:"bytes,2,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) GetPeerId 

func (x *StatPeerRequest) GetPeerId() string

func (*StatPeerRequest) GetTaskId added in v1.1.6 

func (x *StatPeerRequest) GetTaskId() string

func (*StatPeerRequest) ProtoMessage 

func (*StatPeerRequest) ProtoMessage()

func (*StatPeerRequest) ProtoReflect 

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

func (*StatPeerRequest) Reset 

func (x *StatPeerRequest) Reset()

func (*StatPeerRequest) String 

func (x *StatPeerRequest) String() string

func (*StatPeerRequest) Validate 

func (m *StatPeerRequest) Validate() error

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

func (*StatPeerRequest) ValidateAll 

func (m *StatPeerRequest) ValidateAll() error

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

type StatPeerRequestMultiError 

type StatPeerRequestMultiError []error

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

func (StatPeerRequestMultiError) AllErrors 

func (m StatPeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatPeerRequestMultiError) Error 

func (m StatPeerRequestMultiError) Error() string

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

type StatPeerRequestValidationError 

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

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

func (StatPeerRequestValidationError) Cause 

func (e StatPeerRequestValidationError) Cause() error

Cause function returns cause value.

func (StatPeerRequestValidationError) Error 

func (e StatPeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatPeerRequestValidationError) ErrorName 

func (e StatPeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatPeerRequestValidationError) Field 

func (e StatPeerRequestValidationError) Field() string

Field function returns field value.

func (StatPeerRequestValidationError) Key 

func (e StatPeerRequestValidationError) Key() bool

Key function returns key value.

func (StatPeerRequestValidationError) Reason 

func (e StatPeerRequestValidationError) Reason() string

Reason function returns reason value.

type StatTaskRequest 

type StatTaskRequest struct {

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

StatTaskRequest represents request of StatTask.

func (*StatTaskRequest) Descriptor deprecated 

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

Deprecated: Use StatTaskRequest.ProtoReflect.Descriptor instead.

func (*StatTaskRequest) GetId added in v1.2.2 

func (x *StatTaskRequest) GetId() string

func (*StatTaskRequest) ProtoMessage 

func (*StatTaskRequest) ProtoMessage()

func (*StatTaskRequest) ProtoReflect 

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

func (*StatTaskRequest) Reset 

func (x *StatTaskRequest) Reset()

func (*StatTaskRequest) String 

func (x *StatTaskRequest) String() string

func (*StatTaskRequest) Validate 

func (m *StatTaskRequest) Validate() error

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

func (*StatTaskRequest) ValidateAll 

func (m *StatTaskRequest) ValidateAll() error

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

type StatTaskRequestMultiError 

type StatTaskRequestMultiError []error

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

func (StatTaskRequestMultiError) AllErrors 

func (m StatTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatTaskRequestMultiError) Error 

func (m StatTaskRequestMultiError) Error() string

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

type StatTaskRequestValidationError 

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

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

func (StatTaskRequestValidationError) Cause 

func (e StatTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (StatTaskRequestValidationError) Error 

func (e StatTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatTaskRequestValidationError) ErrorName 

func (e StatTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatTaskRequestValidationError) Field 

func (e StatTaskRequestValidationError) Field() string

Field function returns field value.

func (StatTaskRequestValidationError) Key 

func (e StatTaskRequestValidationError) Key() bool

Key function returns key value.

func (StatTaskRequestValidationError) Reason 

func (e StatTaskRequestValidationError) Reason() string

Reason function returns reason value.

type SyncNetworkTopologyRequest added in v1.4.8 

type SyncNetworkTopologyRequest struct {

	// Types that are assignable to Request:
	//
	//	*SyncNetworkTopologyRequest_UpdateProbesOfHostsRequest
	//	*SyncNetworkTopologyRequest_DeleteProbesOfHostsRequest
	Request isSyncNetworkTopologyRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

SyncProbesRequest represents request of SyncProbes.

func (*SyncNetworkTopologyRequest) Descriptor deprecated added in v1.4.8 

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

Deprecated: Use SyncNetworkTopologyRequest.ProtoReflect.Descriptor instead.

func (*SyncNetworkTopologyRequest) GetDeleteProbesOfHostsRequest added in v1.4.8 

func (x *SyncNetworkTopologyRequest) GetDeleteProbesOfHostsRequest() *DeleteHostsRequest

func (*SyncNetworkTopologyRequest) GetRequest added in v1.4.8 

func (m *SyncNetworkTopologyRequest) GetRequest() isSyncNetworkTopologyRequest_Request

func (*SyncNetworkTopologyRequest) GetUpdateProbesOfHostsRequest added in v1.4.8 

func (x *SyncNetworkTopologyRequest) GetUpdateProbesOfHostsRequest() *UpdateHostsRequest

func (*SyncNetworkTopologyRequest) ProtoMessage added in v1.4.8 

func (*SyncNetworkTopologyRequest) ProtoMessage()

func (*SyncNetworkTopologyRequest) ProtoReflect added in v1.4.8 

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

func (*SyncNetworkTopologyRequest) Reset added in v1.4.8 

func (x *SyncNetworkTopologyRequest) Reset()

func (*SyncNetworkTopologyRequest) String added in v1.4.8 

func (x *SyncNetworkTopologyRequest) String() string

func (*SyncNetworkTopologyRequest) Validate added in v1.4.8 

func (m *SyncNetworkTopologyRequest) Validate() error

Validate checks the field values on SyncNetworkTopologyRequest 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 (*SyncNetworkTopologyRequest) ValidateAll added in v1.4.8 

func (m *SyncNetworkTopologyRequest) ValidateAll() error

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

type SyncNetworkTopologyRequestMultiError added in v1.4.8 

type SyncNetworkTopologyRequestMultiError []error

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

func (SyncNetworkTopologyRequestMultiError) AllErrors added in v1.4.8 

func (m SyncNetworkTopologyRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncNetworkTopologyRequestMultiError) Error added in v1.4.8 

func (m SyncNetworkTopologyRequestMultiError) Error() string

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

type SyncNetworkTopologyRequestValidationError added in v1.4.8 

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

SyncNetworkTopologyRequestValidationError is the validation error returned by SyncNetworkTopologyRequest.Validate if the designated constraints aren't met.

func (SyncNetworkTopologyRequestValidationError) Cause added in v1.4.8 

func (e SyncNetworkTopologyRequestValidationError) Cause() error

Cause function returns cause value.

func (SyncNetworkTopologyRequestValidationError) Error added in v1.4.8 

func (e SyncNetworkTopologyRequestValidationError) Error() string

Error satisfies the builtin error interface

func (SyncNetworkTopologyRequestValidationError) ErrorName added in v1.4.8 

func (e SyncNetworkTopologyRequestValidationError) ErrorName() string

ErrorName returns error name.

func (SyncNetworkTopologyRequestValidationError) Field added in v1.4.8 

func (e SyncNetworkTopologyRequestValidationError) Field() string

Field function returns field value.

func (SyncNetworkTopologyRequestValidationError) Key added in v1.4.8 

func (e SyncNetworkTopologyRequestValidationError) Key() bool

Key function returns key value.

func (SyncNetworkTopologyRequestValidationError) Reason added in v1.4.8 

func (e SyncNetworkTopologyRequestValidationError) Reason() string

Reason function returns reason value.

type SyncNetworkTopologyRequest_DeleteProbesOfHostsRequest added in v1.4.8 

type SyncNetworkTopologyRequest_DeleteProbesOfHostsRequest struct {
	DeleteProbesOfHostsRequest *DeleteHostsRequest `protobuf:"bytes,2,opt,name=delete_probes_of_hosts_request,json=deleteProbesOfHostsRequest,proto3,oneof"`
}

type SyncNetworkTopologyRequest_UpdateProbesOfHostsRequest added in v1.4.8 

type SyncNetworkTopologyRequest_UpdateProbesOfHostsRequest struct {
	UpdateProbesOfHostsRequest *UpdateHostsRequest `protobuf:"bytes,1,opt,name=update_probes_of_hosts_request,json=updateProbesOfHostsRequest,proto3,oneof"`
}

type SyncProbesRequest added in v1.4.8 

type SyncProbesRequest struct {

	// Probes information of the host.
	ProbesOfHost *ProbesOfHost `protobuf:"bytes,1,opt,name=probes_of_host,json=probesOfHost,proto3" json:"probes_of_host,omitempty"`
	// contains filtered or unexported fields
}

SyncProbesRequest represents request of SyncProbes.

func (*SyncProbesRequest) Descriptor deprecated added in v1.4.8 

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

Deprecated: Use SyncProbesRequest.ProtoReflect.Descriptor instead.

func (*SyncProbesRequest) GetProbesOfHost added in v1.4.8 

func (x *SyncProbesRequest) GetProbesOfHost() *ProbesOfHost

func (*SyncProbesRequest) ProtoMessage added in v1.4.8 

func (*SyncProbesRequest) ProtoMessage()

func (*SyncProbesRequest) ProtoReflect added in v1.4.8 

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

func (*SyncProbesRequest) Reset added in v1.4.8 

func (x *SyncProbesRequest) Reset()

func (*SyncProbesRequest) String added in v1.4.8 

func (x *SyncProbesRequest) String() string

func (*SyncProbesRequest) Validate added in v1.4.8 

func (m *SyncProbesRequest) Validate() error

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

func (*SyncProbesRequest) ValidateAll added in v1.4.8 

func (m *SyncProbesRequest) ValidateAll() error

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

type SyncProbesRequestMultiError added in v1.4.8 

type SyncProbesRequestMultiError []error

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

func (SyncProbesRequestMultiError) AllErrors added in v1.4.8 

func (m SyncProbesRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncProbesRequestMultiError) Error added in v1.4.8 

func (m SyncProbesRequestMultiError) Error() string

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

type SyncProbesRequestValidationError added in v1.4.8 

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

SyncProbesRequestValidationError is the validation error returned by SyncProbesRequest.Validate if the designated constraints aren't met.

func (SyncProbesRequestValidationError) Cause added in v1.4.8 

func (e SyncProbesRequestValidationError) Cause() error

Cause function returns cause value.

func (SyncProbesRequestValidationError) Error added in v1.4.8 

func (e SyncProbesRequestValidationError) Error() string

Error satisfies the builtin error interface

func (SyncProbesRequestValidationError) ErrorName added in v1.4.8 

func (e SyncProbesRequestValidationError) ErrorName() string

ErrorName returns error name.

func (SyncProbesRequestValidationError) Field added in v1.4.8 

func (e SyncProbesRequestValidationError) Field() string

Field function returns field value.

func (SyncProbesRequestValidationError) Key added in v1.4.8 

func (e SyncProbesRequestValidationError) Key() bool

Key function returns key value.

func (SyncProbesRequestValidationError) Reason added in v1.4.8 

func (e SyncProbesRequestValidationError) Reason() string

Reason function returns reason value.

type SyncProbesResponse added in v1.4.8 

type SyncProbesResponse struct {

	// Hosts needs to be probed.
	Hosts []*v2.Host `protobuf:"bytes,1,rep,name=hosts,proto3" json:"hosts,omitempty"`
	// Probe interval.
	ProbeInterval *durationpb.Duration `protobuf:"bytes,2,opt,name=probe_interval,json=probeInterval,proto3" json:"probe_interval,omitempty"`
	// contains filtered or unexported fields
}

SyncProbesResponse represents response of SyncProbes.

func (*SyncProbesResponse) Descriptor deprecated added in v1.4.8 

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

Deprecated: Use SyncProbesResponse.ProtoReflect.Descriptor instead.

func (*SyncProbesResponse) GetHosts added in v1.4.8 

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

func (*SyncProbesResponse) GetProbeInterval added in v1.4.8 

func (x *SyncProbesResponse) GetProbeInterval() *durationpb.Duration

func (*SyncProbesResponse) ProtoMessage added in v1.4.8 

func (*SyncProbesResponse) ProtoMessage()

func (*SyncProbesResponse) ProtoReflect added in v1.4.8 

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

func (*SyncProbesResponse) Reset added in v1.4.8 

func (x *SyncProbesResponse) Reset()

func (*SyncProbesResponse) String added in v1.4.8 

func (x *SyncProbesResponse) String() string

func (*SyncProbesResponse) Validate added in v1.4.8 

func (m *SyncProbesResponse) Validate() error

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

func (*SyncProbesResponse) ValidateAll added in v1.4.8 

func (m *SyncProbesResponse) ValidateAll() error

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

type SyncProbesResponseMultiError added in v1.4.8 

type SyncProbesResponseMultiError []error

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

func (SyncProbesResponseMultiError) AllErrors added in v1.4.8 

func (m SyncProbesResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncProbesResponseMultiError) Error added in v1.4.8 

func (m SyncProbesResponseMultiError) Error() string

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

type SyncProbesResponseValidationError added in v1.4.8 

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

SyncProbesResponseValidationError is the validation error returned by SyncProbesResponse.Validate if the designated constraints aren't met.

func (SyncProbesResponseValidationError) Cause added in v1.4.8 

func (e SyncProbesResponseValidationError) Cause() error

Cause function returns cause value.

func (SyncProbesResponseValidationError) Error added in v1.4.8 

func (e SyncProbesResponseValidationError) Error() string

Error satisfies the builtin error interface

func (SyncProbesResponseValidationError) ErrorName added in v1.4.8 

func (e SyncProbesResponseValidationError) ErrorName() string

ErrorName returns error name.

func (SyncProbesResponseValidationError) Field added in v1.4.8 

func (e SyncProbesResponseValidationError) Field() string

Field function returns field value.

func (SyncProbesResponseValidationError) Key added in v1.4.8 

func (e SyncProbesResponseValidationError) Key() bool

Key function returns key value.

func (SyncProbesResponseValidationError) Reason added in v1.4.8 

func (e SyncProbesResponseValidationError) Reason() string

Reason function returns reason value.

type TinyTaskResponse 

type TinyTaskResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

TinyTaskResponse represents tiny task response of AnnouncePeerResponse.

func (*TinyTaskResponse) Descriptor deprecated 

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

Deprecated: Use TinyTaskResponse.ProtoReflect.Descriptor instead.

func (*TinyTaskResponse) GetData 

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

func (*TinyTaskResponse) ProtoMessage 

func (*TinyTaskResponse) ProtoMessage()

func (*TinyTaskResponse) ProtoReflect 

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

func (*TinyTaskResponse) Reset 

func (x *TinyTaskResponse) Reset()

func (*TinyTaskResponse) String 

func (x *TinyTaskResponse) String() string

func (*TinyTaskResponse) Validate 

func (m *TinyTaskResponse) Validate() error

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

func (*TinyTaskResponse) ValidateAll 

func (m *TinyTaskResponse) ValidateAll() error

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

type TinyTaskResponseMultiError 

type TinyTaskResponseMultiError []error

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

func (TinyTaskResponseMultiError) AllErrors 

func (m TinyTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TinyTaskResponseMultiError) Error 

func (m TinyTaskResponseMultiError) Error() string

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

type TinyTaskResponseValidationError 

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

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

func (TinyTaskResponseValidationError) Cause 

func (e TinyTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (TinyTaskResponseValidationError) Error 

func (e TinyTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (TinyTaskResponseValidationError) ErrorName 

func (e TinyTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (TinyTaskResponseValidationError) Field 

func (e TinyTaskResponseValidationError) Field() string

Field function returns field value.

func (TinyTaskResponseValidationError) Key 

func (e TinyTaskResponseValidationError) Key() bool

Key function returns key value.

func (TinyTaskResponseValidationError) Reason 

func (e TinyTaskResponseValidationError) Reason() string

Reason function returns reason value.

type UnimplementedSchedulerServer 

type UnimplementedSchedulerServer struct {
}

UnimplementedSchedulerServer should be embedded to have forward compatible implementations.

func (UnimplementedSchedulerServer) AnnounceHost added in v1.2.5 

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

func (UnimplementedSchedulerServer) AnnouncePeer 

func (UnimplementedSchedulerServer) AnnouncePeer(Scheduler_AnnouncePeerServer) error

func (UnimplementedSchedulerServer) ExchangePeer 

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

func (UnimplementedSchedulerServer) LeaveHost added in v1.2.2 

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

func (UnimplementedSchedulerServer) LeavePeer 

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

func (UnimplementedSchedulerServer) StatPeer 

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

func (UnimplementedSchedulerServer) StatTask 

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

func (UnimplementedSchedulerServer) SyncNetworkTopology added in v1.4.8 

func (UnimplementedSchedulerServer) SyncNetworkTopology(Scheduler_SyncNetworkTopologyServer) error

func (UnimplementedSchedulerServer) SyncProbes added in v1.4.8 

func (UnimplementedSchedulerServer) SyncProbes(Scheduler_SyncProbesServer) error

type UnsafeSchedulerServer added in v1.4.1 

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 UpdateHostsRequest added in v1.4.8 

type UpdateHostsRequest struct {

	// Hosts needs to be updated.
	ProbesOfHosts []*ProbesOfHost `protobuf:"bytes,1,rep,name=probes_of_hosts,json=probesOfHosts,proto3" json:"probes_of_hosts,omitempty"`
	// contains filtered or unexported fields
}

UpdateHostsRequest represents update hosts request of SyncNetworkTopologyRequest.

func (*UpdateHostsRequest) Descriptor deprecated added in v1.4.8 

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

Deprecated: Use UpdateHostsRequest.ProtoReflect.Descriptor instead.

func (*UpdateHostsRequest) GetProbesOfHosts added in v1.4.8 

func (x *UpdateHostsRequest) GetProbesOfHosts() []*ProbesOfHost

func (*UpdateHostsRequest) ProtoMessage added in v1.4.8 

func (*UpdateHostsRequest) ProtoMessage()

func (*UpdateHostsRequest) ProtoReflect added in v1.4.8 

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

func (*UpdateHostsRequest) Reset added in v1.4.8 

func (x *UpdateHostsRequest) Reset()

func (*UpdateHostsRequest) String added in v1.4.8 

func (x *UpdateHostsRequest) String() string

func (*UpdateHostsRequest) Validate added in v1.4.8 

func (m *UpdateHostsRequest) Validate() error

Validate checks the field values on UpdateHostsRequest 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 (*UpdateHostsRequest) ValidateAll added in v1.4.8 

func (m *UpdateHostsRequest) ValidateAll() error

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

type UpdateHostsRequestMultiError added in v1.4.8 

type UpdateHostsRequestMultiError []error

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

func (UpdateHostsRequestMultiError) AllErrors added in v1.4.8 

func (m UpdateHostsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UpdateHostsRequestMultiError) Error added in v1.4.8 

func (m UpdateHostsRequestMultiError) Error() string

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

type UpdateHostsRequestValidationError added in v1.4.8 

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

UpdateHostsRequestValidationError is the validation error returned by UpdateHostsRequest.Validate if the designated constraints aren't met.

func (UpdateHostsRequestValidationError) Cause added in v1.4.8 

func (e UpdateHostsRequestValidationError) Cause() error

Cause function returns cause value.

func (UpdateHostsRequestValidationError) Error added in v1.4.8 

func (e UpdateHostsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (UpdateHostsRequestValidationError) ErrorName added in v1.4.8 

func (e UpdateHostsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (UpdateHostsRequestValidationError) Field added in v1.4.8 

func (e UpdateHostsRequestValidationError) Field() string

Field function returns field value.

func (UpdateHostsRequestValidationError) Key added in v1.4.8 

func (e UpdateHostsRequestValidationError) Key() bool

Key function returns key value.

func (UpdateHostsRequestValidationError) Reason added in v1.4.8 

func (e UpdateHostsRequestValidationError) 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.