dfdaemon

package
v2.0.29 Latest Latest
Warning

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

 Go to latest Published: Sep 21, 2023 License: Apache-2.0 Imports: 24 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Dfdaemon_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dfdaemon.v2.Dfdaemon",
	HandlerType: (*DfdaemonServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DownloadTask",
			Handler:    _Dfdaemon_DownloadTask_Handler,
		},
		{
			MethodName: "UploadTask",
			Handler:    _Dfdaemon_UploadTask_Handler,
		},
		{
			MethodName: "StatTask",
			Handler:    _Dfdaemon_StatTask_Handler,
		},
		{
			MethodName: "DeleteTask",
			Handler:    _Dfdaemon_DeleteTask_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SyncPieces",
			Handler:       _Dfdaemon_SyncPieces_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/apis/dfdaemon/v2/dfdaemon.proto",
}

Dfdaemon_ServiceDesc is the grpc.ServiceDesc for Dfdaemon 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 RegisterDfdaemonServer 

func RegisterDfdaemonServer(s grpc.ServiceRegistrar, srv DfdaemonServer)

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 DfdaemonClient 

type DfdaemonClient interface {
	// SyncPieces syncs pieces from the other peers.
	SyncPieces(ctx context.Context, opts ...grpc.CallOption) (Dfdaemon_SyncPiecesClient, error)
	// DownloadTask downloads task back-to-source.
	DownloadTask(ctx context.Context, in *DownloadTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, 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)
}

DfdaemonClient is the client API for Dfdaemon 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 NewDfdaemonClient 

func NewDfdaemonClient(cc grpc.ClientConnInterface) DfdaemonClient

type DfdaemonServer 

type DfdaemonServer interface {
	// SyncPieces syncs pieces from the other peers.
	SyncPieces(Dfdaemon_SyncPiecesServer) error
	// DownloadTask downloads task back-to-source.
	DownloadTask(context.Context, *DownloadTaskRequest) (*emptypb.Empty, 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)
}

DfdaemonServer is the server API for Dfdaemon service. All implementations should embed UnimplementedDfdaemonServer for forward compatibility

type Dfdaemon_SyncPiecesClient 

type Dfdaemon_SyncPiecesClient interface {
	Send(*SyncPiecesRequest) error
	Recv() (*SyncPiecesResponse, error)
	grpc.ClientStream
}

type Dfdaemon_SyncPiecesServer 

type Dfdaemon_SyncPiecesServer interface {
	Send(*SyncPiecesResponse) error
	Recv() (*SyncPiecesRequest, error)
	grpc.ServerStream
}

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 InterestedAllPiecesRequest 

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

InterestedAllPiecesRequest represents interested all pieces request of SyncPiecesRequest.

func (*InterestedAllPiecesRequest) Descriptor deprecated 

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

Deprecated: Use InterestedAllPiecesRequest.ProtoReflect.Descriptor instead.

func (*InterestedAllPiecesRequest) ProtoMessage 

func (*InterestedAllPiecesRequest) ProtoMessage()

func (*InterestedAllPiecesRequest) ProtoReflect 

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

func (*InterestedAllPiecesRequest) Reset 

func (x *InterestedAllPiecesRequest) Reset()

func (*InterestedAllPiecesRequest) String 

func (x *InterestedAllPiecesRequest) String() string

func (*InterestedAllPiecesRequest) Validate 

func (m *InterestedAllPiecesRequest) Validate() error

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

func (m *InterestedAllPiecesRequest) ValidateAll() error

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

type InterestedAllPiecesRequestMultiError 

type InterestedAllPiecesRequestMultiError []error

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

func (InterestedAllPiecesRequestMultiError) AllErrors 

func (m InterestedAllPiecesRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (InterestedAllPiecesRequestMultiError) Error 

func (m InterestedAllPiecesRequestMultiError) Error() string

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

type InterestedAllPiecesRequestValidationError 

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

InterestedAllPiecesRequestValidationError is the validation error returned by InterestedAllPiecesRequest.Validate if the designated constraints aren't met.

func (InterestedAllPiecesRequestValidationError) Cause 

func (e InterestedAllPiecesRequestValidationError) Cause() error

Cause function returns cause value.

func (InterestedAllPiecesRequestValidationError) Error 

func (e InterestedAllPiecesRequestValidationError) Error() string

Error satisfies the builtin error interface

func (InterestedAllPiecesRequestValidationError) ErrorName 

func (e InterestedAllPiecesRequestValidationError) ErrorName() string

ErrorName returns error name.

func (InterestedAllPiecesRequestValidationError) Field 

func (e InterestedAllPiecesRequestValidationError) Field() string

Field function returns field value.

func (InterestedAllPiecesRequestValidationError) Key 

func (e InterestedAllPiecesRequestValidationError) Key() bool

Key function returns key value.

func (InterestedAllPiecesRequestValidationError) Reason 

func (e InterestedAllPiecesRequestValidationError) Reason() string

Reason function returns reason value.

type InterestedPiecesRequest 

type InterestedPiecesRequest struct {

	// Interested piece numbers.
	PieceNumbers []uint32 `protobuf:"varint,1,rep,packed,name=piece_numbers,json=pieceNumbers,proto3" json:"piece_numbers,omitempty"`
	// contains filtered or unexported fields
}

InterestedPiecesRequest represents interested pieces request of SyncPiecesRequest.

func (*InterestedPiecesRequest) Descriptor deprecated 

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

Deprecated: Use InterestedPiecesRequest.ProtoReflect.Descriptor instead.

func (*InterestedPiecesRequest) GetPieceNumbers 

func (x *InterestedPiecesRequest) GetPieceNumbers() []uint32

func (*InterestedPiecesRequest) ProtoMessage 

func (*InterestedPiecesRequest) ProtoMessage()

func (*InterestedPiecesRequest) ProtoReflect 

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

func (*InterestedPiecesRequest) Reset 

func (x *InterestedPiecesRequest) Reset()

func (*InterestedPiecesRequest) String 

func (x *InterestedPiecesRequest) String() string

func (*InterestedPiecesRequest) Validate 

func (m *InterestedPiecesRequest) Validate() error

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

func (m *InterestedPiecesRequest) ValidateAll() error

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

type InterestedPiecesRequestMultiError 

type InterestedPiecesRequestMultiError []error

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

func (InterestedPiecesRequestMultiError) AllErrors 

func (m InterestedPiecesRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (InterestedPiecesRequestMultiError) Error 

func (m InterestedPiecesRequestMultiError) Error() string

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

type InterestedPiecesRequestValidationError 

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

InterestedPiecesRequestValidationError is the validation error returned by InterestedPiecesRequest.Validate if the designated constraints aren't met.

func (InterestedPiecesRequestValidationError) Cause 

func (e InterestedPiecesRequestValidationError) Cause() error

Cause function returns cause value.

func (InterestedPiecesRequestValidationError) Error 

func (e InterestedPiecesRequestValidationError) Error() string

Error satisfies the builtin error interface

func (InterestedPiecesRequestValidationError) ErrorName 

func (e InterestedPiecesRequestValidationError) ErrorName() string

ErrorName returns error name.

func (InterestedPiecesRequestValidationError) Field 

func (e InterestedPiecesRequestValidationError) Field() string

Field function returns field value.

func (InterestedPiecesRequestValidationError) Key 

func (e InterestedPiecesRequestValidationError) Key() bool

Key function returns key value.

func (InterestedPiecesRequestValidationError) Reason 

func (e InterestedPiecesRequestValidationError) Reason() string

Reason function returns reason value.

type InterestedPiecesResponse 

type InterestedPiecesResponse struct {

	// Interested pieces of task.
	Pieces []*v2.Piece `protobuf:"bytes,1,rep,name=pieces,proto3" json:"pieces,omitempty"`
	// contains filtered or unexported fields
}

InterestedPiecesResponse represents interested pieces response of SyncPiecesResponse.

func (*InterestedPiecesResponse) Descriptor deprecated 

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

Deprecated: Use InterestedPiecesResponse.ProtoReflect.Descriptor instead.

func (*InterestedPiecesResponse) GetPieces 

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

func (*InterestedPiecesResponse) ProtoMessage 

func (*InterestedPiecesResponse) ProtoMessage()

func (*InterestedPiecesResponse) ProtoReflect 

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

func (*InterestedPiecesResponse) Reset 

func (x *InterestedPiecesResponse) Reset()

func (*InterestedPiecesResponse) String 

func (x *InterestedPiecesResponse) String() string

func (*InterestedPiecesResponse) Validate 

func (m *InterestedPiecesResponse) Validate() error

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

func (m *InterestedPiecesResponse) ValidateAll() error

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

type InterestedPiecesResponseMultiError 

type InterestedPiecesResponseMultiError []error

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

func (InterestedPiecesResponseMultiError) AllErrors 

func (m InterestedPiecesResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (InterestedPiecesResponseMultiError) Error 

func (m InterestedPiecesResponseMultiError) Error() string

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

type InterestedPiecesResponseValidationError 

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

InterestedPiecesResponseValidationError is the validation error returned by InterestedPiecesResponse.Validate if the designated constraints aren't met.

func (InterestedPiecesResponseValidationError) Cause 

func (e InterestedPiecesResponseValidationError) Cause() error

Cause function returns cause value.

func (InterestedPiecesResponseValidationError) Error 

func (e InterestedPiecesResponseValidationError) Error() string

Error satisfies the builtin error interface

func (InterestedPiecesResponseValidationError) ErrorName 

func (e InterestedPiecesResponseValidationError) ErrorName() string

ErrorName returns error name.

func (InterestedPiecesResponseValidationError) Field 

func (e InterestedPiecesResponseValidationError) Field() string

Field function returns field value.

func (InterestedPiecesResponseValidationError) Key 

func (e InterestedPiecesResponseValidationError) Key() bool

Key function returns key value.

func (InterestedPiecesResponseValidationError) Reason 

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

type StatTaskResponse struct {

	// Task id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Task type.
	Type v2.TaskType `protobuf:"varint,2,opt,name=type,proto3,enum=common.v2.TaskType" json:"type,omitempty"`
	// Download url.
	Url string `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	// Digest of the pieces digest, for example md5:xxx or sha256:yyy.
	Digest *string `protobuf:"bytes,4,opt,name=digest,proto3,oneof" json:"digest,omitempty"`
	// URL tag identifies different task for same url.
	Tag *string `protobuf:"bytes,5,opt,name=tag,proto3,oneof" json:"tag,omitempty"`
	// Application of task.
	Application *string `protobuf:"bytes,6,opt,name=application,proto3,oneof" json:"application,omitempty"`
	// Filter url used to generate task id.
	Filters []string `protobuf:"bytes,7,rep,name=filters,proto3" json:"filters,omitempty"`
	// Task request headers.
	Header map[string]string `` /* 153-byte string literal not displayed */
	// Task piece length.
	PieceLength int32 `protobuf:"varint,9,opt,name=piece_length,json=pieceLength,proto3" json:"piece_length,omitempty"`
	// Task create time.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Task update time.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

StatTaskResponse represents response of StatTask.

func (*StatTaskResponse) Descriptor deprecated 

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

Deprecated: Use StatTaskResponse.ProtoReflect.Descriptor instead.

func (*StatTaskResponse) GetApplication added in v2.0.29 

func (x *StatTaskResponse) GetApplication() string

func (*StatTaskResponse) GetCreatedAt added in v2.0.29 

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

func (*StatTaskResponse) GetDigest added in v2.0.29 

func (x *StatTaskResponse) GetDigest() string

func (*StatTaskResponse) GetFilters added in v2.0.29 

func (x *StatTaskResponse) GetFilters() []string

func (*StatTaskResponse) GetHeader added in v2.0.29 

func (x *StatTaskResponse) GetHeader() map[string]string

func (*StatTaskResponse) GetId added in v2.0.29 

func (x *StatTaskResponse) GetId() string

func (*StatTaskResponse) GetPieceLength added in v2.0.29 

func (x *StatTaskResponse) GetPieceLength() int32

func (*StatTaskResponse) GetTag added in v2.0.29 

func (x *StatTaskResponse) GetTag() string

func (*StatTaskResponse) GetType added in v2.0.29 

func (x *StatTaskResponse) GetType() v2.TaskType

func (*StatTaskResponse) GetUpdatedAt added in v2.0.29 

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

func (*StatTaskResponse) GetUrl added in v2.0.29 

func (x *StatTaskResponse) GetUrl() string

func (*StatTaskResponse) ProtoMessage 

func (*StatTaskResponse) ProtoMessage()

func (*StatTaskResponse) ProtoReflect 

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

func (*StatTaskResponse) Reset 

func (x *StatTaskResponse) Reset()

func (*StatTaskResponse) String 

func (x *StatTaskResponse) String() string

func (*StatTaskResponse) Validate 

func (m *StatTaskResponse) Validate() error

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

func (m *StatTaskResponse) ValidateAll() error

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

type StatTaskResponseMultiError 

type StatTaskResponseMultiError []error

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

func (StatTaskResponseMultiError) AllErrors 

func (m StatTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatTaskResponseMultiError) Error 

func (m StatTaskResponseMultiError) Error() string

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

type StatTaskResponseValidationError 

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

StatTaskResponseValidationError is the validation error returned by StatTaskResponse.Validate if the designated constraints aren't met.

func (StatTaskResponseValidationError) Cause 

func (e StatTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (StatTaskResponseValidationError) Error 

func (e StatTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (StatTaskResponseValidationError) ErrorName 

func (e StatTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (StatTaskResponseValidationError) Field 

func (e StatTaskResponseValidationError) Field() string

Field function returns field value.

func (StatTaskResponseValidationError) Key 

func (e StatTaskResponseValidationError) Key() bool

Key function returns key value.

func (StatTaskResponseValidationError) Reason 

func (e StatTaskResponseValidationError) 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"`
	// Types that are assignable to Request:
	//
	//	*SyncPiecesRequest_InterestedAllPiecesRequest
	//	*SyncPiecesRequest_InterestedPiecesRequest
	Request isSyncPiecesRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

SyncPiecesRequest represents request of AnnouncePeer.

func (*SyncPiecesRequest) Descriptor deprecated 

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

Deprecated: Use SyncPiecesRequest.ProtoReflect.Descriptor instead.

func (*SyncPiecesRequest) GetInterestedAllPiecesRequest 

func (x *SyncPiecesRequest) GetInterestedAllPiecesRequest() *InterestedAllPiecesRequest

func (*SyncPiecesRequest) GetInterestedPiecesRequest 

func (x *SyncPiecesRequest) GetInterestedPiecesRequest() *InterestedPiecesRequest

func (*SyncPiecesRequest) GetRequest 

func (m *SyncPiecesRequest) GetRequest() isSyncPiecesRequest_Request

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 SyncPiecesRequest_InterestedAllPiecesRequest 

type SyncPiecesRequest_InterestedAllPiecesRequest struct {
	InterestedAllPiecesRequest *InterestedAllPiecesRequest `protobuf:"bytes,2,opt,name=interested_all_pieces_request,json=interestedAllPiecesRequest,proto3,oneof"`
}

type SyncPiecesRequest_InterestedPiecesRequest 

type SyncPiecesRequest_InterestedPiecesRequest struct {
	InterestedPiecesRequest *InterestedPiecesRequest `protobuf:"bytes,3,opt,name=interested_pieces_request,json=interestedPiecesRequest,proto3,oneof"`
}

type SyncPiecesResponse 

type SyncPiecesResponse struct {

	// Types that are assignable to Response:
	//
	//	*SyncPiecesResponse_InterestedPiecesResponse
	Response isSyncPiecesResponse_Response `protobuf_oneof:"response"`
	// 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) GetInterestedPiecesResponse 

func (x *SyncPiecesResponse) GetInterestedPiecesResponse() *InterestedPiecesResponse

func (*SyncPiecesResponse) GetResponse 

func (m *SyncPiecesResponse) GetResponse() isSyncPiecesResponse_Response

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 SyncPiecesResponse_InterestedPiecesResponse 

type SyncPiecesResponse_InterestedPiecesResponse struct {
	InterestedPiecesResponse *InterestedPiecesResponse `protobuf:"bytes,1,opt,name=interested_pieces_response,json=interestedPiecesResponse,proto3,oneof"`
}

type UnimplementedDfdaemonServer 

type UnimplementedDfdaemonServer struct {
}

UnimplementedDfdaemonServer should be embedded to have forward compatible implementations.

func (UnimplementedDfdaemonServer) DeleteTask 

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

func (UnimplementedDfdaemonServer) DownloadTask 

func (UnimplementedDfdaemonServer) DownloadTask(context.Context, *DownloadTaskRequest) (*emptypb.Empty, error)

func (UnimplementedDfdaemonServer) StatTask 

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

func (UnimplementedDfdaemonServer) SyncPieces 

func (UnimplementedDfdaemonServer) SyncPieces(Dfdaemon_SyncPiecesServer) error

func (UnimplementedDfdaemonServer) UploadTask 

func (UnimplementedDfdaemonServer) UploadTask(context.Context, *UploadTaskRequest) (*emptypb.Empty, error)

type UnsafeDfdaemonServer 

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

UnsafeDfdaemonServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DfdaemonServer 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
Package mocks is a generated GoMock package.
 Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

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