dfdaemon

Sep 26, 2024

Changes in this version

+ type DeletePersistentCacheTaskRequest struct

+ TaskId string

+ func (*DeletePersistentCacheTaskRequest) Descriptor() ([]byte, []int)

+ func (*DeletePersistentCacheTaskRequest) ProtoMessage()

+ func (m *DeletePersistentCacheTaskRequest) Validate() error

+ func (m *DeletePersistentCacheTaskRequest) ValidateAll() error

+ func (x *DeletePersistentCacheTaskRequest) GetTaskId() string

+ func (x *DeletePersistentCacheTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *DeletePersistentCacheTaskRequest) Reset()

+ func (x *DeletePersistentCacheTaskRequest) String() string

+ type DeletePersistentCacheTaskRequestMultiError []error

+ func (m DeletePersistentCacheTaskRequestMultiError) AllErrors() []error

+ func (m DeletePersistentCacheTaskRequestMultiError) Error() string

+ type DeletePersistentCacheTaskRequestValidationError struct

+ func (e DeletePersistentCacheTaskRequestValidationError) Cause() error

+ func (e DeletePersistentCacheTaskRequestValidationError) Error() string

+ func (e DeletePersistentCacheTaskRequestValidationError) ErrorName() string

+ func (e DeletePersistentCacheTaskRequestValidationError) Field() string

+ func (e DeletePersistentCacheTaskRequestValidationError) Key() bool

+ func (e DeletePersistentCacheTaskRequestValidationError) Reason() string

type DfdaemonDownloadClient

+ DeletePersistentCacheTask func(ctx context.Context, in *DeletePersistentCacheTaskRequest, ...) (*emptypb.Empty, error)

+ DownloadPersistentCacheTask func(ctx context.Context, in *DownloadPersistentCacheTaskRequest, ...) (DfdaemonDownload_DownloadPersistentCacheTaskClient, error)

+ StatPersistentCacheTask func(ctx context.Context, in *StatPersistentCacheTaskRequest, ...) (*v2.PersistentCacheTask, error)

+ UploadPersistentCacheTask func(ctx context.Context, in *UploadPersistentCacheTaskRequest, ...) (*v2.PersistentCacheTask, error)

type DfdaemonDownloadServer

+ DeletePersistentCacheTask func(context.Context, *DeletePersistentCacheTaskRequest) (*emptypb.Empty, error)

+ DownloadPersistentCacheTask func(*DownloadPersistentCacheTaskRequest, ...) error

+ StatPersistentCacheTask func(context.Context, *StatPersistentCacheTaskRequest) (*v2.PersistentCacheTask, error)

+ UploadPersistentCacheTask func(context.Context, *UploadPersistentCacheTaskRequest) (*v2.PersistentCacheTask, error)

+ type DfdaemonDownload_DownloadPersistentCacheTaskClient interface

+ Recv func() (*DownloadPersistentCacheTaskResponse, error)

+ type DfdaemonDownload_DownloadPersistentCacheTaskServer interface

+ Send func(*DownloadPersistentCacheTaskResponse) error

type DfdaemonUploadClient

+ DeletePersistentCacheTask func(ctx context.Context, in *DeletePersistentCacheTaskRequest, ...) (*emptypb.Empty, error)

+ DownloadPersistentCacheTask func(ctx context.Context, in *DownloadPersistentCacheTaskRequest, ...) (DfdaemonUpload_DownloadPersistentCacheTaskClient, error)

+ StatPersistentCacheTask func(ctx context.Context, in *StatPersistentCacheTaskRequest, ...) (*v2.PersistentCacheTask, error)

type DfdaemonUploadServer

+ DeletePersistentCacheTask func(context.Context, *DeletePersistentCacheTaskRequest) (*emptypb.Empty, error)

+ DownloadPersistentCacheTask func(*DownloadPersistentCacheTaskRequest, ...) error

+ StatPersistentCacheTask func(context.Context, *StatPersistentCacheTaskRequest) (*v2.PersistentCacheTask, error)

+ type DfdaemonUpload_DownloadPersistentCacheTaskClient interface

+ Recv func() (*DownloadPersistentCacheTaskResponse, error)

+ type DfdaemonUpload_DownloadPersistentCacheTaskServer interface

+ Send func(*DownloadPersistentCacheTaskResponse) error

+ type DownloadPersistentCacheTaskRequest struct

+ Application *string

+ OutputPath string

+ Persistent bool

+ Tag *string

+ TaskId string

+ Timeout *durationpb.Duration

+ func (*DownloadPersistentCacheTaskRequest) Descriptor() ([]byte, []int)

+ func (*DownloadPersistentCacheTaskRequest) ProtoMessage()

+ func (m *DownloadPersistentCacheTaskRequest) Validate() error

+ func (m *DownloadPersistentCacheTaskRequest) ValidateAll() error

+ func (x *DownloadPersistentCacheTaskRequest) GetApplication() string

+ func (x *DownloadPersistentCacheTaskRequest) GetOutputPath() string

+ func (x *DownloadPersistentCacheTaskRequest) GetPersistent() bool

+ func (x *DownloadPersistentCacheTaskRequest) GetTag() string

+ func (x *DownloadPersistentCacheTaskRequest) GetTaskId() string

+ func (x *DownloadPersistentCacheTaskRequest) GetTimeout() *durationpb.Duration

+ func (x *DownloadPersistentCacheTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *DownloadPersistentCacheTaskRequest) Reset()

+ func (x *DownloadPersistentCacheTaskRequest) String() string

+ type DownloadPersistentCacheTaskRequestMultiError []error

+ func (m DownloadPersistentCacheTaskRequestMultiError) AllErrors() []error

+ func (m DownloadPersistentCacheTaskRequestMultiError) Error() string

+ type DownloadPersistentCacheTaskRequestValidationError struct

+ func (e DownloadPersistentCacheTaskRequestValidationError) Cause() error

+ func (e DownloadPersistentCacheTaskRequestValidationError) Error() string

+ func (e DownloadPersistentCacheTaskRequestValidationError) ErrorName() string

+ func (e DownloadPersistentCacheTaskRequestValidationError) Field() string

+ func (e DownloadPersistentCacheTaskRequestValidationError) Key() bool

+ func (e DownloadPersistentCacheTaskRequestValidationError) Reason() string

+ type DownloadPersistentCacheTaskResponse struct

+ HostId string

+ PeerId string

+ Response isDownloadPersistentCacheTaskResponse_Response

+ TaskId string

+ func (*DownloadPersistentCacheTaskResponse) Descriptor() ([]byte, []int)

+ func (*DownloadPersistentCacheTaskResponse) ProtoMessage()

+ func (m *DownloadPersistentCacheTaskResponse) GetResponse() isDownloadPersistentCacheTaskResponse_Response

+ func (m *DownloadPersistentCacheTaskResponse) Validate() error

+ func (m *DownloadPersistentCacheTaskResponse) ValidateAll() error

+ func (x *DownloadPersistentCacheTaskResponse) GetDownloadPersistentCacheTaskStartedResponse() *DownloadPersistentCacheTaskStartedResponse

+ func (x *DownloadPersistentCacheTaskResponse) GetDownloadPieceFinishedResponse() *DownloadPieceFinishedResponse

+ func (x *DownloadPersistentCacheTaskResponse) GetHostId() string

+ func (x *DownloadPersistentCacheTaskResponse) GetPeerId() string

+ func (x *DownloadPersistentCacheTaskResponse) GetTaskId() string

+ func (x *DownloadPersistentCacheTaskResponse) ProtoReflect() protoreflect.Message

+ func (x *DownloadPersistentCacheTaskResponse) Reset()

+ func (x *DownloadPersistentCacheTaskResponse) String() string

+ type DownloadPersistentCacheTaskResponseMultiError []error

+ func (m DownloadPersistentCacheTaskResponseMultiError) AllErrors() []error

+ func (m DownloadPersistentCacheTaskResponseMultiError) Error() string

+ type DownloadPersistentCacheTaskResponseValidationError struct

+ func (e DownloadPersistentCacheTaskResponseValidationError) Cause() error

+ func (e DownloadPersistentCacheTaskResponseValidationError) Error() string

+ func (e DownloadPersistentCacheTaskResponseValidationError) ErrorName() string

+ func (e DownloadPersistentCacheTaskResponseValidationError) Field() string

+ func (e DownloadPersistentCacheTaskResponseValidationError) Key() bool

+ func (e DownloadPersistentCacheTaskResponseValidationError) Reason() string

+ type DownloadPersistentCacheTaskResponse_DownloadPersistentCacheTaskStartedResponse struct

+ DownloadPersistentCacheTaskStartedResponse *DownloadPersistentCacheTaskStartedResponse

+ type DownloadPersistentCacheTaskResponse_DownloadPieceFinishedResponse struct

+ DownloadPieceFinishedResponse *DownloadPieceFinishedResponse

+ type DownloadPersistentCacheTaskStartedResponse struct

+ ContentLength uint64

+ func (*DownloadPersistentCacheTaskStartedResponse) Descriptor() ([]byte, []int)

+ func (*DownloadPersistentCacheTaskStartedResponse) ProtoMessage()

+ func (m *DownloadPersistentCacheTaskStartedResponse) Validate() error

+ func (m *DownloadPersistentCacheTaskStartedResponse) ValidateAll() error

+ func (x *DownloadPersistentCacheTaskStartedResponse) GetContentLength() uint64

+ func (x *DownloadPersistentCacheTaskStartedResponse) ProtoReflect() protoreflect.Message

+ func (x *DownloadPersistentCacheTaskStartedResponse) Reset()

+ func (x *DownloadPersistentCacheTaskStartedResponse) String() string

+ type DownloadPersistentCacheTaskStartedResponseMultiError []error

+ func (m DownloadPersistentCacheTaskStartedResponseMultiError) AllErrors() []error

+ func (m DownloadPersistentCacheTaskStartedResponseMultiError) Error() string

+ type DownloadPersistentCacheTaskStartedResponseValidationError struct

+ func (e DownloadPersistentCacheTaskStartedResponseValidationError) Cause() error

+ func (e DownloadPersistentCacheTaskStartedResponseValidationError) Error() string

+ func (e DownloadPersistentCacheTaskStartedResponseValidationError) ErrorName() string

+ func (e DownloadPersistentCacheTaskStartedResponseValidationError) Field() string

+ func (e DownloadPersistentCacheTaskStartedResponseValidationError) Key() bool

+ func (e DownloadPersistentCacheTaskStartedResponseValidationError) Reason() string

+ type StatPersistentCacheTaskRequest struct

+ TaskId string

+ func (*StatPersistentCacheTaskRequest) Descriptor() ([]byte, []int)

+ func (*StatPersistentCacheTaskRequest) ProtoMessage()

+ func (m *StatPersistentCacheTaskRequest) Validate() error

+ func (m *StatPersistentCacheTaskRequest) ValidateAll() error

+ func (x *StatPersistentCacheTaskRequest) GetTaskId() string

+ func (x *StatPersistentCacheTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *StatPersistentCacheTaskRequest) Reset()

+ func (x *StatPersistentCacheTaskRequest) String() string

+ type StatPersistentCacheTaskRequestMultiError []error

+ func (m StatPersistentCacheTaskRequestMultiError) AllErrors() []error

+ func (m StatPersistentCacheTaskRequestMultiError) Error() string

+ type StatPersistentCacheTaskRequestValidationError struct

+ func (e StatPersistentCacheTaskRequestValidationError) Cause() error

+ func (e StatPersistentCacheTaskRequestValidationError) Error() string

+ func (e StatPersistentCacheTaskRequestValidationError) ErrorName() string

+ func (e StatPersistentCacheTaskRequestValidationError) Field() string

+ func (e StatPersistentCacheTaskRequestValidationError) Key() bool

+ func (e StatPersistentCacheTaskRequestValidationError) Reason() string

type UnimplementedDfdaemonDownloadServer

+ func (UnimplementedDfdaemonDownloadServer) DeletePersistentCacheTask(context.Context, *DeletePersistentCacheTaskRequest) (*emptypb.Empty, error)

+ func (UnimplementedDfdaemonDownloadServer) DownloadPersistentCacheTask(*DownloadPersistentCacheTaskRequest, ...) error

+ func (UnimplementedDfdaemonDownloadServer) StatPersistentCacheTask(context.Context, *StatPersistentCacheTaskRequest) (*v2.PersistentCacheTask, error)

+ func (UnimplementedDfdaemonDownloadServer) UploadPersistentCacheTask(context.Context, *UploadPersistentCacheTaskRequest) (*v2.PersistentCacheTask, error)

type UnimplementedDfdaemonUploadServer

+ func (UnimplementedDfdaemonUploadServer) DeletePersistentCacheTask(context.Context, *DeletePersistentCacheTaskRequest) (*emptypb.Empty, error)

+ func (UnimplementedDfdaemonUploadServer) DownloadPersistentCacheTask(*DownloadPersistentCacheTaskRequest, ...) error

+ func (UnimplementedDfdaemonUploadServer) StatPersistentCacheTask(context.Context, *StatPersistentCacheTaskRequest) (*v2.PersistentCacheTask, error)

+ type UploadPersistentCacheTaskRequest struct

+ Application *string

+ Path string

+ PersistentReplicaCount uint64

+ Tag *string

+ Timeout *durationpb.Duration

+ Ttl *durationpb.Duration

+ func (*UploadPersistentCacheTaskRequest) Descriptor() ([]byte, []int)

+ func (*UploadPersistentCacheTaskRequest) ProtoMessage()

+ func (m *UploadPersistentCacheTaskRequest) Validate() error

+ func (m *UploadPersistentCacheTaskRequest) ValidateAll() error

+ func (x *UploadPersistentCacheTaskRequest) GetApplication() string

+ func (x *UploadPersistentCacheTaskRequest) GetPath() string

+ func (x *UploadPersistentCacheTaskRequest) GetPersistentReplicaCount() uint64

+ func (x *UploadPersistentCacheTaskRequest) GetTag() string

+ func (x *UploadPersistentCacheTaskRequest) GetTimeout() *durationpb.Duration

+ func (x *UploadPersistentCacheTaskRequest) GetTtl() *durationpb.Duration

+ func (x *UploadPersistentCacheTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *UploadPersistentCacheTaskRequest) Reset()

+ func (x *UploadPersistentCacheTaskRequest) String() string

+ type UploadPersistentCacheTaskRequestMultiError []error

+ func (m UploadPersistentCacheTaskRequestMultiError) AllErrors() []error

+ func (m UploadPersistentCacheTaskRequestMultiError) Error() string

+ type UploadPersistentCacheTaskRequestValidationError struct

+ func (e UploadPersistentCacheTaskRequestValidationError) Cause() error

+ func (e UploadPersistentCacheTaskRequestValidationError) Error() string

+ func (e UploadPersistentCacheTaskRequestValidationError) ErrorName() string

+ func (e UploadPersistentCacheTaskRequestValidationError) Field() string

+ func (e UploadPersistentCacheTaskRequestValidationError) Key() bool

+ func (e UploadPersistentCacheTaskRequestValidationError) Reason() string

Aug 13, 2024

Changes in this version

type DfdaemonUploadClient

+ DeleteTask func(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ StatTask func(ctx context.Context, in *StatTaskRequest, opts ...grpc.CallOption) (*v2.Task, error)

type DfdaemonUploadServer

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

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

type UnimplementedDfdaemonUploadServer

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

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

Jul 17, 2024

Changes in this version

type DownloadCacheTaskStartedResponse

+ ContentLength uint64

+ func (x *DownloadCacheTaskStartedResponse) GetContentLength() uint64

Jun 19, 2024

Changes in this version

type DownloadCacheTaskRequest

+ Persistent bool

+ func (x *DownloadCacheTaskRequest) GetPersistent() bool

Jun 18, 2024

Changes in this version

type UploadCacheTaskRequest

+ Ttl *durationpb.Duration

+ func (x *UploadCacheTaskRequest) GetTtl() *durationpb.Duration

Jun 17, 2024

Changes in this version

type DfdaemonDownloadClient

+ DeleteHost func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)

type DfdaemonDownloadServer

+ DeleteHost func(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

type UnimplementedDfdaemonDownloadServer

+ func (UnimplementedDfdaemonDownloadServer) DeleteHost(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

Jun 17, 2024

Changes in this version

+ type DeleteCacheTaskRequest struct

+ TaskId string

+ func (*DeleteCacheTaskRequest) Descriptor() ([]byte, []int)

+ func (*DeleteCacheTaskRequest) ProtoMessage()

+ func (m *DeleteCacheTaskRequest) Validate() error

+ func (m *DeleteCacheTaskRequest) ValidateAll() error

+ func (x *DeleteCacheTaskRequest) GetTaskId() string

+ func (x *DeleteCacheTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteCacheTaskRequest) Reset()

+ func (x *DeleteCacheTaskRequest) String() string

+ type DeleteCacheTaskRequestMultiError []error

+ func (m DeleteCacheTaskRequestMultiError) AllErrors() []error

+ func (m DeleteCacheTaskRequestMultiError) Error() string

+ type DeleteCacheTaskRequestValidationError struct

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

+ DeleteCacheTask func(ctx context.Context, in *DeleteCacheTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DownloadCacheTask func(ctx context.Context, in *DownloadCacheTaskRequest, opts ...grpc.CallOption) (DfdaemonDownload_DownloadCacheTaskClient, error)

+ StatCacheTask func(ctx context.Context, in *StatCacheTaskRequest, opts ...grpc.CallOption) (*v2.CacheTask, error)

+ UploadCacheTask func(ctx context.Context, in *UploadCacheTaskRequest, opts ...grpc.CallOption) (*v2.CacheTask, error)

type DfdaemonDownloadServer

+ DeleteCacheTask func(context.Context, *DeleteCacheTaskRequest) (*emptypb.Empty, error)

+ DownloadCacheTask func(*DownloadCacheTaskRequest, DfdaemonDownload_DownloadCacheTaskServer) error

+ StatCacheTask func(context.Context, *StatCacheTaskRequest) (*v2.CacheTask, error)

+ UploadCacheTask func(context.Context, *UploadCacheTaskRequest) (*v2.CacheTask, error)

+ type DfdaemonDownload_DownloadCacheTaskClient interface

+ Recv func() (*DownloadCacheTaskResponse, error)

+ type DfdaemonDownload_DownloadCacheTaskServer interface

+ Send func(*DownloadCacheTaskResponse) error

type DfdaemonUploadClient

+ DeleteCacheTask func(ctx context.Context, in *DeleteCacheTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DownloadCacheTask func(ctx context.Context, in *DownloadCacheTaskRequest, opts ...grpc.CallOption) (DfdaemonUpload_DownloadCacheTaskClient, error)

+ StatCacheTask func(ctx context.Context, in *StatCacheTaskRequest, opts ...grpc.CallOption) (*v2.CacheTask, error)

type DfdaemonUploadServer

+ DeleteCacheTask func(context.Context, *DeleteCacheTaskRequest) (*emptypb.Empty, error)

+ DownloadCacheTask func(*DownloadCacheTaskRequest, DfdaemonUpload_DownloadCacheTaskServer) error

+ StatCacheTask func(context.Context, *StatCacheTaskRequest) (*v2.CacheTask, error)

+ type DfdaemonUpload_DownloadCacheTaskClient interface

+ Recv func() (*DownloadCacheTaskResponse, error)

+ type DfdaemonUpload_DownloadCacheTaskServer interface

+ Send func(*DownloadCacheTaskResponse) error

+ type DownloadCacheTaskRequest struct

+ Application *string

+ HostId string

+ OutputPath string

+ PieceLength uint64

+ Tag *string

+ TaskId string

+ Timeout *durationpb.Duration

+ func (*DownloadCacheTaskRequest) Descriptor() ([]byte, []int)

+ func (*DownloadCacheTaskRequest) ProtoMessage()

+ func (m *DownloadCacheTaskRequest) Validate() error

+ func (m *DownloadCacheTaskRequest) ValidateAll() error

+ 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 (x *DownloadCacheTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *DownloadCacheTaskRequest) Reset()

+ func (x *DownloadCacheTaskRequest) String() string

+ type DownloadCacheTaskRequestMultiError []error

+ func (m DownloadCacheTaskRequestMultiError) AllErrors() []error

+ func (m DownloadCacheTaskRequestMultiError) Error() string

+ type DownloadCacheTaskRequestValidationError struct

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

+ HostId string

+ PeerId string

+ Response isDownloadCacheTaskResponse_Response

+ TaskId string

+ func (*DownloadCacheTaskResponse) Descriptor() ([]byte, []int)

+ func (*DownloadCacheTaskResponse) ProtoMessage()

+ func (m *DownloadCacheTaskResponse) GetResponse() isDownloadCacheTaskResponse_Response

+ func (m *DownloadCacheTaskResponse) Validate() error

+ func (m *DownloadCacheTaskResponse) ValidateAll() error

+ func (x *DownloadCacheTaskResponse) GetDownloadCacheTaskStartedResponse() *DownloadCacheTaskStartedResponse

+ func (x *DownloadCacheTaskResponse) GetDownloadPieceFinishedResponse() *DownloadPieceFinishedResponse

+ func (x *DownloadCacheTaskResponse) GetHostId() string

+ func (x *DownloadCacheTaskResponse) GetPeerId() string

+ func (x *DownloadCacheTaskResponse) GetTaskId() string

+ func (x *DownloadCacheTaskResponse) ProtoReflect() protoreflect.Message

+ func (x *DownloadCacheTaskResponse) Reset()

+ func (x *DownloadCacheTaskResponse) String() string

+ type DownloadCacheTaskResponseMultiError []error

+ func (m DownloadCacheTaskResponseMultiError) AllErrors() []error

+ func (m DownloadCacheTaskResponseMultiError) Error() string

+ type DownloadCacheTaskResponseValidationError struct

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

+ DownloadCacheTaskStartedResponse *DownloadCacheTaskStartedResponse

+ type DownloadCacheTaskResponse_DownloadPieceFinishedResponse struct

+ DownloadPieceFinishedResponse *DownloadPieceFinishedResponse

+ type DownloadCacheTaskStartedResponse struct

+ func (*DownloadCacheTaskStartedResponse) Descriptor() ([]byte, []int)

+ func (*DownloadCacheTaskStartedResponse) ProtoMessage()

+ func (m *DownloadCacheTaskStartedResponse) Validate() error

+ func (m *DownloadCacheTaskStartedResponse) ValidateAll() error

+ func (x *DownloadCacheTaskStartedResponse) ProtoReflect() protoreflect.Message

+ func (x *DownloadCacheTaskStartedResponse) Reset()

+ func (x *DownloadCacheTaskStartedResponse) String() string

+ type DownloadCacheTaskStartedResponseMultiError []error

+ func (m DownloadCacheTaskStartedResponseMultiError) AllErrors() []error

+ func (m DownloadCacheTaskStartedResponseMultiError) Error() string

+ type DownloadCacheTaskStartedResponseValidationError struct

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

+ DownloadTask *v2.DownloadTask

+ func (x *DownloadTaskRequest) GetDownloadTask() *v2.DownloadTask

+ type StatCacheTaskRequest struct

+ TaskId string

+ func (*StatCacheTaskRequest) Descriptor() ([]byte, []int)

+ func (*StatCacheTaskRequest) ProtoMessage()

+ func (m *StatCacheTaskRequest) Validate() error

+ func (m *StatCacheTaskRequest) ValidateAll() error

+ func (x *StatCacheTaskRequest) GetTaskId() string

+ func (x *StatCacheTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *StatCacheTaskRequest) Reset()

+ func (x *StatCacheTaskRequest) String() string

+ type StatCacheTaskRequestMultiError []error

+ func (m StatCacheTaskRequestMultiError) AllErrors() []error

+ func (m StatCacheTaskRequestMultiError) Error() string

+ type StatCacheTaskRequestValidationError struct

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

+ func (UnimplementedDfdaemonDownloadServer) DeleteCacheTask(context.Context, *DeleteCacheTaskRequest) (*emptypb.Empty, error)

+ func (UnimplementedDfdaemonDownloadServer) DownloadCacheTask(*DownloadCacheTaskRequest, DfdaemonDownload_DownloadCacheTaskServer) error

+ func (UnimplementedDfdaemonDownloadServer) StatCacheTask(context.Context, *StatCacheTaskRequest) (*v2.CacheTask, error)

+ func (UnimplementedDfdaemonDownloadServer) UploadCacheTask(context.Context, *UploadCacheTaskRequest) (*v2.CacheTask, error)

type UnimplementedDfdaemonUploadServer

+ func (UnimplementedDfdaemonUploadServer) DeleteCacheTask(context.Context, *DeleteCacheTaskRequest) (*emptypb.Empty, error)

+ func (UnimplementedDfdaemonUploadServer) DownloadCacheTask(*DownloadCacheTaskRequest, DfdaemonUpload_DownloadCacheTaskServer) error

+ func (UnimplementedDfdaemonUploadServer) StatCacheTask(context.Context, *StatCacheTaskRequest) (*v2.CacheTask, error)

+ type UploadCacheTaskRequest struct

+ Application *string

+ Path string

+ PersistentReplicaCount uint64

+ PieceLength uint64

+ Tag *string

+ Timeout *durationpb.Duration

+ func (*UploadCacheTaskRequest) Descriptor() ([]byte, []int)

+ func (*UploadCacheTaskRequest) ProtoMessage()

+ func (m *UploadCacheTaskRequest) Validate() error

+ func (m *UploadCacheTaskRequest) ValidateAll() error

+ 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 (x *UploadCacheTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *UploadCacheTaskRequest) Reset()

+ func (x *UploadCacheTaskRequest) String() string

+ type UploadCacheTaskRequestMultiError []error

+ func (m UploadCacheTaskRequestMultiError) AllErrors() []error

+ func (m UploadCacheTaskRequestMultiError) Error() string

+ type UploadCacheTaskRequestValidationError struct

+ 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

Jun 5, 2024

Changes in this version

type DownloadPieceRequest

+ HostId string

+ func (x *DownloadPieceRequest) GetHostId() string

type SyncPiecesRequest

+ HostId string

+ func (x *SyncPiecesRequest) GetHostId() string

Feb 27, 2024

Changes in this version

type DownloadTaskResponse

+ func (x *DownloadTaskResponse) GetDownloadTaskFailedResponse() *DownloadTaskFailedResponse

+ type DownloadTaskResponse_DownloadTaskFailedResponse struct

+ DownloadTaskFailedResponse *DownloadTaskFailedResponse

Feb 27, 2024

Changes in this version

+ type DownloadTaskFailedResponse struct

+ Response isDownloadTaskFailedResponse_Response

+ func (*DownloadTaskFailedResponse) Descriptor() ([]byte, []int)

+ func (*DownloadTaskFailedResponse) ProtoMessage()

+ func (m *DownloadTaskFailedResponse) GetResponse() isDownloadTaskFailedResponse_Response

+ func (m *DownloadTaskFailedResponse) Validate() error

+ func (m *DownloadTaskFailedResponse) ValidateAll() error

+ func (x *DownloadTaskFailedResponse) GetHttpResponse() *v2.HTTPResponse

+ func (x *DownloadTaskFailedResponse) ProtoReflect() protoreflect.Message

+ func (x *DownloadTaskFailedResponse) Reset()

+ func (x *DownloadTaskFailedResponse) String() string

+ type DownloadTaskFailedResponseMultiError []error

+ func (m DownloadTaskFailedResponseMultiError) AllErrors() []error

+ func (m DownloadTaskFailedResponseMultiError) Error() string

+ type DownloadTaskFailedResponseValidationError struct

+ func (e DownloadTaskFailedResponseValidationError) Cause() error

+ func (e DownloadTaskFailedResponseValidationError) Error() string

+ func (e DownloadTaskFailedResponseValidationError) ErrorName() string

+ func (e DownloadTaskFailedResponseValidationError) Field() string

+ func (e DownloadTaskFailedResponseValidationError) Key() bool

+ func (e DownloadTaskFailedResponseValidationError) Reason() string

+ type DownloadTaskFailedResponse_HttpResponse struct

+ HttpResponse *v2.HTTPResponse

type DownloadTaskResponse

+ func (x *DownloadTaskResponse) GetDownloadTaskFailedRequest() *DownloadTaskFailedResponse

+ type DownloadTaskResponse_DownloadTaskFailedRequest struct

+ DownloadTaskFailedRequest *DownloadTaskFailedResponse

Feb 6, 2024

Changes in this version

type DfdaemonDownloadClient

+ LeaveHost func(ctx context.Context, in *LeaveHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

type DfdaemonDownloadServer

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

+ type LeaveHostRequest struct

+ Id string

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

+ func (*LeaveHostRequest) ProtoMessage()

+ func (m *LeaveHostRequest) Validate() error

+ func (m *LeaveHostRequest) ValidateAll() error

+ func (x *LeaveHostRequest) GetId() string

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

+ func (x *LeaveHostRequest) Reset()

+ func (x *LeaveHostRequest) String() string

+ type LeaveHostRequestMultiError []error

+ func (m LeaveHostRequestMultiError) AllErrors() []error

+ func (m LeaveHostRequestMultiError) Error() string

+ type LeaveHostRequestValidationError struct

+ func (e LeaveHostRequestValidationError) Cause() error

+ func (e LeaveHostRequestValidationError) Error() string

+ func (e LeaveHostRequestValidationError) ErrorName() string

+ func (e LeaveHostRequestValidationError) Field() string

+ func (e LeaveHostRequestValidationError) Key() bool

+ func (e LeaveHostRequestValidationError) Reason() string

type UnimplementedDfdaemonDownloadServer

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

Jan 30, 2024

Changes in this version

type DownloadTaskStartedResponse

+ Pieces []*v2.Piece

+ func (x *DownloadTaskStartedResponse) GetPieces() []*v2.Piece

Jan 30, 2024

Changes in this version

type DownloadTaskStartedResponse

+ Range *v2.Range

+ func (x *DownloadTaskStartedResponse) GetRange() *v2.Range

Jan 29, 2024

Changes in this version

+ type DownloadTaskFinishedResponse struct

+ func (*DownloadTaskFinishedResponse) Descriptor() ([]byte, []int)

+ func (*DownloadTaskFinishedResponse) ProtoMessage()

+ func (m *DownloadTaskFinishedResponse) Validate() error

+ func (m *DownloadTaskFinishedResponse) ValidateAll() error

+ func (x *DownloadTaskFinishedResponse) ProtoReflect() protoreflect.Message

+ func (x *DownloadTaskFinishedResponse) Reset()

+ func (x *DownloadTaskFinishedResponse) String() string

+ type DownloadTaskFinishedResponseMultiError []error

+ func (m DownloadTaskFinishedResponseMultiError) AllErrors() []error

+ func (m DownloadTaskFinishedResponseMultiError) Error() string

+ type DownloadTaskFinishedResponseValidationError struct

+ func (e DownloadTaskFinishedResponseValidationError) Cause() error

+ func (e DownloadTaskFinishedResponseValidationError) Error() string

+ func (e DownloadTaskFinishedResponseValidationError) ErrorName() string

+ func (e DownloadTaskFinishedResponseValidationError) Field() string

+ func (e DownloadTaskFinishedResponseValidationError) Key() bool

+ func (e DownloadTaskFinishedResponseValidationError) Reason() string

type DownloadTaskResponse

+ func (x *DownloadTaskResponse) GetDownloadTaskFinishedResponse() *DownloadTaskFinishedResponse

+ type DownloadTaskResponse_DownloadTaskFinishedResponse struct

+ DownloadTaskFinishedResponse *DownloadTaskFinishedResponse

type DownloadTaskStartedResponse

+ ResponseHeader map[string]string

+ func (x *DownloadTaskStartedResponse) GetResponseHeader() map[string]string

Jan 29, 2024

Changes in this version

type DownloadTaskStartedRequest

+ ContentLength uint64

+ func (x *DownloadTaskStartedRequest) GetContentLength() uint64

Jan 29, 2024

Changes in this version

+ type DownloadPieceFinishedRequest struct

+ Piece *v2.Piece

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

+ func (*DownloadPieceFinishedRequest) ProtoMessage()

+ func (m *DownloadPieceFinishedRequest) Validate() error

+ func (m *DownloadPieceFinishedRequest) ValidateAll() error

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

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

+ func (x *DownloadPieceFinishedRequest) Reset()

+ func (x *DownloadPieceFinishedRequest) String() string

+ type DownloadPieceFinishedRequestMultiError []error

+ func (m DownloadPieceFinishedRequestMultiError) AllErrors() []error

+ func (m DownloadPieceFinishedRequestMultiError) Error() string

+ type DownloadPieceFinishedRequestValidationError struct

+ func (e DownloadPieceFinishedRequestValidationError) Cause() error

+ func (e DownloadPieceFinishedRequestValidationError) Error() string

+ func (e DownloadPieceFinishedRequestValidationError) ErrorName() string

+ func (e DownloadPieceFinishedRequestValidationError) Field() string

+ func (e DownloadPieceFinishedRequestValidationError) Key() bool

+ func (e DownloadPieceFinishedRequestValidationError) Reason() string

+ type DownloadTaskFinishedRequest struct

+ func (*DownloadTaskFinishedRequest) Descriptor() ([]byte, []int)

+ func (*DownloadTaskFinishedRequest) ProtoMessage()

+ func (m *DownloadTaskFinishedRequest) Validate() error

+ func (m *DownloadTaskFinishedRequest) ValidateAll() error

+ func (x *DownloadTaskFinishedRequest) ProtoReflect() protoreflect.Message

+ func (x *DownloadTaskFinishedRequest) Reset()

+ func (x *DownloadTaskFinishedRequest) String() string

+ type DownloadTaskFinishedRequestMultiError []error

+ func (m DownloadTaskFinishedRequestMultiError) AllErrors() []error

+ func (m DownloadTaskFinishedRequestMultiError) Error() string

+ type DownloadTaskFinishedRequestValidationError struct

+ func (e DownloadTaskFinishedRequestValidationError) Cause() error

+ func (e DownloadTaskFinishedRequestValidationError) Error() string

+ func (e DownloadTaskFinishedRequestValidationError) ErrorName() string

+ func (e DownloadTaskFinishedRequestValidationError) Field() string

+ func (e DownloadTaskFinishedRequestValidationError) Key() bool

+ func (e DownloadTaskFinishedRequestValidationError) Reason() string

type DownloadTaskResponse

+ Request isDownloadTaskResponse_Request

+ func (m *DownloadTaskResponse) GetRequest() isDownloadTaskResponse_Request

+ func (x *DownloadTaskResponse) GetDownloadPieceFinishedRequest() *DownloadPieceFinishedRequest

+ func (x *DownloadTaskResponse) GetDownloadTaskFinishedRequest() *DownloadTaskFinishedRequest

+ func (x *DownloadTaskResponse) GetDownloadTaskStartedRequest() *DownloadTaskStartedRequest

+ type DownloadTaskResponse_DownloadPieceFinishedRequest struct

+ DownloadPieceFinishedRequest *DownloadPieceFinishedRequest

+ type DownloadTaskResponse_DownloadTaskFinishedRequest struct

+ DownloadTaskFinishedRequest *DownloadTaskFinishedRequest

+ type DownloadTaskResponse_DownloadTaskStartedRequest struct

+ DownloadTaskStartedRequest *DownloadTaskStartedRequest

+ type DownloadTaskStartedRequest struct

+ ResponseHeader map[string]string

+ func (*DownloadTaskStartedRequest) Descriptor() ([]byte, []int)

+ func (*DownloadTaskStartedRequest) ProtoMessage()

+ func (m *DownloadTaskStartedRequest) Validate() error

+ func (m *DownloadTaskStartedRequest) ValidateAll() error

+ func (x *DownloadTaskStartedRequest) GetResponseHeader() map[string]string

+ func (x *DownloadTaskStartedRequest) ProtoReflect() protoreflect.Message

+ func (x *DownloadTaskStartedRequest) Reset()

+ func (x *DownloadTaskStartedRequest) String() string

+ type DownloadTaskStartedRequestMultiError []error

+ func (m DownloadTaskStartedRequestMultiError) AllErrors() []error

+ func (m DownloadTaskStartedRequestMultiError) Error() string

+ type DownloadTaskStartedRequestValidationError struct

+ func (e DownloadTaskStartedRequestValidationError) Cause() error

+ func (e DownloadTaskStartedRequestValidationError) Error() string

+ func (e DownloadTaskStartedRequestValidationError) ErrorName() string

+ func (e DownloadTaskStartedRequestValidationError) Field() string

+ func (e DownloadTaskStartedRequestValidationError) Key() bool

+ func (e DownloadTaskStartedRequestValidationError) Reason() string

Jan 22, 2024

Changes in this version

type DownloadTaskResponse

+ ResponseHeader map[string]string

+ func (x *DownloadTaskResponse) GetResponseHeader() map[string]string

Jan 18, 2024

Changes in this version

type DownloadTaskResponse

+ Header map[string]string

+ func (x *DownloadTaskResponse) GetHeader() map[string]string

type SyncPiecesResponse

+ Header map[string]string

+ func (x *SyncPiecesResponse) GetHeader() map[string]string

Jan 11, 2024

Changes in this version

type SyncPiecesResponse

+ Length uint64

+ Number uint32

+ Offset uint64

+ func (x *SyncPiecesResponse) GetLength() uint64

+ func (x *SyncPiecesResponse) GetNumber() uint32

+ func (x *SyncPiecesResponse) GetOffset() uint64

Dec 19, 2023

Changes in this version

type DfdaemonUploadClient

+ TriggerDownloadTask func(ctx context.Context, in *TriggerDownloadTaskRequest, opts ...grpc.CallOption) (*TriggerDownloadTaskResponse, error)

type DfdaemonUploadServer

+ TriggerDownloadTask func(context.Context, *TriggerDownloadTaskRequest) (*TriggerDownloadTaskResponse, error)

+ type TriggerDownloadTaskRequest struct

+ Download *v2.Download

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

+ func (*TriggerDownloadTaskRequest) ProtoMessage()

+ func (m *TriggerDownloadTaskRequest) Validate() error

+ func (m *TriggerDownloadTaskRequest) ValidateAll() error

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

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

+ func (x *TriggerDownloadTaskRequest) Reset()

+ func (x *TriggerDownloadTaskRequest) String() string

+ type TriggerDownloadTaskRequestMultiError []error

+ func (m TriggerDownloadTaskRequestMultiError) AllErrors() []error

+ func (m TriggerDownloadTaskRequestMultiError) Error() string

+ type TriggerDownloadTaskRequestValidationError struct

+ func (e TriggerDownloadTaskRequestValidationError) Cause() error

+ func (e TriggerDownloadTaskRequestValidationError) Error() string

+ func (e TriggerDownloadTaskRequestValidationError) ErrorName() string

+ func (e TriggerDownloadTaskRequestValidationError) Field() string

+ func (e TriggerDownloadTaskRequestValidationError) Key() bool

+ func (e TriggerDownloadTaskRequestValidationError) Reason() string

+ type TriggerDownloadTaskResponse struct

+ HostId string

+ PeerId string

+ TaskId string

+ func (*TriggerDownloadTaskResponse) Descriptor() ([]byte, []int)

+ func (*TriggerDownloadTaskResponse) ProtoMessage()

+ func (m *TriggerDownloadTaskResponse) Validate() error

+ func (m *TriggerDownloadTaskResponse) ValidateAll() error

+ func (x *TriggerDownloadTaskResponse) GetHostId() string

+ func (x *TriggerDownloadTaskResponse) GetPeerId() string

+ func (x *TriggerDownloadTaskResponse) GetTaskId() string

+ func (x *TriggerDownloadTaskResponse) ProtoReflect() protoreflect.Message

+ func (x *TriggerDownloadTaskResponse) Reset()

+ func (x *TriggerDownloadTaskResponse) String() string

+ type TriggerDownloadTaskResponseMultiError []error

+ func (m TriggerDownloadTaskResponseMultiError) AllErrors() []error

+ func (m TriggerDownloadTaskResponseMultiError) Error() string

+ type TriggerDownloadTaskResponseValidationError struct

+ func (e TriggerDownloadTaskResponseValidationError) Cause() error

+ func (e TriggerDownloadTaskResponseValidationError) Error() string

+ func (e TriggerDownloadTaskResponseValidationError) ErrorName() string

+ func (e TriggerDownloadTaskResponseValidationError) Field() string

+ func (e TriggerDownloadTaskResponseValidationError) Key() bool

+ func (e TriggerDownloadTaskResponseValidationError) Reason() string

type UnimplementedDfdaemonUploadServer

+ func (UnimplementedDfdaemonUploadServer) TriggerDownloadTask(context.Context, *TriggerDownloadTaskRequest) (*TriggerDownloadTaskResponse, error)

Dec 19, 2023

Changes in this version

+ type DownloadPieceFinishedResponse struct

+ Piece *v2.Piece

+ func (*DownloadPieceFinishedResponse) Descriptor() ([]byte, []int)

+ func (*DownloadPieceFinishedResponse) ProtoMessage()

+ func (m *DownloadPieceFinishedResponse) Validate() error

+ func (m *DownloadPieceFinishedResponse) ValidateAll() error

+ func (x *DownloadPieceFinishedResponse) GetPiece() *v2.Piece

+ func (x *DownloadPieceFinishedResponse) ProtoReflect() protoreflect.Message

+ func (x *DownloadPieceFinishedResponse) Reset()

+ func (x *DownloadPieceFinishedResponse) String() string

+ type DownloadPieceFinishedResponseMultiError []error

+ func (m DownloadPieceFinishedResponseMultiError) AllErrors() []error

+ func (m DownloadPieceFinishedResponseMultiError) Error() string

+ type DownloadPieceFinishedResponseValidationError struct

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

+ Response isDownloadTaskResponse_Response

+ func (m *DownloadTaskResponse) GetResponse() isDownloadTaskResponse_Response

+ func (x *DownloadTaskResponse) GetDownloadPieceFinishedResponse() *DownloadPieceFinishedResponse

+ func (x *DownloadTaskResponse) GetDownloadTaskStartedResponse() *DownloadTaskStartedResponse

+ type DownloadTaskResponse_DownloadPieceFinishedResponse struct

+ DownloadPieceFinishedResponse *DownloadPieceFinishedResponse

+ type DownloadTaskResponse_DownloadTaskStartedResponse struct

+ DownloadTaskStartedResponse *DownloadTaskStartedResponse

+ type DownloadTaskStartedResponse struct

+ ContentLength uint64

+ func (*DownloadTaskStartedResponse) Descriptor() ([]byte, []int)

+ func (*DownloadTaskStartedResponse) ProtoMessage()

+ func (m *DownloadTaskStartedResponse) Validate() error

+ func (m *DownloadTaskStartedResponse) ValidateAll() error

+ func (x *DownloadTaskStartedResponse) GetContentLength() uint64

+ func (x *DownloadTaskStartedResponse) ProtoReflect() protoreflect.Message

+ func (x *DownloadTaskStartedResponse) Reset()

+ func (x *DownloadTaskStartedResponse) String() string

+ type DownloadTaskStartedResponseMultiError []error

+ func (m DownloadTaskStartedResponseMultiError) AllErrors() []error

+ func (m DownloadTaskStartedResponseMultiError) Error() string

+ type DownloadTaskStartedResponseValidationError struct

+ 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

Dec 19, 2023

Changes in this version

type DownloadTaskResponse

+ HostId string

+ PeerId string

+ TaskId string

+ func (x *DownloadTaskResponse) GetHostId() string

+ func (x *DownloadTaskResponse) GetPeerId() string

+ func (x *DownloadTaskResponse) GetTaskId() string

Dec 18, 2023

Changes in this version

type DfdaemonUploadClient

+ DownloadTask func(ctx context.Context, in *DownloadTaskRequest, opts ...grpc.CallOption) (DfdaemonUpload_DownloadTaskClient, error)

type DfdaemonUploadServer

+ DownloadTask func(*DownloadTaskRequest, DfdaemonUpload_DownloadTaskServer) error

+ type DfdaemonUpload_DownloadTaskClient interface

+ Recv func() (*DownloadTaskResponse, error)

+ type DfdaemonUpload_DownloadTaskServer interface

+ Send func(*DownloadTaskResponse) error

type UnimplementedDfdaemonUploadServer

+ func (UnimplementedDfdaemonUploadServer) DownloadTask(*DownloadTaskRequest, DfdaemonUpload_DownloadTaskServer) error

Dec 18, 2023

Changes in this version

+ var DfdaemonDownload_ServiceDesc = grpc.ServiceDesc

+ var DfdaemonUpload_ServiceDesc = grpc.ServiceDesc

+ func RegisterDfdaemonDownloadServer(s grpc.ServiceRegistrar, srv DfdaemonDownloadServer)

+ func RegisterDfdaemonUploadServer(s grpc.ServiceRegistrar, srv DfdaemonUploadServer)

+ type DfdaemonDownloadClient interface

+ DeleteTask func(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DownloadTask func(ctx context.Context, in *DownloadTaskRequest, opts ...grpc.CallOption) (DfdaemonDownload_DownloadTaskClient, error)

+ StatTask func(ctx context.Context, in *StatTaskRequest, opts ...grpc.CallOption) (*v2.Task, error)

+ UploadTask func(ctx context.Context, in *UploadTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewDfdaemonDownloadClient(cc grpc.ClientConnInterface) DfdaemonDownloadClient

+ type DfdaemonDownloadServer interface

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

+ DownloadTask func(*DownloadTaskRequest, DfdaemonDownload_DownloadTaskServer) error

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

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

+ type DfdaemonDownload_DownloadTaskClient interface

+ Recv func() (*DownloadTaskResponse, error)

+ type DfdaemonDownload_DownloadTaskServer interface

+ Send func(*DownloadTaskResponse) error

+ type DfdaemonUploadClient interface

+ DownloadPiece func(ctx context.Context, in *DownloadPieceRequest, opts ...grpc.CallOption) (*DownloadPieceResponse, error)

+ SyncPieces func(ctx context.Context, in *SyncPiecesRequest, opts ...grpc.CallOption) (DfdaemonUpload_SyncPiecesClient, error)

+ func NewDfdaemonUploadClient(cc grpc.ClientConnInterface) DfdaemonUploadClient

+ type DfdaemonUploadServer interface

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

+ SyncPieces func(*SyncPiecesRequest, DfdaemonUpload_SyncPiecesServer) error

+ type DfdaemonUpload_SyncPiecesClient interface

+ Recv func() (*SyncPiecesResponse, error)

+ type DfdaemonUpload_SyncPiecesServer interface

+ Send func(*SyncPiecesResponse) error

+ type UnimplementedDfdaemonDownloadServer struct

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

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

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

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

+ type UnimplementedDfdaemonUploadServer struct

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

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

+ type UnsafeDfdaemonDownloadServer interface

+ type UnsafeDfdaemonUploadServer interface

Dec 7, 2023

Changes in this version

type SyncPiecesRequest

+ InterestedPieceNumbers []uint32

+ func (x *SyncPiecesRequest) GetInterestedPieceNumbers() []uint32

type SyncPiecesResponse

+ PieceNumber uint32

+ func (x *SyncPiecesResponse) GetPieceNumber() uint32

Dec 6, 2023

Changes in this version

type DfdaemonClient

+ DownloadPiece func(ctx context.Context, in *DownloadPieceRequest, opts ...grpc.CallOption) (*DownloadPieceResponse, error)

type DfdaemonServer

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

+ type DownloadPieceRequest struct

+ PieceNumber uint32

+ TaskId string

+ func (*DownloadPieceRequest) Descriptor() ([]byte, []int)

+ func (*DownloadPieceRequest) ProtoMessage()

+ func (m *DownloadPieceRequest) Validate() error

+ func (m *DownloadPieceRequest) ValidateAll() error

+ func (x *DownloadPieceRequest) GetPieceNumber() uint32

+ func (x *DownloadPieceRequest) GetTaskId() string

+ func (x *DownloadPieceRequest) ProtoReflect() protoreflect.Message

+ func (x *DownloadPieceRequest) Reset()

+ func (x *DownloadPieceRequest) String() string

+ type DownloadPieceRequestMultiError []error

+ func (m DownloadPieceRequestMultiError) AllErrors() []error

+ func (m DownloadPieceRequestMultiError) Error() string

+ type DownloadPieceRequestValidationError struct

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

+ Piece *v2.Piece

+ func (*DownloadPieceResponse) Descriptor() ([]byte, []int)

+ func (*DownloadPieceResponse) ProtoMessage()

+ func (m *DownloadPieceResponse) Validate() error

+ func (m *DownloadPieceResponse) ValidateAll() error

+ func (x *DownloadPieceResponse) GetPiece() *v2.Piece

+ func (x *DownloadPieceResponse) ProtoReflect() protoreflect.Message

+ func (x *DownloadPieceResponse) Reset()

+ func (x *DownloadPieceResponse) String() string

+ type DownloadPieceResponseMultiError []error

+ func (m DownloadPieceResponseMultiError) AllErrors() []error

+ func (m DownloadPieceResponseMultiError) Error() string

+ type DownloadPieceResponseValidationError struct

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

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

Nov 20, 2023

Changes in this version

type DownloadTaskResponse

+ ContentLength int64

+ func (x *DownloadTaskResponse) GetContentLength() int64

Nov 16, 2023

Changes in this version

+ type Dfdaemon_DownloadTaskClient interface

+ Recv func() (*DownloadTaskResponse, error)

+ type Dfdaemon_DownloadTaskServer interface

+ Send func(*DownloadTaskResponse) error

+ type DownloadTaskResponse struct

+ Piece *v2.Piece

+ func (*DownloadTaskResponse) Descriptor() ([]byte, []int)

+ func (*DownloadTaskResponse) ProtoMessage()

+ func (m *DownloadTaskResponse) Validate() error

+ func (m *DownloadTaskResponse) ValidateAll() error

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

+ func (x *DownloadTaskResponse) ProtoReflect() protoreflect.Message

+ func (x *DownloadTaskResponse) Reset()

+ func (x *DownloadTaskResponse) String() string

+ type DownloadTaskResponseMultiError []error

+ func (m DownloadTaskResponseMultiError) AllErrors() []error

+ func (m DownloadTaskResponseMultiError) Error() string

+ type DownloadTaskResponseValidationError struct

+ 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

Nov 6, 2023

Changes in this version

type GetPieceNumbersRequest

+ TaskId string

+ func (x *GetPieceNumbersRequest) GetTaskId() string

Nov 1, 2023

Changes in this version

type DfdaemonClient

+ GetPieceNumbers func(ctx context.Context, in *GetPieceNumbersRequest, opts ...grpc.CallOption) (*GetPieceNumbersResponse, error)

type DfdaemonServer

+ GetPieceNumbers func(context.Context, *GetPieceNumbersRequest) (*GetPieceNumbersResponse, error)

type UnimplementedDfdaemonServer

+ func (UnimplementedDfdaemonServer) GetPieceNumbers(context.Context, *GetPieceNumbersRequest) (*GetPieceNumbersResponse, error)

Nov 1, 2023

Changes in this version

+ type GetPieceNumbersRequest struct

+ func (*GetPieceNumbersRequest) Descriptor() ([]byte, []int)

+ func (*GetPieceNumbersRequest) ProtoMessage()

+ func (m *GetPieceNumbersRequest) Validate() error

+ func (m *GetPieceNumbersRequest) ValidateAll() error

+ func (x *GetPieceNumbersRequest) ProtoReflect() protoreflect.Message

+ func (x *GetPieceNumbersRequest) Reset()

+ func (x *GetPieceNumbersRequest) String() string

+ type GetPieceNumbersRequestMultiError []error

+ func (m GetPieceNumbersRequestMultiError) AllErrors() []error

+ func (m GetPieceNumbersRequestMultiError) Error() string

+ type GetPieceNumbersRequestValidationError struct

+ func (e GetPieceNumbersRequestValidationError) Cause() error

+ func (e GetPieceNumbersRequestValidationError) Error() string

+ func (e GetPieceNumbersRequestValidationError) ErrorName() string

+ func (e GetPieceNumbersRequestValidationError) Field() string

+ func (e GetPieceNumbersRequestValidationError) Key() bool

+ func (e GetPieceNumbersRequestValidationError) Reason() string

+ type GetPieceNumbersResponse struct

+ PieceNumbers []int32

+ func (*GetPieceNumbersResponse) Descriptor() ([]byte, []int)

+ func (*GetPieceNumbersResponse) ProtoMessage()

+ func (m *GetPieceNumbersResponse) Validate() error

+ func (m *GetPieceNumbersResponse) ValidateAll() error

+ func (x *GetPieceNumbersResponse) GetPieceNumbers() []int32

+ func (x *GetPieceNumbersResponse) ProtoReflect() protoreflect.Message

+ func (x *GetPieceNumbersResponse) Reset()

+ func (x *GetPieceNumbersResponse) String() string

+ type GetPieceNumbersResponseMultiError []error

+ func (m GetPieceNumbersResponseMultiError) AllErrors() []error

+ func (m GetPieceNumbersResponseMultiError) Error() string

+ type GetPieceNumbersResponseValidationError struct

+ func (e GetPieceNumbersResponseValidationError) Cause() error

+ func (e GetPieceNumbersResponseValidationError) Error() string

+ func (e GetPieceNumbersResponseValidationError) ErrorName() string

+ func (e GetPieceNumbersResponseValidationError) Field() string

+ func (e GetPieceNumbersResponseValidationError) Key() bool

+ func (e GetPieceNumbersResponseValidationError) Reason() string

type SyncPiecesRequest

+ func (x *SyncPiecesRequest) GetGetPieceNumbersRequest() *GetPieceNumbersRequest

+ type SyncPiecesRequest_GetPieceNumbersRequest struct

+ GetPieceNumbersRequest *GetPieceNumbersRequest

type SyncPiecesResponse

+ func (x *SyncPiecesResponse) GetGetPieceNumbersResponse() *GetPieceNumbersResponse

+ type SyncPiecesResponse_GetPieceNumbersResponse struct

+ GetPieceNumbersResponse *GetPieceNumbersResponse

Nov 1, 2023

Changes in this version

type InterestedAllPiecesResponse

+ Piece *v2.Piece

+ func (x *InterestedAllPiecesResponse) GetPiece() *v2.Piece

type InterestedPiecesResponse

+ Piece *v2.Piece

+ func (x *InterestedPiecesResponse) GetPiece() *v2.Piece

Oct 10, 2023

Changes in this version

+ type InterestedAllPiecesResponse struct

+ Pieces []*v2.Piece

+ func (*InterestedAllPiecesResponse) Descriptor() ([]byte, []int)

+ func (*InterestedAllPiecesResponse) ProtoMessage()

+ func (m *InterestedAllPiecesResponse) Validate() error

+ func (m *InterestedAllPiecesResponse) ValidateAll() error

+ func (x *InterestedAllPiecesResponse) GetPieces() []*v2.Piece

+ func (x *InterestedAllPiecesResponse) ProtoReflect() protoreflect.Message

+ func (x *InterestedAllPiecesResponse) Reset()

+ func (x *InterestedAllPiecesResponse) String() string

+ type InterestedAllPiecesResponseMultiError []error

+ func (m InterestedAllPiecesResponseMultiError) AllErrors() []error

+ func (m InterestedAllPiecesResponseMultiError) Error() string

+ type InterestedAllPiecesResponseValidationError struct

+ func (e InterestedAllPiecesResponseValidationError) Cause() error

+ func (e InterestedAllPiecesResponseValidationError) Error() string

+ func (e InterestedAllPiecesResponseValidationError) ErrorName() string

+ func (e InterestedAllPiecesResponseValidationError) Field() string

+ func (e InterestedAllPiecesResponseValidationError) Key() bool

+ func (e InterestedAllPiecesResponseValidationError) Reason() string

type SyncPiecesResponse

+ func (x *SyncPiecesResponse) GetInterestedAllPiecesResponse() *InterestedAllPiecesResponse

+ type SyncPiecesResponse_InterestedAllPiecesResponse struct

+ InterestedAllPiecesResponse *InterestedAllPiecesResponse

Sep 21, 2023

Changes in this version

type StatTaskResponse

+ Application *string

+ CreatedAt *timestamppb.Timestamp

+ Digest *string

+ Filters []string

+ Header map[string]string

+ Id string

+ PieceLength int32

+ Tag *string

+ Type v2.TaskType

+ UpdatedAt *timestamppb.Timestamp

+ Url string

+ func (x *StatTaskResponse) GetApplication() string

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

+ func (x *StatTaskResponse) GetDigest() string

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

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

+ func (x *StatTaskResponse) GetId() string

+ func (x *StatTaskResponse) GetPieceLength() int32

+ func (x *StatTaskResponse) GetTag() string

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

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

+ func (x *StatTaskResponse) GetUrl() string

Sep 11, 2023

Changes in this version

type SyncPiecesRequest

+ TaskId string

+ func (x *SyncPiecesRequest) GetTaskId() string

Jul 20, 2023

Changes in this version

+ var Dfdaemon_ServiceDesc = grpc.ServiceDesc

+ var File_pkg_apis_dfdaemon_v2_dfdaemon_proto protoreflect.FileDescriptor

+ func RegisterDfdaemonServer(s grpc.ServiceRegistrar, srv DfdaemonServer)

+ type DeleteTaskRequest struct

+ TaskId string

+ func (*DeleteTaskRequest) Descriptor() ([]byte, []int)

+ func (*DeleteTaskRequest) ProtoMessage()

+ func (m *DeleteTaskRequest) Validate() error

+ func (m *DeleteTaskRequest) ValidateAll() error

+ func (x *DeleteTaskRequest) GetTaskId() string

+ func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteTaskRequest) Reset()

+ func (x *DeleteTaskRequest) String() string

+ type DeleteTaskRequestMultiError []error

+ func (m DeleteTaskRequestMultiError) AllErrors() []error

+ func (m DeleteTaskRequestMultiError) Error() string

+ type DeleteTaskRequestValidationError struct

+ 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 DfdaemonClient interface

+ DeleteTask func(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DownloadTask func(ctx context.Context, in *DownloadTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ StatTask func(ctx context.Context, in *StatTaskRequest, opts ...grpc.CallOption) (*v2.Task, error)

+ SyncPieces func(ctx context.Context, opts ...grpc.CallOption) (Dfdaemon_SyncPiecesClient, error)

+ UploadTask func(ctx context.Context, in *UploadTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewDfdaemonClient(cc grpc.ClientConnInterface) DfdaemonClient

+ type DfdaemonServer interface

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

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

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

+ SyncPieces func(Dfdaemon_SyncPiecesServer) error

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

+ type Dfdaemon_SyncPiecesClient interface

+ Recv func() (*SyncPiecesResponse, error)

+ Send func(*SyncPiecesRequest) error

+ type Dfdaemon_SyncPiecesServer interface

+ Recv func() (*SyncPiecesRequest, error)

+ Send func(*SyncPiecesResponse) error

+ type DownloadTaskRequest struct

+ Download *v2.Download

+ func (*DownloadTaskRequest) Descriptor() ([]byte, []int)

+ func (*DownloadTaskRequest) ProtoMessage()

+ func (m *DownloadTaskRequest) Validate() error

+ func (m *DownloadTaskRequest) ValidateAll() error

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

+ func (x *DownloadTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *DownloadTaskRequest) Reset()

+ func (x *DownloadTaskRequest) String() string

+ type DownloadTaskRequestMultiError []error

+ func (m DownloadTaskRequestMultiError) AllErrors() []error

+ func (m DownloadTaskRequestMultiError) Error() string

+ type DownloadTaskRequestValidationError struct

+ 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 InterestedAllPiecesRequest struct

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

+ func (*InterestedAllPiecesRequest) ProtoMessage()

+ func (m *InterestedAllPiecesRequest) Validate() error

+ func (m *InterestedAllPiecesRequest) ValidateAll() error

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

+ func (x *InterestedAllPiecesRequest) Reset()

+ func (x *InterestedAllPiecesRequest) String() string

+ type InterestedAllPiecesRequestMultiError []error

+ func (m InterestedAllPiecesRequestMultiError) AllErrors() []error

+ func (m InterestedAllPiecesRequestMultiError) Error() string

+ type InterestedAllPiecesRequestValidationError struct

+ func (e InterestedAllPiecesRequestValidationError) Cause() error

+ func (e InterestedAllPiecesRequestValidationError) Error() string

+ func (e InterestedAllPiecesRequestValidationError) ErrorName() string

+ func (e InterestedAllPiecesRequestValidationError) Field() string

+ func (e InterestedAllPiecesRequestValidationError) Key() bool

+ func (e InterestedAllPiecesRequestValidationError) Reason() string

+ type InterestedPiecesRequest struct

+ PieceNumbers []uint32

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

+ func (*InterestedPiecesRequest) ProtoMessage()

+ func (m *InterestedPiecesRequest) Validate() error

+ func (m *InterestedPiecesRequest) ValidateAll() error

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

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

+ func (x *InterestedPiecesRequest) Reset()

+ func (x *InterestedPiecesRequest) String() string

+ type InterestedPiecesRequestMultiError []error

+ func (m InterestedPiecesRequestMultiError) AllErrors() []error

+ func (m InterestedPiecesRequestMultiError) Error() string

+ type InterestedPiecesRequestValidationError struct

+ func (e InterestedPiecesRequestValidationError) Cause() error

+ func (e InterestedPiecesRequestValidationError) Error() string

+ func (e InterestedPiecesRequestValidationError) ErrorName() string

+ func (e InterestedPiecesRequestValidationError) Field() string

+ func (e InterestedPiecesRequestValidationError) Key() bool

+ func (e InterestedPiecesRequestValidationError) Reason() string

+ type InterestedPiecesResponse struct

+ Pieces []*v2.Piece

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

+ func (*InterestedPiecesResponse) ProtoMessage()

+ func (m *InterestedPiecesResponse) Validate() error

+ func (m *InterestedPiecesResponse) ValidateAll() error

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

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

+ func (x *InterestedPiecesResponse) Reset()

+ func (x *InterestedPiecesResponse) String() string

+ type InterestedPiecesResponseMultiError []error

+ func (m InterestedPiecesResponseMultiError) AllErrors() []error

+ func (m InterestedPiecesResponseMultiError) Error() string

+ type InterestedPiecesResponseValidationError struct

+ func (e InterestedPiecesResponseValidationError) Cause() error

+ func (e InterestedPiecesResponseValidationError) Error() string

+ func (e InterestedPiecesResponseValidationError) ErrorName() string

+ func (e InterestedPiecesResponseValidationError) Field() string

+ func (e InterestedPiecesResponseValidationError) Key() bool

+ func (e InterestedPiecesResponseValidationError) Reason() string

+ type StatTaskRequest struct

+ TaskId string

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

+ func (*StatTaskRequest) ProtoMessage()

+ func (m *StatTaskRequest) Validate() error

+ func (m *StatTaskRequest) ValidateAll() error

+ func (x *StatTaskRequest) GetTaskId() string

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

+ func (x *StatTaskRequest) Reset()

+ func (x *StatTaskRequest) String() string

+ type StatTaskRequestMultiError []error

+ func (m StatTaskRequestMultiError) AllErrors() []error

+ func (m StatTaskRequestMultiError) Error() string

+ type StatTaskRequestValidationError struct

+ 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 StatTaskResponse struct

+ Task *v2.Task

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

+ func (*StatTaskResponse) ProtoMessage()

+ func (m *StatTaskResponse) Validate() error

+ func (m *StatTaskResponse) ValidateAll() error

+ func (x *StatTaskResponse) GetTask() *v2.Task

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

+ func (x *StatTaskResponse) Reset()

+ func (x *StatTaskResponse) String() string

+ type StatTaskResponseMultiError []error

+ func (m StatTaskResponseMultiError) AllErrors() []error

+ func (m StatTaskResponseMultiError) Error() string

+ type StatTaskResponseValidationError struct

+ func (e StatTaskResponseValidationError) Cause() error

+ func (e StatTaskResponseValidationError) Error() string

+ func (e StatTaskResponseValidationError) ErrorName() string

+ func (e StatTaskResponseValidationError) Field() string

+ func (e StatTaskResponseValidationError) Key() bool

+ func (e StatTaskResponseValidationError) Reason() string

+ type SyncPiecesRequest struct

+ Request isSyncPiecesRequest_Request

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

+ func (*SyncPiecesRequest) ProtoMessage()

+ func (m *SyncPiecesRequest) GetRequest() isSyncPiecesRequest_Request

+ func (m *SyncPiecesRequest) Validate() error

+ func (m *SyncPiecesRequest) ValidateAll() error

+ func (x *SyncPiecesRequest) GetInterestedAllPiecesRequest() *InterestedAllPiecesRequest

+ func (x *SyncPiecesRequest) GetInterestedPiecesRequest() *InterestedPiecesRequest

+ func (x *SyncPiecesRequest) ProtoReflect() protoreflect.Message

+ func (x *SyncPiecesRequest) Reset()

+ func (x *SyncPiecesRequest) String() string

+ type SyncPiecesRequestMultiError []error

+ func (m SyncPiecesRequestMultiError) AllErrors() []error

+ func (m SyncPiecesRequestMultiError) Error() string

+ type SyncPiecesRequestValidationError struct

+ 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 SyncPiecesRequest_InterestedAllPiecesRequest struct

+ InterestedAllPiecesRequest *InterestedAllPiecesRequest

+ type SyncPiecesRequest_InterestedPiecesRequest struct

+ InterestedPiecesRequest *InterestedPiecesRequest

+ type SyncPiecesResponse struct

+ Response isSyncPiecesResponse_Response

+ func (*SyncPiecesResponse) Descriptor() ([]byte, []int)

+ func (*SyncPiecesResponse) ProtoMessage()

+ func (m *SyncPiecesResponse) GetResponse() isSyncPiecesResponse_Response

+ func (m *SyncPiecesResponse) Validate() error

+ func (m *SyncPiecesResponse) ValidateAll() error

+ func (x *SyncPiecesResponse) GetInterestedPiecesResponse() *InterestedPiecesResponse

+ func (x *SyncPiecesResponse) ProtoReflect() protoreflect.Message

+ func (x *SyncPiecesResponse) Reset()

+ func (x *SyncPiecesResponse) String() string

+ type SyncPiecesResponseMultiError []error

+ func (m SyncPiecesResponseMultiError) AllErrors() []error

+ func (m SyncPiecesResponseMultiError) Error() string

+ type SyncPiecesResponseValidationError struct

+ 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 SyncPiecesResponse_InterestedPiecesResponse struct

+ InterestedPiecesResponse *InterestedPiecesResponse

+ type UnimplementedDfdaemonServer struct

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

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

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

+ func (UnimplementedDfdaemonServer) SyncPieces(Dfdaemon_SyncPiecesServer) error

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

+ type UnsafeDfdaemonServer interface

+ type UploadTaskRequest struct

+ Task *v2.Task

+ func (*UploadTaskRequest) Descriptor() ([]byte, []int)

+ func (*UploadTaskRequest) ProtoMessage()

+ func (m *UploadTaskRequest) Validate() error

+ func (m *UploadTaskRequest) ValidateAll() error

+ func (x *UploadTaskRequest) GetTask() *v2.Task

+ func (x *UploadTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *UploadTaskRequest) Reset()

+ func (x *UploadTaskRequest) String() string

+ type UploadTaskRequestMultiError []error

+ func (m UploadTaskRequestMultiError) AllErrors() []error

+ func (m UploadTaskRequestMultiError) Error() string

+ type UploadTaskRequestValidationError struct

+ 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