v2

package
v1.1.6 Latest Latest
Warning

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

Go to latest
Published: Sep 19, 2022 License: Apache-2.0 Imports: 25 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_pkg_apis_scheduler_v2_scheduler_proto protoreflect.FileDescriptor

Functions

func RegisterSchedulerServer

func RegisterSchedulerServer(s *grpc.Server, srv SchedulerServer)

Types

type AnnouncePeerRequest

type AnnouncePeerRequest struct {

	// Types that are assignable to Request:
	//	*AnnouncePeerRequest_RegisterRequest
	//	*AnnouncePeerRequest_PeerDownloadStartedRequest
	//	*AnnouncePeerRequest_PeerDownloadBackToSourceRequest
	//	*AnnouncePeerRequest_PeerDownloadFinishedRequest
	//	*AnnouncePeerRequest_PieceDownloadFinishedRequest
	//	*AnnouncePeerRequest_PeerDownloadBackToSourceFailed
	//	*AnnouncePeerRequest_PieceDownloadFailed
	//	*AnnouncePeerRequest_PieceInfoSyncFailed
	//	*AnnouncePeerRequest_ScheduleFailed
	Request isAnnouncePeerRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

AnnouncePeerRequest represents request of AnnouncePeer.

func (*AnnouncePeerRequest) Descriptor deprecated

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

Deprecated: Use AnnouncePeerRequest.ProtoReflect.Descriptor instead.

func (*AnnouncePeerRequest) GetPeerDownloadBackToSourceFailed

func (x *AnnouncePeerRequest) GetPeerDownloadBackToSourceFailed() *v21.PeerDownloadBackToSourceFailed

func (*AnnouncePeerRequest) GetPeerDownloadBackToSourceRequest

func (x *AnnouncePeerRequest) GetPeerDownloadBackToSourceRequest() *PeerDownloadBackToSourceRequest

func (*AnnouncePeerRequest) GetPeerDownloadFinishedRequest

func (x *AnnouncePeerRequest) GetPeerDownloadFinishedRequest() *PeerDownloadFinishedRequest

func (*AnnouncePeerRequest) GetPeerDownloadStartedRequest

func (x *AnnouncePeerRequest) GetPeerDownloadStartedRequest() *PeerDownloadStartedRequest

func (*AnnouncePeerRequest) GetPieceDownloadFailed

func (x *AnnouncePeerRequest) GetPieceDownloadFailed() *v21.PieceDownloadFailed

func (*AnnouncePeerRequest) GetPieceDownloadFinishedRequest

func (x *AnnouncePeerRequest) GetPieceDownloadFinishedRequest() *PieceDownloadFinishedRequest

func (*AnnouncePeerRequest) GetPieceInfoSyncFailed

func (x *AnnouncePeerRequest) GetPieceInfoSyncFailed() *v21.PieceInfoSyncFailed

func (*AnnouncePeerRequest) GetRegisterRequest

func (x *AnnouncePeerRequest) GetRegisterRequest() *RegisterRequest

func (*AnnouncePeerRequest) GetRequest

func (m *AnnouncePeerRequest) GetRequest() isAnnouncePeerRequest_Request

func (*AnnouncePeerRequest) GetScheduleFailed

func (x *AnnouncePeerRequest) GetScheduleFailed() *v21.ScheduleFailed

func (*AnnouncePeerRequest) ProtoMessage

func (*AnnouncePeerRequest) ProtoMessage()

func (*AnnouncePeerRequest) ProtoReflect

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

func (*AnnouncePeerRequest) Reset

func (x *AnnouncePeerRequest) Reset()

func (*AnnouncePeerRequest) String

func (x *AnnouncePeerRequest) String() string

func (*AnnouncePeerRequest) Validate

func (m *AnnouncePeerRequest) Validate() error

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

func (*AnnouncePeerRequest) ValidateAll

func (m *AnnouncePeerRequest) ValidateAll() error

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

type AnnouncePeerRequestMultiError

type AnnouncePeerRequestMultiError []error

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

func (AnnouncePeerRequestMultiError) AllErrors

func (m AnnouncePeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnouncePeerRequestMultiError) Error

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

type AnnouncePeerRequestValidationError

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

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

func (AnnouncePeerRequestValidationError) Cause

Cause function returns cause value.

func (AnnouncePeerRequestValidationError) Error

Error satisfies the builtin error interface

func (AnnouncePeerRequestValidationError) ErrorName

ErrorName returns error name.

func (AnnouncePeerRequestValidationError) Field

Field function returns field value.

func (AnnouncePeerRequestValidationError) Key

Key function returns key value.

func (AnnouncePeerRequestValidationError) Reason

Reason function returns reason value.

type AnnouncePeerRequest_PeerDownloadBackToSourceFailed

type AnnouncePeerRequest_PeerDownloadBackToSourceFailed struct {
	PeerDownloadBackToSourceFailed *v21.PeerDownloadBackToSourceFailed `protobuf:"bytes,6,opt,name=peer_download_back_to_source_failed,json=peerDownloadBackToSourceFailed,proto3,oneof"`
}

type AnnouncePeerRequest_PeerDownloadBackToSourceRequest

type AnnouncePeerRequest_PeerDownloadBackToSourceRequest struct {
	PeerDownloadBackToSourceRequest *PeerDownloadBackToSourceRequest `protobuf:"bytes,3,opt,name=peer_download_back_to_source_request,json=peerDownloadBackToSourceRequest,proto3,oneof"`
}

type AnnouncePeerRequest_PeerDownloadFinishedRequest

type AnnouncePeerRequest_PeerDownloadFinishedRequest struct {
	PeerDownloadFinishedRequest *PeerDownloadFinishedRequest `protobuf:"bytes,4,opt,name=peer_download_finished_request,json=peerDownloadFinishedRequest,proto3,oneof"`
}

type AnnouncePeerRequest_PeerDownloadStartedRequest

type AnnouncePeerRequest_PeerDownloadStartedRequest struct {
	PeerDownloadStartedRequest *PeerDownloadStartedRequest `protobuf:"bytes,2,opt,name=peer_download_started_request,json=peerDownloadStartedRequest,proto3,oneof"`
}

type AnnouncePeerRequest_PieceDownloadFailed

type AnnouncePeerRequest_PieceDownloadFailed struct {
	PieceDownloadFailed *v21.PieceDownloadFailed `protobuf:"bytes,7,opt,name=piece_download_failed,json=pieceDownloadFailed,proto3,oneof"`
}

type AnnouncePeerRequest_PieceDownloadFinishedRequest

type AnnouncePeerRequest_PieceDownloadFinishedRequest struct {
	PieceDownloadFinishedRequest *PieceDownloadFinishedRequest `protobuf:"bytes,5,opt,name=piece_download_finished_request,json=pieceDownloadFinishedRequest,proto3,oneof"`
}

type AnnouncePeerRequest_PieceInfoSyncFailed

type AnnouncePeerRequest_PieceInfoSyncFailed struct {
	PieceInfoSyncFailed *v21.PieceInfoSyncFailed `protobuf:"bytes,8,opt,name=piece_info_sync_failed,json=pieceInfoSyncFailed,proto3,oneof"`
}

type AnnouncePeerRequest_RegisterRequest

type AnnouncePeerRequest_RegisterRequest struct {
	RegisterRequest *RegisterRequest `protobuf:"bytes,1,opt,name=register_request,json=registerRequest,proto3,oneof"`
}

type AnnouncePeerRequest_ScheduleFailed

type AnnouncePeerRequest_ScheduleFailed struct {
	ScheduleFailed *v21.ScheduleFailed `protobuf:"bytes,9,opt,name=schedule_failed,json=scheduleFailed,proto3,oneof"`
}

type AnnouncePeerResponse

type AnnouncePeerResponse struct {

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

AnnouncePeerResponse represents response of AnnouncePeer.

func (*AnnouncePeerResponse) Descriptor deprecated

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

Deprecated: Use AnnouncePeerResponse.ProtoReflect.Descriptor instead.

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

func (x *AnnouncePeerResponse) GetScheduleFailed() *v21.ScheduleFailed

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

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

type AnnouncePeerResponseValidationError

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

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

func (AnnouncePeerResponseValidationError) Cause

Cause function returns cause value.

func (AnnouncePeerResponseValidationError) Error

Error satisfies the builtin error interface

func (AnnouncePeerResponseValidationError) ErrorName

ErrorName returns error name.

func (AnnouncePeerResponseValidationError) Field

Field function returns field value.

func (AnnouncePeerResponseValidationError) Key

Key function returns key value.

func (AnnouncePeerResponseValidationError) Reason

Reason function returns reason value.

type AnnouncePeerResponse_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_ScheduleFailed

type AnnouncePeerResponse_ScheduleFailed struct {
	ScheduleFailed *v21.ScheduleFailed `protobuf:"bytes,5,opt,name=scheduleFailed,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 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

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

Cause function returns cause value.

func (ExchangePeerRequestValidationError) Error

Error satisfies the builtin error interface

func (ExchangePeerRequestValidationError) ErrorName

ErrorName returns error name.

func (ExchangePeerRequestValidationError) Field

Field function returns field value.

func (ExchangePeerRequestValidationError) Key

Key function returns key value.

func (ExchangePeerRequestValidationError) Reason

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

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

Cause function returns cause value.

func (ExchangePeerResponseValidationError) Error

Error satisfies the builtin error interface

func (ExchangePeerResponseValidationError) ErrorName

ErrorName returns error name.

func (ExchangePeerResponseValidationError) Field

Field function returns field value.

func (ExchangePeerResponseValidationError) Key

Key function returns key value.

func (ExchangePeerResponseValidationError) Reason

Reason function returns reason value.

type Host

type Host struct {

	// Host id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Host ipv4.
	Ipv4 string `protobuf:"bytes,2,opt,name=ipv4,proto3" json:"ipv4,omitempty"`
	// Host ipv6.
	Ipv6 string `protobuf:"bytes,3,opt,name=ipv6,proto3" json:"ipv6,omitempty"`
	// Peer hostname.
	Hostname string `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,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"`
	// Security domain for network.
	SecurityDomain string `protobuf:"bytes,7,opt,name=security_domain,json=securityDomain,proto3" json:"security_domain,omitempty"`
	// Host location(area, country, province, city, etc.).
	Location []string `protobuf:"bytes,8,rep,name=location,proto3" json:"location,omitempty"`
	// IDC where the peer host is located.
	Idc string `protobuf:"bytes,9,opt,name=idc,proto3" json:"idc,omitempty"`
	// Network topology(switch, router, etc.).
	NetTopology []string `protobuf:"bytes,10,rep,name=net_topology,json=netTopology,proto3" json:"net_topology,omitempty"`
	// contains filtered or unexported fields
}

Host metadata.

func (*Host) Descriptor deprecated

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

Deprecated: Use Host.ProtoReflect.Descriptor instead.

func (*Host) GetDownloadPort

func (x *Host) GetDownloadPort() int32

func (*Host) GetHostname

func (x *Host) GetHostname() string

func (*Host) GetId

func (x *Host) GetId() string

func (*Host) GetIdc

func (x *Host) GetIdc() string

func (*Host) GetIpv4

func (x *Host) GetIpv4() string

func (*Host) GetIpv6

func (x *Host) GetIpv6() string

func (*Host) GetLocation

func (x *Host) GetLocation() []string

func (*Host) GetNetTopology

func (x *Host) GetNetTopology() []string

func (*Host) GetPort

func (x *Host) GetPort() int32

func (*Host) GetSecurityDomain

func (x *Host) GetSecurityDomain() string

func (*Host) ProtoMessage

func (*Host) ProtoMessage()

func (*Host) ProtoReflect

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

func (*Host) Reset

func (x *Host) Reset()

func (*Host) String

func (x *Host) String() string

func (*Host) Validate

func (m *Host) Validate() error

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

func (m *Host) ValidateAll() error

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

type HostMultiError

type HostMultiError []error

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

func (HostMultiError) AllErrors

func (m HostMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (HostMultiError) Error

func (m HostMultiError) Error() string

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

type HostValidationError

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

HostValidationError is the validation error returned by Host.Validate if the designated constraints aren't met.

func (HostValidationError) Cause

func (e HostValidationError) Cause() error

Cause function returns cause value.

func (HostValidationError) Error

func (e HostValidationError) Error() string

Error satisfies the builtin error interface

func (HostValidationError) ErrorName

func (e HostValidationError) ErrorName() string

ErrorName returns error name.

func (HostValidationError) Field

func (e HostValidationError) Field() string

Field function returns field value.

func (HostValidationError) Key

func (e HostValidationError) Key() bool

Key function returns key value.

func (HostValidationError) Reason

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

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

Cause function returns cause value.

func (LeavePeerRequestValidationError) Error

Error satisfies the builtin error interface

func (LeavePeerRequestValidationError) ErrorName

ErrorName returns error name.

func (LeavePeerRequestValidationError) Field

Field function returns field value.

func (LeavePeerRequestValidationError) Key

Key function returns key value.

func (LeavePeerRequestValidationError) Reason

Reason function returns reason value.

type LeaveTaskRequest

type LeaveTaskRequest struct {

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

LeaveTaskRequest represents request of LeaveTask.

func (*LeaveTaskRequest) Descriptor deprecated

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

Deprecated: Use LeaveTaskRequest.ProtoReflect.Descriptor instead.

func (*LeaveTaskRequest) GetTaskId

func (x *LeaveTaskRequest) GetTaskId() string

func (*LeaveTaskRequest) ProtoMessage

func (*LeaveTaskRequest) ProtoMessage()

func (*LeaveTaskRequest) ProtoReflect

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

func (*LeaveTaskRequest) Reset

func (x *LeaveTaskRequest) Reset()

func (*LeaveTaskRequest) String

func (x *LeaveTaskRequest) String() string

func (*LeaveTaskRequest) Validate

func (m *LeaveTaskRequest) Validate() error

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

func (m *LeaveTaskRequest) ValidateAll() error

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

type LeaveTaskRequestMultiError

type LeaveTaskRequestMultiError []error

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

func (LeaveTaskRequestMultiError) AllErrors

func (m LeaveTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LeaveTaskRequestMultiError) Error

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

type LeaveTaskRequestValidationError

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

LeaveTaskRequestValidationError is the validation error returned by LeaveTaskRequest.Validate if the designated constraints aren't met.

func (LeaveTaskRequestValidationError) Cause

Cause function returns cause value.

func (LeaveTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (LeaveTaskRequestValidationError) ErrorName

ErrorName returns error name.

func (LeaveTaskRequestValidationError) Field

Field function returns field value.

func (LeaveTaskRequestValidationError) Key

Key function returns key value.

func (LeaveTaskRequestValidationError) Reason

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

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

type NeedBackToSourceResponseValidationError

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

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

func (NeedBackToSourceResponseValidationError) Cause

Cause function returns cause value.

func (NeedBackToSourceResponseValidationError) Error

Error satisfies the builtin error interface

func (NeedBackToSourceResponseValidationError) ErrorName

ErrorName returns error name.

func (NeedBackToSourceResponseValidationError) Field

Field function returns field value.

func (NeedBackToSourceResponseValidationError) Key

Key function returns key value.

func (NeedBackToSourceResponseValidationError) Reason

Reason function returns reason value.

type NormalTaskResponse

type NormalTaskResponse struct {

	// Candidate parents.
	CandidateParents []*Peer `protobuf:"bytes,1,rep,name=candidate_parents,json=candidateParents,proto3" json:"candidate_parents,omitempty"`
	// Concurrent downloading count from main peer.
	ParallelCount int32 `protobuf:"varint,2,opt,name=parallel_count,json=parallelCount,proto3" json:"parallel_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() []*Peer

func (*NormalTaskResponse) GetParallelCount

func (x *NormalTaskResponse) GetParallelCount() 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

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

type NormalTaskResponseValidationError

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

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

func (NormalTaskResponseValidationError) Cause

Cause function returns cause value.

func (NormalTaskResponseValidationError) Error

Error satisfies the builtin error interface

func (NormalTaskResponseValidationError) ErrorName

ErrorName returns error name.

func (NormalTaskResponseValidationError) Field

Field function returns field value.

func (NormalTaskResponseValidationError) Key

Key function returns key value.

func (NormalTaskResponseValidationError) Reason

Reason function returns reason value.

type Peer

type Peer struct {

	// Peer id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Pieces of peer.
	Pieces []*v2.Piece `protobuf:"bytes,2,rep,name=pieces,proto3" json:"pieces,omitempty"`
	// Task info.
	Task *Task `protobuf:"bytes,3,opt,name=task,proto3" json:"task,omitempty"`
	// Host info.
	Host *Host `protobuf:"bytes,4,opt,name=host,proto3" json:"host,omitempty"`
	// Peer state.
	State string `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	// Peer create time.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Peer update time.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

Peer metadata.

func (*Peer) Descriptor deprecated

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

Deprecated: Use Peer.ProtoReflect.Descriptor instead.

func (*Peer) GetCreatedAt

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

func (*Peer) GetHost

func (x *Peer) GetHost() *Host

func (*Peer) GetId

func (x *Peer) GetId() string

func (*Peer) GetPieces

func (x *Peer) GetPieces() []*v2.Piece

func (*Peer) GetState

func (x *Peer) GetState() string

func (*Peer) GetTask

func (x *Peer) GetTask() *Task

func (*Peer) GetUpdatedAt

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

func (*Peer) ProtoMessage

func (*Peer) ProtoMessage()

func (*Peer) ProtoReflect

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

func (*Peer) Reset

func (x *Peer) Reset()

func (*Peer) String

func (x *Peer) String() string

func (*Peer) Validate

func (m *Peer) Validate() error

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

func (m *Peer) ValidateAll() error

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

type PeerDownloadBackToSourceRequest

type PeerDownloadBackToSourceRequest struct {

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

PeerDownloadBackToSourceRequest represents peer download back-to-source request of AnnouncePeerRequest.

func (*PeerDownloadBackToSourceRequest) Descriptor deprecated

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

Deprecated: Use PeerDownloadBackToSourceRequest.ProtoReflect.Descriptor instead.

func (*PeerDownloadBackToSourceRequest) GetReason

func (x *PeerDownloadBackToSourceRequest) GetReason() string

func (*PeerDownloadBackToSourceRequest) ProtoMessage

func (*PeerDownloadBackToSourceRequest) ProtoMessage()

func (*PeerDownloadBackToSourceRequest) ProtoReflect

func (*PeerDownloadBackToSourceRequest) Reset

func (*PeerDownloadBackToSourceRequest) String

func (*PeerDownloadBackToSourceRequest) Validate

func (m *PeerDownloadBackToSourceRequest) Validate() error

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

func (m *PeerDownloadBackToSourceRequest) ValidateAll() error

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

type PeerDownloadBackToSourceRequestMultiError

type PeerDownloadBackToSourceRequestMultiError []error

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

func (PeerDownloadBackToSourceRequestMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (PeerDownloadBackToSourceRequestMultiError) Error

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

type PeerDownloadBackToSourceRequestValidationError

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

PeerDownloadBackToSourceRequestValidationError is the validation error returned by PeerDownloadBackToSourceRequest.Validate if the designated constraints aren't met.

func (PeerDownloadBackToSourceRequestValidationError) Cause

Cause function returns cause value.

func (PeerDownloadBackToSourceRequestValidationError) Error

Error satisfies the builtin error interface

func (PeerDownloadBackToSourceRequestValidationError) ErrorName

ErrorName returns error name.

func (PeerDownloadBackToSourceRequestValidationError) Field

Field function returns field value.

func (PeerDownloadBackToSourceRequestValidationError) Key

Key function returns key value.

func (PeerDownloadBackToSourceRequestValidationError) Reason

Reason function returns reason value.

type PeerDownloadFinishedRequest

type PeerDownloadFinishedRequest struct {

	// Total content length.
	ContentLength int64 `protobuf:"varint,1,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// Total traffic of p2p network.
	Traffic uint64 `protobuf:"varint,2,opt,name=traffic,proto3" json:"traffic,omitempty"`
	// contains filtered or unexported fields
}

PeerDownloadFinishedRequest represents peer download finished request of AnnouncePeerRequest.

func (*PeerDownloadFinishedRequest) Descriptor deprecated

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

Deprecated: Use PeerDownloadFinishedRequest.ProtoReflect.Descriptor instead.

func (*PeerDownloadFinishedRequest) GetContentLength

func (x *PeerDownloadFinishedRequest) GetContentLength() int64

func (*PeerDownloadFinishedRequest) GetTraffic

func (x *PeerDownloadFinishedRequest) GetTraffic() uint64

func (*PeerDownloadFinishedRequest) ProtoMessage

func (*PeerDownloadFinishedRequest) ProtoMessage()

func (*PeerDownloadFinishedRequest) ProtoReflect

func (*PeerDownloadFinishedRequest) Reset

func (x *PeerDownloadFinishedRequest) Reset()

func (*PeerDownloadFinishedRequest) String

func (x *PeerDownloadFinishedRequest) String() string

func (*PeerDownloadFinishedRequest) Validate

func (m *PeerDownloadFinishedRequest) Validate() error

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

func (m *PeerDownloadFinishedRequest) ValidateAll() error

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

type PeerDownloadFinishedRequestMultiError

type PeerDownloadFinishedRequestMultiError []error

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

func (PeerDownloadFinishedRequestMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (PeerDownloadFinishedRequestMultiError) Error

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

type PeerDownloadFinishedRequestValidationError

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

PeerDownloadFinishedRequestValidationError is the validation error returned by PeerDownloadFinishedRequest.Validate if the designated constraints aren't met.

func (PeerDownloadFinishedRequestValidationError) Cause

Cause function returns cause value.

func (PeerDownloadFinishedRequestValidationError) Error

Error satisfies the builtin error interface

func (PeerDownloadFinishedRequestValidationError) ErrorName

ErrorName returns error name.

func (PeerDownloadFinishedRequestValidationError) Field

Field function returns field value.

func (PeerDownloadFinishedRequestValidationError) Key

Key function returns key value.

func (PeerDownloadFinishedRequestValidationError) Reason

Reason function returns reason value.

type PeerDownloadStartedRequest

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

TaskDownloadStartedRequest represents peer download started request of AnnouncePeerRequest.

func (*PeerDownloadStartedRequest) Descriptor deprecated

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

Deprecated: Use PeerDownloadStartedRequest.ProtoReflect.Descriptor instead.

func (*PeerDownloadStartedRequest) ProtoMessage

func (*PeerDownloadStartedRequest) ProtoMessage()

func (*PeerDownloadStartedRequest) ProtoReflect

func (*PeerDownloadStartedRequest) Reset

func (x *PeerDownloadStartedRequest) Reset()

func (*PeerDownloadStartedRequest) String

func (x *PeerDownloadStartedRequest) String() string

func (*PeerDownloadStartedRequest) Validate

func (m *PeerDownloadStartedRequest) Validate() error

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

func (m *PeerDownloadStartedRequest) ValidateAll() error

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

type PeerDownloadStartedRequestMultiError

type PeerDownloadStartedRequestMultiError []error

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

func (PeerDownloadStartedRequestMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (PeerDownloadStartedRequestMultiError) Error

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

type PeerDownloadStartedRequestValidationError

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

PeerDownloadStartedRequestValidationError is the validation error returned by PeerDownloadStartedRequest.Validate if the designated constraints aren't met.

func (PeerDownloadStartedRequestValidationError) Cause

Cause function returns cause value.

func (PeerDownloadStartedRequestValidationError) Error

Error satisfies the builtin error interface

func (PeerDownloadStartedRequestValidationError) ErrorName

ErrorName returns error name.

func (PeerDownloadStartedRequestValidationError) Field

Field function returns field value.

func (PeerDownloadStartedRequestValidationError) Key

Key function returns key value.

func (PeerDownloadStartedRequestValidationError) Reason

Reason function returns reason value.

type PeerMultiError

type PeerMultiError []error

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

func (PeerMultiError) AllErrors

func (m PeerMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PeerMultiError) Error

func (m PeerMultiError) Error() string

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

type PeerValidationError

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

PeerValidationError is the validation error returned by Peer.Validate if the designated constraints aren't met.

func (PeerValidationError) Cause

func (e PeerValidationError) Cause() error

Cause function returns cause value.

func (PeerValidationError) Error

func (e PeerValidationError) Error() string

Error satisfies the builtin error interface

func (PeerValidationError) ErrorName

func (e PeerValidationError) ErrorName() string

ErrorName returns error name.

func (PeerValidationError) Field

func (e PeerValidationError) Field() string

Field function returns field value.

func (PeerValidationError) Key

func (e PeerValidationError) Key() bool

Key function returns key value.

func (PeerValidationError) Reason

func (e PeerValidationError) Reason() string

Reason function returns reason value.

type PieceDownloadFinishedRequest

type PieceDownloadFinishedRequest struct {

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

PieceDownloadFinishedRequest represents piece download finished request of AnnouncePeerRequest.

func (*PieceDownloadFinishedRequest) Descriptor deprecated

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

Deprecated: Use PieceDownloadFinishedRequest.ProtoReflect.Descriptor instead.

func (*PieceDownloadFinishedRequest) GetPiece

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

func (*PieceDownloadFinishedRequest) ProtoMessage

func (*PieceDownloadFinishedRequest) ProtoMessage()

func (*PieceDownloadFinishedRequest) ProtoReflect

func (*PieceDownloadFinishedRequest) Reset

func (x *PieceDownloadFinishedRequest) Reset()

func (*PieceDownloadFinishedRequest) String

func (*PieceDownloadFinishedRequest) Validate

func (m *PieceDownloadFinishedRequest) Validate() error

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

func (m *PieceDownloadFinishedRequest) ValidateAll() error

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

type PieceDownloadFinishedRequestMultiError

type PieceDownloadFinishedRequestMultiError []error

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

func (PieceDownloadFinishedRequestMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (PieceDownloadFinishedRequestMultiError) Error

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

type PieceDownloadFinishedRequestValidationError

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

PieceDownloadFinishedRequestValidationError is the validation error returned by PieceDownloadFinishedRequest.Validate if the designated constraints aren't met.

func (PieceDownloadFinishedRequestValidationError) Cause

Cause function returns cause value.

func (PieceDownloadFinishedRequestValidationError) Error

Error satisfies the builtin error interface

func (PieceDownloadFinishedRequestValidationError) ErrorName

ErrorName returns error name.

func (PieceDownloadFinishedRequestValidationError) Field

Field function returns field value.

func (PieceDownloadFinishedRequestValidationError) Key

Key function returns key value.

func (PieceDownloadFinishedRequestValidationError) Reason

Reason function returns reason value.

type RegisterRequest

type RegisterRequest 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"`
	// Task metadata.
	Metadata *v2.Metadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Host info.
	Host *Host `protobuf:"bytes,4,opt,name=host,proto3" json:"host,omitempty"`
	// Task type.
	TaskType v2.TaskType `protobuf:"varint,5,opt,name=task_type,json=taskType,proto3,enum=common.TaskType" json:"task_type,omitempty"`
	// Pattern includes p2p, seed-peer and source.
	Pattern v2.Pattern `protobuf:"varint,6,opt,name=pattern,proto3,enum=common.Pattern" json:"pattern,omitempty"`
	// contains filtered or unexported fields
}

RegisteredRequest represents registered request of AnnouncePeerRequest.

func (*RegisterRequest) Descriptor deprecated

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetHost

func (x *RegisterRequest) GetHost() *Host

func (*RegisterRequest) GetMetadata

func (x *RegisterRequest) GetMetadata() *v2.Metadata

func (*RegisterRequest) GetPattern

func (x *RegisterRequest) GetPattern() v2.Pattern

func (*RegisterRequest) GetPeerId

func (x *RegisterRequest) GetPeerId() string

func (*RegisterRequest) GetTaskId

func (x *RegisterRequest) GetTaskId() string

func (*RegisterRequest) GetTaskType

func (x *RegisterRequest) GetTaskType() v2.TaskType

func (*RegisterRequest) ProtoMessage

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect

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

func (*RegisterRequest) Reset

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String

func (x *RegisterRequest) String() string

func (*RegisterRequest) Validate

func (m *RegisterRequest) Validate() error

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

func (m *RegisterRequest) ValidateAll() error

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

type RegisterRequestMultiError

type RegisterRequestMultiError []error

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

func (RegisterRequestMultiError) AllErrors

func (m RegisterRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RegisterRequestMultiError) Error

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

type RegisterRequestValidationError

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

RegisterRequestValidationError is the validation error returned by RegisterRequest.Validate if the designated constraints aren't met.

func (RegisterRequestValidationError) Cause

Cause function returns cause value.

func (RegisterRequestValidationError) Error

Error satisfies the builtin error interface

func (RegisterRequestValidationError) ErrorName

func (e RegisterRequestValidationError) ErrorName() string

ErrorName returns error name.

func (RegisterRequestValidationError) Field

Field function returns field value.

func (RegisterRequestValidationError) Key

Key function returns key value.

func (RegisterRequestValidationError) Reason

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) (*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) (*Task, error)
	// LeaveTask releases task in scheduler.
	LeaveTask(ctx context.Context, in *LeaveTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

SchedulerClient is the client API for Scheduler service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#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) (*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) (*Task, error)
	// LeaveTask releases task in scheduler.
	LeaveTask(context.Context, *LeaveTaskRequest) (*emptypb.Empty, error)
}

SchedulerServer is the server API for Scheduler service.

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

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

Cause function returns cause value.

func (SmallTaskResponseValidationError) Error

Error satisfies the builtin error interface

func (SmallTaskResponseValidationError) ErrorName

ErrorName returns error name.

func (SmallTaskResponseValidationError) Field

Field function returns field value.

func (SmallTaskResponseValidationError) Key

Key function returns key value.

func (SmallTaskResponseValidationError) Reason

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

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

type StatPeerRequestValidationError

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

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

func (StatPeerRequestValidationError) Cause

Cause function returns cause value.

func (StatPeerRequestValidationError) Error

Error satisfies the builtin error interface

func (StatPeerRequestValidationError) ErrorName

func (e StatPeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatPeerRequestValidationError) Field

Field function returns field value.

func (StatPeerRequestValidationError) Key

Key function returns key value.

func (StatPeerRequestValidationError) Reason

Reason function returns reason value.

type StatTaskRequest

type StatTaskRequest struct {

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

StatTaskRequest represents request of StatTask.

func (*StatTaskRequest) Descriptor deprecated

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

Deprecated: Use StatTaskRequest.ProtoReflect.Descriptor instead.

func (*StatTaskRequest) GetTaskId

func (x *StatTaskRequest) GetTaskId() string

func (*StatTaskRequest) ProtoMessage

func (*StatTaskRequest) ProtoMessage()

func (*StatTaskRequest) ProtoReflect

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

func (*StatTaskRequest) Reset

func (x *StatTaskRequest) Reset()

func (*StatTaskRequest) String

func (x *StatTaskRequest) String() string

func (*StatTaskRequest) Validate

func (m *StatTaskRequest) Validate() error

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

func (*StatTaskRequest) ValidateAll

func (m *StatTaskRequest) ValidateAll() error

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

type StatTaskRequestMultiError

type StatTaskRequestMultiError []error

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

func (StatTaskRequestMultiError) AllErrors

func (m StatTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatTaskRequestMultiError) Error

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

type StatTaskRequestValidationError

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

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

func (StatTaskRequestValidationError) Cause

Cause function returns cause value.

func (StatTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (StatTaskRequestValidationError) ErrorName

func (e StatTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatTaskRequestValidationError) Field

Field function returns field value.

func (StatTaskRequestValidationError) Key

Key function returns key value.

func (StatTaskRequestValidationError) Reason

Reason function returns reason value.

type Task

type Task struct {

	// Task id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Task type.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Task size scope.
	SizeScope v2.SizeScope `protobuf:"varint,3,opt,name=size_scope,json=sizeScope,proto3,enum=common.SizeScope" json:"size_scope,omitempty"`
	// Pieces of task.
	Pieces []*v2.Piece `protobuf:"bytes,4,rep,name=pieces,proto3" json:"pieces,omitempty"`
	// Task state.
	State string `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	// Task metadata.
	Metadata *v2.Metadata `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Task content length.
	ContentLength int64 `protobuf:"varint,7,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// Task peer count.
	PeerCount int32 `protobuf:"varint,8,opt,name=peer_count,json=peerCount,proto3" json:"peer_count,omitempty"`
	// Task contains available peer.
	HasAvailablePeer bool `protobuf:"varint,9,opt,name=hasAvailablePeer,proto3" json:"hasAvailablePeer,omitempty"`
	// Task create time.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Task update time.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

Task metadata.

func (*Task) Descriptor deprecated

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetContentLength

func (x *Task) GetContentLength() int64

func (*Task) GetCreatedAt

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

func (*Task) GetHasAvailablePeer

func (x *Task) GetHasAvailablePeer() bool

func (*Task) GetId

func (x *Task) GetId() string

func (*Task) GetMetadata

func (x *Task) GetMetadata() *v2.Metadata

func (*Task) GetPeerCount

func (x *Task) GetPeerCount() int32

func (*Task) GetPieces

func (x *Task) GetPieces() []*v2.Piece

func (*Task) GetSizeScope

func (x *Task) GetSizeScope() v2.SizeScope

func (*Task) GetState

func (x *Task) GetState() string

func (*Task) GetType

func (x *Task) GetType() string

func (*Task) GetUpdatedAt

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

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) ProtoReflect

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

func (*Task) Reset

func (x *Task) Reset()

func (*Task) String

func (x *Task) String() string

func (*Task) Validate

func (m *Task) Validate() error

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

func (m *Task) ValidateAll() error

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

type TaskMultiError

type TaskMultiError []error

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

func (TaskMultiError) AllErrors

func (m TaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskMultiError) Error

func (m TaskMultiError) Error() string

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

type TaskValidationError

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

TaskValidationError is the validation error returned by Task.Validate if the designated constraints aren't met.

func (TaskValidationError) Cause

func (e TaskValidationError) Cause() error

Cause function returns cause value.

func (TaskValidationError) Error

func (e TaskValidationError) Error() string

Error satisfies the builtin error interface

func (TaskValidationError) ErrorName

func (e TaskValidationError) ErrorName() string

ErrorName returns error name.

func (TaskValidationError) Field

func (e TaskValidationError) Field() string

Field function returns field value.

func (TaskValidationError) Key

func (e TaskValidationError) Key() bool

Key function returns key value.

func (TaskValidationError) Reason

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

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

Cause function returns cause value.

func (TinyTaskResponseValidationError) Error

Error satisfies the builtin error interface

func (TinyTaskResponseValidationError) ErrorName

ErrorName returns error name.

func (TinyTaskResponseValidationError) Field

Field function returns field value.

func (TinyTaskResponseValidationError) Key

Key function returns key value.

func (TinyTaskResponseValidationError) Reason

Reason function returns reason value.

type UnimplementedSchedulerServer

type UnimplementedSchedulerServer struct {
}

UnimplementedSchedulerServer can be embedded to have forward compatible implementations.

func (*UnimplementedSchedulerServer) AnnouncePeer

func (*UnimplementedSchedulerServer) ExchangePeer

func (*UnimplementedSchedulerServer) LeavePeer

func (*UnimplementedSchedulerServer) LeaveTask

func (*UnimplementedSchedulerServer) StatPeer

func (*UnimplementedSchedulerServer) StatTask

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