dfdaemon

package
v2.0.0-...-1b619d4 Latest Latest
Warning

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

 Go to latest Published: Jul 16, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DfdaemonDownload_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dfdaemon.v2.DfdaemonDownload",
	HandlerType: (*DfdaemonDownloadServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UploadTask",
			Handler:    _DfdaemonDownload_UploadTask_Handler,
		},
		{
			MethodName: "StatTask",
			Handler:    _DfdaemonDownload_StatTask_Handler,
		},
		{
			MethodName: "DeleteTask",
			Handler:    _DfdaemonDownload_DeleteTask_Handler,
		},
		{
			MethodName: "DeleteHost",
			Handler:    _DfdaemonDownload_DeleteHost_Handler,
		},
		{
			MethodName: "UploadCacheTask",
			Handler:    _DfdaemonDownload_UploadCacheTask_Handler,
		},
		{
			MethodName: "StatCacheTask",
			Handler:    _DfdaemonDownload_StatCacheTask_Handler,
		},
		{
			MethodName: "DeleteCacheTask",
			Handler:    _DfdaemonDownload_DeleteCacheTask_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "DownloadTask",
			Handler:       _DfdaemonDownload_DownloadTask_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DownloadCacheTask",
			Handler:       _DfdaemonDownload_DownloadCacheTask_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/apis/dfdaemon/v2/dfdaemon.proto",
}

DfdaemonDownload_ServiceDesc is the grpc.ServiceDesc for DfdaemonDownload service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DfdaemonUpload_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dfdaemon.v2.DfdaemonUpload",
	HandlerType: (*DfdaemonUploadServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DownloadPiece",
			Handler:    _DfdaemonUpload_DownloadPiece_Handler,
		},
		{
			MethodName: "StatCacheTask",
			Handler:    _DfdaemonUpload_StatCacheTask_Handler,
		},
		{
			MethodName: "DeleteCacheTask",
			Handler:    _DfdaemonUpload_DeleteCacheTask_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "DownloadTask",
			Handler:       _DfdaemonUpload_DownloadTask_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SyncPieces",
			Handler:       _DfdaemonUpload_SyncPieces_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DownloadCacheTask",
			Handler:       _DfdaemonUpload_DownloadCacheTask_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/apis/dfdaemon/v2/dfdaemon.proto",
}

DfdaemonUpload_ServiceDesc is the grpc.ServiceDesc for DfdaemonUpload service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_pkg_apis_dfdaemon_v2_dfdaemon_proto protoreflect.FileDescriptor

Functions

func RegisterDfdaemonDownloadServer 

func RegisterDfdaemonDownloadServer(s grpc.ServiceRegistrar, srv DfdaemonDownloadServer)

func RegisterDfdaemonUploadServer 

func RegisterDfdaemonUploadServer(s grpc.ServiceRegistrar, srv DfdaemonUploadServer)

Types

type DeleteCacheTaskRequest 

type DeleteCacheTaskRequest struct {

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

DeleteCacheTaskRequest represents request of DeleteCacheTask.

func (*DeleteCacheTaskRequest) Descriptor deprecated 

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

Deprecated: Use DeleteCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteCacheTaskRequest) GetTaskId 

func (x *DeleteCacheTaskRequest) GetTaskId() string

func (*DeleteCacheTaskRequest) ProtoMessage 

func (*DeleteCacheTaskRequest) ProtoMessage()

func (*DeleteCacheTaskRequest) ProtoReflect 

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

func (*DeleteCacheTaskRequest) Reset 

func (x *DeleteCacheTaskRequest) Reset()

func (*DeleteCacheTaskRequest) String 

func (x *DeleteCacheTaskRequest) String() string

func (*DeleteCacheTaskRequest) Validate 

func (m *DeleteCacheTaskRequest) Validate() error

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

func (*DeleteCacheTaskRequest) ValidateAll 

func (m *DeleteCacheTaskRequest) ValidateAll() error

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

type DeleteCacheTaskRequestMultiError 

type DeleteCacheTaskRequestMultiError []error

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

func (DeleteCacheTaskRequestMultiError) AllErrors 

func (m DeleteCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteCacheTaskRequestMultiError) Error 

func (m DeleteCacheTaskRequestMultiError) Error() string

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

type DeleteCacheTaskRequestValidationError 

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

DeleteCacheTaskRequestValidationError is the validation error returned by DeleteCacheTaskRequest.Validate if the designated constraints aren't met.

func (DeleteCacheTaskRequestValidationError) Cause 

func (e DeleteCacheTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (DeleteCacheTaskRequestValidationError) Error 

func (e DeleteCacheTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DeleteCacheTaskRequestValidationError) ErrorName 

func (e DeleteCacheTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DeleteCacheTaskRequestValidationError) Field 

func (e DeleteCacheTaskRequestValidationError) Field() string

Field function returns field value.

func (DeleteCacheTaskRequestValidationError) Key 

func (e DeleteCacheTaskRequestValidationError) Key() bool

Key function returns key value.

func (DeleteCacheTaskRequestValidationError) Reason 

func (e DeleteCacheTaskRequestValidationError) Reason() string

Reason function returns reason value.

type DeleteTaskRequest 

type DeleteTaskRequest struct {

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

DeleteTaskRequest represents request of DeleteTask.

func (*DeleteTaskRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskRequest) GetTaskId 

func (x *DeleteTaskRequest) GetTaskId() string

func (*DeleteTaskRequest) ProtoMessage 

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) ProtoReflect 

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

func (*DeleteTaskRequest) Reset 

func (x *DeleteTaskRequest) Reset()

func (*DeleteTaskRequest) String 

func (x *DeleteTaskRequest) String() string

func (*DeleteTaskRequest) Validate 

func (m *DeleteTaskRequest) Validate() error

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

func (*DeleteTaskRequest) ValidateAll 

func (m *DeleteTaskRequest) ValidateAll() error

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

type DeleteTaskRequestMultiError 

type DeleteTaskRequestMultiError []error

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

func (DeleteTaskRequestMultiError) AllErrors 

func (m DeleteTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteTaskRequestMultiError) Error 

func (m DeleteTaskRequestMultiError) Error() string

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

type DeleteTaskRequestValidationError 

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

DeleteTaskRequestValidationError is the validation error returned by DeleteTaskRequest.Validate if the designated constraints aren't met.

func (DeleteTaskRequestValidationError) Cause 

func (e DeleteTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (DeleteTaskRequestValidationError) Error 

func (e DeleteTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DeleteTaskRequestValidationError) ErrorName 

func (e DeleteTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DeleteTaskRequestValidationError) Field 

func (e DeleteTaskRequestValidationError) Field() string

Field function returns field value.

func (DeleteTaskRequestValidationError) Key 

func (e DeleteTaskRequestValidationError) Key() bool

Key function returns key value.

func (DeleteTaskRequestValidationError) Reason 

func (e DeleteTaskRequestValidationError) Reason() string

Reason function returns reason value.

type DfdaemonDownloadClient 

type DfdaemonDownloadClient interface {
	// DownloadTask downloads task from p2p network.
	DownloadTask(ctx context.Context, in *DownloadTaskRequest, opts ...grpc.CallOption) (DfdaemonDownload_DownloadTaskClient, error)
	// UploadTask uploads task to p2p network.
	UploadTask(ctx context.Context, in *UploadTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// StatTask stats task information.
	StatTask(ctx context.Context, in *StatTaskRequest, opts ...grpc.CallOption) (*v2.Task, error)
	// DeleteTask deletes task from p2p network.
	DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// DeleteHost releases host in scheduler.
	DeleteHost(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// DownloadCacheTask downloads cache task from p2p network.
	DownloadCacheTask(ctx context.Context, in *DownloadCacheTaskRequest, opts ...grpc.CallOption) (DfdaemonDownload_DownloadCacheTaskClient, error)
	// UploadCacheTask uploads cache task to p2p network.
	UploadCacheTask(ctx context.Context, in *UploadCacheTaskRequest, opts ...grpc.CallOption) (*v2.CacheTask, error)
	// StatCacheTask stats cache task information.
	StatCacheTask(ctx context.Context, in *StatCacheTaskRequest, opts ...grpc.CallOption) (*v2.CacheTask, error)
	// DeleteCacheTask deletes cache task from p2p network.
	DeleteCacheTask(ctx context.Context, in *DeleteCacheTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DfdaemonDownloadClient is the client API for DfdaemonDownload service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDfdaemonDownloadClient 

func NewDfdaemonDownloadClient(cc grpc.ClientConnInterface) DfdaemonDownloadClient

type DfdaemonDownloadServer 

type DfdaemonDownloadServer interface {
	// DownloadTask downloads task from p2p network.
	DownloadTask(*DownloadTaskRequest, DfdaemonDownload_DownloadTaskServer) error
	// UploadTask uploads task to p2p network.
	UploadTask(context.Context, *UploadTaskRequest) (*emptypb.Empty, error)
	// StatTask stats task information.
	StatTask(context.Context, *StatTaskRequest) (*v2.Task, error)
	// DeleteTask deletes task from p2p network.
	DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)
	// DeleteHost releases host in scheduler.
	DeleteHost(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// DownloadCacheTask downloads cache task from p2p network.
	DownloadCacheTask(*DownloadCacheTaskRequest, DfdaemonDownload_DownloadCacheTaskServer) error
	// UploadCacheTask uploads cache task to p2p network.
	UploadCacheTask(context.Context, *UploadCacheTaskRequest) (*v2.CacheTask, error)
	// StatCacheTask stats cache task information.
	StatCacheTask(context.Context, *StatCacheTaskRequest) (*v2.CacheTask, error)
	// DeleteCacheTask deletes cache task from p2p network.
	DeleteCacheTask(context.Context, *DeleteCacheTaskRequest) (*emptypb.Empty, error)
}

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

type DfdaemonDownload_DownloadCacheTaskClient 

type DfdaemonDownload_DownloadCacheTaskClient interface {
	Recv() (*DownloadCacheTaskResponse, error)
	grpc.ClientStream
}

type DfdaemonDownload_DownloadCacheTaskServer 

type DfdaemonDownload_DownloadCacheTaskServer interface {
	Send(*DownloadCacheTaskResponse) error
	grpc.ServerStream
}

type DfdaemonDownload_DownloadTaskClient 

type DfdaemonDownload_DownloadTaskClient interface {
	Recv() (*DownloadTaskResponse, error)
	grpc.ClientStream
}

type DfdaemonDownload_DownloadTaskServer 

type DfdaemonDownload_DownloadTaskServer interface {
	Send(*DownloadTaskResponse) error
	grpc.ServerStream
}

type DfdaemonUploadClient 

type DfdaemonUploadClient interface {
	// DownloadTask downloads task from p2p network.
	DownloadTask(ctx context.Context, in *DownloadTaskRequest, opts ...grpc.CallOption) (DfdaemonUpload_DownloadTaskClient, error)
	// SyncPieces syncs piece metadatas from remote peer.
	SyncPieces(ctx context.Context, in *SyncPiecesRequest, opts ...grpc.CallOption) (DfdaemonUpload_SyncPiecesClient, error)
	// DownloadPiece downloads piece from the remote peer.
	DownloadPiece(ctx context.Context, in *DownloadPieceRequest, opts ...grpc.CallOption) (*DownloadPieceResponse, error)
	// DownloadCacheTask downloads cache task from p2p network.
	DownloadCacheTask(ctx context.Context, in *DownloadCacheTaskRequest, opts ...grpc.CallOption) (DfdaemonUpload_DownloadCacheTaskClient, error)
	// StatCacheTask stats cache task information.
	StatCacheTask(ctx context.Context, in *StatCacheTaskRequest, opts ...grpc.CallOption) (*v2.CacheTask, error)
	// DeleteCacheTask deletes cache task from p2p network.
	DeleteCacheTask(ctx context.Context, in *DeleteCacheTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DfdaemonUploadClient is the client API for DfdaemonUpload service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDfdaemonUploadClient 

func NewDfdaemonUploadClient(cc grpc.ClientConnInterface) DfdaemonUploadClient

type DfdaemonUploadServer 

type DfdaemonUploadServer interface {
	// DownloadTask downloads task from p2p network.
	DownloadTask(*DownloadTaskRequest, DfdaemonUpload_DownloadTaskServer) error
	// SyncPieces syncs piece metadatas from remote peer.
	SyncPieces(*SyncPiecesRequest, DfdaemonUpload_SyncPiecesServer) error
	// DownloadPiece downloads piece from the remote peer.
	DownloadPiece(context.Context, *DownloadPieceRequest) (*DownloadPieceResponse, error)
	// DownloadCacheTask downloads cache task from p2p network.
	DownloadCacheTask(*DownloadCacheTaskRequest, DfdaemonUpload_DownloadCacheTaskServer) error
	// StatCacheTask stats cache task information.
	StatCacheTask(context.Context, *StatCacheTaskRequest) (*v2.CacheTask, error)
	// DeleteCacheTask deletes cache task from p2p network.
	DeleteCacheTask(context.Context, *DeleteCacheTaskRequest) (*emptypb.Empty, error)
}

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

type DfdaemonUpload_DownloadCacheTaskClient 

type DfdaemonUpload_DownloadCacheTaskClient interface {
	Recv() (*DownloadCacheTaskResponse, error)
	grpc.ClientStream
}

type DfdaemonUpload_DownloadCacheTaskServer 

type DfdaemonUpload_DownloadCacheTaskServer interface {
	Send(*DownloadCacheTaskResponse) error
	grpc.ServerStream
}

type DfdaemonUpload_DownloadTaskClient 

type DfdaemonUpload_DownloadTaskClient interface {
	Recv() (*DownloadTaskResponse, error)
	grpc.ClientStream
}

type DfdaemonUpload_DownloadTaskServer 

type DfdaemonUpload_DownloadTaskServer interface {
	Send(*DownloadTaskResponse) error
	grpc.ServerStream
}

type DfdaemonUpload_SyncPiecesClient 

type DfdaemonUpload_SyncPiecesClient interface {
	Recv() (*SyncPiecesResponse, error)
	grpc.ClientStream
}

type DfdaemonUpload_SyncPiecesServer 

type DfdaemonUpload_SyncPiecesServer interface {
	Send(*SyncPiecesResponse) error
	grpc.ServerStream
}

type DownloadCacheTaskRequest 

type DownloadCacheTaskRequest struct {

	// Host id.
	HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// Task id.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Persistent represents whether the cache task is persistent.
	// If the cache task is persistent, the cache peer will
	// not be deleted when dfdamon runs garbage collection.
	Persistent bool `protobuf:"varint,3,opt,name=persistent,proto3" json:"persistent,omitempty"`
	// Tag is used to distinguish different cache tasks.
	Tag *string `protobuf:"bytes,4,opt,name=tag,proto3,oneof" json:"tag,omitempty"`
	// Application of task.
	Application *string `protobuf:"bytes,5,opt,name=application,proto3,oneof" json:"application,omitempty"`
	// Task piece length.
	PieceLength uint64 `protobuf:"varint,6,opt,name=piece_length,json=pieceLength,proto3" json:"piece_length,omitempty"`
	// File path to be exported.
	OutputPath string `protobuf:"bytes,7,opt,name=output_path,json=outputPath,proto3" json:"output_path,omitempty"`
	// Download timeout.
	Timeout *durationpb.Duration `protobuf:"bytes,8,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

DownloadCacheTaskRequest represents request of DownloadCacheTask.

func (*DownloadCacheTaskRequest) Descriptor deprecated 

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

Deprecated: Use DownloadCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*DownloadCacheTaskRequest) GetApplication 

func (x *DownloadCacheTaskRequest) GetApplication() string

func (*DownloadCacheTaskRequest) GetHostId 

func (x *DownloadCacheTaskRequest) GetHostId() string

func (*DownloadCacheTaskRequest) GetOutputPath 

func (x *DownloadCacheTaskRequest) GetOutputPath() string

func (*DownloadCacheTaskRequest) GetPersistent 

func (x *DownloadCacheTaskRequest) GetPersistent() bool

func (*DownloadCacheTaskRequest) GetPieceLength 

func (x *DownloadCacheTaskRequest) GetPieceLength() uint64

func (*DownloadCacheTaskRequest) GetTag 

func (x *DownloadCacheTaskRequest) GetTag() string

func (*DownloadCacheTaskRequest) GetTaskId 

func (x *DownloadCacheTaskRequest) GetTaskId() string

func (*DownloadCacheTaskRequest) GetTimeout 

func (x *DownloadCacheTaskRequest) GetTimeout() *durationpb.Duration

func (*DownloadCacheTaskRequest) ProtoMessage 

func (*DownloadCacheTaskRequest) ProtoMessage()

func (*DownloadCacheTaskRequest) ProtoReflect 

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

func (*DownloadCacheTaskRequest) Reset 

func (x *DownloadCacheTaskRequest) Reset()

func (*DownloadCacheTaskRequest) String 

func (x *DownloadCacheTaskRequest) String() string

func (*DownloadCacheTaskRequest) Validate 

func (m *DownloadCacheTaskRequest) Validate() error

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

func (*DownloadCacheTaskRequest) ValidateAll 

func (m *DownloadCacheTaskRequest) ValidateAll() error

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

type DownloadCacheTaskRequestMultiError 

type DownloadCacheTaskRequestMultiError []error

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

func (DownloadCacheTaskRequestMultiError) AllErrors 

func (m DownloadCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadCacheTaskRequestMultiError) Error 

func (m DownloadCacheTaskRequestMultiError) Error() string

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

type DownloadCacheTaskRequestValidationError 

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

DownloadCacheTaskRequestValidationError is the validation error returned by DownloadCacheTaskRequest.Validate if the designated constraints aren't met.

func (DownloadCacheTaskRequestValidationError) Cause 

func (e DownloadCacheTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadCacheTaskRequestValidationError) Error 

func (e DownloadCacheTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadCacheTaskRequestValidationError) ErrorName 

func (e DownloadCacheTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadCacheTaskRequestValidationError) Field 

func (e DownloadCacheTaskRequestValidationError) Field() string

Field function returns field value.

func (DownloadCacheTaskRequestValidationError) Key 

func (e DownloadCacheTaskRequestValidationError) Key() bool

Key function returns key value.

func (DownloadCacheTaskRequestValidationError) Reason 

func (e DownloadCacheTaskRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadCacheTaskResponse 

type DownloadCacheTaskResponse struct {

	// Host id.
	HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// Task id.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Peer id.
	PeerId string `protobuf:"bytes,3,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// Types that are assignable to Response:
	//
	//	*DownloadCacheTaskResponse_DownloadCacheTaskStartedResponse
	//	*DownloadCacheTaskResponse_DownloadPieceFinishedResponse
	Response isDownloadCacheTaskResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

DownloadCacheTaskResponse represents response of DownloadCacheTask.

func (*DownloadCacheTaskResponse) Descriptor deprecated 

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

Deprecated: Use DownloadCacheTaskResponse.ProtoReflect.Descriptor instead.

func (*DownloadCacheTaskResponse) GetDownloadCacheTaskStartedResponse 

func (x *DownloadCacheTaskResponse) GetDownloadCacheTaskStartedResponse() *DownloadCacheTaskStartedResponse

func (*DownloadCacheTaskResponse) GetDownloadPieceFinishedResponse 

func (x *DownloadCacheTaskResponse) GetDownloadPieceFinishedResponse() *DownloadPieceFinishedResponse

func (*DownloadCacheTaskResponse) GetHostId 

func (x *DownloadCacheTaskResponse) GetHostId() string

func (*DownloadCacheTaskResponse) GetPeerId 

func (x *DownloadCacheTaskResponse) GetPeerId() string

func (*DownloadCacheTaskResponse) GetResponse 

func (m *DownloadCacheTaskResponse) GetResponse() isDownloadCacheTaskResponse_Response

func (*DownloadCacheTaskResponse) GetTaskId 

func (x *DownloadCacheTaskResponse) GetTaskId() string

func (*DownloadCacheTaskResponse) ProtoMessage 

func (*DownloadCacheTaskResponse) ProtoMessage()

func (*DownloadCacheTaskResponse) ProtoReflect 

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

func (*DownloadCacheTaskResponse) Reset 

func (x *DownloadCacheTaskResponse) Reset()

func (*DownloadCacheTaskResponse) String 

func (x *DownloadCacheTaskResponse) String() string

func (*DownloadCacheTaskResponse) Validate 

func (m *DownloadCacheTaskResponse) Validate() error

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

func (*DownloadCacheTaskResponse) ValidateAll 

func (m *DownloadCacheTaskResponse) ValidateAll() error

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

type DownloadCacheTaskResponseMultiError 

type DownloadCacheTaskResponseMultiError []error

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

func (DownloadCacheTaskResponseMultiError) AllErrors 

func (m DownloadCacheTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadCacheTaskResponseMultiError) Error 

func (m DownloadCacheTaskResponseMultiError) Error() string

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

type DownloadCacheTaskResponseValidationError 

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

DownloadCacheTaskResponseValidationError is the validation error returned by DownloadCacheTaskResponse.Validate if the designated constraints aren't met.

func (DownloadCacheTaskResponseValidationError) Cause 

func (e DownloadCacheTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadCacheTaskResponseValidationError) Error 

func (e DownloadCacheTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadCacheTaskResponseValidationError) ErrorName 

func (e DownloadCacheTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadCacheTaskResponseValidationError) Field 

func (e DownloadCacheTaskResponseValidationError) Field() string

Field function returns field value.

func (DownloadCacheTaskResponseValidationError) Key 

func (e DownloadCacheTaskResponseValidationError) Key() bool

Key function returns key value.

func (DownloadCacheTaskResponseValidationError) Reason 

func (e DownloadCacheTaskResponseValidationError) Reason() string

Reason function returns reason value.

type DownloadCacheTaskResponse_DownloadCacheTaskStartedResponse 

type DownloadCacheTaskResponse_DownloadCacheTaskStartedResponse struct {
	DownloadCacheTaskStartedResponse *DownloadCacheTaskStartedResponse `protobuf:"bytes,4,opt,name=download_cache_task_started_response,json=downloadCacheTaskStartedResponse,proto3,oneof"`
}

type DownloadCacheTaskResponse_DownloadPieceFinishedResponse 

type DownloadCacheTaskResponse_DownloadPieceFinishedResponse struct {
	DownloadPieceFinishedResponse *DownloadPieceFinishedResponse `protobuf:"bytes,5,opt,name=download_piece_finished_response,json=downloadPieceFinishedResponse,proto3,oneof"`
}

type DownloadCacheTaskStartedResponse 

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

DownloadCacheTaskStartedResponse represents task download started response of DownloadCacheTaskResponse.

func (*DownloadCacheTaskStartedResponse) Descriptor deprecated 

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

Deprecated: Use DownloadCacheTaskStartedResponse.ProtoReflect.Descriptor instead.

func (*DownloadCacheTaskStartedResponse) ProtoMessage 

func (*DownloadCacheTaskStartedResponse) ProtoMessage()

func (*DownloadCacheTaskStartedResponse) ProtoReflect 

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

func (*DownloadCacheTaskStartedResponse) Reset 

func (x *DownloadCacheTaskStartedResponse) Reset()

func (*DownloadCacheTaskStartedResponse) String 

func (x *DownloadCacheTaskStartedResponse) String() string

func (*DownloadCacheTaskStartedResponse) Validate 

func (m *DownloadCacheTaskStartedResponse) Validate() error

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

func (*DownloadCacheTaskStartedResponse) ValidateAll 

func (m *DownloadCacheTaskStartedResponse) ValidateAll() error

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

type DownloadCacheTaskStartedResponseMultiError 

type DownloadCacheTaskStartedResponseMultiError []error

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

func (DownloadCacheTaskStartedResponseMultiError) AllErrors 

func (m DownloadCacheTaskStartedResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadCacheTaskStartedResponseMultiError) Error 

func (m DownloadCacheTaskStartedResponseMultiError) Error() string

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

type DownloadCacheTaskStartedResponseValidationError 

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

DownloadCacheTaskStartedResponseValidationError is the validation error returned by DownloadCacheTaskStartedResponse.Validate if the designated constraints aren't met.

func (DownloadCacheTaskStartedResponseValidationError) Cause 

func (e DownloadCacheTaskStartedResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadCacheTaskStartedResponseValidationError) Error 

func (e DownloadCacheTaskStartedResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadCacheTaskStartedResponseValidationError) ErrorName 

func (e DownloadCacheTaskStartedResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadCacheTaskStartedResponseValidationError) Field 

func (e DownloadCacheTaskStartedResponseValidationError) Field() string

Field function returns field value.

func (DownloadCacheTaskStartedResponseValidationError) Key 

func (e DownloadCacheTaskStartedResponseValidationError) Key() bool

Key function returns key value.

func (DownloadCacheTaskStartedResponseValidationError) Reason 

func (e DownloadCacheTaskStartedResponseValidationError) Reason() string

Reason function returns reason value.

type DownloadPieceFinishedResponse 

type DownloadPieceFinishedResponse struct {

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

DownloadPieceFinishedResponse represents piece download finished response of DownloadTaskResponse.

func (*DownloadPieceFinishedResponse) Descriptor deprecated 

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

Deprecated: Use DownloadPieceFinishedResponse.ProtoReflect.Descriptor instead.

func (*DownloadPieceFinishedResponse) GetPiece 

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

func (*DownloadPieceFinishedResponse) ProtoMessage 

func (*DownloadPieceFinishedResponse) ProtoMessage()

func (*DownloadPieceFinishedResponse) ProtoReflect 

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

func (*DownloadPieceFinishedResponse) Reset 

func (x *DownloadPieceFinishedResponse) Reset()

func (*DownloadPieceFinishedResponse) String 

func (x *DownloadPieceFinishedResponse) String() string

func (*DownloadPieceFinishedResponse) Validate 

func (m *DownloadPieceFinishedResponse) Validate() error

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

func (*DownloadPieceFinishedResponse) ValidateAll 

func (m *DownloadPieceFinishedResponse) ValidateAll() error

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

type DownloadPieceFinishedResponseMultiError 

type DownloadPieceFinishedResponseMultiError []error

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

func (DownloadPieceFinishedResponseMultiError) AllErrors 

func (m DownloadPieceFinishedResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPieceFinishedResponseMultiError) Error 

func (m DownloadPieceFinishedResponseMultiError) Error() string

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

type DownloadPieceFinishedResponseValidationError 

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

DownloadPieceFinishedResponseValidationError is the validation error returned by DownloadPieceFinishedResponse.Validate if the designated constraints aren't met.

func (DownloadPieceFinishedResponseValidationError) Cause 

func (e DownloadPieceFinishedResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadPieceFinishedResponseValidationError) Error 

func (e DownloadPieceFinishedResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPieceFinishedResponseValidationError) ErrorName 

func (e DownloadPieceFinishedResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPieceFinishedResponseValidationError) Field 

func (e DownloadPieceFinishedResponseValidationError) Field() string

Field function returns field value.

func (DownloadPieceFinishedResponseValidationError) Key 

func (e DownloadPieceFinishedResponseValidationError) Key() bool

Key function returns key value.

func (DownloadPieceFinishedResponseValidationError) Reason 

func (e DownloadPieceFinishedResponseValidationError) Reason() string

Reason function returns reason value.

type DownloadPieceRequest 

type DownloadPieceRequest struct {

	// Host id.
	HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// Task id.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Piece number.
	PieceNumber uint32 `protobuf:"varint,3,opt,name=piece_number,json=pieceNumber,proto3" json:"piece_number,omitempty"`
	// contains filtered or unexported fields
}

DownloadPieceRequest represents request of DownloadPiece.

func (*DownloadPieceRequest) Descriptor deprecated 

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

Deprecated: Use DownloadPieceRequest.ProtoReflect.Descriptor instead.

func (*DownloadPieceRequest) GetHostId 

func (x *DownloadPieceRequest) GetHostId() string

func (*DownloadPieceRequest) GetPieceNumber 

func (x *DownloadPieceRequest) GetPieceNumber() uint32

func (*DownloadPieceRequest) GetTaskId 

func (x *DownloadPieceRequest) GetTaskId() string

func (*DownloadPieceRequest) ProtoMessage 

func (*DownloadPieceRequest) ProtoMessage()

func (*DownloadPieceRequest) ProtoReflect 

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

func (*DownloadPieceRequest) Reset 

func (x *DownloadPieceRequest) Reset()

func (*DownloadPieceRequest) String 

func (x *DownloadPieceRequest) String() string

func (*DownloadPieceRequest) Validate 

func (m *DownloadPieceRequest) Validate() error

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

func (*DownloadPieceRequest) ValidateAll 

func (m *DownloadPieceRequest) ValidateAll() error

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

type DownloadPieceRequestMultiError 

type DownloadPieceRequestMultiError []error

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

func (DownloadPieceRequestMultiError) AllErrors 

func (m DownloadPieceRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPieceRequestMultiError) Error 

func (m DownloadPieceRequestMultiError) Error() string

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

type DownloadPieceRequestValidationError 

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

DownloadPieceRequestValidationError is the validation error returned by DownloadPieceRequest.Validate if the designated constraints aren't met.

func (DownloadPieceRequestValidationError) Cause 

func (e DownloadPieceRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPieceRequestValidationError) Error 

func (e DownloadPieceRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPieceRequestValidationError) ErrorName 

func (e DownloadPieceRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPieceRequestValidationError) Field 

func (e DownloadPieceRequestValidationError) Field() string

Field function returns field value.

func (DownloadPieceRequestValidationError) Key 

func (e DownloadPieceRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPieceRequestValidationError) Reason 

func (e DownloadPieceRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPieceResponse 

type DownloadPieceResponse struct {

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

DownloadPieceResponse represents response of DownloadPieces.

func (*DownloadPieceResponse) Descriptor deprecated 

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

Deprecated: Use DownloadPieceResponse.ProtoReflect.Descriptor instead.

func (*DownloadPieceResponse) GetPiece 

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

func (*DownloadPieceResponse) ProtoMessage 

func (*DownloadPieceResponse) ProtoMessage()

func (*DownloadPieceResponse) ProtoReflect 

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

func (*DownloadPieceResponse) Reset 

func (x *DownloadPieceResponse) Reset()

func (*DownloadPieceResponse) String 

func (x *DownloadPieceResponse) String() string

func (*DownloadPieceResponse) Validate 

func (m *DownloadPieceResponse) Validate() error

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

func (*DownloadPieceResponse) ValidateAll 

func (m *DownloadPieceResponse) ValidateAll() error

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

type DownloadPieceResponseMultiError 

type DownloadPieceResponseMultiError []error

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

func (DownloadPieceResponseMultiError) AllErrors 

func (m DownloadPieceResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPieceResponseMultiError) Error 

func (m DownloadPieceResponseMultiError) Error() string

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

type DownloadPieceResponseValidationError 

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

DownloadPieceResponseValidationError is the validation error returned by DownloadPieceResponse.Validate if the designated constraints aren't met.

func (DownloadPieceResponseValidationError) Cause 

func (e DownloadPieceResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadPieceResponseValidationError) Error 

func (e DownloadPieceResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPieceResponseValidationError) ErrorName 

func (e DownloadPieceResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPieceResponseValidationError) Field 

func (e DownloadPieceResponseValidationError) Field() string

Field function returns field value.

func (DownloadPieceResponseValidationError) Key 

func (e DownloadPieceResponseValidationError) Key() bool

Key function returns key value.

func (DownloadPieceResponseValidationError) Reason 

func (e DownloadPieceResponseValidationError) Reason() string

Reason function returns reason value.

type DownloadTaskRequest 

type DownloadTaskRequest struct {

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

DownloadTaskRequest represents request of DownloadTask.

func (*DownloadTaskRequest) Descriptor deprecated 

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

Deprecated: Use DownloadTaskRequest.ProtoReflect.Descriptor instead.

func (*DownloadTaskRequest) GetDownload 

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

func (*DownloadTaskRequest) ProtoMessage 

func (*DownloadTaskRequest) ProtoMessage()

func (*DownloadTaskRequest) ProtoReflect 

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

func (*DownloadTaskRequest) Reset 

func (x *DownloadTaskRequest) Reset()

func (*DownloadTaskRequest) String 

func (x *DownloadTaskRequest) String() string

func (*DownloadTaskRequest) Validate 

func (m *DownloadTaskRequest) Validate() error

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

func (*DownloadTaskRequest) ValidateAll 

func (m *DownloadTaskRequest) ValidateAll() error

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

type DownloadTaskRequestMultiError 

type DownloadTaskRequestMultiError []error

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

func (DownloadTaskRequestMultiError) AllErrors 

func (m DownloadTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadTaskRequestMultiError) Error 

func (m DownloadTaskRequestMultiError) Error() string

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

type DownloadTaskRequestValidationError 

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

DownloadTaskRequestValidationError is the validation error returned by DownloadTaskRequest.Validate if the designated constraints aren't met.

func (DownloadTaskRequestValidationError) Cause 

func (e DownloadTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadTaskRequestValidationError) Error 

func (e DownloadTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadTaskRequestValidationError) ErrorName 

func (e DownloadTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadTaskRequestValidationError) Field 

func (e DownloadTaskRequestValidationError) Field() string

Field function returns field value.

func (DownloadTaskRequestValidationError) Key 

func (e DownloadTaskRequestValidationError) Key() bool

Key function returns key value.

func (DownloadTaskRequestValidationError) Reason 

func (e DownloadTaskRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadTaskResponse 

type DownloadTaskResponse struct {

	// Host id.
	HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// Task id.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Peer id.
	PeerId string `protobuf:"bytes,3,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// Types that are assignable to Response:
	//
	//	*DownloadTaskResponse_DownloadTaskStartedResponse
	//	*DownloadTaskResponse_DownloadPieceFinishedResponse
	Response isDownloadTaskResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

DownloadTaskResponse represents response of DownloadTask.

func (*DownloadTaskResponse) Descriptor deprecated 

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

Deprecated: Use DownloadTaskResponse.ProtoReflect.Descriptor instead.

func (*DownloadTaskResponse) GetDownloadPieceFinishedResponse 

func (x *DownloadTaskResponse) GetDownloadPieceFinishedResponse() *DownloadPieceFinishedResponse

func (*DownloadTaskResponse) GetDownloadTaskStartedResponse 

func (x *DownloadTaskResponse) GetDownloadTaskStartedResponse() *DownloadTaskStartedResponse

func (*DownloadTaskResponse) GetHostId 

func (x *DownloadTaskResponse) GetHostId() string

func (*DownloadTaskResponse) GetPeerId 

func (x *DownloadTaskResponse) GetPeerId() string

func (*DownloadTaskResponse) GetResponse 

func (m *DownloadTaskResponse) GetResponse() isDownloadTaskResponse_Response

func (*DownloadTaskResponse) GetTaskId 

func (x *DownloadTaskResponse) GetTaskId() string

func (*DownloadTaskResponse) ProtoMessage 

func (*DownloadTaskResponse) ProtoMessage()

func (*DownloadTaskResponse) ProtoReflect 

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

func (*DownloadTaskResponse) Reset 

func (x *DownloadTaskResponse) Reset()

func (*DownloadTaskResponse) String 

func (x *DownloadTaskResponse) String() string

func (*DownloadTaskResponse) Validate 

func (m *DownloadTaskResponse) Validate() error

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

func (*DownloadTaskResponse) ValidateAll 

func (m *DownloadTaskResponse) ValidateAll() error

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

type DownloadTaskResponseMultiError 

type DownloadTaskResponseMultiError []error

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

func (DownloadTaskResponseMultiError) AllErrors 

func (m DownloadTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadTaskResponseMultiError) Error 

func (m DownloadTaskResponseMultiError) Error() string

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

type DownloadTaskResponseValidationError 

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

DownloadTaskResponseValidationError is the validation error returned by DownloadTaskResponse.Validate if the designated constraints aren't met.

func (DownloadTaskResponseValidationError) Cause 

func (e DownloadTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadTaskResponseValidationError) Error 

func (e DownloadTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadTaskResponseValidationError) ErrorName 

func (e DownloadTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadTaskResponseValidationError) Field 

func (e DownloadTaskResponseValidationError) Field() string

Field function returns field value.

func (DownloadTaskResponseValidationError) Key 

func (e DownloadTaskResponseValidationError) Key() bool

Key function returns key value.

func (DownloadTaskResponseValidationError) Reason 

func (e DownloadTaskResponseValidationError) Reason() string

Reason function returns reason value.

type DownloadTaskResponse_DownloadPieceFinishedResponse 

type DownloadTaskResponse_DownloadPieceFinishedResponse struct {
	DownloadPieceFinishedResponse *DownloadPieceFinishedResponse `protobuf:"bytes,5,opt,name=download_piece_finished_response,json=downloadPieceFinishedResponse,proto3,oneof"`
}

type DownloadTaskResponse_DownloadTaskStartedResponse 

type DownloadTaskResponse_DownloadTaskStartedResponse struct {
	DownloadTaskStartedResponse *DownloadTaskStartedResponse `protobuf:"bytes,4,opt,name=download_task_started_response,json=downloadTaskStartedResponse,proto3,oneof"`
}

type DownloadTaskStartedResponse 

type DownloadTaskStartedResponse struct {

	// Task content length.
	ContentLength uint64 `protobuf:"varint,1,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// Range is url range of request. If protocol is http, range
	// is parsed from http header. If other protocol, range comes
	// from download range field.
	Range *v2.Range `protobuf:"bytes,2,opt,name=range,proto3,oneof" json:"range,omitempty"`
	// Task response headers.
	ResponseHeader map[string]string `` /* 191-byte string literal not displayed */
	// Need to download pieces.
	Pieces []*v2.Piece `protobuf:"bytes,4,rep,name=pieces,proto3" json:"pieces,omitempty"`
	// contains filtered or unexported fields
}

DownloadTaskStartedResponse represents task download started response of DownloadTaskResponse.

func (*DownloadTaskStartedResponse) Descriptor deprecated 

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

Deprecated: Use DownloadTaskStartedResponse.ProtoReflect.Descriptor instead.

func (*DownloadTaskStartedResponse) GetContentLength 

func (x *DownloadTaskStartedResponse) GetContentLength() uint64

func (*DownloadTaskStartedResponse) GetPieces 

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

func (*DownloadTaskStartedResponse) GetRange 

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

func (*DownloadTaskStartedResponse) GetResponseHeader 

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

func (*DownloadTaskStartedResponse) ProtoMessage 

func (*DownloadTaskStartedResponse) ProtoMessage()

func (*DownloadTaskStartedResponse) ProtoReflect 

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

func (*DownloadTaskStartedResponse) Reset 

func (x *DownloadTaskStartedResponse) Reset()

func (*DownloadTaskStartedResponse) String 

func (x *DownloadTaskStartedResponse) String() string

func (*DownloadTaskStartedResponse) Validate 

func (m *DownloadTaskStartedResponse) Validate() error

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

func (*DownloadTaskStartedResponse) ValidateAll 

func (m *DownloadTaskStartedResponse) ValidateAll() error

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

type DownloadTaskStartedResponseMultiError 

type DownloadTaskStartedResponseMultiError []error

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

func (DownloadTaskStartedResponseMultiError) AllErrors 

func (m DownloadTaskStartedResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadTaskStartedResponseMultiError) Error 

func (m DownloadTaskStartedResponseMultiError) Error() string

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

type DownloadTaskStartedResponseValidationError 

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

DownloadTaskStartedResponseValidationError is the validation error returned by DownloadTaskStartedResponse.Validate if the designated constraints aren't met.

func (DownloadTaskStartedResponseValidationError) Cause 

func (e DownloadTaskStartedResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadTaskStartedResponseValidationError) Error 

func (e DownloadTaskStartedResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadTaskStartedResponseValidationError) ErrorName 

func (e DownloadTaskStartedResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadTaskStartedResponseValidationError) Field 

func (e DownloadTaskStartedResponseValidationError) Field() string

Field function returns field value.

func (DownloadTaskStartedResponseValidationError) Key 

func (e DownloadTaskStartedResponseValidationError) Key() bool

Key function returns key value.

func (DownloadTaskStartedResponseValidationError) Reason 

func (e DownloadTaskStartedResponseValidationError) Reason() string

Reason function returns reason value.

type StatCacheTaskRequest 

type StatCacheTaskRequest struct {

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

StatCacheTaskRequest represents request of StatCacheTask.

func (*StatCacheTaskRequest) Descriptor deprecated 

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

Deprecated: Use StatCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*StatCacheTaskRequest) GetTaskId 

func (x *StatCacheTaskRequest) GetTaskId() string

func (*StatCacheTaskRequest) ProtoMessage 

func (*StatCacheTaskRequest) ProtoMessage()

func (*StatCacheTaskRequest) ProtoReflect 

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

func (*StatCacheTaskRequest) Reset 

func (x *StatCacheTaskRequest) Reset()

func (*StatCacheTaskRequest) String 

func (x *StatCacheTaskRequest) String() string

func (*StatCacheTaskRequest) Validate 

func (m *StatCacheTaskRequest) Validate() error

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

func (*StatCacheTaskRequest) ValidateAll 

func (m *StatCacheTaskRequest) ValidateAll() error

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

type StatCacheTaskRequestMultiError 

type StatCacheTaskRequestMultiError []error

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

func (StatCacheTaskRequestMultiError) AllErrors 

func (m StatCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatCacheTaskRequestMultiError) Error 

func (m StatCacheTaskRequestMultiError) Error() string

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

type StatCacheTaskRequestValidationError 

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

StatCacheTaskRequestValidationError is the validation error returned by StatCacheTaskRequest.Validate if the designated constraints aren't met.

func (StatCacheTaskRequestValidationError) Cause 

func (e StatCacheTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (StatCacheTaskRequestValidationError) Error 

func (e StatCacheTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatCacheTaskRequestValidationError) ErrorName 

func (e StatCacheTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatCacheTaskRequestValidationError) Field 

func (e StatCacheTaskRequestValidationError) Field() string

Field function returns field value.

func (StatCacheTaskRequestValidationError) Key 

func (e StatCacheTaskRequestValidationError) Key() bool

Key function returns key value.

func (StatCacheTaskRequestValidationError) Reason 

func (e StatCacheTaskRequestValidationError) Reason() string

Reason function returns reason value.

type StatTaskRequest 

type StatTaskRequest struct {

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

StatTaskRequest represents request of StatTask.

func (*StatTaskRequest) Descriptor deprecated 

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

Deprecated: Use StatTaskRequest.ProtoReflect.Descriptor instead.

func (*StatTaskRequest) GetTaskId 

func (x *StatTaskRequest) GetTaskId() string

func (*StatTaskRequest) ProtoMessage 

func (*StatTaskRequest) ProtoMessage()

func (*StatTaskRequest) ProtoReflect 

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

func (*StatTaskRequest) Reset 

func (x *StatTaskRequest) Reset()

func (*StatTaskRequest) String 

func (x *StatTaskRequest) String() string

func (*StatTaskRequest) Validate 

func (m *StatTaskRequest) Validate() error

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

func (*StatTaskRequest) ValidateAll 

func (m *StatTaskRequest) ValidateAll() error

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

type StatTaskRequestMultiError 

type StatTaskRequestMultiError []error

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

func (StatTaskRequestMultiError) AllErrors 

func (m StatTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatTaskRequestMultiError) Error 

func (m StatTaskRequestMultiError) Error() string

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

type StatTaskRequestValidationError 

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

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

func (StatTaskRequestValidationError) Cause 

func (e StatTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (StatTaskRequestValidationError) Error 

func (e StatTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatTaskRequestValidationError) ErrorName 

func (e StatTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatTaskRequestValidationError) Field 

func (e StatTaskRequestValidationError) Field() string

Field function returns field value.

func (StatTaskRequestValidationError) Key 

func (e StatTaskRequestValidationError) Key() bool

Key function returns key value.

func (StatTaskRequestValidationError) Reason 

func (e StatTaskRequestValidationError) Reason() string

Reason function returns reason value.

type SyncPiecesRequest 

type SyncPiecesRequest struct {

	// Host id.
	HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// Task id.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Interested piece numbers.
	InterestedPieceNumbers []uint32 `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

SyncPiecesRequest represents request of SyncPieces.

func (*SyncPiecesRequest) Descriptor deprecated 

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

Deprecated: Use SyncPiecesRequest.ProtoReflect.Descriptor instead.

func (*SyncPiecesRequest) GetHostId 

func (x *SyncPiecesRequest) GetHostId() string

func (*SyncPiecesRequest) GetInterestedPieceNumbers 

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

func (*SyncPiecesRequest) GetTaskId 

func (x *SyncPiecesRequest) GetTaskId() string

func (*SyncPiecesRequest) ProtoMessage 

func (*SyncPiecesRequest) ProtoMessage()

func (*SyncPiecesRequest) ProtoReflect 

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

func (*SyncPiecesRequest) Reset 

func (x *SyncPiecesRequest) Reset()

func (*SyncPiecesRequest) String 

func (x *SyncPiecesRequest) String() string

func (*SyncPiecesRequest) Validate 

func (m *SyncPiecesRequest) Validate() error

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

func (*SyncPiecesRequest) ValidateAll 

func (m *SyncPiecesRequest) ValidateAll() error

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

type SyncPiecesRequestMultiError 

type SyncPiecesRequestMultiError []error

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

func (SyncPiecesRequestMultiError) AllErrors 

func (m SyncPiecesRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncPiecesRequestMultiError) Error 

func (m SyncPiecesRequestMultiError) Error() string

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

type SyncPiecesRequestValidationError 

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

SyncPiecesRequestValidationError is the validation error returned by SyncPiecesRequest.Validate if the designated constraints aren't met.

func (SyncPiecesRequestValidationError) Cause 

func (e SyncPiecesRequestValidationError) Cause() error

Cause function returns cause value.

func (SyncPiecesRequestValidationError) Error 

func (e SyncPiecesRequestValidationError) Error() string

Error satisfies the builtin error interface

func (SyncPiecesRequestValidationError) ErrorName 

func (e SyncPiecesRequestValidationError) ErrorName() string

ErrorName returns error name.

func (SyncPiecesRequestValidationError) Field 

func (e SyncPiecesRequestValidationError) Field() string

Field function returns field value.

func (SyncPiecesRequestValidationError) Key 

func (e SyncPiecesRequestValidationError) Key() bool

Key function returns key value.

func (SyncPiecesRequestValidationError) Reason 

func (e SyncPiecesRequestValidationError) Reason() string

Reason function returns reason value.

type SyncPiecesResponse 

type SyncPiecesResponse struct {

	// Exist piece number.
	Number uint32 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// Piece offset.
	Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// Piece length.
	Length uint64 `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

SyncPiecesResponse represents response of SyncPieces.

func (*SyncPiecesResponse) Descriptor deprecated 

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

Deprecated: Use SyncPiecesResponse.ProtoReflect.Descriptor instead.

func (*SyncPiecesResponse) GetLength 

func (x *SyncPiecesResponse) GetLength() uint64

func (*SyncPiecesResponse) GetNumber 

func (x *SyncPiecesResponse) GetNumber() uint32

func (*SyncPiecesResponse) GetOffset 

func (x *SyncPiecesResponse) GetOffset() uint64

func (*SyncPiecesResponse) ProtoMessage 

func (*SyncPiecesResponse) ProtoMessage()

func (*SyncPiecesResponse) ProtoReflect 

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

func (*SyncPiecesResponse) Reset 

func (x *SyncPiecesResponse) Reset()

func (*SyncPiecesResponse) String 

func (x *SyncPiecesResponse) String() string

func (*SyncPiecesResponse) Validate 

func (m *SyncPiecesResponse) Validate() error

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

func (*SyncPiecesResponse) ValidateAll 

func (m *SyncPiecesResponse) ValidateAll() error

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

type SyncPiecesResponseMultiError 

type SyncPiecesResponseMultiError []error

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

func (SyncPiecesResponseMultiError) AllErrors 

func (m SyncPiecesResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncPiecesResponseMultiError) Error 

func (m SyncPiecesResponseMultiError) Error() string

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

type SyncPiecesResponseValidationError 

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

SyncPiecesResponseValidationError is the validation error returned by SyncPiecesResponse.Validate if the designated constraints aren't met.

func (SyncPiecesResponseValidationError) Cause 

func (e SyncPiecesResponseValidationError) Cause() error

Cause function returns cause value.

func (SyncPiecesResponseValidationError) Error 

func (e SyncPiecesResponseValidationError) Error() string

Error satisfies the builtin error interface

func (SyncPiecesResponseValidationError) ErrorName 

func (e SyncPiecesResponseValidationError) ErrorName() string

ErrorName returns error name.

func (SyncPiecesResponseValidationError) Field 

func (e SyncPiecesResponseValidationError) Field() string

Field function returns field value.

func (SyncPiecesResponseValidationError) Key 

func (e SyncPiecesResponseValidationError) Key() bool

Key function returns key value.

func (SyncPiecesResponseValidationError) Reason 

func (e SyncPiecesResponseValidationError) Reason() string

Reason function returns reason value.

type UnimplementedDfdaemonDownloadServer 

type UnimplementedDfdaemonDownloadServer struct {
}

UnimplementedDfdaemonDownloadServer should be embedded to have forward compatible implementations.

func (UnimplementedDfdaemonDownloadServer) DeleteCacheTask 

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

func (UnimplementedDfdaemonDownloadServer) DeleteHost 

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

func (UnimplementedDfdaemonDownloadServer) DeleteTask 

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

func (UnimplementedDfdaemonDownloadServer) DownloadCacheTask 

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

func (UnimplementedDfdaemonDownloadServer) DownloadTask 

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

func (UnimplementedDfdaemonDownloadServer) StatCacheTask 

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

func (UnimplementedDfdaemonDownloadServer) StatTask 

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

func (UnimplementedDfdaemonDownloadServer) UploadCacheTask 

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

func (UnimplementedDfdaemonDownloadServer) UploadTask 

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

type UnimplementedDfdaemonUploadServer 

type UnimplementedDfdaemonUploadServer struct {
}

UnimplementedDfdaemonUploadServer should be embedded to have forward compatible implementations.

func (UnimplementedDfdaemonUploadServer) DeleteCacheTask 

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

func (UnimplementedDfdaemonUploadServer) DownloadCacheTask 

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

func (UnimplementedDfdaemonUploadServer) DownloadPiece 

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

func (UnimplementedDfdaemonUploadServer) DownloadTask 

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

func (UnimplementedDfdaemonUploadServer) StatCacheTask 

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

func (UnimplementedDfdaemonUploadServer) SyncPieces 

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

type UnsafeDfdaemonDownloadServer 

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

UnsafeDfdaemonDownloadServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DfdaemonDownloadServer will result in compilation errors.

type UnsafeDfdaemonUploadServer 

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

UnsafeDfdaemonUploadServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DfdaemonUploadServer will result in compilation errors.

type UploadCacheTaskRequest 

type UploadCacheTaskRequest struct {

	// Upload file path of cache task.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Replica count of the persistent cache task.
	PersistentReplicaCount uint64 `` /* 130-byte string literal not displayed */
	// Tag is used to distinguish different cache tasks.
	Tag *string `protobuf:"bytes,3,opt,name=tag,proto3,oneof" json:"tag,omitempty"`
	// Application of task.
	Application *string `protobuf:"bytes,4,opt,name=application,proto3,oneof" json:"application,omitempty"`
	// Task piece length.
	PieceLength uint64 `protobuf:"varint,5,opt,name=piece_length,json=pieceLength,proto3" json:"piece_length,omitempty"`
	// TTL of the cache task.
	Ttl *durationpb.Duration `protobuf:"bytes,6,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// Upload timeout.
	Timeout *durationpb.Duration `protobuf:"bytes,7,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

UploadCacheTaskRequest represents request of UploadCacheTask.

func (*UploadCacheTaskRequest) Descriptor deprecated 

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

Deprecated: Use UploadCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*UploadCacheTaskRequest) GetApplication 

func (x *UploadCacheTaskRequest) GetApplication() string

func (*UploadCacheTaskRequest) GetPath 

func (x *UploadCacheTaskRequest) GetPath() string

func (*UploadCacheTaskRequest) GetPersistentReplicaCount 

func (x *UploadCacheTaskRequest) GetPersistentReplicaCount() uint64

func (*UploadCacheTaskRequest) GetPieceLength 

func (x *UploadCacheTaskRequest) GetPieceLength() uint64

func (*UploadCacheTaskRequest) GetTag 

func (x *UploadCacheTaskRequest) GetTag() string

func (*UploadCacheTaskRequest) GetTimeout 

func (x *UploadCacheTaskRequest) GetTimeout() *durationpb.Duration

func (*UploadCacheTaskRequest) GetTtl 

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

func (*UploadCacheTaskRequest) ProtoMessage 

func (*UploadCacheTaskRequest) ProtoMessage()

func (*UploadCacheTaskRequest) ProtoReflect 

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

func (*UploadCacheTaskRequest) Reset 

func (x *UploadCacheTaskRequest) Reset()

func (*UploadCacheTaskRequest) String 

func (x *UploadCacheTaskRequest) String() string

func (*UploadCacheTaskRequest) Validate 

func (m *UploadCacheTaskRequest) Validate() error

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

func (*UploadCacheTaskRequest) ValidateAll 

func (m *UploadCacheTaskRequest) ValidateAll() error

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

type UploadCacheTaskRequestMultiError 

type UploadCacheTaskRequestMultiError []error

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

func (UploadCacheTaskRequestMultiError) AllErrors 

func (m UploadCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UploadCacheTaskRequestMultiError) Error 

func (m UploadCacheTaskRequestMultiError) Error() string

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

type UploadCacheTaskRequestValidationError 

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

UploadCacheTaskRequestValidationError is the validation error returned by UploadCacheTaskRequest.Validate if the designated constraints aren't met.

func (UploadCacheTaskRequestValidationError) Cause 

func (e UploadCacheTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (UploadCacheTaskRequestValidationError) Error 

func (e UploadCacheTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (UploadCacheTaskRequestValidationError) ErrorName 

func (e UploadCacheTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (UploadCacheTaskRequestValidationError) Field 

func (e UploadCacheTaskRequestValidationError) Field() string

Field function returns field value.

func (UploadCacheTaskRequestValidationError) Key 

func (e UploadCacheTaskRequestValidationError) Key() bool

Key function returns key value.

func (UploadCacheTaskRequestValidationError) Reason 

func (e UploadCacheTaskRequestValidationError) Reason() string

Reason function returns reason value.

type UploadTaskRequest 

type UploadTaskRequest struct {

	// Task metadata.
	Task *v2.Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

UploadTaskRequest represents request of UploadTask.

func (*UploadTaskRequest) Descriptor deprecated 

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

Deprecated: Use UploadTaskRequest.ProtoReflect.Descriptor instead.

func (*UploadTaskRequest) GetTask 

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

func (*UploadTaskRequest) ProtoMessage 

func (*UploadTaskRequest) ProtoMessage()

func (*UploadTaskRequest) ProtoReflect 

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

func (*UploadTaskRequest) Reset 

func (x *UploadTaskRequest) Reset()

func (*UploadTaskRequest) String 

func (x *UploadTaskRequest) String() string

func (*UploadTaskRequest) Validate 

func (m *UploadTaskRequest) Validate() error

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

func (*UploadTaskRequest) ValidateAll 

func (m *UploadTaskRequest) ValidateAll() error

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

type UploadTaskRequestMultiError 

type UploadTaskRequestMultiError []error

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

func (UploadTaskRequestMultiError) AllErrors 

func (m UploadTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UploadTaskRequestMultiError) Error 

func (m UploadTaskRequestMultiError) Error() string

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

type UploadTaskRequestValidationError 

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

UploadTaskRequestValidationError is the validation error returned by UploadTaskRequest.Validate if the designated constraints aren't met.

func (UploadTaskRequestValidationError) Cause 

func (e UploadTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (UploadTaskRequestValidationError) Error 

func (e UploadTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (UploadTaskRequestValidationError) ErrorName 

func (e UploadTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (UploadTaskRequestValidationError) Field 

func (e UploadTaskRequestValidationError) Field() string

Field function returns field value.

func (UploadTaskRequestValidationError) Key 

func (e UploadTaskRequestValidationError) Key() bool

Key function returns key value.

func (UploadTaskRequestValidationError) Reason 

func (e UploadTaskRequestValidationError) Reason() string

Reason function returns reason value.

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.