Documentation
¶
Index ¶
- Variables
- func RegisterDfdaemonDownloadServer(s grpc.ServiceRegistrar, srv DfdaemonDownloadServer)
- func RegisterDfdaemonUploadServer(s grpc.ServiceRegistrar, srv DfdaemonUploadServer)
- type DeleteCacheTaskRequest
- func (*DeleteCacheTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteCacheTaskRequest) GetTaskId() string
- func (*DeleteCacheTaskRequest) ProtoMessage()
- func (x *DeleteCacheTaskRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteCacheTaskRequest) Reset()
- func (x *DeleteCacheTaskRequest) String() string
- func (m *DeleteCacheTaskRequest) Validate() error
- func (m *DeleteCacheTaskRequest) ValidateAll() error
- type DeleteCacheTaskRequestMultiError
- type DeleteCacheTaskRequestValidationError
- func (e DeleteCacheTaskRequestValidationError) Cause() error
- func (e DeleteCacheTaskRequestValidationError) Error() string
- func (e DeleteCacheTaskRequestValidationError) ErrorName() string
- func (e DeleteCacheTaskRequestValidationError) Field() string
- func (e DeleteCacheTaskRequestValidationError) Key() bool
- func (e DeleteCacheTaskRequestValidationError) Reason() string
- type DeleteTaskRequest
- func (*DeleteTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteTaskRequest) GetTaskId() string
- func (*DeleteTaskRequest) ProtoMessage()
- func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteTaskRequest) Reset()
- func (x *DeleteTaskRequest) String() string
- func (m *DeleteTaskRequest) Validate() error
- func (m *DeleteTaskRequest) ValidateAll() error
- type DeleteTaskRequestMultiError
- type DeleteTaskRequestValidationError
- func (e DeleteTaskRequestValidationError) Cause() error
- func (e DeleteTaskRequestValidationError) Error() string
- func (e DeleteTaskRequestValidationError) ErrorName() string
- func (e DeleteTaskRequestValidationError) Field() string
- func (e DeleteTaskRequestValidationError) Key() bool
- func (e DeleteTaskRequestValidationError) Reason() string
- type DfdaemonDownloadClient
- type DfdaemonDownloadServer
- type DfdaemonDownload_DownloadCacheTaskClient
- type DfdaemonDownload_DownloadCacheTaskServer
- type DfdaemonDownload_DownloadTaskClient
- type DfdaemonDownload_DownloadTaskServer
- type DfdaemonUploadClient
- type DfdaemonUploadServer
- type DfdaemonUpload_DownloadCacheTaskClient
- type DfdaemonUpload_DownloadCacheTaskServer
- type DfdaemonUpload_DownloadTaskClient
- type DfdaemonUpload_DownloadTaskServer
- type DfdaemonUpload_SyncPiecesClient
- type DfdaemonUpload_SyncPiecesServer
- type DownloadCacheTaskRequest
- func (*DownloadCacheTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadCacheTaskRequest) GetApplication() string
- func (x *DownloadCacheTaskRequest) GetHostId() string
- func (x *DownloadCacheTaskRequest) GetOutputPath() string
- func (x *DownloadCacheTaskRequest) GetPieceLength() uint64
- func (x *DownloadCacheTaskRequest) GetTag() string
- func (x *DownloadCacheTaskRequest) GetTaskId() string
- func (x *DownloadCacheTaskRequest) GetTimeout() *durationpb.Duration
- func (*DownloadCacheTaskRequest) ProtoMessage()
- func (x *DownloadCacheTaskRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadCacheTaskRequest) Reset()
- func (x *DownloadCacheTaskRequest) String() string
- func (m *DownloadCacheTaskRequest) Validate() error
- func (m *DownloadCacheTaskRequest) ValidateAll() error
- type DownloadCacheTaskRequestMultiError
- type DownloadCacheTaskRequestValidationError
- func (e DownloadCacheTaskRequestValidationError) Cause() error
- func (e DownloadCacheTaskRequestValidationError) Error() string
- func (e DownloadCacheTaskRequestValidationError) ErrorName() string
- func (e DownloadCacheTaskRequestValidationError) Field() string
- func (e DownloadCacheTaskRequestValidationError) Key() bool
- func (e DownloadCacheTaskRequestValidationError) Reason() string
- type DownloadCacheTaskResponse
- func (*DownloadCacheTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadCacheTaskResponse) GetDownloadCacheTaskStartedResponse() *DownloadCacheTaskStartedResponse
- func (x *DownloadCacheTaskResponse) GetDownloadPieceFinishedResponse() *DownloadPieceFinishedResponse
- func (x *DownloadCacheTaskResponse) GetHostId() string
- func (x *DownloadCacheTaskResponse) GetPeerId() string
- func (m *DownloadCacheTaskResponse) GetResponse() isDownloadCacheTaskResponse_Response
- func (x *DownloadCacheTaskResponse) GetTaskId() string
- func (*DownloadCacheTaskResponse) ProtoMessage()
- func (x *DownloadCacheTaskResponse) ProtoReflect() protoreflect.Message
- func (x *DownloadCacheTaskResponse) Reset()
- func (x *DownloadCacheTaskResponse) String() string
- func (m *DownloadCacheTaskResponse) Validate() error
- func (m *DownloadCacheTaskResponse) ValidateAll() error
- type DownloadCacheTaskResponseMultiError
- type DownloadCacheTaskResponseValidationError
- func (e DownloadCacheTaskResponseValidationError) Cause() error
- func (e DownloadCacheTaskResponseValidationError) Error() string
- func (e DownloadCacheTaskResponseValidationError) ErrorName() string
- func (e DownloadCacheTaskResponseValidationError) Field() string
- func (e DownloadCacheTaskResponseValidationError) Key() bool
- func (e DownloadCacheTaskResponseValidationError) Reason() string
- type DownloadCacheTaskResponse_DownloadCacheTaskStartedResponse
- type DownloadCacheTaskResponse_DownloadPieceFinishedResponse
- type DownloadCacheTaskStartedResponse
- func (*DownloadCacheTaskStartedResponse) Descriptor() ([]byte, []int)deprecated
- func (*DownloadCacheTaskStartedResponse) ProtoMessage()
- func (x *DownloadCacheTaskStartedResponse) ProtoReflect() protoreflect.Message
- func (x *DownloadCacheTaskStartedResponse) Reset()
- func (x *DownloadCacheTaskStartedResponse) String() string
- func (m *DownloadCacheTaskStartedResponse) Validate() error
- func (m *DownloadCacheTaskStartedResponse) ValidateAll() error
- type DownloadCacheTaskStartedResponseMultiError
- type DownloadCacheTaskStartedResponseValidationError
- func (e DownloadCacheTaskStartedResponseValidationError) Cause() error
- func (e DownloadCacheTaskStartedResponseValidationError) Error() string
- func (e DownloadCacheTaskStartedResponseValidationError) ErrorName() string
- func (e DownloadCacheTaskStartedResponseValidationError) Field() string
- func (e DownloadCacheTaskStartedResponseValidationError) Key() bool
- func (e DownloadCacheTaskStartedResponseValidationError) Reason() string
- type DownloadPieceFinishedResponse
- func (*DownloadPieceFinishedResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadPieceFinishedResponse) GetPiece() *v2.Piece
- func (*DownloadPieceFinishedResponse) ProtoMessage()
- func (x *DownloadPieceFinishedResponse) ProtoReflect() protoreflect.Message
- func (x *DownloadPieceFinishedResponse) Reset()
- func (x *DownloadPieceFinishedResponse) String() string
- func (m *DownloadPieceFinishedResponse) Validate() error
- func (m *DownloadPieceFinishedResponse) ValidateAll() error
- type DownloadPieceFinishedResponseMultiError
- type DownloadPieceFinishedResponseValidationError
- func (e DownloadPieceFinishedResponseValidationError) Cause() error
- func (e DownloadPieceFinishedResponseValidationError) Error() string
- func (e DownloadPieceFinishedResponseValidationError) ErrorName() string
- func (e DownloadPieceFinishedResponseValidationError) Field() string
- func (e DownloadPieceFinishedResponseValidationError) Key() bool
- func (e DownloadPieceFinishedResponseValidationError) Reason() string
- type DownloadPieceRequest
- func (*DownloadPieceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadPieceRequest) GetHostId() string
- func (x *DownloadPieceRequest) GetPieceNumber() uint32
- func (x *DownloadPieceRequest) GetTaskId() string
- func (*DownloadPieceRequest) ProtoMessage()
- func (x *DownloadPieceRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadPieceRequest) Reset()
- func (x *DownloadPieceRequest) String() string
- func (m *DownloadPieceRequest) Validate() error
- func (m *DownloadPieceRequest) ValidateAll() error
- type DownloadPieceRequestMultiError
- type DownloadPieceRequestValidationError
- func (e DownloadPieceRequestValidationError) Cause() error
- func (e DownloadPieceRequestValidationError) Error() string
- func (e DownloadPieceRequestValidationError) ErrorName() string
- func (e DownloadPieceRequestValidationError) Field() string
- func (e DownloadPieceRequestValidationError) Key() bool
- func (e DownloadPieceRequestValidationError) Reason() string
- type DownloadPieceResponse
- func (*DownloadPieceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadPieceResponse) GetPiece() *v2.Piece
- func (*DownloadPieceResponse) ProtoMessage()
- func (x *DownloadPieceResponse) ProtoReflect() protoreflect.Message
- func (x *DownloadPieceResponse) Reset()
- func (x *DownloadPieceResponse) String() string
- func (m *DownloadPieceResponse) Validate() error
- func (m *DownloadPieceResponse) ValidateAll() error
- type DownloadPieceResponseMultiError
- type DownloadPieceResponseValidationError
- func (e DownloadPieceResponseValidationError) Cause() error
- func (e DownloadPieceResponseValidationError) Error() string
- func (e DownloadPieceResponseValidationError) ErrorName() string
- func (e DownloadPieceResponseValidationError) Field() string
- func (e DownloadPieceResponseValidationError) Key() bool
- func (e DownloadPieceResponseValidationError) Reason() string
- type DownloadTaskRequest
- func (*DownloadTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadTaskRequest) GetDownloadTask() *v2.DownloadTask
- func (*DownloadTaskRequest) ProtoMessage()
- func (x *DownloadTaskRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadTaskRequest) Reset()
- func (x *DownloadTaskRequest) String() string
- func (m *DownloadTaskRequest) Validate() error
- func (m *DownloadTaskRequest) ValidateAll() error
- type DownloadTaskRequestMultiError
- type DownloadTaskRequestValidationError
- func (e DownloadTaskRequestValidationError) Cause() error
- func (e DownloadTaskRequestValidationError) Error() string
- func (e DownloadTaskRequestValidationError) ErrorName() string
- func (e DownloadTaskRequestValidationError) Field() string
- func (e DownloadTaskRequestValidationError) Key() bool
- func (e DownloadTaskRequestValidationError) Reason() string
- type DownloadTaskResponse
- func (*DownloadTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadTaskResponse) GetDownloadPieceFinishedResponse() *DownloadPieceFinishedResponse
- func (x *DownloadTaskResponse) GetDownloadTaskStartedResponse() *DownloadTaskStartedResponse
- func (x *DownloadTaskResponse) GetHostId() string
- func (x *DownloadTaskResponse) GetPeerId() string
- func (m *DownloadTaskResponse) GetResponse() isDownloadTaskResponse_Response
- func (x *DownloadTaskResponse) GetTaskId() string
- func (*DownloadTaskResponse) ProtoMessage()
- func (x *DownloadTaskResponse) ProtoReflect() protoreflect.Message
- func (x *DownloadTaskResponse) Reset()
- func (x *DownloadTaskResponse) String() string
- func (m *DownloadTaskResponse) Validate() error
- func (m *DownloadTaskResponse) ValidateAll() error
- type DownloadTaskResponseMultiError
- type DownloadTaskResponseValidationError
- func (e DownloadTaskResponseValidationError) Cause() error
- func (e DownloadTaskResponseValidationError) Error() string
- func (e DownloadTaskResponseValidationError) ErrorName() string
- func (e DownloadTaskResponseValidationError) Field() string
- func (e DownloadTaskResponseValidationError) Key() bool
- func (e DownloadTaskResponseValidationError) Reason() string
- type DownloadTaskResponse_DownloadPieceFinishedResponse
- type DownloadTaskResponse_DownloadTaskStartedResponse
- type DownloadTaskStartedResponse
- func (*DownloadTaskStartedResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadTaskStartedResponse) GetContentLength() uint64
- func (x *DownloadTaskStartedResponse) GetPieces() []*v2.Piece
- func (x *DownloadTaskStartedResponse) GetRange() *v2.Range
- func (x *DownloadTaskStartedResponse) GetResponseHeader() map[string]string
- func (*DownloadTaskStartedResponse) ProtoMessage()
- func (x *DownloadTaskStartedResponse) ProtoReflect() protoreflect.Message
- func (x *DownloadTaskStartedResponse) Reset()
- func (x *DownloadTaskStartedResponse) String() string
- func (m *DownloadTaskStartedResponse) Validate() error
- func (m *DownloadTaskStartedResponse) ValidateAll() error
- type DownloadTaskStartedResponseMultiError
- type DownloadTaskStartedResponseValidationError
- func (e DownloadTaskStartedResponseValidationError) Cause() error
- func (e DownloadTaskStartedResponseValidationError) Error() string
- func (e DownloadTaskStartedResponseValidationError) ErrorName() string
- func (e DownloadTaskStartedResponseValidationError) Field() string
- func (e DownloadTaskStartedResponseValidationError) Key() bool
- func (e DownloadTaskStartedResponseValidationError) Reason() string
- type StatCacheTaskRequest
- func (*StatCacheTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatCacheTaskRequest) GetTaskId() string
- func (*StatCacheTaskRequest) ProtoMessage()
- func (x *StatCacheTaskRequest) ProtoReflect() protoreflect.Message
- func (x *StatCacheTaskRequest) Reset()
- func (x *StatCacheTaskRequest) String() string
- func (m *StatCacheTaskRequest) Validate() error
- func (m *StatCacheTaskRequest) ValidateAll() error
- type StatCacheTaskRequestMultiError
- type StatCacheTaskRequestValidationError
- func (e StatCacheTaskRequestValidationError) Cause() error
- func (e StatCacheTaskRequestValidationError) Error() string
- func (e StatCacheTaskRequestValidationError) ErrorName() string
- func (e StatCacheTaskRequestValidationError) Field() string
- func (e StatCacheTaskRequestValidationError) Key() bool
- func (e StatCacheTaskRequestValidationError) Reason() string
- type StatTaskRequest
- func (*StatTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatTaskRequest) GetTaskId() string
- func (*StatTaskRequest) ProtoMessage()
- func (x *StatTaskRequest) ProtoReflect() protoreflect.Message
- func (x *StatTaskRequest) Reset()
- func (x *StatTaskRequest) String() string
- func (m *StatTaskRequest) Validate() error
- func (m *StatTaskRequest) ValidateAll() error
- type StatTaskRequestMultiError
- type StatTaskRequestValidationError
- func (e StatTaskRequestValidationError) Cause() error
- func (e StatTaskRequestValidationError) Error() string
- func (e StatTaskRequestValidationError) ErrorName() string
- func (e StatTaskRequestValidationError) Field() string
- func (e StatTaskRequestValidationError) Key() bool
- func (e StatTaskRequestValidationError) Reason() string
- type SyncPiecesRequest
- func (*SyncPiecesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SyncPiecesRequest) GetHostId() string
- func (x *SyncPiecesRequest) GetInterestedPieceNumbers() []uint32
- func (x *SyncPiecesRequest) GetTaskId() string
- func (*SyncPiecesRequest) ProtoMessage()
- func (x *SyncPiecesRequest) ProtoReflect() protoreflect.Message
- func (x *SyncPiecesRequest) Reset()
- func (x *SyncPiecesRequest) String() string
- func (m *SyncPiecesRequest) Validate() error
- func (m *SyncPiecesRequest) ValidateAll() error
- type SyncPiecesRequestMultiError
- type SyncPiecesRequestValidationError
- func (e SyncPiecesRequestValidationError) Cause() error
- func (e SyncPiecesRequestValidationError) Error() string
- func (e SyncPiecesRequestValidationError) ErrorName() string
- func (e SyncPiecesRequestValidationError) Field() string
- func (e SyncPiecesRequestValidationError) Key() bool
- func (e SyncPiecesRequestValidationError) Reason() string
- type SyncPiecesResponse
- func (*SyncPiecesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SyncPiecesResponse) GetLength() uint64
- func (x *SyncPiecesResponse) GetNumber() uint32
- func (x *SyncPiecesResponse) GetOffset() uint64
- func (*SyncPiecesResponse) ProtoMessage()
- func (x *SyncPiecesResponse) ProtoReflect() protoreflect.Message
- func (x *SyncPiecesResponse) Reset()
- func (x *SyncPiecesResponse) String() string
- func (m *SyncPiecesResponse) Validate() error
- func (m *SyncPiecesResponse) ValidateAll() error
- type SyncPiecesResponseMultiError
- type SyncPiecesResponseValidationError
- func (e SyncPiecesResponseValidationError) Cause() error
- func (e SyncPiecesResponseValidationError) Error() string
- func (e SyncPiecesResponseValidationError) ErrorName() string
- func (e SyncPiecesResponseValidationError) Field() string
- func (e SyncPiecesResponseValidationError) Key() bool
- func (e SyncPiecesResponseValidationError) Reason() string
- type UnimplementedDfdaemonDownloadServer
- func (UnimplementedDfdaemonDownloadServer) DeleteCacheTask(context.Context, *DeleteCacheTaskRequest) (*emptypb.Empty, error)
- func (UnimplementedDfdaemonDownloadServer) DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)
- func (UnimplementedDfdaemonDownloadServer) DownloadCacheTask(*DownloadCacheTaskRequest, DfdaemonDownload_DownloadCacheTaskServer) error
- func (UnimplementedDfdaemonDownloadServer) DownloadTask(*DownloadTaskRequest, DfdaemonDownload_DownloadTaskServer) error
- func (UnimplementedDfdaemonDownloadServer) LeaveHost(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
- func (UnimplementedDfdaemonDownloadServer) StatCacheTask(context.Context, *StatCacheTaskRequest) (*v2.CacheTask, error)
- func (UnimplementedDfdaemonDownloadServer) StatTask(context.Context, *StatTaskRequest) (*v2.Task, error)
- func (UnimplementedDfdaemonDownloadServer) UploadCacheTask(context.Context, *UploadCacheTaskRequest) (*v2.CacheTask, error)
- func (UnimplementedDfdaemonDownloadServer) UploadTask(context.Context, *UploadTaskRequest) (*emptypb.Empty, error)
- type UnimplementedDfdaemonUploadServer
- func (UnimplementedDfdaemonUploadServer) DeleteCacheTask(context.Context, *DeleteCacheTaskRequest) (*emptypb.Empty, error)
- func (UnimplementedDfdaemonUploadServer) DownloadCacheTask(*DownloadCacheTaskRequest, DfdaemonUpload_DownloadCacheTaskServer) error
- func (UnimplementedDfdaemonUploadServer) DownloadPiece(context.Context, *DownloadPieceRequest) (*DownloadPieceResponse, error)
- func (UnimplementedDfdaemonUploadServer) DownloadTask(*DownloadTaskRequest, DfdaemonUpload_DownloadTaskServer) error
- func (UnimplementedDfdaemonUploadServer) StatCacheTask(context.Context, *StatCacheTaskRequest) (*v2.CacheTask, error)
- func (UnimplementedDfdaemonUploadServer) SyncPieces(*SyncPiecesRequest, DfdaemonUpload_SyncPiecesServer) error
- type UnsafeDfdaemonDownloadServer
- type UnsafeDfdaemonUploadServer
- type UploadCacheTaskRequest
- func (*UploadCacheTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UploadCacheTaskRequest) GetApplication() string
- func (x *UploadCacheTaskRequest) GetPath() string
- func (x *UploadCacheTaskRequest) GetPersistentReplicaCount() uint64
- func (x *UploadCacheTaskRequest) GetPieceLength() uint64
- func (x *UploadCacheTaskRequest) GetTag() string
- func (x *UploadCacheTaskRequest) GetTimeout() *durationpb.Duration
- func (*UploadCacheTaskRequest) ProtoMessage()
- func (x *UploadCacheTaskRequest) ProtoReflect() protoreflect.Message
- func (x *UploadCacheTaskRequest) Reset()
- func (x *UploadCacheTaskRequest) String() string
- func (m *UploadCacheTaskRequest) Validate() error
- func (m *UploadCacheTaskRequest) ValidateAll() error
- type UploadCacheTaskRequestMultiError
- type UploadCacheTaskRequestValidationError
- func (e UploadCacheTaskRequestValidationError) Cause() error
- func (e UploadCacheTaskRequestValidationError) Error() string
- func (e UploadCacheTaskRequestValidationError) ErrorName() string
- func (e UploadCacheTaskRequestValidationError) Field() string
- func (e UploadCacheTaskRequestValidationError) Key() bool
- func (e UploadCacheTaskRequestValidationError) Reason() string
- type UploadTaskRequest
- func (*UploadTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UploadTaskRequest) GetTask() *v2.Task
- func (*UploadTaskRequest) ProtoMessage()
- func (x *UploadTaskRequest) ProtoReflect() protoreflect.Message
- func (x *UploadTaskRequest) Reset()
- func (x *UploadTaskRequest) String() string
- func (m *UploadTaskRequest) Validate() error
- func (m *UploadTaskRequest) ValidateAll() error
- type UploadTaskRequestMultiError
- type UploadTaskRequestValidationError
- func (e UploadTaskRequestValidationError) Cause() error
- func (e UploadTaskRequestValidationError) Error() string
- func (e UploadTaskRequestValidationError) ErrorName() string
- func (e UploadTaskRequestValidationError) Field() string
- func (e UploadTaskRequestValidationError) Key() bool
- func (e UploadTaskRequestValidationError) Reason() string
Constants ¶
This section is empty.
Variables ¶
var DfdaemonDownload_ServiceDesc = grpc.ServiceDesc{ ServiceName: "dfdaemon.v2.DfdaemonDownload", HandlerType: (*DfdaemonDownloadServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "UploadTask", Handler: _DfdaemonDownload_UploadTask_Handler, }, { MethodName: "StatTask", Handler: _DfdaemonDownload_StatTask_Handler, }, { MethodName: "DeleteTask", Handler: _DfdaemonDownload_DeleteTask_Handler, }, { MethodName: "LeaveHost", Handler: _DfdaemonDownload_LeaveHost_Handler, }, { MethodName: "UploadCacheTask", Handler: _DfdaemonDownload_UploadCacheTask_Handler, }, { MethodName: "StatCacheTask", Handler: _DfdaemonDownload_StatCacheTask_Handler, }, { MethodName: "DeleteCacheTask", Handler: _DfdaemonDownload_DeleteCacheTask_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "DownloadTask", Handler: _DfdaemonDownload_DownloadTask_Handler, ServerStreams: true, }, { StreamName: "DownloadCacheTask", Handler: _DfdaemonDownload_DownloadCacheTask_Handler, ServerStreams: true, }, }, Metadata: "pkg/apis/dfdaemon/v2/dfdaemon.proto", }
DfdaemonDownload_ServiceDesc is the grpc.ServiceDesc for DfdaemonDownload service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var DfdaemonUpload_ServiceDesc = grpc.ServiceDesc{ ServiceName: "dfdaemon.v2.DfdaemonUpload", HandlerType: (*DfdaemonUploadServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "DownloadPiece", Handler: _DfdaemonUpload_DownloadPiece_Handler, }, { MethodName: "StatCacheTask", Handler: _DfdaemonUpload_StatCacheTask_Handler, }, { MethodName: "DeleteCacheTask", Handler: _DfdaemonUpload_DeleteCacheTask_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "DownloadTask", Handler: _DfdaemonUpload_DownloadTask_Handler, ServerStreams: true, }, { StreamName: "SyncPieces", Handler: _DfdaemonUpload_SyncPieces_Handler, ServerStreams: true, }, { StreamName: "DownloadCacheTask", Handler: _DfdaemonUpload_DownloadCacheTask_Handler, ServerStreams: true, }, }, Metadata: "pkg/apis/dfdaemon/v2/dfdaemon.proto", }
DfdaemonUpload_ServiceDesc is the grpc.ServiceDesc for DfdaemonUpload service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_pkg_apis_dfdaemon_v2_dfdaemon_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDfdaemonDownloadServer ¶ added in v2.0.63
func RegisterDfdaemonDownloadServer(s grpc.ServiceRegistrar, srv DfdaemonDownloadServer)
func RegisterDfdaemonUploadServer ¶ added in v2.0.63
func RegisterDfdaemonUploadServer(s grpc.ServiceRegistrar, srv DfdaemonUploadServer)
Types ¶
type DeleteCacheTaskRequest ¶ added in v2.0.116
type DeleteCacheTaskRequest struct { // Task id. TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // contains filtered or unexported fields }
DeleteCacheTaskRequest represents request of DeleteCacheTask.
func (*DeleteCacheTaskRequest) Descriptor
deprecated
added in
v2.0.116
func (*DeleteCacheTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteCacheTaskRequest.ProtoReflect.Descriptor instead.
func (*DeleteCacheTaskRequest) GetTaskId ¶ added in v2.0.116
func (x *DeleteCacheTaskRequest) GetTaskId() string
func (*DeleteCacheTaskRequest) ProtoMessage ¶ added in v2.0.116
func (*DeleteCacheTaskRequest) ProtoMessage()
func (*DeleteCacheTaskRequest) ProtoReflect ¶ added in v2.0.116
func (x *DeleteCacheTaskRequest) ProtoReflect() protoreflect.Message
func (*DeleteCacheTaskRequest) Reset ¶ added in v2.0.116
func (x *DeleteCacheTaskRequest) Reset()
func (*DeleteCacheTaskRequest) String ¶ added in v2.0.116
func (x *DeleteCacheTaskRequest) String() string
func (*DeleteCacheTaskRequest) Validate ¶ added in v2.0.116
func (m *DeleteCacheTaskRequest) Validate() error
Validate checks the field values on DeleteCacheTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*DeleteCacheTaskRequest) ValidateAll ¶ added in v2.0.116
func (m *DeleteCacheTaskRequest) ValidateAll() error
ValidateAll checks the field values on DeleteCacheTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeleteCacheTaskRequestMultiError, or nil if none found.
type DeleteCacheTaskRequestMultiError ¶ added in v2.0.116
type DeleteCacheTaskRequestMultiError []error
DeleteCacheTaskRequestMultiError is an error wrapping multiple validation errors returned by DeleteCacheTaskRequest.ValidateAll() if the designated constraints aren't met.
func (DeleteCacheTaskRequestMultiError) AllErrors ¶ added in v2.0.116
func (m DeleteCacheTaskRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DeleteCacheTaskRequestMultiError) Error ¶ added in v2.0.116
func (m DeleteCacheTaskRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DeleteCacheTaskRequestValidationError ¶ added in v2.0.116
type DeleteCacheTaskRequestValidationError struct {
// contains filtered or unexported fields
}
DeleteCacheTaskRequestValidationError is the validation error returned by DeleteCacheTaskRequest.Validate if the designated constraints aren't met.
func (DeleteCacheTaskRequestValidationError) Cause ¶ added in v2.0.116
func (e DeleteCacheTaskRequestValidationError) Cause() error
Cause function returns cause value.
func (DeleteCacheTaskRequestValidationError) Error ¶ added in v2.0.116
func (e DeleteCacheTaskRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DeleteCacheTaskRequestValidationError) ErrorName ¶ added in v2.0.116
func (e DeleteCacheTaskRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DeleteCacheTaskRequestValidationError) Field ¶ added in v2.0.116
func (e DeleteCacheTaskRequestValidationError) Field() string
Field function returns field value.
func (DeleteCacheTaskRequestValidationError) Key ¶ added in v2.0.116
func (e DeleteCacheTaskRequestValidationError) Key() bool
Key function returns key value.
func (DeleteCacheTaskRequestValidationError) Reason ¶ added in v2.0.116
func (e DeleteCacheTaskRequestValidationError) Reason() string
Reason function returns reason value.
type DeleteTaskRequest ¶
type DeleteTaskRequest struct { // Task id. TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // contains filtered or unexported fields }
DeleteTaskRequest represents request of DeleteTask.
func (*DeleteTaskRequest) Descriptor
deprecated
func (*DeleteTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.
func (*DeleteTaskRequest) GetTaskId ¶
func (x *DeleteTaskRequest) GetTaskId() string
func (*DeleteTaskRequest) ProtoMessage ¶
func (*DeleteTaskRequest) ProtoMessage()
func (*DeleteTaskRequest) ProtoReflect ¶
func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message
func (*DeleteTaskRequest) Reset ¶
func (x *DeleteTaskRequest) Reset()
func (*DeleteTaskRequest) String ¶
func (x *DeleteTaskRequest) String() string
func (*DeleteTaskRequest) Validate ¶
func (m *DeleteTaskRequest) Validate() error
Validate checks the field values on DeleteTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*DeleteTaskRequest) ValidateAll ¶
func (m *DeleteTaskRequest) ValidateAll() error
ValidateAll checks the field values on DeleteTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeleteTaskRequestMultiError, or nil if none found.
type DeleteTaskRequestMultiError ¶
type DeleteTaskRequestMultiError []error
DeleteTaskRequestMultiError is an error wrapping multiple validation errors returned by DeleteTaskRequest.ValidateAll() if the designated constraints aren't met.
func (DeleteTaskRequestMultiError) AllErrors ¶
func (m DeleteTaskRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DeleteTaskRequestMultiError) Error ¶
func (m DeleteTaskRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DeleteTaskRequestValidationError ¶
type DeleteTaskRequestValidationError struct {
// contains filtered or unexported fields
}
DeleteTaskRequestValidationError is the validation error returned by DeleteTaskRequest.Validate if the designated constraints aren't met.
func (DeleteTaskRequestValidationError) Cause ¶
func (e DeleteTaskRequestValidationError) Cause() error
Cause function returns cause value.
func (DeleteTaskRequestValidationError) Error ¶
func (e DeleteTaskRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DeleteTaskRequestValidationError) ErrorName ¶
func (e DeleteTaskRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DeleteTaskRequestValidationError) Field ¶
func (e DeleteTaskRequestValidationError) Field() string
Field function returns field value.
func (DeleteTaskRequestValidationError) Key ¶
func (e DeleteTaskRequestValidationError) Key() bool
Key function returns key value.
func (DeleteTaskRequestValidationError) Reason ¶
func (e DeleteTaskRequestValidationError) Reason() string
Reason function returns reason value.
type DfdaemonDownloadClient ¶ added in v2.0.63
type DfdaemonDownloadClient interface { // DownloadTask downloads task from p2p network. DownloadTask(ctx context.Context, in *DownloadTaskRequest, opts ...grpc.CallOption) (DfdaemonDownload_DownloadTaskClient, error) // UploadTask uploads task to p2p network. UploadTask(ctx context.Context, in *UploadTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // StatTask stats task information. StatTask(ctx context.Context, in *StatTaskRequest, opts ...grpc.CallOption) (*v2.Task, error) // DeleteTask deletes task from p2p network. DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // LeaveHost releases host in scheduler. LeaveHost(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) // DownloadCacheTask downloads cache task from p2p network. DownloadCacheTask(ctx context.Context, in *DownloadCacheTaskRequest, opts ...grpc.CallOption) (DfdaemonDownload_DownloadCacheTaskClient, error) // UploadCacheTask uploads cache task to p2p network. UploadCacheTask(ctx context.Context, in *UploadCacheTaskRequest, opts ...grpc.CallOption) (*v2.CacheTask, error) // StatCacheTask stats cache task information. StatCacheTask(ctx context.Context, in *StatCacheTaskRequest, opts ...grpc.CallOption) (*v2.CacheTask, error) // DeleteCacheTask deletes cache task from p2p network. DeleteCacheTask(ctx context.Context, in *DeleteCacheTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) }
DfdaemonDownloadClient is the client API for DfdaemonDownload 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 NewDfdaemonDownloadClient ¶ added in v2.0.63
func NewDfdaemonDownloadClient(cc grpc.ClientConnInterface) DfdaemonDownloadClient
type DfdaemonDownloadServer ¶ added in v2.0.63
type DfdaemonDownloadServer interface { // DownloadTask downloads task from p2p network. DownloadTask(*DownloadTaskRequest, DfdaemonDownload_DownloadTaskServer) error // UploadTask uploads task to p2p network. UploadTask(context.Context, *UploadTaskRequest) (*emptypb.Empty, error) // StatTask stats task information. StatTask(context.Context, *StatTaskRequest) (*v2.Task, error) // DeleteTask deletes task from p2p network. DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error) // LeaveHost releases host in scheduler. LeaveHost(context.Context, *emptypb.Empty) (*emptypb.Empty, error) // DownloadCacheTask downloads cache task from p2p network. DownloadCacheTask(*DownloadCacheTaskRequest, DfdaemonDownload_DownloadCacheTaskServer) error // UploadCacheTask uploads cache task to p2p network. UploadCacheTask(context.Context, *UploadCacheTaskRequest) (*v2.CacheTask, error) // StatCacheTask stats cache task information. StatCacheTask(context.Context, *StatCacheTaskRequest) (*v2.CacheTask, error) // DeleteCacheTask deletes cache task from p2p network. DeleteCacheTask(context.Context, *DeleteCacheTaskRequest) (*emptypb.Empty, error) }
DfdaemonDownloadServer is the server API for DfdaemonDownload service. All implementations should embed UnimplementedDfdaemonDownloadServer for forward compatibility
type DfdaemonDownload_DownloadCacheTaskClient ¶ added in v2.0.116
type DfdaemonDownload_DownloadCacheTaskClient interface { Recv() (*DownloadCacheTaskResponse, error) grpc.ClientStream }
type DfdaemonDownload_DownloadCacheTaskServer ¶ added in v2.0.116
type DfdaemonDownload_DownloadCacheTaskServer interface { Send(*DownloadCacheTaskResponse) error grpc.ServerStream }
type DfdaemonDownload_DownloadTaskClient ¶ added in v2.0.63
type DfdaemonDownload_DownloadTaskClient interface { Recv() (*DownloadTaskResponse, error) grpc.ClientStream }
type DfdaemonDownload_DownloadTaskServer ¶ added in v2.0.63
type DfdaemonDownload_DownloadTaskServer interface { Send(*DownloadTaskResponse) error grpc.ServerStream }
type DfdaemonUploadClient ¶ added in v2.0.63
type DfdaemonUploadClient interface { // DownloadTask downloads task from p2p network. DownloadTask(ctx context.Context, in *DownloadTaskRequest, opts ...grpc.CallOption) (DfdaemonUpload_DownloadTaskClient, error) // SyncPieces syncs piece metadatas from remote peer. SyncPieces(ctx context.Context, in *SyncPiecesRequest, opts ...grpc.CallOption) (DfdaemonUpload_SyncPiecesClient, error) // DownloadPiece downloads piece from the remote peer. DownloadPiece(ctx context.Context, in *DownloadPieceRequest, opts ...grpc.CallOption) (*DownloadPieceResponse, error) // DownloadCacheTask downloads cache task from p2p network. DownloadCacheTask(ctx context.Context, in *DownloadCacheTaskRequest, opts ...grpc.CallOption) (DfdaemonUpload_DownloadCacheTaskClient, error) // StatCacheTask stats cache task information. StatCacheTask(ctx context.Context, in *StatCacheTaskRequest, opts ...grpc.CallOption) (*v2.CacheTask, error) // DeleteCacheTask deletes cache task from p2p network. DeleteCacheTask(ctx context.Context, in *DeleteCacheTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) }
DfdaemonUploadClient is the client API for DfdaemonUpload 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 NewDfdaemonUploadClient ¶ added in v2.0.63
func NewDfdaemonUploadClient(cc grpc.ClientConnInterface) DfdaemonUploadClient
type DfdaemonUploadServer ¶ added in v2.0.63
type DfdaemonUploadServer interface { // DownloadTask downloads task from p2p network. DownloadTask(*DownloadTaskRequest, DfdaemonUpload_DownloadTaskServer) error // SyncPieces syncs piece metadatas from remote peer. SyncPieces(*SyncPiecesRequest, DfdaemonUpload_SyncPiecesServer) error // DownloadPiece downloads piece from the remote peer. DownloadPiece(context.Context, *DownloadPieceRequest) (*DownloadPieceResponse, error) // DownloadCacheTask downloads cache task from p2p network. DownloadCacheTask(*DownloadCacheTaskRequest, DfdaemonUpload_DownloadCacheTaskServer) error // StatCacheTask stats cache task information. StatCacheTask(context.Context, *StatCacheTaskRequest) (*v2.CacheTask, error) // DeleteCacheTask deletes cache task from p2p network. DeleteCacheTask(context.Context, *DeleteCacheTaskRequest) (*emptypb.Empty, error) }
DfdaemonUploadServer is the server API for DfdaemonUpload service. All implementations should embed UnimplementedDfdaemonUploadServer for forward compatibility
type DfdaemonUpload_DownloadCacheTaskClient ¶ added in v2.0.116
type DfdaemonUpload_DownloadCacheTaskClient interface { Recv() (*DownloadCacheTaskResponse, error) grpc.ClientStream }
type DfdaemonUpload_DownloadCacheTaskServer ¶ added in v2.0.116
type DfdaemonUpload_DownloadCacheTaskServer interface { Send(*DownloadCacheTaskResponse) error grpc.ServerStream }
type DfdaemonUpload_DownloadTaskClient ¶ added in v2.0.64
type DfdaemonUpload_DownloadTaskClient interface { Recv() (*DownloadTaskResponse, error) grpc.ClientStream }
type DfdaemonUpload_DownloadTaskServer ¶ added in v2.0.64
type DfdaemonUpload_DownloadTaskServer interface { Send(*DownloadTaskResponse) error grpc.ServerStream }
type DfdaemonUpload_SyncPiecesClient ¶ added in v2.0.63
type DfdaemonUpload_SyncPiecesClient interface { Recv() (*SyncPiecesResponse, error) grpc.ClientStream }
type DfdaemonUpload_SyncPiecesServer ¶ added in v2.0.63
type DfdaemonUpload_SyncPiecesServer interface { Send(*SyncPiecesResponse) error grpc.ServerStream }
type DownloadCacheTaskRequest ¶ added in v2.0.116
type DownloadCacheTaskRequest struct { // Host id. HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"` // Task id. TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // Tag is used to distinguish different cache tasks. Tag *string `protobuf:"bytes,3,opt,name=tag,proto3,oneof" json:"tag,omitempty"` // Application of task. Application *string `protobuf:"bytes,4,opt,name=application,proto3,oneof" json:"application,omitempty"` // Task piece length. PieceLength uint64 `protobuf:"varint,5,opt,name=piece_length,json=pieceLength,proto3" json:"piece_length,omitempty"` // File path to be exported. OutputPath string `protobuf:"bytes,6,opt,name=output_path,json=outputPath,proto3" json:"output_path,omitempty"` // Download timeout. Timeout *durationpb.Duration `protobuf:"bytes,7,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"` // contains filtered or unexported fields }
DownloadCacheTaskRequest represents request of DownloadCacheTask.
func (*DownloadCacheTaskRequest) Descriptor
deprecated
added in
v2.0.116
func (*DownloadCacheTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadCacheTaskRequest.ProtoReflect.Descriptor instead.
func (*DownloadCacheTaskRequest) GetApplication ¶ added in v2.0.116
func (x *DownloadCacheTaskRequest) GetApplication() string
func (*DownloadCacheTaskRequest) GetHostId ¶ added in v2.0.116
func (x *DownloadCacheTaskRequest) GetHostId() string
func (*DownloadCacheTaskRequest) GetOutputPath ¶ added in v2.0.116
func (x *DownloadCacheTaskRequest) GetOutputPath() string
func (*DownloadCacheTaskRequest) GetPieceLength ¶ added in v2.0.116
func (x *DownloadCacheTaskRequest) GetPieceLength() uint64
func (*DownloadCacheTaskRequest) GetTag ¶ added in v2.0.116
func (x *DownloadCacheTaskRequest) GetTag() string
func (*DownloadCacheTaskRequest) GetTaskId ¶ added in v2.0.116
func (x *DownloadCacheTaskRequest) GetTaskId() string
func (*DownloadCacheTaskRequest) GetTimeout ¶ added in v2.0.116
func (x *DownloadCacheTaskRequest) GetTimeout() *durationpb.Duration
func (*DownloadCacheTaskRequest) ProtoMessage ¶ added in v2.0.116
func (*DownloadCacheTaskRequest) ProtoMessage()
func (*DownloadCacheTaskRequest) ProtoReflect ¶ added in v2.0.116
func (x *DownloadCacheTaskRequest) ProtoReflect() protoreflect.Message
func (*DownloadCacheTaskRequest) Reset ¶ added in v2.0.116
func (x *DownloadCacheTaskRequest) Reset()
func (*DownloadCacheTaskRequest) String ¶ added in v2.0.116
func (x *DownloadCacheTaskRequest) String() string
func (*DownloadCacheTaskRequest) Validate ¶ added in v2.0.116
func (m *DownloadCacheTaskRequest) Validate() error
Validate checks the field values on DownloadCacheTaskRequest 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 (*DownloadCacheTaskRequest) ValidateAll ¶ added in v2.0.116
func (m *DownloadCacheTaskRequest) ValidateAll() error
ValidateAll checks the field values on DownloadCacheTaskRequest 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 DownloadCacheTaskRequestMultiError, or nil if none found.
type DownloadCacheTaskRequestMultiError ¶ added in v2.0.116
type DownloadCacheTaskRequestMultiError []error
DownloadCacheTaskRequestMultiError is an error wrapping multiple validation errors returned by DownloadCacheTaskRequest.ValidateAll() if the designated constraints aren't met.
func (DownloadCacheTaskRequestMultiError) AllErrors ¶ added in v2.0.116
func (m DownloadCacheTaskRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadCacheTaskRequestMultiError) Error ¶ added in v2.0.116
func (m DownloadCacheTaskRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadCacheTaskRequestValidationError ¶ added in v2.0.116
type DownloadCacheTaskRequestValidationError struct {
// contains filtered or unexported fields
}
DownloadCacheTaskRequestValidationError is the validation error returned by DownloadCacheTaskRequest.Validate if the designated constraints aren't met.
func (DownloadCacheTaskRequestValidationError) Cause ¶ added in v2.0.116
func (e DownloadCacheTaskRequestValidationError) Cause() error
Cause function returns cause value.
func (DownloadCacheTaskRequestValidationError) Error ¶ added in v2.0.116
func (e DownloadCacheTaskRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadCacheTaskRequestValidationError) ErrorName ¶ added in v2.0.116
func (e DownloadCacheTaskRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadCacheTaskRequestValidationError) Field ¶ added in v2.0.116
func (e DownloadCacheTaskRequestValidationError) Field() string
Field function returns field value.
func (DownloadCacheTaskRequestValidationError) Key ¶ added in v2.0.116
func (e DownloadCacheTaskRequestValidationError) Key() bool
Key function returns key value.
func (DownloadCacheTaskRequestValidationError) Reason ¶ added in v2.0.116
func (e DownloadCacheTaskRequestValidationError) Reason() string
Reason function returns reason value.
type DownloadCacheTaskResponse ¶ added in v2.0.116
type DownloadCacheTaskResponse struct { // Host id. HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"` // Task id. TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // Peer id. PeerId string `protobuf:"bytes,3,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"` // Types that are assignable to Response: // // *DownloadCacheTaskResponse_DownloadCacheTaskStartedResponse // *DownloadCacheTaskResponse_DownloadPieceFinishedResponse Response isDownloadCacheTaskResponse_Response `protobuf_oneof:"response"` // contains filtered or unexported fields }
DownloadCacheTaskResponse represents response of DownloadCacheTask.
func (*DownloadCacheTaskResponse) Descriptor
deprecated
added in
v2.0.116
func (*DownloadCacheTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use DownloadCacheTaskResponse.ProtoReflect.Descriptor instead.
func (*DownloadCacheTaskResponse) GetDownloadCacheTaskStartedResponse ¶ added in v2.0.116
func (x *DownloadCacheTaskResponse) GetDownloadCacheTaskStartedResponse() *DownloadCacheTaskStartedResponse
func (*DownloadCacheTaskResponse) GetDownloadPieceFinishedResponse ¶ added in v2.0.116
func (x *DownloadCacheTaskResponse) GetDownloadPieceFinishedResponse() *DownloadPieceFinishedResponse
func (*DownloadCacheTaskResponse) GetHostId ¶ added in v2.0.116
func (x *DownloadCacheTaskResponse) GetHostId() string
func (*DownloadCacheTaskResponse) GetPeerId ¶ added in v2.0.116
func (x *DownloadCacheTaskResponse) GetPeerId() string
func (*DownloadCacheTaskResponse) GetResponse ¶ added in v2.0.116
func (m *DownloadCacheTaskResponse) GetResponse() isDownloadCacheTaskResponse_Response
func (*DownloadCacheTaskResponse) GetTaskId ¶ added in v2.0.116
func (x *DownloadCacheTaskResponse) GetTaskId() string
func (*DownloadCacheTaskResponse) ProtoMessage ¶ added in v2.0.116
func (*DownloadCacheTaskResponse) ProtoMessage()
func (*DownloadCacheTaskResponse) ProtoReflect ¶ added in v2.0.116
func (x *DownloadCacheTaskResponse) ProtoReflect() protoreflect.Message
func (*DownloadCacheTaskResponse) Reset ¶ added in v2.0.116
func (x *DownloadCacheTaskResponse) Reset()
func (*DownloadCacheTaskResponse) String ¶ added in v2.0.116
func (x *DownloadCacheTaskResponse) String() string
func (*DownloadCacheTaskResponse) Validate ¶ added in v2.0.116
func (m *DownloadCacheTaskResponse) Validate() error
Validate checks the field values on DownloadCacheTaskResponse 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 (*DownloadCacheTaskResponse) ValidateAll ¶ added in v2.0.116
func (m *DownloadCacheTaskResponse) ValidateAll() error
ValidateAll checks the field values on DownloadCacheTaskResponse 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 DownloadCacheTaskResponseMultiError, or nil if none found.
type DownloadCacheTaskResponseMultiError ¶ added in v2.0.116
type DownloadCacheTaskResponseMultiError []error
DownloadCacheTaskResponseMultiError is an error wrapping multiple validation errors returned by DownloadCacheTaskResponse.ValidateAll() if the designated constraints aren't met.
func (DownloadCacheTaskResponseMultiError) AllErrors ¶ added in v2.0.116
func (m DownloadCacheTaskResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadCacheTaskResponseMultiError) Error ¶ added in v2.0.116
func (m DownloadCacheTaskResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadCacheTaskResponseValidationError ¶ added in v2.0.116
type DownloadCacheTaskResponseValidationError struct {
// contains filtered or unexported fields
}
DownloadCacheTaskResponseValidationError is the validation error returned by DownloadCacheTaskResponse.Validate if the designated constraints aren't met.
func (DownloadCacheTaskResponseValidationError) Cause ¶ added in v2.0.116
func (e DownloadCacheTaskResponseValidationError) Cause() error
Cause function returns cause value.
func (DownloadCacheTaskResponseValidationError) Error ¶ added in v2.0.116
func (e DownloadCacheTaskResponseValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadCacheTaskResponseValidationError) ErrorName ¶ added in v2.0.116
func (e DownloadCacheTaskResponseValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadCacheTaskResponseValidationError) Field ¶ added in v2.0.116
func (e DownloadCacheTaskResponseValidationError) Field() string
Field function returns field value.
func (DownloadCacheTaskResponseValidationError) Key ¶ added in v2.0.116
func (e DownloadCacheTaskResponseValidationError) Key() bool
Key function returns key value.
func (DownloadCacheTaskResponseValidationError) Reason ¶ added in v2.0.116
func (e DownloadCacheTaskResponseValidationError) Reason() string
Reason function returns reason value.
type DownloadCacheTaskResponse_DownloadCacheTaskStartedResponse ¶ added in v2.0.116
type DownloadCacheTaskResponse_DownloadCacheTaskStartedResponse struct {
DownloadCacheTaskStartedResponse *DownloadCacheTaskStartedResponse `protobuf:"bytes,4,opt,name=download_cache_task_started_response,json=downloadCacheTaskStartedResponse,proto3,oneof"`
}
type DownloadCacheTaskResponse_DownloadPieceFinishedResponse ¶ added in v2.0.116
type DownloadCacheTaskResponse_DownloadPieceFinishedResponse struct {
DownloadPieceFinishedResponse *DownloadPieceFinishedResponse `protobuf:"bytes,5,opt,name=download_piece_finished_response,json=downloadPieceFinishedResponse,proto3,oneof"`
}
type DownloadCacheTaskStartedResponse ¶ added in v2.0.116
type DownloadCacheTaskStartedResponse struct {
// contains filtered or unexported fields
}
DownloadCacheTaskStartedResponse represents task download started response of DownloadCacheTaskResponse.
func (*DownloadCacheTaskStartedResponse) Descriptor
deprecated
added in
v2.0.116
func (*DownloadCacheTaskStartedResponse) Descriptor() ([]byte, []int)
Deprecated: Use DownloadCacheTaskStartedResponse.ProtoReflect.Descriptor instead.
func (*DownloadCacheTaskStartedResponse) ProtoMessage ¶ added in v2.0.116
func (*DownloadCacheTaskStartedResponse) ProtoMessage()
func (*DownloadCacheTaskStartedResponse) ProtoReflect ¶ added in v2.0.116
func (x *DownloadCacheTaskStartedResponse) ProtoReflect() protoreflect.Message
func (*DownloadCacheTaskStartedResponse) Reset ¶ added in v2.0.116
func (x *DownloadCacheTaskStartedResponse) Reset()
func (*DownloadCacheTaskStartedResponse) String ¶ added in v2.0.116
func (x *DownloadCacheTaskStartedResponse) String() string
func (*DownloadCacheTaskStartedResponse) Validate ¶ added in v2.0.116
func (m *DownloadCacheTaskStartedResponse) Validate() error
Validate checks the field values on DownloadCacheTaskStartedResponse 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 (*DownloadCacheTaskStartedResponse) ValidateAll ¶ added in v2.0.116
func (m *DownloadCacheTaskStartedResponse) ValidateAll() error
ValidateAll checks the field values on DownloadCacheTaskStartedResponse 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 DownloadCacheTaskStartedResponseMultiError, or nil if none found.
type DownloadCacheTaskStartedResponseMultiError ¶ added in v2.0.116
type DownloadCacheTaskStartedResponseMultiError []error
DownloadCacheTaskStartedResponseMultiError is an error wrapping multiple validation errors returned by DownloadCacheTaskStartedResponse.ValidateAll() if the designated constraints aren't met.
func (DownloadCacheTaskStartedResponseMultiError) AllErrors ¶ added in v2.0.116
func (m DownloadCacheTaskStartedResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadCacheTaskStartedResponseMultiError) Error ¶ added in v2.0.116
func (m DownloadCacheTaskStartedResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadCacheTaskStartedResponseValidationError ¶ added in v2.0.116
type DownloadCacheTaskStartedResponseValidationError struct {
// contains filtered or unexported fields
}
DownloadCacheTaskStartedResponseValidationError is the validation error returned by DownloadCacheTaskStartedResponse.Validate if the designated constraints aren't met.
func (DownloadCacheTaskStartedResponseValidationError) Cause ¶ added in v2.0.116
func (e DownloadCacheTaskStartedResponseValidationError) Cause() error
Cause function returns cause value.
func (DownloadCacheTaskStartedResponseValidationError) Error ¶ added in v2.0.116
func (e DownloadCacheTaskStartedResponseValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadCacheTaskStartedResponseValidationError) ErrorName ¶ added in v2.0.116
func (e DownloadCacheTaskStartedResponseValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadCacheTaskStartedResponseValidationError) Field ¶ added in v2.0.116
func (e DownloadCacheTaskStartedResponseValidationError) Field() string
Field function returns field value.
func (DownloadCacheTaskStartedResponseValidationError) Key ¶ added in v2.0.116
func (e DownloadCacheTaskStartedResponseValidationError) Key() bool
Key function returns key value.
func (DownloadCacheTaskStartedResponseValidationError) Reason ¶ added in v2.0.116
func (e DownloadCacheTaskStartedResponseValidationError) Reason() string
Reason function returns reason value.
type DownloadPieceFinishedResponse ¶ added in v2.0.66
type DownloadPieceFinishedResponse struct { // Finished piece of task. Piece *v2.Piece `protobuf:"bytes,1,opt,name=piece,proto3" json:"piece,omitempty"` // contains filtered or unexported fields }
DownloadPieceFinishedResponse represents piece download finished response of DownloadTaskResponse.
func (*DownloadPieceFinishedResponse) Descriptor
deprecated
added in
v2.0.66
func (*DownloadPieceFinishedResponse) Descriptor() ([]byte, []int)
Deprecated: Use DownloadPieceFinishedResponse.ProtoReflect.Descriptor instead.
func (*DownloadPieceFinishedResponse) GetPiece ¶ added in v2.0.66
func (x *DownloadPieceFinishedResponse) GetPiece() *v2.Piece
func (*DownloadPieceFinishedResponse) ProtoMessage ¶ added in v2.0.66
func (*DownloadPieceFinishedResponse) ProtoMessage()
func (*DownloadPieceFinishedResponse) ProtoReflect ¶ added in v2.0.66
func (x *DownloadPieceFinishedResponse) ProtoReflect() protoreflect.Message
func (*DownloadPieceFinishedResponse) Reset ¶ added in v2.0.66
func (x *DownloadPieceFinishedResponse) Reset()
func (*DownloadPieceFinishedResponse) String ¶ added in v2.0.66
func (x *DownloadPieceFinishedResponse) String() string
func (*DownloadPieceFinishedResponse) Validate ¶ added in v2.0.66
func (m *DownloadPieceFinishedResponse) Validate() error
Validate checks the field values on DownloadPieceFinishedResponse 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 (*DownloadPieceFinishedResponse) ValidateAll ¶ added in v2.0.66
func (m *DownloadPieceFinishedResponse) ValidateAll() error
ValidateAll checks the field values on DownloadPieceFinishedResponse 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 DownloadPieceFinishedResponseMultiError, or nil if none found.
type DownloadPieceFinishedResponseMultiError ¶ added in v2.0.66
type DownloadPieceFinishedResponseMultiError []error
DownloadPieceFinishedResponseMultiError is an error wrapping multiple validation errors returned by DownloadPieceFinishedResponse.ValidateAll() if the designated constraints aren't met.
func (DownloadPieceFinishedResponseMultiError) AllErrors ¶ added in v2.0.66
func (m DownloadPieceFinishedResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadPieceFinishedResponseMultiError) Error ¶ added in v2.0.66
func (m DownloadPieceFinishedResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadPieceFinishedResponseValidationError ¶ added in v2.0.66
type DownloadPieceFinishedResponseValidationError struct {
// contains filtered or unexported fields
}
DownloadPieceFinishedResponseValidationError is the validation error returned by DownloadPieceFinishedResponse.Validate if the designated constraints aren't met.
func (DownloadPieceFinishedResponseValidationError) Cause ¶ added in v2.0.66
func (e DownloadPieceFinishedResponseValidationError) Cause() error
Cause function returns cause value.
func (DownloadPieceFinishedResponseValidationError) Error ¶ added in v2.0.66
func (e DownloadPieceFinishedResponseValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadPieceFinishedResponseValidationError) ErrorName ¶ added in v2.0.66
func (e DownloadPieceFinishedResponseValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadPieceFinishedResponseValidationError) Field ¶ added in v2.0.66
func (e DownloadPieceFinishedResponseValidationError) Field() string
Field function returns field value.
func (DownloadPieceFinishedResponseValidationError) Key ¶ added in v2.0.66
func (e DownloadPieceFinishedResponseValidationError) Key() bool
Key function returns key value.
func (DownloadPieceFinishedResponseValidationError) Reason ¶ added in v2.0.66
func (e DownloadPieceFinishedResponseValidationError) Reason() string
Reason function returns reason value.
type DownloadPieceRequest ¶ added in v2.0.59
type DownloadPieceRequest struct { // Host id. HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"` // Task id. TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // Piece number. PieceNumber uint32 `protobuf:"varint,3,opt,name=piece_number,json=pieceNumber,proto3" json:"piece_number,omitempty"` // contains filtered or unexported fields }
DownloadPieceRequest represents request of DownloadPiece.
func (*DownloadPieceRequest) Descriptor
deprecated
added in
v2.0.59
func (*DownloadPieceRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadPieceRequest.ProtoReflect.Descriptor instead.
func (*DownloadPieceRequest) GetHostId ¶ added in v2.0.115
func (x *DownloadPieceRequest) GetHostId() string
func (*DownloadPieceRequest) GetPieceNumber ¶ added in v2.0.59
func (x *DownloadPieceRequest) GetPieceNumber() uint32
func (*DownloadPieceRequest) GetTaskId ¶ added in v2.0.59
func (x *DownloadPieceRequest) GetTaskId() string
func (*DownloadPieceRequest) ProtoMessage ¶ added in v2.0.59
func (*DownloadPieceRequest) ProtoMessage()
func (*DownloadPieceRequest) ProtoReflect ¶ added in v2.0.59
func (x *DownloadPieceRequest) ProtoReflect() protoreflect.Message
func (*DownloadPieceRequest) Reset ¶ added in v2.0.59
func (x *DownloadPieceRequest) Reset()
func (*DownloadPieceRequest) String ¶ added in v2.0.59
func (x *DownloadPieceRequest) String() string
func (*DownloadPieceRequest) Validate ¶ added in v2.0.59
func (m *DownloadPieceRequest) Validate() error
Validate checks the field values on DownloadPieceRequest 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 (*DownloadPieceRequest) ValidateAll ¶ added in v2.0.59
func (m *DownloadPieceRequest) ValidateAll() error
ValidateAll checks the field values on DownloadPieceRequest 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 DownloadPieceRequestMultiError, or nil if none found.
type DownloadPieceRequestMultiError ¶ added in v2.0.59
type DownloadPieceRequestMultiError []error
DownloadPieceRequestMultiError is an error wrapping multiple validation errors returned by DownloadPieceRequest.ValidateAll() if the designated constraints aren't met.
func (DownloadPieceRequestMultiError) AllErrors ¶ added in v2.0.59
func (m DownloadPieceRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadPieceRequestMultiError) Error ¶ added in v2.0.59
func (m DownloadPieceRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadPieceRequestValidationError ¶ added in v2.0.59
type DownloadPieceRequestValidationError struct {
// contains filtered or unexported fields
}
DownloadPieceRequestValidationError is the validation error returned by DownloadPieceRequest.Validate if the designated constraints aren't met.
func (DownloadPieceRequestValidationError) Cause ¶ added in v2.0.59
func (e DownloadPieceRequestValidationError) Cause() error
Cause function returns cause value.
func (DownloadPieceRequestValidationError) Error ¶ added in v2.0.59
func (e DownloadPieceRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadPieceRequestValidationError) ErrorName ¶ added in v2.0.59
func (e DownloadPieceRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadPieceRequestValidationError) Field ¶ added in v2.0.59
func (e DownloadPieceRequestValidationError) Field() string
Field function returns field value.
func (DownloadPieceRequestValidationError) Key ¶ added in v2.0.59
func (e DownloadPieceRequestValidationError) Key() bool
Key function returns key value.
func (DownloadPieceRequestValidationError) Reason ¶ added in v2.0.59
func (e DownloadPieceRequestValidationError) Reason() string
Reason function returns reason value.
type DownloadPieceResponse ¶ added in v2.0.59
type DownloadPieceResponse struct { // Piece information. Piece *v2.Piece `protobuf:"bytes,1,opt,name=piece,proto3" json:"piece,omitempty"` // contains filtered or unexported fields }
DownloadPieceResponse represents response of DownloadPieces.
func (*DownloadPieceResponse) Descriptor
deprecated
added in
v2.0.59
func (*DownloadPieceResponse) Descriptor() ([]byte, []int)
Deprecated: Use DownloadPieceResponse.ProtoReflect.Descriptor instead.
func (*DownloadPieceResponse) GetPiece ¶ added in v2.0.59
func (x *DownloadPieceResponse) GetPiece() *v2.Piece
func (*DownloadPieceResponse) ProtoMessage ¶ added in v2.0.59
func (*DownloadPieceResponse) ProtoMessage()
func (*DownloadPieceResponse) ProtoReflect ¶ added in v2.0.59
func (x *DownloadPieceResponse) ProtoReflect() protoreflect.Message
func (*DownloadPieceResponse) Reset ¶ added in v2.0.59
func (x *DownloadPieceResponse) Reset()
func (*DownloadPieceResponse) String ¶ added in v2.0.59
func (x *DownloadPieceResponse) String() string
func (*DownloadPieceResponse) Validate ¶ added in v2.0.59
func (m *DownloadPieceResponse) Validate() error
Validate checks the field values on DownloadPieceResponse 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 (*DownloadPieceResponse) ValidateAll ¶ added in v2.0.59
func (m *DownloadPieceResponse) ValidateAll() error
ValidateAll checks the field values on DownloadPieceResponse 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 DownloadPieceResponseMultiError, or nil if none found.
type DownloadPieceResponseMultiError ¶ added in v2.0.59
type DownloadPieceResponseMultiError []error
DownloadPieceResponseMultiError is an error wrapping multiple validation errors returned by DownloadPieceResponse.ValidateAll() if the designated constraints aren't met.
func (DownloadPieceResponseMultiError) AllErrors ¶ added in v2.0.59
func (m DownloadPieceResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadPieceResponseMultiError) Error ¶ added in v2.0.59
func (m DownloadPieceResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadPieceResponseValidationError ¶ added in v2.0.59
type DownloadPieceResponseValidationError struct {
// contains filtered or unexported fields
}
DownloadPieceResponseValidationError is the validation error returned by DownloadPieceResponse.Validate if the designated constraints aren't met.
func (DownloadPieceResponseValidationError) Cause ¶ added in v2.0.59
func (e DownloadPieceResponseValidationError) Cause() error
Cause function returns cause value.
func (DownloadPieceResponseValidationError) Error ¶ added in v2.0.59
func (e DownloadPieceResponseValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadPieceResponseValidationError) ErrorName ¶ added in v2.0.59
func (e DownloadPieceResponseValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadPieceResponseValidationError) Field ¶ added in v2.0.59
func (e DownloadPieceResponseValidationError) Field() string
Field function returns field value.
func (DownloadPieceResponseValidationError) Key ¶ added in v2.0.59
func (e DownloadPieceResponseValidationError) Key() bool
Key function returns key value.
func (DownloadPieceResponseValidationError) Reason ¶ added in v2.0.59
func (e DownloadPieceResponseValidationError) Reason() string
Reason function returns reason value.
type DownloadTaskRequest ¶
type DownloadTaskRequest struct { // Download information. DownloadTask *v2.DownloadTask `protobuf:"bytes,1,opt,name=download_task,json=downloadTask,proto3" json:"download_task,omitempty"` // contains filtered or unexported fields }
DownloadTaskRequest represents request of DownloadTask.
func (*DownloadTaskRequest) Descriptor
deprecated
func (*DownloadTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadTaskRequest.ProtoReflect.Descriptor instead.
func (*DownloadTaskRequest) GetDownloadTask ¶ added in v2.0.116
func (x *DownloadTaskRequest) GetDownloadTask() *v2.DownloadTask
func (*DownloadTaskRequest) ProtoMessage ¶
func (*DownloadTaskRequest) ProtoMessage()
func (*DownloadTaskRequest) ProtoReflect ¶
func (x *DownloadTaskRequest) ProtoReflect() protoreflect.Message
func (*DownloadTaskRequest) Reset ¶
func (x *DownloadTaskRequest) Reset()
func (*DownloadTaskRequest) String ¶
func (x *DownloadTaskRequest) String() string
func (*DownloadTaskRequest) Validate ¶
func (m *DownloadTaskRequest) Validate() error
Validate checks the field values on DownloadTaskRequest 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 (*DownloadTaskRequest) ValidateAll ¶
func (m *DownloadTaskRequest) ValidateAll() error
ValidateAll checks the field values on DownloadTaskRequest 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 DownloadTaskRequestMultiError, or nil if none found.
type DownloadTaskRequestMultiError ¶
type DownloadTaskRequestMultiError []error
DownloadTaskRequestMultiError is an error wrapping multiple validation errors returned by DownloadTaskRequest.ValidateAll() if the designated constraints aren't met.
func (DownloadTaskRequestMultiError) AllErrors ¶
func (m DownloadTaskRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadTaskRequestMultiError) Error ¶
func (m DownloadTaskRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadTaskRequestValidationError ¶
type DownloadTaskRequestValidationError struct {
// contains filtered or unexported fields
}
DownloadTaskRequestValidationError is the validation error returned by DownloadTaskRequest.Validate if the designated constraints aren't met.
func (DownloadTaskRequestValidationError) Cause ¶
func (e DownloadTaskRequestValidationError) Cause() error
Cause function returns cause value.
func (DownloadTaskRequestValidationError) Error ¶
func (e DownloadTaskRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadTaskRequestValidationError) ErrorName ¶
func (e DownloadTaskRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadTaskRequestValidationError) Field ¶
func (e DownloadTaskRequestValidationError) Field() string
Field function returns field value.
func (DownloadTaskRequestValidationError) Key ¶
func (e DownloadTaskRequestValidationError) Key() bool
Key function returns key value.
func (DownloadTaskRequestValidationError) Reason ¶
func (e DownloadTaskRequestValidationError) Reason() string
Reason function returns reason value.
type DownloadTaskResponse ¶ added in v2.0.51
type DownloadTaskResponse struct { // Host id. HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"` // Task id. TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // Peer id. PeerId string `protobuf:"bytes,3,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"` // Types that are assignable to Response: // // *DownloadTaskResponse_DownloadTaskStartedResponse // *DownloadTaskResponse_DownloadPieceFinishedResponse Response isDownloadTaskResponse_Response `protobuf_oneof:"response"` // contains filtered or unexported fields }
DownloadTaskResponse represents response of DownloadTask.
func (*DownloadTaskResponse) Descriptor
deprecated
added in
v2.0.51
func (*DownloadTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use DownloadTaskResponse.ProtoReflect.Descriptor instead.
func (*DownloadTaskResponse) GetDownloadPieceFinishedResponse ¶ added in v2.0.66
func (x *DownloadTaskResponse) GetDownloadPieceFinishedResponse() *DownloadPieceFinishedResponse
func (*DownloadTaskResponse) GetDownloadTaskStartedResponse ¶ added in v2.0.66
func (x *DownloadTaskResponse) GetDownloadTaskStartedResponse() *DownloadTaskStartedResponse
func (*DownloadTaskResponse) GetHostId ¶ added in v2.0.65
func (x *DownloadTaskResponse) GetHostId() string
func (*DownloadTaskResponse) GetPeerId ¶ added in v2.0.65
func (x *DownloadTaskResponse) GetPeerId() string
func (*DownloadTaskResponse) GetResponse ¶ added in v2.0.66
func (m *DownloadTaskResponse) GetResponse() isDownloadTaskResponse_Response
func (*DownloadTaskResponse) GetTaskId ¶ added in v2.0.65
func (x *DownloadTaskResponse) GetTaskId() string
func (*DownloadTaskResponse) ProtoMessage ¶ added in v2.0.51
func (*DownloadTaskResponse) ProtoMessage()
func (*DownloadTaskResponse) ProtoReflect ¶ added in v2.0.51
func (x *DownloadTaskResponse) ProtoReflect() protoreflect.Message
func (*DownloadTaskResponse) Reset ¶ added in v2.0.51
func (x *DownloadTaskResponse) Reset()
func (*DownloadTaskResponse) String ¶ added in v2.0.51
func (x *DownloadTaskResponse) String() string
func (*DownloadTaskResponse) Validate ¶ added in v2.0.51
func (m *DownloadTaskResponse) Validate() error
Validate checks the field values on DownloadTaskResponse 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 (*DownloadTaskResponse) ValidateAll ¶ added in v2.0.51
func (m *DownloadTaskResponse) ValidateAll() error
ValidateAll checks the field values on DownloadTaskResponse 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 DownloadTaskResponseMultiError, or nil if none found.
type DownloadTaskResponseMultiError ¶ added in v2.0.51
type DownloadTaskResponseMultiError []error
DownloadTaskResponseMultiError is an error wrapping multiple validation errors returned by DownloadTaskResponse.ValidateAll() if the designated constraints aren't met.
func (DownloadTaskResponseMultiError) AllErrors ¶ added in v2.0.51
func (m DownloadTaskResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadTaskResponseMultiError) Error ¶ added in v2.0.51
func (m DownloadTaskResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadTaskResponseValidationError ¶ added in v2.0.51
type DownloadTaskResponseValidationError struct {
// contains filtered or unexported fields
}
DownloadTaskResponseValidationError is the validation error returned by DownloadTaskResponse.Validate if the designated constraints aren't met.
func (DownloadTaskResponseValidationError) Cause ¶ added in v2.0.51
func (e DownloadTaskResponseValidationError) Cause() error
Cause function returns cause value.
func (DownloadTaskResponseValidationError) Error ¶ added in v2.0.51
func (e DownloadTaskResponseValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadTaskResponseValidationError) ErrorName ¶ added in v2.0.51
func (e DownloadTaskResponseValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadTaskResponseValidationError) Field ¶ added in v2.0.51
func (e DownloadTaskResponseValidationError) Field() string
Field function returns field value.
func (DownloadTaskResponseValidationError) Key ¶ added in v2.0.51
func (e DownloadTaskResponseValidationError) Key() bool
Key function returns key value.
func (DownloadTaskResponseValidationError) Reason ¶ added in v2.0.51
func (e DownloadTaskResponseValidationError) Reason() string
Reason function returns reason value.
type DownloadTaskResponse_DownloadPieceFinishedResponse ¶ added in v2.0.66
type DownloadTaskResponse_DownloadPieceFinishedResponse struct {
DownloadPieceFinishedResponse *DownloadPieceFinishedResponse `protobuf:"bytes,5,opt,name=download_piece_finished_response,json=downloadPieceFinishedResponse,proto3,oneof"`
}
type DownloadTaskResponse_DownloadTaskStartedResponse ¶ added in v2.0.66
type DownloadTaskResponse_DownloadTaskStartedResponse struct {
DownloadTaskStartedResponse *DownloadTaskStartedResponse `protobuf:"bytes,4,opt,name=download_task_started_response,json=downloadTaskStartedResponse,proto3,oneof"`
}
type DownloadTaskStartedResponse ¶ added in v2.0.66
type DownloadTaskStartedResponse struct { // Task content length. ContentLength uint64 `protobuf:"varint,1,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"` // Range is url range of request. If protocol is http, range // is parsed from http header. If other protocol, range comes // from download range field. Range *v2.Range `protobuf:"bytes,2,opt,name=range,proto3,oneof" json:"range,omitempty"` // Task response headers. ResponseHeader map[string]string `` /* 191-byte string literal not displayed */ // Need to download pieces. Pieces []*v2.Piece `protobuf:"bytes,4,rep,name=pieces,proto3" json:"pieces,omitempty"` // contains filtered or unexported fields }
DownloadTaskStartedResponse represents task download started response of DownloadTaskResponse.
func (*DownloadTaskStartedResponse) Descriptor
deprecated
added in
v2.0.66
func (*DownloadTaskStartedResponse) Descriptor() ([]byte, []int)
Deprecated: Use DownloadTaskStartedResponse.ProtoReflect.Descriptor instead.
func (*DownloadTaskStartedResponse) GetContentLength ¶ added in v2.0.66
func (x *DownloadTaskStartedResponse) GetContentLength() uint64
func (*DownloadTaskStartedResponse) GetPieces ¶ added in v2.0.91
func (x *DownloadTaskStartedResponse) GetPieces() []*v2.Piece
func (*DownloadTaskStartedResponse) GetRange ¶ added in v2.0.90
func (x *DownloadTaskStartedResponse) GetRange() *v2.Range
func (*DownloadTaskStartedResponse) GetResponseHeader ¶ added in v2.0.89
func (x *DownloadTaskStartedResponse) GetResponseHeader() map[string]string
func (*DownloadTaskStartedResponse) ProtoMessage ¶ added in v2.0.66
func (*DownloadTaskStartedResponse) ProtoMessage()
func (*DownloadTaskStartedResponse) ProtoReflect ¶ added in v2.0.66
func (x *DownloadTaskStartedResponse) ProtoReflect() protoreflect.Message
func (*DownloadTaskStartedResponse) Reset ¶ added in v2.0.66
func (x *DownloadTaskStartedResponse) Reset()
func (*DownloadTaskStartedResponse) String ¶ added in v2.0.66
func (x *DownloadTaskStartedResponse) String() string
func (*DownloadTaskStartedResponse) Validate ¶ added in v2.0.66
func (m *DownloadTaskStartedResponse) Validate() error
Validate checks the field values on DownloadTaskStartedResponse 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 (*DownloadTaskStartedResponse) ValidateAll ¶ added in v2.0.66
func (m *DownloadTaskStartedResponse) ValidateAll() error
ValidateAll checks the field values on DownloadTaskStartedResponse 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 DownloadTaskStartedResponseMultiError, or nil if none found.
type DownloadTaskStartedResponseMultiError ¶ added in v2.0.66
type DownloadTaskStartedResponseMultiError []error
DownloadTaskStartedResponseMultiError is an error wrapping multiple validation errors returned by DownloadTaskStartedResponse.ValidateAll() if the designated constraints aren't met.
func (DownloadTaskStartedResponseMultiError) AllErrors ¶ added in v2.0.66
func (m DownloadTaskStartedResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DownloadTaskStartedResponseMultiError) Error ¶ added in v2.0.66
func (m DownloadTaskStartedResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DownloadTaskStartedResponseValidationError ¶ added in v2.0.66
type DownloadTaskStartedResponseValidationError struct {
// contains filtered or unexported fields
}
DownloadTaskStartedResponseValidationError is the validation error returned by DownloadTaskStartedResponse.Validate if the designated constraints aren't met.
func (DownloadTaskStartedResponseValidationError) Cause ¶ added in v2.0.66
func (e DownloadTaskStartedResponseValidationError) Cause() error
Cause function returns cause value.
func (DownloadTaskStartedResponseValidationError) Error ¶ added in v2.0.66
func (e DownloadTaskStartedResponseValidationError) Error() string
Error satisfies the builtin error interface
func (DownloadTaskStartedResponseValidationError) ErrorName ¶ added in v2.0.66
func (e DownloadTaskStartedResponseValidationError) ErrorName() string
ErrorName returns error name.
func (DownloadTaskStartedResponseValidationError) Field ¶ added in v2.0.66
func (e DownloadTaskStartedResponseValidationError) Field() string
Field function returns field value.
func (DownloadTaskStartedResponseValidationError) Key ¶ added in v2.0.66
func (e DownloadTaskStartedResponseValidationError) Key() bool
Key function returns key value.
func (DownloadTaskStartedResponseValidationError) Reason ¶ added in v2.0.66
func (e DownloadTaskStartedResponseValidationError) Reason() string
Reason function returns reason value.
type StatCacheTaskRequest ¶ added in v2.0.116
type StatCacheTaskRequest struct { // Task id. TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // contains filtered or unexported fields }
StatCacheTaskRequest represents request of StatCacheTask.
func (*StatCacheTaskRequest) Descriptor
deprecated
added in
v2.0.116
func (*StatCacheTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatCacheTaskRequest.ProtoReflect.Descriptor instead.
func (*StatCacheTaskRequest) GetTaskId ¶ added in v2.0.116
func (x *StatCacheTaskRequest) GetTaskId() string
func (*StatCacheTaskRequest) ProtoMessage ¶ added in v2.0.116
func (*StatCacheTaskRequest) ProtoMessage()
func (*StatCacheTaskRequest) ProtoReflect ¶ added in v2.0.116
func (x *StatCacheTaskRequest) ProtoReflect() protoreflect.Message
func (*StatCacheTaskRequest) Reset ¶ added in v2.0.116
func (x *StatCacheTaskRequest) Reset()
func (*StatCacheTaskRequest) String ¶ added in v2.0.116
func (x *StatCacheTaskRequest) String() string
func (*StatCacheTaskRequest) Validate ¶ added in v2.0.116
func (m *StatCacheTaskRequest) Validate() error
Validate checks the field values on StatCacheTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*StatCacheTaskRequest) ValidateAll ¶ added in v2.0.116
func (m *StatCacheTaskRequest) ValidateAll() error
ValidateAll checks the field values on StatCacheTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StatCacheTaskRequestMultiError, or nil if none found.
type StatCacheTaskRequestMultiError ¶ added in v2.0.116
type StatCacheTaskRequestMultiError []error
StatCacheTaskRequestMultiError is an error wrapping multiple validation errors returned by StatCacheTaskRequest.ValidateAll() if the designated constraints aren't met.
func (StatCacheTaskRequestMultiError) AllErrors ¶ added in v2.0.116
func (m StatCacheTaskRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StatCacheTaskRequestMultiError) Error ¶ added in v2.0.116
func (m StatCacheTaskRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StatCacheTaskRequestValidationError ¶ added in v2.0.116
type StatCacheTaskRequestValidationError struct {
// contains filtered or unexported fields
}
StatCacheTaskRequestValidationError is the validation error returned by StatCacheTaskRequest.Validate if the designated constraints aren't met.
func (StatCacheTaskRequestValidationError) Cause ¶ added in v2.0.116
func (e StatCacheTaskRequestValidationError) Cause() error
Cause function returns cause value.
func (StatCacheTaskRequestValidationError) Error ¶ added in v2.0.116
func (e StatCacheTaskRequestValidationError) Error() string
Error satisfies the builtin error interface
func (StatCacheTaskRequestValidationError) ErrorName ¶ added in v2.0.116
func (e StatCacheTaskRequestValidationError) ErrorName() string
ErrorName returns error name.
func (StatCacheTaskRequestValidationError) Field ¶ added in v2.0.116
func (e StatCacheTaskRequestValidationError) Field() string
Field function returns field value.
func (StatCacheTaskRequestValidationError) Key ¶ added in v2.0.116
func (e StatCacheTaskRequestValidationError) Key() bool
Key function returns key value.
func (StatCacheTaskRequestValidationError) Reason ¶ added in v2.0.116
func (e StatCacheTaskRequestValidationError) Reason() string
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 ¶
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 SyncPiecesRequest ¶
type SyncPiecesRequest struct { // Host id. HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"` // Task id. TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // Interested piece numbers. InterestedPieceNumbers []uint32 `` /* 137-byte string literal not displayed */ // contains filtered or unexported fields }
SyncPiecesRequest represents request of SyncPieces.
func (*SyncPiecesRequest) Descriptor
deprecated
func (*SyncPiecesRequest) Descriptor() ([]byte, []int)
Deprecated: Use SyncPiecesRequest.ProtoReflect.Descriptor instead.
func (*SyncPiecesRequest) GetHostId ¶ added in v2.0.115
func (x *SyncPiecesRequest) GetHostId() string
func (*SyncPiecesRequest) GetInterestedPieceNumbers ¶ added in v2.0.61
func (x *SyncPiecesRequest) GetInterestedPieceNumbers() []uint32
func (*SyncPiecesRequest) GetTaskId ¶ added in v2.0.26
func (x *SyncPiecesRequest) GetTaskId() string
func (*SyncPiecesRequest) ProtoMessage ¶
func (*SyncPiecesRequest) ProtoMessage()
func (*SyncPiecesRequest) ProtoReflect ¶
func (x *SyncPiecesRequest) ProtoReflect() protoreflect.Message
func (*SyncPiecesRequest) Reset ¶
func (x *SyncPiecesRequest) Reset()
func (*SyncPiecesRequest) String ¶
func (x *SyncPiecesRequest) String() string
func (*SyncPiecesRequest) Validate ¶
func (m *SyncPiecesRequest) Validate() error
Validate checks the field values on SyncPiecesRequest 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 (*SyncPiecesRequest) ValidateAll ¶
func (m *SyncPiecesRequest) ValidateAll() error
ValidateAll checks the field values on SyncPiecesRequest 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 SyncPiecesRequestMultiError, or nil if none found.
type SyncPiecesRequestMultiError ¶
type SyncPiecesRequestMultiError []error
SyncPiecesRequestMultiError is an error wrapping multiple validation errors returned by SyncPiecesRequest.ValidateAll() if the designated constraints aren't met.
func (SyncPiecesRequestMultiError) AllErrors ¶
func (m SyncPiecesRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (SyncPiecesRequestMultiError) Error ¶
func (m SyncPiecesRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type SyncPiecesRequestValidationError ¶
type SyncPiecesRequestValidationError struct {
// contains filtered or unexported fields
}
SyncPiecesRequestValidationError is the validation error returned by SyncPiecesRequest.Validate if the designated constraints aren't met.
func (SyncPiecesRequestValidationError) Cause ¶
func (e SyncPiecesRequestValidationError) Cause() error
Cause function returns cause value.
func (SyncPiecesRequestValidationError) Error ¶
func (e SyncPiecesRequestValidationError) Error() string
Error satisfies the builtin error interface
func (SyncPiecesRequestValidationError) ErrorName ¶
func (e SyncPiecesRequestValidationError) ErrorName() string
ErrorName returns error name.
func (SyncPiecesRequestValidationError) Field ¶
func (e SyncPiecesRequestValidationError) Field() string
Field function returns field value.
func (SyncPiecesRequestValidationError) Key ¶
func (e SyncPiecesRequestValidationError) Key() bool
Key function returns key value.
func (SyncPiecesRequestValidationError) Reason ¶
func (e SyncPiecesRequestValidationError) Reason() string
Reason function returns reason value.
type SyncPiecesResponse ¶
type SyncPiecesResponse struct { // Exist piece number. Number uint32 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"` // Piece offset. Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` // Piece length. Length uint64 `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"` // contains filtered or unexported fields }
SyncPiecesResponse represents response of SyncPieces.
func (*SyncPiecesResponse) Descriptor
deprecated
func (*SyncPiecesResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncPiecesResponse.ProtoReflect.Descriptor instead.
func (*SyncPiecesResponse) GetLength ¶ added in v2.0.77
func (x *SyncPiecesResponse) GetLength() uint64
func (*SyncPiecesResponse) GetNumber ¶ added in v2.0.77
func (x *SyncPiecesResponse) GetNumber() uint32
func (*SyncPiecesResponse) GetOffset ¶ added in v2.0.77
func (x *SyncPiecesResponse) GetOffset() uint64
func (*SyncPiecesResponse) ProtoMessage ¶
func (*SyncPiecesResponse) ProtoMessage()
func (*SyncPiecesResponse) ProtoReflect ¶
func (x *SyncPiecesResponse) ProtoReflect() protoreflect.Message
func (*SyncPiecesResponse) Reset ¶
func (x *SyncPiecesResponse) Reset()
func (*SyncPiecesResponse) String ¶
func (x *SyncPiecesResponse) String() string
func (*SyncPiecesResponse) Validate ¶
func (m *SyncPiecesResponse) Validate() error
Validate checks the field values on SyncPiecesResponse 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 (*SyncPiecesResponse) ValidateAll ¶
func (m *SyncPiecesResponse) ValidateAll() error
ValidateAll checks the field values on SyncPiecesResponse 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 SyncPiecesResponseMultiError, or nil if none found.
type SyncPiecesResponseMultiError ¶
type SyncPiecesResponseMultiError []error
SyncPiecesResponseMultiError is an error wrapping multiple validation errors returned by SyncPiecesResponse.ValidateAll() if the designated constraints aren't met.
func (SyncPiecesResponseMultiError) AllErrors ¶
func (m SyncPiecesResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (SyncPiecesResponseMultiError) Error ¶
func (m SyncPiecesResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type SyncPiecesResponseValidationError ¶
type SyncPiecesResponseValidationError struct {
// contains filtered or unexported fields
}
SyncPiecesResponseValidationError is the validation error returned by SyncPiecesResponse.Validate if the designated constraints aren't met.
func (SyncPiecesResponseValidationError) Cause ¶
func (e SyncPiecesResponseValidationError) Cause() error
Cause function returns cause value.
func (SyncPiecesResponseValidationError) Error ¶
func (e SyncPiecesResponseValidationError) Error() string
Error satisfies the builtin error interface
func (SyncPiecesResponseValidationError) ErrorName ¶
func (e SyncPiecesResponseValidationError) ErrorName() string
ErrorName returns error name.
func (SyncPiecesResponseValidationError) Field ¶
func (e SyncPiecesResponseValidationError) Field() string
Field function returns field value.
func (SyncPiecesResponseValidationError) Key ¶
func (e SyncPiecesResponseValidationError) Key() bool
Key function returns key value.
func (SyncPiecesResponseValidationError) Reason ¶
func (e SyncPiecesResponseValidationError) Reason() string
Reason function returns reason value.
type UnimplementedDfdaemonDownloadServer ¶ added in v2.0.63
type UnimplementedDfdaemonDownloadServer struct { }
UnimplementedDfdaemonDownloadServer should be embedded to have forward compatible implementations.
func (UnimplementedDfdaemonDownloadServer) DeleteCacheTask ¶ added in v2.0.116
func (UnimplementedDfdaemonDownloadServer) DeleteCacheTask(context.Context, *DeleteCacheTaskRequest) (*emptypb.Empty, error)
func (UnimplementedDfdaemonDownloadServer) DeleteTask ¶ added in v2.0.63
func (UnimplementedDfdaemonDownloadServer) DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)
func (UnimplementedDfdaemonDownloadServer) DownloadCacheTask ¶ added in v2.0.116
func (UnimplementedDfdaemonDownloadServer) DownloadCacheTask(*DownloadCacheTaskRequest, DfdaemonDownload_DownloadCacheTaskServer) error
func (UnimplementedDfdaemonDownloadServer) DownloadTask ¶ added in v2.0.63
func (UnimplementedDfdaemonDownloadServer) DownloadTask(*DownloadTaskRequest, DfdaemonDownload_DownloadTaskServer) error
func (UnimplementedDfdaemonDownloadServer) StatCacheTask ¶ added in v2.0.116
func (UnimplementedDfdaemonDownloadServer) StatCacheTask(context.Context, *StatCacheTaskRequest) (*v2.CacheTask, error)
func (UnimplementedDfdaemonDownloadServer) StatTask ¶ added in v2.0.63
func (UnimplementedDfdaemonDownloadServer) StatTask(context.Context, *StatTaskRequest) (*v2.Task, error)
func (UnimplementedDfdaemonDownloadServer) UploadCacheTask ¶ added in v2.0.116
func (UnimplementedDfdaemonDownloadServer) UploadCacheTask(context.Context, *UploadCacheTaskRequest) (*v2.CacheTask, error)
func (UnimplementedDfdaemonDownloadServer) UploadTask ¶ added in v2.0.63
func (UnimplementedDfdaemonDownloadServer) UploadTask(context.Context, *UploadTaskRequest) (*emptypb.Empty, error)
type UnimplementedDfdaemonUploadServer ¶ added in v2.0.63
type UnimplementedDfdaemonUploadServer struct { }
UnimplementedDfdaemonUploadServer should be embedded to have forward compatible implementations.
func (UnimplementedDfdaemonUploadServer) DeleteCacheTask ¶ added in v2.0.116
func (UnimplementedDfdaemonUploadServer) DeleteCacheTask(context.Context, *DeleteCacheTaskRequest) (*emptypb.Empty, error)
func (UnimplementedDfdaemonUploadServer) DownloadCacheTask ¶ added in v2.0.116
func (UnimplementedDfdaemonUploadServer) DownloadCacheTask(*DownloadCacheTaskRequest, DfdaemonUpload_DownloadCacheTaskServer) error
func (UnimplementedDfdaemonUploadServer) DownloadPiece ¶ added in v2.0.63
func (UnimplementedDfdaemonUploadServer) DownloadPiece(context.Context, *DownloadPieceRequest) (*DownloadPieceResponse, error)
func (UnimplementedDfdaemonUploadServer) DownloadTask ¶ added in v2.0.64
func (UnimplementedDfdaemonUploadServer) DownloadTask(*DownloadTaskRequest, DfdaemonUpload_DownloadTaskServer) error
func (UnimplementedDfdaemonUploadServer) StatCacheTask ¶ added in v2.0.116
func (UnimplementedDfdaemonUploadServer) StatCacheTask(context.Context, *StatCacheTaskRequest) (*v2.CacheTask, error)
func (UnimplementedDfdaemonUploadServer) SyncPieces ¶ added in v2.0.63
func (UnimplementedDfdaemonUploadServer) SyncPieces(*SyncPiecesRequest, DfdaemonUpload_SyncPiecesServer) error
type UnsafeDfdaemonDownloadServer ¶ added in v2.0.63
type UnsafeDfdaemonDownloadServer interface {
// contains filtered or unexported methods
}
UnsafeDfdaemonDownloadServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DfdaemonDownloadServer will result in compilation errors.
type UnsafeDfdaemonUploadServer ¶ added in v2.0.63
type UnsafeDfdaemonUploadServer interface {
// contains filtered or unexported methods
}
UnsafeDfdaemonUploadServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DfdaemonUploadServer will result in compilation errors.
type UploadCacheTaskRequest ¶ added in v2.0.116
type UploadCacheTaskRequest struct { // Upload file path of cache task. Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // Replica count of the persistent cache task. PersistentReplicaCount uint64 `` /* 130-byte string literal not displayed */ // Tag is used to distinguish different cache tasks. Tag *string `protobuf:"bytes,3,opt,name=tag,proto3,oneof" json:"tag,omitempty"` // Application of task. Application *string `protobuf:"bytes,4,opt,name=application,proto3,oneof" json:"application,omitempty"` // Task piece length. PieceLength uint64 `protobuf:"varint,5,opt,name=piece_length,json=pieceLength,proto3" json:"piece_length,omitempty"` // Download timeout. Timeout *durationpb.Duration `protobuf:"bytes,6,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"` // contains filtered or unexported fields }
UploadCacheTaskRequest represents request of UploadCacheTask.
func (*UploadCacheTaskRequest) Descriptor
deprecated
added in
v2.0.116
func (*UploadCacheTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use UploadCacheTaskRequest.ProtoReflect.Descriptor instead.
func (*UploadCacheTaskRequest) GetApplication ¶ added in v2.0.116
func (x *UploadCacheTaskRequest) GetApplication() string
func (*UploadCacheTaskRequest) GetPath ¶ added in v2.0.116
func (x *UploadCacheTaskRequest) GetPath() string
func (*UploadCacheTaskRequest) GetPersistentReplicaCount ¶ added in v2.0.116
func (x *UploadCacheTaskRequest) GetPersistentReplicaCount() uint64
func (*UploadCacheTaskRequest) GetPieceLength ¶ added in v2.0.116
func (x *UploadCacheTaskRequest) GetPieceLength() uint64
func (*UploadCacheTaskRequest) GetTag ¶ added in v2.0.116
func (x *UploadCacheTaskRequest) GetTag() string
func (*UploadCacheTaskRequest) GetTimeout ¶ added in v2.0.116
func (x *UploadCacheTaskRequest) GetTimeout() *durationpb.Duration
func (*UploadCacheTaskRequest) ProtoMessage ¶ added in v2.0.116
func (*UploadCacheTaskRequest) ProtoMessage()
func (*UploadCacheTaskRequest) ProtoReflect ¶ added in v2.0.116
func (x *UploadCacheTaskRequest) ProtoReflect() protoreflect.Message
func (*UploadCacheTaskRequest) Reset ¶ added in v2.0.116
func (x *UploadCacheTaskRequest) Reset()
func (*UploadCacheTaskRequest) String ¶ added in v2.0.116
func (x *UploadCacheTaskRequest) String() string
func (*UploadCacheTaskRequest) Validate ¶ added in v2.0.116
func (m *UploadCacheTaskRequest) Validate() error
Validate checks the field values on UploadCacheTaskRequest 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 (*UploadCacheTaskRequest) ValidateAll ¶ added in v2.0.116
func (m *UploadCacheTaskRequest) ValidateAll() error
ValidateAll checks the field values on UploadCacheTaskRequest 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 UploadCacheTaskRequestMultiError, or nil if none found.
type UploadCacheTaskRequestMultiError ¶ added in v2.0.116
type UploadCacheTaskRequestMultiError []error
UploadCacheTaskRequestMultiError is an error wrapping multiple validation errors returned by UploadCacheTaskRequest.ValidateAll() if the designated constraints aren't met.
func (UploadCacheTaskRequestMultiError) AllErrors ¶ added in v2.0.116
func (m UploadCacheTaskRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (UploadCacheTaskRequestMultiError) Error ¶ added in v2.0.116
func (m UploadCacheTaskRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type UploadCacheTaskRequestValidationError ¶ added in v2.0.116
type UploadCacheTaskRequestValidationError struct {
// contains filtered or unexported fields
}
UploadCacheTaskRequestValidationError is the validation error returned by UploadCacheTaskRequest.Validate if the designated constraints aren't met.
func (UploadCacheTaskRequestValidationError) Cause ¶ added in v2.0.116
func (e UploadCacheTaskRequestValidationError) Cause() error
Cause function returns cause value.
func (UploadCacheTaskRequestValidationError) Error ¶ added in v2.0.116
func (e UploadCacheTaskRequestValidationError) Error() string
Error satisfies the builtin error interface
func (UploadCacheTaskRequestValidationError) ErrorName ¶ added in v2.0.116
func (e UploadCacheTaskRequestValidationError) ErrorName() string
ErrorName returns error name.
func (UploadCacheTaskRequestValidationError) Field ¶ added in v2.0.116
func (e UploadCacheTaskRequestValidationError) Field() string
Field function returns field value.
func (UploadCacheTaskRequestValidationError) Key ¶ added in v2.0.116
func (e UploadCacheTaskRequestValidationError) Key() bool
Key function returns key value.
func (UploadCacheTaskRequestValidationError) Reason ¶ added in v2.0.116
func (e UploadCacheTaskRequestValidationError) Reason() string
Reason function returns reason value.
type UploadTaskRequest ¶
type UploadTaskRequest struct { // Task metadata. Task *v2.Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` // contains filtered or unexported fields }
UploadTaskRequest represents request of UploadTask.
func (*UploadTaskRequest) Descriptor
deprecated
func (*UploadTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use UploadTaskRequest.ProtoReflect.Descriptor instead.
func (*UploadTaskRequest) GetTask ¶
func (x *UploadTaskRequest) GetTask() *v2.Task
func (*UploadTaskRequest) ProtoMessage ¶
func (*UploadTaskRequest) ProtoMessage()
func (*UploadTaskRequest) ProtoReflect ¶
func (x *UploadTaskRequest) ProtoReflect() protoreflect.Message
func (*UploadTaskRequest) Reset ¶
func (x *UploadTaskRequest) Reset()
func (*UploadTaskRequest) String ¶
func (x *UploadTaskRequest) String() string
func (*UploadTaskRequest) Validate ¶
func (m *UploadTaskRequest) Validate() error
Validate checks the field values on UploadTaskRequest 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 (*UploadTaskRequest) ValidateAll ¶
func (m *UploadTaskRequest) ValidateAll() error
ValidateAll checks the field values on UploadTaskRequest 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 UploadTaskRequestMultiError, or nil if none found.
type UploadTaskRequestMultiError ¶
type UploadTaskRequestMultiError []error
UploadTaskRequestMultiError is an error wrapping multiple validation errors returned by UploadTaskRequest.ValidateAll() if the designated constraints aren't met.
func (UploadTaskRequestMultiError) AllErrors ¶
func (m UploadTaskRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (UploadTaskRequestMultiError) Error ¶
func (m UploadTaskRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type UploadTaskRequestValidationError ¶
type UploadTaskRequestValidationError struct {
// contains filtered or unexported fields
}
UploadTaskRequestValidationError is the validation error returned by UploadTaskRequest.Validate if the designated constraints aren't met.
func (UploadTaskRequestValidationError) Cause ¶
func (e UploadTaskRequestValidationError) Cause() error
Cause function returns cause value.
func (UploadTaskRequestValidationError) Error ¶
func (e UploadTaskRequestValidationError) Error() string
Error satisfies the builtin error interface
func (UploadTaskRequestValidationError) ErrorName ¶
func (e UploadTaskRequestValidationError) ErrorName() string
ErrorName returns error name.
func (UploadTaskRequestValidationError) Field ¶
func (e UploadTaskRequestValidationError) Field() string
Field function returns field value.
func (UploadTaskRequestValidationError) Key ¶
func (e UploadTaskRequestValidationError) Key() bool
Key function returns key value.
func (UploadTaskRequestValidationError) Reason ¶
func (e UploadTaskRequestValidationError) Reason() string
Reason function returns reason value.