dfdaemon

package
v2.0.146 Latest Latest
Warning

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

 Go to latest Published: Aug 12, 2024 License: Apache-2.0 Imports: 24 Imported by: 9

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

func RegisterDfdaemonDownloadServer(s grpc.ServiceRegistrar, srv DfdaemonDownloadServer)

func RegisterDfdaemonUploadServer added in v2.0.63 

func RegisterDfdaemonUploadServer(s grpc.ServiceRegistrar, srv DfdaemonUploadServer)

Types

type DeleteCacheTaskRequest added in v2.0.116 

type DeleteCacheTaskRequest struct {

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

DeleteCacheTaskRequest represents request of DeleteCacheTask.

func (*DeleteCacheTaskRequest) Descriptor deprecated added in v2.0.116 

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

Deprecated: Use DeleteCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteCacheTaskRequest) GetTaskId added in v2.0.116 

func (x *DeleteCacheTaskRequest) GetTaskId() string

func (*DeleteCacheTaskRequest) ProtoMessage added in v2.0.116 

func (*DeleteCacheTaskRequest) ProtoMessage()

func (*DeleteCacheTaskRequest) ProtoReflect added in v2.0.116 

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

func (*DeleteCacheTaskRequest) Reset added in v2.0.116 

func (x *DeleteCacheTaskRequest) Reset()

func (*DeleteCacheTaskRequest) String added in v2.0.116 

func (x *DeleteCacheTaskRequest) String() string

func (*DeleteCacheTaskRequest) Validate added in v2.0.116 

func (m *DeleteCacheTaskRequest) Validate() error

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

func (*DeleteCacheTaskRequest) ValidateAll added in v2.0.116 

func (m *DeleteCacheTaskRequest) ValidateAll() error

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

type DeleteCacheTaskRequestMultiError added in v2.0.116 

type DeleteCacheTaskRequestMultiError []error

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

func (DeleteCacheTaskRequestMultiError) AllErrors added in v2.0.116 

func (m DeleteCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteCacheTaskRequestMultiError) Error added in v2.0.116 

func (m DeleteCacheTaskRequestMultiError) Error() string

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

type DeleteCacheTaskRequestValidationError added in v2.0.116 

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

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

func (DeleteCacheTaskRequestValidationError) Cause added in v2.0.116 

func (e DeleteCacheTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (DeleteCacheTaskRequestValidationError) Error added in v2.0.116 

func (e DeleteCacheTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DeleteCacheTaskRequestValidationError) ErrorName added in v2.0.116 

func (e DeleteCacheTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DeleteCacheTaskRequestValidationError) Field added in v2.0.116 

func (e DeleteCacheTaskRequestValidationError) Field() string

Field function returns field value.

func (DeleteCacheTaskRequestValidationError) Key added in v2.0.116 

func (e DeleteCacheTaskRequestValidationError) Key() bool

Key function returns key value.

func (DeleteCacheTaskRequestValidationError) Reason added in v2.0.116 

func (e DeleteCacheTaskRequestValidationError) Reason() string

Reason function returns reason value.

type DeleteTaskRequest 

type DeleteTaskRequest struct {

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

DeleteTaskRequest represents request of DeleteTask.

func (*DeleteTaskRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskRequest) GetTaskId 

func (x *DeleteTaskRequest) GetTaskId() string

func (*DeleteTaskRequest) ProtoMessage 

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) ProtoReflect 

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

func (*DeleteTaskRequest) Reset 

func (x *DeleteTaskRequest) Reset()

func (*DeleteTaskRequest) String 

func (x *DeleteTaskRequest) String() string

func (*DeleteTaskRequest) Validate 

func (m *DeleteTaskRequest) Validate() error

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

func (*DeleteTaskRequest) ValidateAll 

func (m *DeleteTaskRequest) ValidateAll() error

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

type DeleteTaskRequestMultiError 

type DeleteTaskRequestMultiError []error

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

func (DeleteTaskRequestMultiError) AllErrors 

func (m DeleteTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteTaskRequestMultiError) Error 

func (m DeleteTaskRequestMultiError) Error() string

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

type DeleteTaskRequestValidationError 

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

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

func (DeleteTaskRequestValidationError) Cause 

func (e DeleteTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (DeleteTaskRequestValidationError) Error 

func (e DeleteTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DeleteTaskRequestValidationError) ErrorName 

func (e DeleteTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DeleteTaskRequestValidationError) Field 

func (e DeleteTaskRequestValidationError) Field() string

Field function returns field value.

func (DeleteTaskRequestValidationError) Key 

func (e DeleteTaskRequestValidationError) Key() bool

Key function returns key value.

func (DeleteTaskRequestValidationError) Reason 

func (e DeleteTaskRequestValidationError) Reason() string

Reason function returns reason value.

type DfdaemonDownloadClient added in v2.0.63 

type DfdaemonDownloadClient interface {
	// DownloadTask downloads task from p2p network.
	DownloadTask(ctx context.Context, in *DownloadTaskRequest, opts ...grpc.CallOption) (DfdaemonDownload_DownloadTaskClient, error)
	// UploadTask uploads task to p2p network.
	UploadTask(ctx context.Context, in *UploadTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// StatTask stats task information.
	StatTask(ctx context.Context, in *StatTaskRequest, opts ...grpc.CallOption) (*v2.Task, error)
	// DeleteTask deletes task from p2p network.
	DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// 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 added in v2.0.63 

func NewDfdaemonDownloadClient(cc grpc.ClientConnInterface) DfdaemonDownloadClient

type DfdaemonDownloadServer added in v2.0.63 

type DfdaemonDownloadServer interface {
	// DownloadTask downloads task from p2p network.
	DownloadTask(*DownloadTaskRequest, DfdaemonDownload_DownloadTaskServer) error
	// UploadTask uploads task to p2p network.
	UploadTask(context.Context, *UploadTaskRequest) (*emptypb.Empty, error)
	// StatTask stats task information.
	StatTask(context.Context, *StatTaskRequest) (*v2.Task, error)
	// DeleteTask deletes task from p2p network.
	DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)
	// 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 added in v2.0.116 

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

type DfdaemonDownload_DownloadCacheTaskServer added in v2.0.116 

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

type DfdaemonDownload_DownloadTaskClient added in v2.0.63 

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

type DfdaemonDownload_DownloadTaskServer added in v2.0.63 

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

type DfdaemonUploadClient added in v2.0.63 

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

DfdaemonUploadClient is the client API for DfdaemonUpload service.

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

func NewDfdaemonUploadClient added in v2.0.63 

func NewDfdaemonUploadClient(cc grpc.ClientConnInterface) DfdaemonUploadClient

type DfdaemonUploadServer added in v2.0.63 

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

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

type DfdaemonUpload_DownloadCacheTaskClient added in v2.0.116 

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

type DfdaemonUpload_DownloadCacheTaskServer added in v2.0.116 

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

type DfdaemonUpload_DownloadTaskClient added in v2.0.64 

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

type DfdaemonUpload_DownloadTaskServer added in v2.0.64 

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

type DfdaemonUpload_SyncPiecesClient added in v2.0.63 

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

type DfdaemonUpload_SyncPiecesServer added in v2.0.63 

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

type DownloadCacheTaskRequest added in v2.0.116 

type DownloadCacheTaskRequest struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,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 dfdaemon runs garbage collection.
	Persistent bool `protobuf:"varint,2,opt,name=persistent,proto3" json:"persistent,omitempty"`
	// Tag is used to distinguish different cache tasks.
	Tag *string `protobuf:"bytes,3,opt,name=tag,proto3,oneof" json:"tag,omitempty"`
	// Application of task.
	Application *string `protobuf:"bytes,4,opt,name=application,proto3,oneof" json:"application,omitempty"`
	// File path to be exported.
	OutputPath string `protobuf:"bytes,5,opt,name=output_path,json=outputPath,proto3" json:"output_path,omitempty"`
	// Download timeout.
	Timeout *durationpb.Duration `protobuf:"bytes,6,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

DownloadCacheTaskRequest represents request of DownloadCacheTask.

func (*DownloadCacheTaskRequest) Descriptor deprecated added in v2.0.116 

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

Deprecated: Use DownloadCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*DownloadCacheTaskRequest) GetApplication added in v2.0.116 

func (x *DownloadCacheTaskRequest) GetApplication() string

func (*DownloadCacheTaskRequest) GetOutputPath added in v2.0.116 

func (x *DownloadCacheTaskRequest) GetOutputPath() string

func (*DownloadCacheTaskRequest) GetPersistent added in v2.0.124 

func (x *DownloadCacheTaskRequest) GetPersistent() bool

func (*DownloadCacheTaskRequest) GetTag added in v2.0.116 

func (x *DownloadCacheTaskRequest) GetTag() string

func (*DownloadCacheTaskRequest) GetTaskId added in v2.0.116 

func (x *DownloadCacheTaskRequest) GetTaskId() string

func (*DownloadCacheTaskRequest) GetTimeout added in v2.0.116 

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

func (*DownloadCacheTaskRequest) ProtoMessage added in v2.0.116 

func (*DownloadCacheTaskRequest) ProtoMessage()

func (*DownloadCacheTaskRequest) ProtoReflect added in v2.0.116 

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

func (*DownloadCacheTaskRequest) Reset added in v2.0.116 

func (x *DownloadCacheTaskRequest) Reset()

func (*DownloadCacheTaskRequest) String added in v2.0.116 

func (x *DownloadCacheTaskRequest) String() string

func (*DownloadCacheTaskRequest) Validate added in v2.0.116 

func (m *DownloadCacheTaskRequest) Validate() error

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

func (*DownloadCacheTaskRequest) ValidateAll added in v2.0.116 

func (m *DownloadCacheTaskRequest) ValidateAll() error

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

type DownloadCacheTaskRequestMultiError added in v2.0.116 

type DownloadCacheTaskRequestMultiError []error

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

func (DownloadCacheTaskRequestMultiError) AllErrors added in v2.0.116 

func (m DownloadCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadCacheTaskRequestMultiError) Error added in v2.0.116 

func (m DownloadCacheTaskRequestMultiError) Error() string

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

type DownloadCacheTaskRequestValidationError added in v2.0.116 

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

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

func (DownloadCacheTaskRequestValidationError) Cause added in v2.0.116 

func (e DownloadCacheTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadCacheTaskRequestValidationError) Error added in v2.0.116 

func (e DownloadCacheTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadCacheTaskRequestValidationError) ErrorName added in v2.0.116 

func (e DownloadCacheTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadCacheTaskRequestValidationError) Field added in v2.0.116 

func (e DownloadCacheTaskRequestValidationError) Field() string

Field function returns field value.

func (DownloadCacheTaskRequestValidationError) Key added in v2.0.116 

func (e DownloadCacheTaskRequestValidationError) Key() bool

Key function returns key value.

func (DownloadCacheTaskRequestValidationError) Reason added in v2.0.116 

func (e DownloadCacheTaskRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadCacheTaskResponse added in v2.0.116 

type DownloadCacheTaskResponse struct {

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

DownloadCacheTaskResponse represents response of DownloadCacheTask.

func (*DownloadCacheTaskResponse) Descriptor deprecated added in v2.0.116 

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

Deprecated: Use DownloadCacheTaskResponse.ProtoReflect.Descriptor instead.

func (*DownloadCacheTaskResponse) GetDownloadCacheTaskStartedResponse added in v2.0.116 

func (x *DownloadCacheTaskResponse) GetDownloadCacheTaskStartedResponse() *DownloadCacheTaskStartedResponse

func (*DownloadCacheTaskResponse) GetDownloadPieceFinishedResponse added in v2.0.116 

func (x *DownloadCacheTaskResponse) GetDownloadPieceFinishedResponse() *DownloadPieceFinishedResponse

func (*DownloadCacheTaskResponse) GetHostId added in v2.0.116 

func (x *DownloadCacheTaskResponse) GetHostId() string

func (*DownloadCacheTaskResponse) GetPeerId added in v2.0.116 

func (x *DownloadCacheTaskResponse) GetPeerId() string

func (*DownloadCacheTaskResponse) GetResponse added in v2.0.116 

func (m *DownloadCacheTaskResponse) GetResponse() isDownloadCacheTaskResponse_Response

func (*DownloadCacheTaskResponse) GetTaskId added in v2.0.116 

func (x *DownloadCacheTaskResponse) GetTaskId() string

func (*DownloadCacheTaskResponse) ProtoMessage added in v2.0.116 

func (*DownloadCacheTaskResponse) ProtoMessage()

func (*DownloadCacheTaskResponse) ProtoReflect added in v2.0.116 

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

func (*DownloadCacheTaskResponse) Reset added in v2.0.116 

func (x *DownloadCacheTaskResponse) Reset()

func (*DownloadCacheTaskResponse) String added in v2.0.116 

func (x *DownloadCacheTaskResponse) String() string

func (*DownloadCacheTaskResponse) Validate added in v2.0.116 

func (m *DownloadCacheTaskResponse) Validate() error

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

func (*DownloadCacheTaskResponse) ValidateAll added in v2.0.116 

func (m *DownloadCacheTaskResponse) ValidateAll() error

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

type DownloadCacheTaskResponseMultiError added in v2.0.116 

type DownloadCacheTaskResponseMultiError []error

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

func (DownloadCacheTaskResponseMultiError) AllErrors added in v2.0.116 

func (m DownloadCacheTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadCacheTaskResponseMultiError) Error added in v2.0.116 

func (m DownloadCacheTaskResponseMultiError) Error() string

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

type DownloadCacheTaskResponseValidationError added in v2.0.116 

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

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

func (DownloadCacheTaskResponseValidationError) Cause added in v2.0.116 

func (e DownloadCacheTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadCacheTaskResponseValidationError) Error added in v2.0.116 

func (e DownloadCacheTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadCacheTaskResponseValidationError) ErrorName added in v2.0.116 

func (e DownloadCacheTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadCacheTaskResponseValidationError) Field added in v2.0.116 

func (e DownloadCacheTaskResponseValidationError) Field() string

Field function returns field value.

func (DownloadCacheTaskResponseValidationError) Key added in v2.0.116 

func (e DownloadCacheTaskResponseValidationError) Key() bool

Key function returns key value.

func (DownloadCacheTaskResponseValidationError) Reason added in v2.0.116 

func (e DownloadCacheTaskResponseValidationError) Reason() string

Reason function returns reason value.

type DownloadCacheTaskResponse_DownloadCacheTaskStartedResponse added in v2.0.116 

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

type DownloadCacheTaskResponse_DownloadPieceFinishedResponse added in v2.0.116 

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

type DownloadCacheTaskStartedResponse added in v2.0.116 

type DownloadCacheTaskStartedResponse struct {

	// Task content length.
	ContentLength uint64 `protobuf:"varint,1,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// contains filtered or unexported fields
}

DownloadCacheTaskStartedResponse represents task download started response of DownloadCacheTaskResponse.

func (*DownloadCacheTaskStartedResponse) Descriptor deprecated added in v2.0.116 

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

Deprecated: Use DownloadCacheTaskStartedResponse.ProtoReflect.Descriptor instead.

func (*DownloadCacheTaskStartedResponse) GetContentLength added in v2.0.141 

func (x *DownloadCacheTaskStartedResponse) GetContentLength() uint64

func (*DownloadCacheTaskStartedResponse) ProtoMessage added in v2.0.116 

func (*DownloadCacheTaskStartedResponse) ProtoMessage()

func (*DownloadCacheTaskStartedResponse) ProtoReflect added in v2.0.116 

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

func (*DownloadCacheTaskStartedResponse) Reset added in v2.0.116 

func (x *DownloadCacheTaskStartedResponse) Reset()

func (*DownloadCacheTaskStartedResponse) String added in v2.0.116 

func (x *DownloadCacheTaskStartedResponse) String() string

func (*DownloadCacheTaskStartedResponse) Validate added in v2.0.116 

func (m *DownloadCacheTaskStartedResponse) Validate() error

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

func (*DownloadCacheTaskStartedResponse) ValidateAll added in v2.0.116 

func (m *DownloadCacheTaskStartedResponse) ValidateAll() error

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

type DownloadCacheTaskStartedResponseMultiError added in v2.0.116 

type DownloadCacheTaskStartedResponseMultiError []error

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

func (DownloadCacheTaskStartedResponseMultiError) AllErrors added in v2.0.116 

func (m DownloadCacheTaskStartedResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadCacheTaskStartedResponseMultiError) Error added in v2.0.116 

func (m DownloadCacheTaskStartedResponseMultiError) Error() string

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

type DownloadCacheTaskStartedResponseValidationError added in v2.0.116 

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

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

func (DownloadCacheTaskStartedResponseValidationError) Cause added in v2.0.116 

func (e DownloadCacheTaskStartedResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadCacheTaskStartedResponseValidationError) Error added in v2.0.116 

func (e DownloadCacheTaskStartedResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadCacheTaskStartedResponseValidationError) ErrorName added in v2.0.116 

func (e DownloadCacheTaskStartedResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadCacheTaskStartedResponseValidationError) Field added in v2.0.116 

func (e DownloadCacheTaskStartedResponseValidationError) Field() string

Field function returns field value.

func (DownloadCacheTaskStartedResponseValidationError) Key added in v2.0.116 

func (e DownloadCacheTaskStartedResponseValidationError) Key() bool

Key function returns key value.

func (DownloadCacheTaskStartedResponseValidationError) Reason added in v2.0.116 

func (e DownloadCacheTaskStartedResponseValidationError) Reason() string

Reason function returns reason value.

type DownloadPieceFinishedResponse added in v2.0.66 

type DownloadPieceFinishedResponse struct {

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

DownloadPieceFinishedResponse represents piece download finished response of DownloadTaskResponse.

func (*DownloadPieceFinishedResponse) Descriptor deprecated added in v2.0.66 

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

Deprecated: Use DownloadPieceFinishedResponse.ProtoReflect.Descriptor instead.

func (*DownloadPieceFinishedResponse) GetPiece added in v2.0.66 

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

func (*DownloadPieceFinishedResponse) ProtoMessage added in v2.0.66 

func (*DownloadPieceFinishedResponse) ProtoMessage()

func (*DownloadPieceFinishedResponse) ProtoReflect added in v2.0.66 

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

func (*DownloadPieceFinishedResponse) Reset added in v2.0.66 

func (x *DownloadPieceFinishedResponse) Reset()

func (*DownloadPieceFinishedResponse) String added in v2.0.66 

func (x *DownloadPieceFinishedResponse) String() string

func (*DownloadPieceFinishedResponse) Validate added in v2.0.66 

func (m *DownloadPieceFinishedResponse) Validate() error

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

func (*DownloadPieceFinishedResponse) ValidateAll added in v2.0.66 

func (m *DownloadPieceFinishedResponse) ValidateAll() error

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

type DownloadPieceFinishedResponseMultiError added in v2.0.66 

type DownloadPieceFinishedResponseMultiError []error

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

func (DownloadPieceFinishedResponseMultiError) AllErrors added in v2.0.66 

func (m DownloadPieceFinishedResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPieceFinishedResponseMultiError) Error added in v2.0.66 

func (m DownloadPieceFinishedResponseMultiError) Error() string

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

type DownloadPieceFinishedResponseValidationError added in v2.0.66 

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

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

func (DownloadPieceFinishedResponseValidationError) Cause added in v2.0.66 

func (e DownloadPieceFinishedResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadPieceFinishedResponseValidationError) Error added in v2.0.66 

func (e DownloadPieceFinishedResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPieceFinishedResponseValidationError) ErrorName added in v2.0.66 

func (e DownloadPieceFinishedResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPieceFinishedResponseValidationError) Field added in v2.0.66 

func (e DownloadPieceFinishedResponseValidationError) Field() string

Field function returns field value.

func (DownloadPieceFinishedResponseValidationError) Key added in v2.0.66 

func (e DownloadPieceFinishedResponseValidationError) Key() bool

Key function returns key value.

func (DownloadPieceFinishedResponseValidationError) Reason added in v2.0.66 

func (e DownloadPieceFinishedResponseValidationError) Reason() string

Reason function returns reason value.

type DownloadPieceRequest added in v2.0.59 

type DownloadPieceRequest struct {

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

DownloadPieceRequest represents request of DownloadPiece.

func (*DownloadPieceRequest) Descriptor deprecated added in v2.0.59 

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

Deprecated: Use DownloadPieceRequest.ProtoReflect.Descriptor instead.

func (*DownloadPieceRequest) GetHostId added in v2.0.115 

func (x *DownloadPieceRequest) GetHostId() string

func (*DownloadPieceRequest) GetPieceNumber added in v2.0.59 

func (x *DownloadPieceRequest) GetPieceNumber() uint32

func (*DownloadPieceRequest) GetTaskId added in v2.0.59 

func (x *DownloadPieceRequest) GetTaskId() string

func (*DownloadPieceRequest) ProtoMessage added in v2.0.59 

func (*DownloadPieceRequest) ProtoMessage()

func (*DownloadPieceRequest) ProtoReflect added in v2.0.59 

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

func (*DownloadPieceRequest) Reset added in v2.0.59 

func (x *DownloadPieceRequest) Reset()

func (*DownloadPieceRequest) String added in v2.0.59 

func (x *DownloadPieceRequest) String() string

func (*DownloadPieceRequest) Validate added in v2.0.59 

func (m *DownloadPieceRequest) Validate() error

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

func (*DownloadPieceRequest) ValidateAll added in v2.0.59 

func (m *DownloadPieceRequest) ValidateAll() error

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

type DownloadPieceRequestMultiError added in v2.0.59 

type DownloadPieceRequestMultiError []error

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

func (DownloadPieceRequestMultiError) AllErrors added in v2.0.59 

func (m DownloadPieceRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPieceRequestMultiError) Error added in v2.0.59 

func (m DownloadPieceRequestMultiError) Error() string

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

type DownloadPieceRequestValidationError added in v2.0.59 

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

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

func (DownloadPieceRequestValidationError) Cause added in v2.0.59 

func (e DownloadPieceRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPieceRequestValidationError) Error added in v2.0.59 

func (e DownloadPieceRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPieceRequestValidationError) ErrorName added in v2.0.59 

func (e DownloadPieceRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPieceRequestValidationError) Field added in v2.0.59 

func (e DownloadPieceRequestValidationError) Field() string

Field function returns field value.

func (DownloadPieceRequestValidationError) Key added in v2.0.59 

func (e DownloadPieceRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPieceRequestValidationError) Reason added in v2.0.59 

func (e DownloadPieceRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPieceResponse added in v2.0.59 

type DownloadPieceResponse struct {

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

DownloadPieceResponse represents response of DownloadPieces.

func (*DownloadPieceResponse) Descriptor deprecated added in v2.0.59 

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

Deprecated: Use DownloadPieceResponse.ProtoReflect.Descriptor instead.

func (*DownloadPieceResponse) GetPiece added in v2.0.59 

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

func (*DownloadPieceResponse) ProtoMessage added in v2.0.59 

func (*DownloadPieceResponse) ProtoMessage()

func (*DownloadPieceResponse) ProtoReflect added in v2.0.59 

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

func (*DownloadPieceResponse) Reset added in v2.0.59 

func (x *DownloadPieceResponse) Reset()

func (*DownloadPieceResponse) String added in v2.0.59 

func (x *DownloadPieceResponse) String() string

func (*DownloadPieceResponse) Validate added in v2.0.59 

func (m *DownloadPieceResponse) Validate() error

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

func (*DownloadPieceResponse) ValidateAll added in v2.0.59 

func (m *DownloadPieceResponse) ValidateAll() error

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

type DownloadPieceResponseMultiError added in v2.0.59 

type DownloadPieceResponseMultiError []error

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

func (DownloadPieceResponseMultiError) AllErrors added in v2.0.59 

func (m DownloadPieceResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPieceResponseMultiError) Error added in v2.0.59 

func (m DownloadPieceResponseMultiError) Error() string

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

type DownloadPieceResponseValidationError added in v2.0.59 

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

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

func (DownloadPieceResponseValidationError) Cause added in v2.0.59 

func (e DownloadPieceResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadPieceResponseValidationError) Error added in v2.0.59 

func (e DownloadPieceResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPieceResponseValidationError) ErrorName added in v2.0.59 

func (e DownloadPieceResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPieceResponseValidationError) Field added in v2.0.59 

func (e DownloadPieceResponseValidationError) Field() string

Field function returns field value.

func (DownloadPieceResponseValidationError) Key added in v2.0.59 

func (e DownloadPieceResponseValidationError) Key() bool

Key function returns key value.

func (DownloadPieceResponseValidationError) Reason added in v2.0.59 

func (e DownloadPieceResponseValidationError) Reason() string

Reason function returns reason value.

type DownloadTaskRequest 

type DownloadTaskRequest struct {

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

DownloadTaskRequest represents request of DownloadTask.

func (*DownloadTaskRequest) Descriptor deprecated 

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

Deprecated: Use DownloadTaskRequest.ProtoReflect.Descriptor instead.

func (*DownloadTaskRequest) GetDownload 

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

func (*DownloadTaskRequest) ProtoMessage 

func (*DownloadTaskRequest) ProtoMessage()

func (*DownloadTaskRequest) ProtoReflect 

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

func (*DownloadTaskRequest) Reset 

func (x *DownloadTaskRequest) Reset()

func (*DownloadTaskRequest) String 

func (x *DownloadTaskRequest) String() string

func (*DownloadTaskRequest) Validate 

func (m *DownloadTaskRequest) Validate() error

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

func (*DownloadTaskRequest) ValidateAll 

func (m *DownloadTaskRequest) ValidateAll() error

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

type DownloadTaskRequestMultiError 

type DownloadTaskRequestMultiError []error

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

func (DownloadTaskRequestMultiError) AllErrors 

func (m DownloadTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadTaskRequestMultiError) Error 

func (m DownloadTaskRequestMultiError) Error() string

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

type DownloadTaskRequestValidationError 

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

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

func (DownloadTaskRequestValidationError) Cause 

func (e DownloadTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadTaskRequestValidationError) Error 

func (e DownloadTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadTaskRequestValidationError) ErrorName 

func (e DownloadTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadTaskRequestValidationError) Field 

func (e DownloadTaskRequestValidationError) Field() string

Field function returns field value.

func (DownloadTaskRequestValidationError) Key 

func (e DownloadTaskRequestValidationError) Key() bool

Key function returns key value.

func (DownloadTaskRequestValidationError) Reason 

func (e DownloadTaskRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadTaskResponse added in v2.0.51 

type DownloadTaskResponse struct {

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

DownloadTaskResponse represents response of DownloadTask.

func (*DownloadTaskResponse) Descriptor deprecated added in v2.0.51 

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

Deprecated: Use DownloadTaskResponse.ProtoReflect.Descriptor instead.

func (*DownloadTaskResponse) GetDownloadPieceFinishedResponse added in v2.0.66 

func (x *DownloadTaskResponse) GetDownloadPieceFinishedResponse() *DownloadPieceFinishedResponse

func (*DownloadTaskResponse) GetDownloadTaskStartedResponse added in v2.0.66 

func (x *DownloadTaskResponse) GetDownloadTaskStartedResponse() *DownloadTaskStartedResponse

func (*DownloadTaskResponse) GetHostId added in v2.0.65 

func (x *DownloadTaskResponse) GetHostId() string

func (*DownloadTaskResponse) GetPeerId added in v2.0.65 

func (x *DownloadTaskResponse) GetPeerId() string

func (*DownloadTaskResponse) GetResponse added in v2.0.66 

func (m *DownloadTaskResponse) GetResponse() isDownloadTaskResponse_Response

func (*DownloadTaskResponse) GetTaskId added in v2.0.65 

func (x *DownloadTaskResponse) GetTaskId() string

func (*DownloadTaskResponse) ProtoMessage added in v2.0.51 

func (*DownloadTaskResponse) ProtoMessage()

func (*DownloadTaskResponse) ProtoReflect added in v2.0.51 

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

func (*DownloadTaskResponse) Reset added in v2.0.51 

func (x *DownloadTaskResponse) Reset()

func (*DownloadTaskResponse) String added in v2.0.51 

func (x *DownloadTaskResponse) String() string

func (*DownloadTaskResponse) Validate added in v2.0.51 

func (m *DownloadTaskResponse) Validate() error

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

func (*DownloadTaskResponse) ValidateAll added in v2.0.51 

func (m *DownloadTaskResponse) ValidateAll() error

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

type DownloadTaskResponseMultiError added in v2.0.51 

type DownloadTaskResponseMultiError []error

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

func (DownloadTaskResponseMultiError) AllErrors added in v2.0.51 

func (m DownloadTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadTaskResponseMultiError) Error added in v2.0.51 

func (m DownloadTaskResponseMultiError) Error() string

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

type DownloadTaskResponseValidationError added in v2.0.51 

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

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

func (DownloadTaskResponseValidationError) Cause added in v2.0.51 

func (e DownloadTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadTaskResponseValidationError) Error added in v2.0.51 

func (e DownloadTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadTaskResponseValidationError) ErrorName added in v2.0.51 

func (e DownloadTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadTaskResponseValidationError) Field added in v2.0.51 

func (e DownloadTaskResponseValidationError) Field() string

Field function returns field value.

func (DownloadTaskResponseValidationError) Key added in v2.0.51 

func (e DownloadTaskResponseValidationError) Key() bool

Key function returns key value.

func (DownloadTaskResponseValidationError) Reason added in v2.0.51 

func (e DownloadTaskResponseValidationError) Reason() string

Reason function returns reason value.

type DownloadTaskResponse_DownloadPieceFinishedResponse added in v2.0.66 

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

type DownloadTaskResponse_DownloadTaskStartedResponse added in v2.0.66 

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

type DownloadTaskStartedResponse added in v2.0.66 

type DownloadTaskStartedResponse struct {

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

DownloadTaskStartedResponse represents task download started response of DownloadTaskResponse.

func (*DownloadTaskStartedResponse) Descriptor deprecated added in v2.0.66 

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

Deprecated: Use DownloadTaskStartedResponse.ProtoReflect.Descriptor instead.

func (*DownloadTaskStartedResponse) GetContentLength added in v2.0.66 

func (x *DownloadTaskStartedResponse) GetContentLength() uint64

func (*DownloadTaskStartedResponse) GetPieces added in v2.0.91 

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

func (*DownloadTaskStartedResponse) GetRange added in v2.0.90 

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

func (*DownloadTaskStartedResponse) GetResponseHeader added in v2.0.89 

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

func (*DownloadTaskStartedResponse) ProtoMessage added in v2.0.66 

func (*DownloadTaskStartedResponse) ProtoMessage()

func (*DownloadTaskStartedResponse) ProtoReflect added in v2.0.66 

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

func (*DownloadTaskStartedResponse) Reset added in v2.0.66 

func (x *DownloadTaskStartedResponse) Reset()

func (*DownloadTaskStartedResponse) String added in v2.0.66 

func (x *DownloadTaskStartedResponse) String() string

func (*DownloadTaskStartedResponse) Validate added in v2.0.66 

func (m *DownloadTaskStartedResponse) Validate() error

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

func (*DownloadTaskStartedResponse) ValidateAll added in v2.0.66 

func (m *DownloadTaskStartedResponse) ValidateAll() error

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

type DownloadTaskStartedResponseMultiError added in v2.0.66 

type DownloadTaskStartedResponseMultiError []error

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

func (DownloadTaskStartedResponseMultiError) AllErrors added in v2.0.66 

func (m DownloadTaskStartedResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadTaskStartedResponseMultiError) Error added in v2.0.66 

func (m DownloadTaskStartedResponseMultiError) Error() string

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

type DownloadTaskStartedResponseValidationError added in v2.0.66 

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

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

func (DownloadTaskStartedResponseValidationError) Cause added in v2.0.66 

func (e DownloadTaskStartedResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadTaskStartedResponseValidationError) Error added in v2.0.66 

func (e DownloadTaskStartedResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadTaskStartedResponseValidationError) ErrorName added in v2.0.66 

func (e DownloadTaskStartedResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadTaskStartedResponseValidationError) Field added in v2.0.66 

func (e DownloadTaskStartedResponseValidationError) Field() string

Field function returns field value.

func (DownloadTaskStartedResponseValidationError) Key added in v2.0.66 

func (e DownloadTaskStartedResponseValidationError) Key() bool

Key function returns key value.

func (DownloadTaskStartedResponseValidationError) Reason added in v2.0.66 

func (e DownloadTaskStartedResponseValidationError) Reason() string

Reason function returns reason value.

type StatCacheTaskRequest added in v2.0.116 

type StatCacheTaskRequest struct {

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

StatCacheTaskRequest represents request of StatCacheTask.

func (*StatCacheTaskRequest) Descriptor deprecated added in v2.0.116 

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

Deprecated: Use StatCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*StatCacheTaskRequest) GetTaskId added in v2.0.116 

func (x *StatCacheTaskRequest) GetTaskId() string

func (*StatCacheTaskRequest) ProtoMessage added in v2.0.116 

func (*StatCacheTaskRequest) ProtoMessage()

func (*StatCacheTaskRequest) ProtoReflect added in v2.0.116 

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

func (*StatCacheTaskRequest) Reset added in v2.0.116 

func (x *StatCacheTaskRequest) Reset()

func (*StatCacheTaskRequest) String added in v2.0.116 

func (x *StatCacheTaskRequest) String() string

func (*StatCacheTaskRequest) Validate added in v2.0.116 

func (m *StatCacheTaskRequest) Validate() error

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

func (*StatCacheTaskRequest) ValidateAll added in v2.0.116 

func (m *StatCacheTaskRequest) ValidateAll() error

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

type StatCacheTaskRequestMultiError added in v2.0.116 

type StatCacheTaskRequestMultiError []error

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

func (StatCacheTaskRequestMultiError) AllErrors added in v2.0.116 

func (m StatCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatCacheTaskRequestMultiError) Error added in v2.0.116 

func (m StatCacheTaskRequestMultiError) Error() string

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

type StatCacheTaskRequestValidationError added in v2.0.116 

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

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

func (StatCacheTaskRequestValidationError) Cause added in v2.0.116 

func (e StatCacheTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (StatCacheTaskRequestValidationError) Error added in v2.0.116 

func (e StatCacheTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatCacheTaskRequestValidationError) ErrorName added in v2.0.116 

func (e StatCacheTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatCacheTaskRequestValidationError) Field added in v2.0.116 

func (e StatCacheTaskRequestValidationError) Field() string

Field function returns field value.

func (StatCacheTaskRequestValidationError) Key added in v2.0.116 

func (e StatCacheTaskRequestValidationError) Key() bool

Key function returns key value.

func (StatCacheTaskRequestValidationError) Reason added in v2.0.116 

func (e StatCacheTaskRequestValidationError) Reason() string

Reason function returns reason value.

type StatTaskRequest 

type StatTaskRequest struct {

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

StatTaskRequest represents request of StatTask.

func (*StatTaskRequest) Descriptor deprecated 

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

Deprecated: Use StatTaskRequest.ProtoReflect.Descriptor instead.

func (*StatTaskRequest) GetTaskId 

func (x *StatTaskRequest) GetTaskId() string

func (*StatTaskRequest) ProtoMessage 

func (*StatTaskRequest) ProtoMessage()

func (*StatTaskRequest) ProtoReflect 

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

func (*StatTaskRequest) Reset 

func (x *StatTaskRequest) Reset()

func (*StatTaskRequest) String 

func (x *StatTaskRequest) String() string

func (*StatTaskRequest) Validate 

func (m *StatTaskRequest) Validate() error

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

func (*StatTaskRequest) ValidateAll 

func (m *StatTaskRequest) ValidateAll() error

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

type StatTaskRequestMultiError 

type StatTaskRequestMultiError []error

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

func (StatTaskRequestMultiError) AllErrors 

func (m StatTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatTaskRequestMultiError) Error 

func (m StatTaskRequestMultiError) Error() string

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

type StatTaskRequestValidationError 

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

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

func (StatTaskRequestValidationError) Cause 

func (e StatTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (StatTaskRequestValidationError) Error 

func (e StatTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatTaskRequestValidationError) ErrorName 

func (e StatTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatTaskRequestValidationError) Field 

func (e StatTaskRequestValidationError) Field() string

Field function returns field value.

func (StatTaskRequestValidationError) Key 

func (e StatTaskRequestValidationError) Key() bool

Key function returns key value.

func (StatTaskRequestValidationError) Reason 

func (e StatTaskRequestValidationError) Reason() string

Reason function returns reason value.

type SyncPiecesRequest 

type SyncPiecesRequest struct {

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

SyncPiecesRequest represents request of SyncPieces.

func (*SyncPiecesRequest) Descriptor deprecated 

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

Deprecated: Use SyncPiecesRequest.ProtoReflect.Descriptor instead.

func (*SyncPiecesRequest) GetHostId added in v2.0.115 

func (x *SyncPiecesRequest) GetHostId() string

func (*SyncPiecesRequest) GetInterestedPieceNumbers added in v2.0.61 

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

func (*SyncPiecesRequest) GetTaskId added in v2.0.26 

func (x *SyncPiecesRequest) GetTaskId() string

func (*SyncPiecesRequest) ProtoMessage 

func (*SyncPiecesRequest) ProtoMessage()

func (*SyncPiecesRequest) ProtoReflect 

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

func (*SyncPiecesRequest) Reset 

func (x *SyncPiecesRequest) Reset()

func (*SyncPiecesRequest) String 

func (x *SyncPiecesRequest) String() string

func (*SyncPiecesRequest) Validate 

func (m *SyncPiecesRequest) Validate() error

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

func (*SyncPiecesRequest) ValidateAll 

func (m *SyncPiecesRequest) ValidateAll() error

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

type SyncPiecesRequestMultiError 

type SyncPiecesRequestMultiError []error

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

func (SyncPiecesRequestMultiError) AllErrors 

func (m SyncPiecesRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncPiecesRequestMultiError) Error 

func (m SyncPiecesRequestMultiError) Error() string

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

type SyncPiecesRequestValidationError 

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

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

func (SyncPiecesRequestValidationError) Cause 

func (e SyncPiecesRequestValidationError) Cause() error

Cause function returns cause value.

func (SyncPiecesRequestValidationError) Error 

func (e SyncPiecesRequestValidationError) Error() string

Error satisfies the builtin error interface

func (SyncPiecesRequestValidationError) ErrorName 

func (e SyncPiecesRequestValidationError) ErrorName() string

ErrorName returns error name.

func (SyncPiecesRequestValidationError) Field 

func (e SyncPiecesRequestValidationError) Field() string

Field function returns field value.

func (SyncPiecesRequestValidationError) Key 

func (e SyncPiecesRequestValidationError) Key() bool

Key function returns key value.

func (SyncPiecesRequestValidationError) Reason 

func (e SyncPiecesRequestValidationError) Reason() string

Reason function returns reason value.

type SyncPiecesResponse 

type SyncPiecesResponse struct {

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

SyncPiecesResponse represents response of SyncPieces.

func (*SyncPiecesResponse) Descriptor deprecated 

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

Deprecated: Use SyncPiecesResponse.ProtoReflect.Descriptor instead.

func (*SyncPiecesResponse) GetLength added in v2.0.77 

func (x *SyncPiecesResponse) GetLength() uint64

func (*SyncPiecesResponse) GetNumber added in v2.0.77 

func (x *SyncPiecesResponse) GetNumber() uint32

func (*SyncPiecesResponse) GetOffset added in v2.0.77 

func (x *SyncPiecesResponse) GetOffset() uint64

func (*SyncPiecesResponse) ProtoMessage 

func (*SyncPiecesResponse) ProtoMessage()

func (*SyncPiecesResponse) ProtoReflect 

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

func (*SyncPiecesResponse) Reset 

func (x *SyncPiecesResponse) Reset()

func (*SyncPiecesResponse) String 

func (x *SyncPiecesResponse) String() string

func (*SyncPiecesResponse) Validate 

func (m *SyncPiecesResponse) Validate() error

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

func (*SyncPiecesResponse) ValidateAll 

func (m *SyncPiecesResponse) ValidateAll() error

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

type SyncPiecesResponseMultiError 

type SyncPiecesResponseMultiError []error

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

func (SyncPiecesResponseMultiError) AllErrors 

func (m SyncPiecesResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncPiecesResponseMultiError) Error 

func (m SyncPiecesResponseMultiError) Error() string

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

type SyncPiecesResponseValidationError 

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

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

func (SyncPiecesResponseValidationError) Cause 

func (e SyncPiecesResponseValidationError) Cause() error

Cause function returns cause value.

func (SyncPiecesResponseValidationError) Error 

func (e SyncPiecesResponseValidationError) Error() string

Error satisfies the builtin error interface

func (SyncPiecesResponseValidationError) ErrorName 

func (e SyncPiecesResponseValidationError) ErrorName() string

ErrorName returns error name.

func (SyncPiecesResponseValidationError) Field 

func (e SyncPiecesResponseValidationError) Field() string

Field function returns field value.

func (SyncPiecesResponseValidationError) Key 

func (e SyncPiecesResponseValidationError) Key() bool

Key function returns key value.

func (SyncPiecesResponseValidationError) Reason 

func (e SyncPiecesResponseValidationError) Reason() string

Reason function returns reason value.

type UnimplementedDfdaemonDownloadServer added in v2.0.63 

type UnimplementedDfdaemonDownloadServer struct {
}

UnimplementedDfdaemonDownloadServer should be embedded to have forward compatible implementations.

func (UnimplementedDfdaemonDownloadServer) DeleteCacheTask added in v2.0.116 

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

func (UnimplementedDfdaemonDownloadServer) DeleteHost added in v2.0.118 

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

func (UnimplementedDfdaemonDownloadServer) DeleteTask added in v2.0.63 

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

func (UnimplementedDfdaemonDownloadServer) DownloadCacheTask added in v2.0.116 

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

func (UnimplementedDfdaemonDownloadServer) DownloadTask added in v2.0.63 

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

func (UnimplementedDfdaemonDownloadServer) StatCacheTask added in v2.0.116 

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

func (UnimplementedDfdaemonDownloadServer) StatTask added in v2.0.63 

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

func (UnimplementedDfdaemonDownloadServer) UploadCacheTask added in v2.0.116 

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

func (UnimplementedDfdaemonDownloadServer) UploadTask added in v2.0.63 

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

type UnimplementedDfdaemonUploadServer added in v2.0.63 

type UnimplementedDfdaemonUploadServer struct {
}

UnimplementedDfdaemonUploadServer should be embedded to have forward compatible implementations.

func (UnimplementedDfdaemonUploadServer) DeleteCacheTask added in v2.0.116 

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

func (UnimplementedDfdaemonUploadServer) DownloadCacheTask added in v2.0.116 

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

func (UnimplementedDfdaemonUploadServer) DownloadPiece added in v2.0.63 

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

func (UnimplementedDfdaemonUploadServer) DownloadTask added in v2.0.64 

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

func (UnimplementedDfdaemonUploadServer) StatCacheTask added in v2.0.116 

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

func (UnimplementedDfdaemonUploadServer) SyncPieces added in v2.0.63 

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

type UnsafeDfdaemonDownloadServer added in v2.0.63 

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

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

type UnsafeDfdaemonUploadServer added in v2.0.63 

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

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

type UploadCacheTaskRequest added in v2.0.116 

type UploadCacheTaskRequest struct {

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

UploadCacheTaskRequest represents request of UploadCacheTask.

func (*UploadCacheTaskRequest) Descriptor deprecated added in v2.0.116 

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

Deprecated: Use UploadCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*UploadCacheTaskRequest) GetApplication added in v2.0.116 

func (x *UploadCacheTaskRequest) GetApplication() string

func (*UploadCacheTaskRequest) GetPath added in v2.0.116 

func (x *UploadCacheTaskRequest) GetPath() string

func (*UploadCacheTaskRequest) GetPersistentReplicaCount added in v2.0.116 

func (x *UploadCacheTaskRequest) GetPersistentReplicaCount() uint64

func (*UploadCacheTaskRequest) GetTag added in v2.0.116 

func (x *UploadCacheTaskRequest) GetTag() string

func (*UploadCacheTaskRequest) GetTimeout added in v2.0.116 

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

func (*UploadCacheTaskRequest) GetTtl added in v2.0.123 

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

func (*UploadCacheTaskRequest) ProtoMessage added in v2.0.116 

func (*UploadCacheTaskRequest) ProtoMessage()

func (*UploadCacheTaskRequest) ProtoReflect added in v2.0.116 

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

func (*UploadCacheTaskRequest) Reset added in v2.0.116 

func (x *UploadCacheTaskRequest) Reset()

func (*UploadCacheTaskRequest) String added in v2.0.116 

func (x *UploadCacheTaskRequest) String() string

func (*UploadCacheTaskRequest) Validate added in v2.0.116 

func (m *UploadCacheTaskRequest) Validate() error

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

func (*UploadCacheTaskRequest) ValidateAll added in v2.0.116 

func (m *UploadCacheTaskRequest) ValidateAll() error

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

type UploadCacheTaskRequestMultiError added in v2.0.116 

type UploadCacheTaskRequestMultiError []error

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

func (UploadCacheTaskRequestMultiError) AllErrors added in v2.0.116 

func (m UploadCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UploadCacheTaskRequestMultiError) Error added in v2.0.116 

func (m UploadCacheTaskRequestMultiError) Error() string

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

type UploadCacheTaskRequestValidationError added in v2.0.116 

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

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

func (UploadCacheTaskRequestValidationError) Cause added in v2.0.116 

func (e UploadCacheTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (UploadCacheTaskRequestValidationError) Error added in v2.0.116 

func (e UploadCacheTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (UploadCacheTaskRequestValidationError) ErrorName added in v2.0.116 

func (e UploadCacheTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (UploadCacheTaskRequestValidationError) Field added in v2.0.116 

func (e UploadCacheTaskRequestValidationError) Field() string

Field function returns field value.

func (UploadCacheTaskRequestValidationError) Key added in v2.0.116 

func (e UploadCacheTaskRequestValidationError) Key() bool

Key function returns key value.

func (UploadCacheTaskRequestValidationError) Reason added in v2.0.116 

func (e UploadCacheTaskRequestValidationError) Reason() string

Reason function returns reason value.

type UploadTaskRequest 

type UploadTaskRequest struct {

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

UploadTaskRequest represents request of UploadTask.

func (*UploadTaskRequest) Descriptor deprecated 

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

Deprecated: Use UploadTaskRequest.ProtoReflect.Descriptor instead.

func (*UploadTaskRequest) GetTask 

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

func (*UploadTaskRequest) ProtoMessage 

func (*UploadTaskRequest) ProtoMessage()

func (*UploadTaskRequest) ProtoReflect 

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

func (*UploadTaskRequest) Reset 

func (x *UploadTaskRequest) Reset()

func (*UploadTaskRequest) String 

func (x *UploadTaskRequest) String() string

func (*UploadTaskRequest) Validate 

func (m *UploadTaskRequest) Validate() error

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

func (*UploadTaskRequest) ValidateAll 

func (m *UploadTaskRequest) ValidateAll() error

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

type UploadTaskRequestMultiError 

type UploadTaskRequestMultiError []error

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

func (UploadTaskRequestMultiError) AllErrors 

func (m UploadTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UploadTaskRequestMultiError) Error 

func (m UploadTaskRequestMultiError) Error() string

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

type UploadTaskRequestValidationError 

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

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

func (UploadTaskRequestValidationError) Cause 

func (e UploadTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (UploadTaskRequestValidationError) Error 

func (e UploadTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (UploadTaskRequestValidationError) ErrorName 

func (e UploadTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (UploadTaskRequestValidationError) Field 

func (e UploadTaskRequestValidationError) Field() string

Field function returns field value.

func (UploadTaskRequestValidationError) Key 

func (e UploadTaskRequestValidationError) Key() bool

Key function returns key value.

func (UploadTaskRequestValidationError) Reason 

func (e UploadTaskRequestValidationError) Reason() string

Reason function returns reason value.

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.