dfdaemon

package
v2.0.71 Latest Latest
Warning

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

 Go to latest Published: Dec 22, 2023 License: Apache-2.0 Imports: 23 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "DownloadTask",
			Handler:       _DfdaemonDownload_DownloadTask_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)

View Source 
var DfdaemonUpload_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dfdaemon.v2.DfdaemonUpload",
	HandlerType: (*DfdaemonUploadServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "TriggerDownloadTask",
			Handler:    _DfdaemonUpload_TriggerDownloadTask_Handler,
		},
		{
			MethodName: "DownloadPiece",
			Handler:    _DfdaemonUpload_DownloadPiece_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SyncPieces",
			Handler:       _DfdaemonUpload_SyncPieces_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)

View Source 
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 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 back-to-source.
	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)
}

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 back-to-source.
	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)
}

DfdaemonDownloadServer is the server API for DfdaemonDownload service. All implementations should embed UnimplementedDfdaemonDownloadServer for forward compatibility

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 {
	// TriggerDownloadTask triggers download task.
	TriggerDownloadTask(ctx context.Context, in *TriggerDownloadTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, 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)
}

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 {
	// TriggerDownloadTask triggers download task.
	TriggerDownloadTask(context.Context, *TriggerDownloadTaskRequest) (*emptypb.Empty, 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)
}

DfdaemonUploadServer is the server API for DfdaemonUpload service. All implementations should embed UnimplementedDfdaemonUploadServer for forward compatibility

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 DownloadPieceRequest added in v2.0.59 

type DownloadPieceRequest struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Piece number.
	PieceNumber uint32 `protobuf:"varint,2,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) 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.
	Download *v2.Download `protobuf:"bytes,1,opt,name=download,proto3" json:"download,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) GetDownload 

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

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"`
	// Task content length.
	ContentLength uint64 `protobuf:"varint,4,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// Finished piece of task.
	Piece *v2.Piece `protobuf:"bytes,5,opt,name=piece,proto3" json:"piece,omitempty"`
	// 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) GetContentLength added in v2.0.54 

func (x *DownloadTaskResponse) GetContentLength() uint64

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) GetPiece added in v2.0.51 

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

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

	// Task id.
	TaskId string `protobuf:"bytes,1,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) 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.
	PieceNumber uint32 `protobuf:"varint,1,opt,name=piece_number,json=pieceNumber,proto3" json:"piece_number,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) GetPieceNumber added in v2.0.61 

func (x *SyncPiecesResponse) GetPieceNumber() uint32

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 TriggerDownloadTaskRequest added in v2.0.67 

type TriggerDownloadTaskRequest struct {

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

TriggerDownloadTaskRequest represents request of TriggerDownloadTask.

func (*TriggerDownloadTaskRequest) Descriptor deprecated added in v2.0.67 

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

Deprecated: Use TriggerDownloadTaskRequest.ProtoReflect.Descriptor instead.

func (*TriggerDownloadTaskRequest) GetDownload added in v2.0.67 

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

func (*TriggerDownloadTaskRequest) ProtoMessage added in v2.0.67 

func (*TriggerDownloadTaskRequest) ProtoMessage()

func (*TriggerDownloadTaskRequest) ProtoReflect added in v2.0.67 

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

func (*TriggerDownloadTaskRequest) Reset added in v2.0.67 

func (x *TriggerDownloadTaskRequest) Reset()

func (*TriggerDownloadTaskRequest) String added in v2.0.67 

func (x *TriggerDownloadTaskRequest) String() string

func (*TriggerDownloadTaskRequest) Validate added in v2.0.67 

func (m *TriggerDownloadTaskRequest) Validate() error

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

func (m *TriggerDownloadTaskRequest) ValidateAll() error

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

type TriggerDownloadTaskRequestMultiError added in v2.0.67 

type TriggerDownloadTaskRequestMultiError []error

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

func (TriggerDownloadTaskRequestMultiError) AllErrors added in v2.0.67 

func (m TriggerDownloadTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TriggerDownloadTaskRequestMultiError) Error added in v2.0.67 

func (m TriggerDownloadTaskRequestMultiError) Error() string

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

type TriggerDownloadTaskRequestValidationError added in v2.0.67 

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

TriggerDownloadTaskRequestValidationError is the validation error returned by TriggerDownloadTaskRequest.Validate if the designated constraints aren't met.

func (TriggerDownloadTaskRequestValidationError) Cause added in v2.0.67 

func (e TriggerDownloadTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (TriggerDownloadTaskRequestValidationError) Error added in v2.0.67 

func (e TriggerDownloadTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (TriggerDownloadTaskRequestValidationError) ErrorName added in v2.0.67 

func (e TriggerDownloadTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (TriggerDownloadTaskRequestValidationError) Field added in v2.0.67 

func (e TriggerDownloadTaskRequestValidationError) Field() string

Field function returns field value.

func (TriggerDownloadTaskRequestValidationError) Key added in v2.0.67 

func (e TriggerDownloadTaskRequestValidationError) Key() bool

Key function returns key value.

func (TriggerDownloadTaskRequestValidationError) Reason added in v2.0.67 

func (e TriggerDownloadTaskRequestValidationError) 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) DeleteTask added in v2.0.63 

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

func (UnimplementedDfdaemonDownloadServer) DownloadTask added in v2.0.63 

func (UnimplementedDfdaemonDownloadServer) DownloadTask(*DownloadTaskRequest, DfdaemonDownload_DownloadTaskServer) error

func (UnimplementedDfdaemonDownloadServer) StatTask added in v2.0.63 

func (UnimplementedDfdaemonDownloadServer) StatTask(context.Context, *StatTaskRequest) (*v2.Task, 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) DownloadPiece added in v2.0.63 

func (UnimplementedDfdaemonUploadServer) DownloadPiece(context.Context, *DownloadPieceRequest) (*DownloadPieceResponse, error)

func (UnimplementedDfdaemonUploadServer) SyncPieces added in v2.0.63 

func (UnimplementedDfdaemonUploadServer) SyncPieces(*SyncPiecesRequest, DfdaemonUpload_SyncPiecesServer) error

func (UnimplementedDfdaemonUploadServer) TriggerDownloadTask added in v2.0.67 

func (UnimplementedDfdaemonUploadServer) TriggerDownloadTask(context.Context, *TriggerDownloadTaskRequest) (*emptypb.Empty, 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 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.

Source Files

View all Source files

Directories

Path Synopsis
Code generated by MockGen.
 Code generated by MockGen.

Jump to

Keyboard shortcuts

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