dfdaemon

package
v2.0.164 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DfdaemonDownload_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dfdaemon.v2.DfdaemonDownload",
	HandlerType: (*DfdaemonDownloadServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UploadTask",
			Handler:    _DfdaemonDownload_UploadTask_Handler,
		},
		{
			MethodName: "StatTask",
			Handler:    _DfdaemonDownload_StatTask_Handler,
		},
		{
			MethodName: "DeleteTask",
			Handler:    _DfdaemonDownload_DeleteTask_Handler,
		},
		{
			MethodName: "DeleteHost",
			Handler:    _DfdaemonDownload_DeleteHost_Handler,
		},
		{
			MethodName: "UploadPersistentCacheTask",
			Handler:    _DfdaemonDownload_UploadPersistentCacheTask_Handler,
		},
		{
			MethodName: "StatPersistentCacheTask",
			Handler:    _DfdaemonDownload_StatPersistentCacheTask_Handler,
		},
		{
			MethodName: "DeletePersistentCacheTask",
			Handler:    _DfdaemonDownload_DeletePersistentCacheTask_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "DownloadTask",
			Handler:       _DfdaemonDownload_DownloadTask_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DownloadPersistentCacheTask",
			Handler:       _DfdaemonDownload_DownloadPersistentCacheTask_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: "StatTask",
			Handler:    _DfdaemonUpload_StatTask_Handler,
		},
		{
			MethodName: "DeleteTask",
			Handler:    _DfdaemonUpload_DeleteTask_Handler,
		},
		{
			MethodName: "DownloadPiece",
			Handler:    _DfdaemonUpload_DownloadPiece_Handler,
		},
		{
			MethodName: "StatPersistentCacheTask",
			Handler:    _DfdaemonUpload_StatPersistentCacheTask_Handler,
		},
		{
			MethodName: "DeletePersistentCacheTask",
			Handler:    _DfdaemonUpload_DeletePersistentCacheTask_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "DownloadTask",
			Handler:       _DfdaemonUpload_DownloadTask_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SyncPieces",
			Handler:       _DfdaemonUpload_SyncPieces_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DownloadPersistentCacheTask",
			Handler:       _DfdaemonUpload_DownloadPersistentCacheTask_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 DeletePersistentCacheTaskRequest added in v2.0.161 

type DeletePersistentCacheTaskRequest struct {

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

DeletePersistentCacheTaskRequest represents request of DeletePersistentCacheTask.

func (*DeletePersistentCacheTaskRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use DeletePersistentCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*DeletePersistentCacheTaskRequest) GetTaskId added in v2.0.161 

func (x *DeletePersistentCacheTaskRequest) GetTaskId() string

func (*DeletePersistentCacheTaskRequest) ProtoMessage added in v2.0.161 

func (*DeletePersistentCacheTaskRequest) ProtoMessage()

func (*DeletePersistentCacheTaskRequest) ProtoReflect added in v2.0.161 

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

func (*DeletePersistentCacheTaskRequest) Reset added in v2.0.161 

func (x *DeletePersistentCacheTaskRequest) Reset()

func (*DeletePersistentCacheTaskRequest) String added in v2.0.161 

func (x *DeletePersistentCacheTaskRequest) String() string

func (*DeletePersistentCacheTaskRequest) Validate added in v2.0.161 

func (m *DeletePersistentCacheTaskRequest) Validate() error

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

func (m *DeletePersistentCacheTaskRequest) ValidateAll() error

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

type DeletePersistentCacheTaskRequestMultiError added in v2.0.161 

type DeletePersistentCacheTaskRequestMultiError []error

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

func (DeletePersistentCacheTaskRequestMultiError) AllErrors added in v2.0.161 

func (m DeletePersistentCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeletePersistentCacheTaskRequestMultiError) Error added in v2.0.161 

func (m DeletePersistentCacheTaskRequestMultiError) Error() string

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

type DeletePersistentCacheTaskRequestValidationError added in v2.0.161 

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

DeletePersistentCacheTaskRequestValidationError is the validation error returned by DeletePersistentCacheTaskRequest.Validate if the designated constraints aren't met.

func (DeletePersistentCacheTaskRequestValidationError) Cause added in v2.0.161 

func (e DeletePersistentCacheTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (DeletePersistentCacheTaskRequestValidationError) Error added in v2.0.161 

func (e DeletePersistentCacheTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DeletePersistentCacheTaskRequestValidationError) ErrorName added in v2.0.161 

func (e DeletePersistentCacheTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DeletePersistentCacheTaskRequestValidationError) Field added in v2.0.161 

func (e DeletePersistentCacheTaskRequestValidationError) Field() string

Field function returns field value.

func (DeletePersistentCacheTaskRequestValidationError) Key added in v2.0.161 

func (e DeletePersistentCacheTaskRequestValidationError) Key() bool

Key function returns key value.

func (DeletePersistentCacheTaskRequestValidationError) Reason added in v2.0.161 

func (e DeletePersistentCacheTaskRequestValidationError) 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)
	// DownloadPersistentCacheTask downloads persistent cache task from p2p network.
	DownloadPersistentCacheTask(ctx context.Context, in *DownloadPersistentCacheTaskRequest, opts ...grpc.CallOption) (DfdaemonDownload_DownloadPersistentCacheTaskClient, error)
	// UploadPersistentCacheTask uploads persistent cache task to p2p network.
	UploadPersistentCacheTask(ctx context.Context, in *UploadPersistentCacheTaskRequest, opts ...grpc.CallOption) (*v2.PersistentCacheTask, error)
	// StatPersistentCacheTask stats persistent cache task information.
	StatPersistentCacheTask(ctx context.Context, in *StatPersistentCacheTaskRequest, opts ...grpc.CallOption) (*v2.PersistentCacheTask, error)
	// DeletePersistentCacheTask deletes persistent cache task from p2p network.
	DeletePersistentCacheTask(ctx context.Context, in *DeletePersistentCacheTaskRequest, 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)
	// DownloadPersistentCacheTask downloads persistent cache task from p2p network.
	DownloadPersistentCacheTask(*DownloadPersistentCacheTaskRequest, DfdaemonDownload_DownloadPersistentCacheTaskServer) error
	// UploadPersistentCacheTask uploads persistent cache task to p2p network.
	UploadPersistentCacheTask(context.Context, *UploadPersistentCacheTaskRequest) (*v2.PersistentCacheTask, error)
	// StatPersistentCacheTask stats persistent cache task information.
	StatPersistentCacheTask(context.Context, *StatPersistentCacheTaskRequest) (*v2.PersistentCacheTask, error)
	// DeletePersistentCacheTask deletes persistent cache task from p2p network.
	DeletePersistentCacheTask(context.Context, *DeletePersistentCacheTaskRequest) (*emptypb.Empty, error)
}

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

type DfdaemonDownload_DownloadPersistentCacheTaskClient added in v2.0.161 

type DfdaemonDownload_DownloadPersistentCacheTaskClient interface {
	Recv() (*DownloadPersistentCacheTaskResponse, error)
	grpc.ClientStream
}

type DfdaemonDownload_DownloadPersistentCacheTaskServer added in v2.0.161 

type DfdaemonDownload_DownloadPersistentCacheTaskServer interface {
	Send(*DownloadPersistentCacheTaskResponse) 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)
	// 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)
	// 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)
	// DownloadPersistentCacheTask downloads persistent cache task from p2p network.
	DownloadPersistentCacheTask(ctx context.Context, in *DownloadPersistentCacheTaskRequest, opts ...grpc.CallOption) (DfdaemonUpload_DownloadPersistentCacheTaskClient, error)
	// StatPersistentCacheTask stats persistent cache task information.
	StatPersistentCacheTask(ctx context.Context, in *StatPersistentCacheTaskRequest, opts ...grpc.CallOption) (*v2.PersistentCacheTask, error)
	// DeletePersistentCacheTask deletes persistent cache task from p2p network.
	DeletePersistentCacheTask(ctx context.Context, in *DeletePersistentCacheTaskRequest, 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
	// StatTask stats task information.
	StatTask(context.Context, *StatTaskRequest) (*v2.Task, error)
	// DeleteTask deletes task from p2p network.
	DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)
	// SyncPieces syncs piece metadatas from remote peer.
	SyncPieces(*SyncPiecesRequest, DfdaemonUpload_SyncPiecesServer) error
	// DownloadPiece downloads piece from the remote peer.
	DownloadPiece(context.Context, *DownloadPieceRequest) (*DownloadPieceResponse, error)
	// DownloadPersistentCacheTask downloads persistent cache task from p2p network.
	DownloadPersistentCacheTask(*DownloadPersistentCacheTaskRequest, DfdaemonUpload_DownloadPersistentCacheTaskServer) error
	// StatPersistentCacheTask stats persistent cache task information.
	StatPersistentCacheTask(context.Context, *StatPersistentCacheTaskRequest) (*v2.PersistentCacheTask, error)
	// DeletePersistentCacheTask deletes persistent cache task from p2p network.
	DeletePersistentCacheTask(context.Context, *DeletePersistentCacheTaskRequest) (*emptypb.Empty, error)
}

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

type DfdaemonUpload_DownloadPersistentCacheTaskClient added in v2.0.161 

type DfdaemonUpload_DownloadPersistentCacheTaskClient interface {
	Recv() (*DownloadPersistentCacheTaskResponse, error)
	grpc.ClientStream
}

type DfdaemonUpload_DownloadPersistentCacheTaskServer added in v2.0.161 

type DfdaemonUpload_DownloadPersistentCacheTaskServer interface {
	Send(*DownloadPersistentCacheTaskResponse) 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 DownloadPersistentCacheTaskRequest added in v2.0.161 

type DownloadPersistentCacheTaskRequest struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Persistent represents whether the persistent cache task is persistent.
	// If the persistent cache task is persistent, the persistent 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 persistent 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
}

DownloadPersistentCacheTaskRequest represents request of DownloadPersistentCacheTask.

func (*DownloadPersistentCacheTaskRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use DownloadPersistentCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*DownloadPersistentCacheTaskRequest) GetApplication added in v2.0.161 

func (x *DownloadPersistentCacheTaskRequest) GetApplication() string

func (*DownloadPersistentCacheTaskRequest) GetOutputPath added in v2.0.161 

func (x *DownloadPersistentCacheTaskRequest) GetOutputPath() string

func (*DownloadPersistentCacheTaskRequest) GetPersistent added in v2.0.161 

func (x *DownloadPersistentCacheTaskRequest) GetPersistent() bool

func (*DownloadPersistentCacheTaskRequest) GetTag added in v2.0.161 

func (x *DownloadPersistentCacheTaskRequest) GetTag() string

func (*DownloadPersistentCacheTaskRequest) GetTaskId added in v2.0.161 

func (x *DownloadPersistentCacheTaskRequest) GetTaskId() string

func (*DownloadPersistentCacheTaskRequest) GetTimeout added in v2.0.161 

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

func (*DownloadPersistentCacheTaskRequest) ProtoMessage added in v2.0.161 

func (*DownloadPersistentCacheTaskRequest) ProtoMessage()

func (*DownloadPersistentCacheTaskRequest) ProtoReflect added in v2.0.161 

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

func (*DownloadPersistentCacheTaskRequest) Reset added in v2.0.161 

func (x *DownloadPersistentCacheTaskRequest) Reset()

func (*DownloadPersistentCacheTaskRequest) String added in v2.0.161 

func (x *DownloadPersistentCacheTaskRequest) String() string

func (*DownloadPersistentCacheTaskRequest) Validate added in v2.0.161 

func (m *DownloadPersistentCacheTaskRequest) Validate() error

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

func (m *DownloadPersistentCacheTaskRequest) ValidateAll() error

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

type DownloadPersistentCacheTaskRequestMultiError added in v2.0.161 

type DownloadPersistentCacheTaskRequestMultiError []error

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

func (DownloadPersistentCacheTaskRequestMultiError) AllErrors added in v2.0.161 

func (m DownloadPersistentCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPersistentCacheTaskRequestMultiError) Error added in v2.0.161 

func (m DownloadPersistentCacheTaskRequestMultiError) Error() string

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

type DownloadPersistentCacheTaskRequestValidationError added in v2.0.161 

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

DownloadPersistentCacheTaskRequestValidationError is the validation error returned by DownloadPersistentCacheTaskRequest.Validate if the designated constraints aren't met.

func (DownloadPersistentCacheTaskRequestValidationError) Cause added in v2.0.161 

func (e DownloadPersistentCacheTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPersistentCacheTaskRequestValidationError) Error added in v2.0.161 

func (e DownloadPersistentCacheTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPersistentCacheTaskRequestValidationError) ErrorName added in v2.0.161 

func (e DownloadPersistentCacheTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPersistentCacheTaskRequestValidationError) Field added in v2.0.161 

func (e DownloadPersistentCacheTaskRequestValidationError) Field() string

Field function returns field value.

func (DownloadPersistentCacheTaskRequestValidationError) Key added in v2.0.161 

func (e DownloadPersistentCacheTaskRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPersistentCacheTaskRequestValidationError) Reason added in v2.0.161 

func (e DownloadPersistentCacheTaskRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPersistentCacheTaskResponse added in v2.0.161 

type DownloadPersistentCacheTaskResponse 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:
	//
	//	*DownloadPersistentCacheTaskResponse_DownloadPersistentCacheTaskStartedResponse
	//	*DownloadPersistentCacheTaskResponse_DownloadPieceFinishedResponse
	Response isDownloadPersistentCacheTaskResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

DownloadPersistentCacheTaskResponse represents response of DownloadPersistentCacheTask.

func (*DownloadPersistentCacheTaskResponse) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use DownloadPersistentCacheTaskResponse.ProtoReflect.Descriptor instead.

func (*DownloadPersistentCacheTaskResponse) GetDownloadPersistentCacheTaskStartedResponse added in v2.0.161 

func (x *DownloadPersistentCacheTaskResponse) GetDownloadPersistentCacheTaskStartedResponse() *DownloadPersistentCacheTaskStartedResponse

func (*DownloadPersistentCacheTaskResponse) GetDownloadPieceFinishedResponse added in v2.0.161 

func (x *DownloadPersistentCacheTaskResponse) GetDownloadPieceFinishedResponse() *DownloadPieceFinishedResponse

func (*DownloadPersistentCacheTaskResponse) GetHostId added in v2.0.161 

func (x *DownloadPersistentCacheTaskResponse) GetHostId() string

func (*DownloadPersistentCacheTaskResponse) GetPeerId added in v2.0.161 

func (x *DownloadPersistentCacheTaskResponse) GetPeerId() string

func (*DownloadPersistentCacheTaskResponse) GetResponse added in v2.0.161 

func (m *DownloadPersistentCacheTaskResponse) GetResponse() isDownloadPersistentCacheTaskResponse_Response

func (*DownloadPersistentCacheTaskResponse) GetTaskId added in v2.0.161 

func (x *DownloadPersistentCacheTaskResponse) GetTaskId() string

func (*DownloadPersistentCacheTaskResponse) ProtoMessage added in v2.0.161 

func (*DownloadPersistentCacheTaskResponse) ProtoMessage()

func (*DownloadPersistentCacheTaskResponse) ProtoReflect added in v2.0.161 

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

func (*DownloadPersistentCacheTaskResponse) Reset added in v2.0.161 

func (x *DownloadPersistentCacheTaskResponse) Reset()

func (*DownloadPersistentCacheTaskResponse) String added in v2.0.161 

func (x *DownloadPersistentCacheTaskResponse) String() string

func (*DownloadPersistentCacheTaskResponse) Validate added in v2.0.161 

func (m *DownloadPersistentCacheTaskResponse) Validate() error

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

func (m *DownloadPersistentCacheTaskResponse) ValidateAll() error

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

type DownloadPersistentCacheTaskResponseMultiError added in v2.0.161 

type DownloadPersistentCacheTaskResponseMultiError []error

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

func (DownloadPersistentCacheTaskResponseMultiError) AllErrors added in v2.0.161 

func (m DownloadPersistentCacheTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPersistentCacheTaskResponseMultiError) Error added in v2.0.161 

func (m DownloadPersistentCacheTaskResponseMultiError) Error() string

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

type DownloadPersistentCacheTaskResponseValidationError added in v2.0.161 

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

DownloadPersistentCacheTaskResponseValidationError is the validation error returned by DownloadPersistentCacheTaskResponse.Validate if the designated constraints aren't met.

func (DownloadPersistentCacheTaskResponseValidationError) Cause added in v2.0.161 

func (e DownloadPersistentCacheTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadPersistentCacheTaskResponseValidationError) Error added in v2.0.161 

func (e DownloadPersistentCacheTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPersistentCacheTaskResponseValidationError) ErrorName added in v2.0.161 

func (e DownloadPersistentCacheTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPersistentCacheTaskResponseValidationError) Field added in v2.0.161 

func (e DownloadPersistentCacheTaskResponseValidationError) Field() string

Field function returns field value.

func (DownloadPersistentCacheTaskResponseValidationError) Key added in v2.0.161 

func (e DownloadPersistentCacheTaskResponseValidationError) Key() bool

Key function returns key value.

func (DownloadPersistentCacheTaskResponseValidationError) Reason added in v2.0.161 

func (e DownloadPersistentCacheTaskResponseValidationError) Reason() string

Reason function returns reason value.

type DownloadPersistentCacheTaskResponse_DownloadPersistentCacheTaskStartedResponse added in v2.0.161 

type DownloadPersistentCacheTaskResponse_DownloadPersistentCacheTaskStartedResponse struct {
	DownloadPersistentCacheTaskStartedResponse *DownloadPersistentCacheTaskStartedResponse `` /* 136-byte string literal not displayed */
}

type DownloadPersistentCacheTaskResponse_DownloadPieceFinishedResponse added in v2.0.161 

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

type DownloadPersistentCacheTaskStartedResponse added in v2.0.161 

type DownloadPersistentCacheTaskStartedResponse 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
}

DownloadPersistentCacheTaskStartedResponse represents task download started response of DownloadPersistentCacheTaskResponse.

func (*DownloadPersistentCacheTaskStartedResponse) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use DownloadPersistentCacheTaskStartedResponse.ProtoReflect.Descriptor instead.

func (*DownloadPersistentCacheTaskStartedResponse) GetContentLength added in v2.0.161 

func (x *DownloadPersistentCacheTaskStartedResponse) GetContentLength() uint64

func (*DownloadPersistentCacheTaskStartedResponse) ProtoMessage added in v2.0.161 

func (*DownloadPersistentCacheTaskStartedResponse) ProtoMessage()

func (*DownloadPersistentCacheTaskStartedResponse) ProtoReflect added in v2.0.161 

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

func (*DownloadPersistentCacheTaskStartedResponse) Reset added in v2.0.161 

func (x *DownloadPersistentCacheTaskStartedResponse) Reset()

func (*DownloadPersistentCacheTaskStartedResponse) String added in v2.0.161 

func (x *DownloadPersistentCacheTaskStartedResponse) String() string

func (*DownloadPersistentCacheTaskStartedResponse) Validate added in v2.0.161 

func (m *DownloadPersistentCacheTaskStartedResponse) Validate() error

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

func (m *DownloadPersistentCacheTaskStartedResponse) ValidateAll() error

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

type DownloadPersistentCacheTaskStartedResponseMultiError added in v2.0.161 

type DownloadPersistentCacheTaskStartedResponseMultiError []error

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

func (DownloadPersistentCacheTaskStartedResponseMultiError) AllErrors added in v2.0.161 

func (m DownloadPersistentCacheTaskStartedResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPersistentCacheTaskStartedResponseMultiError) Error added in v2.0.161 

func (m DownloadPersistentCacheTaskStartedResponseMultiError) Error() string

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

type DownloadPersistentCacheTaskStartedResponseValidationError added in v2.0.161 

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

DownloadPersistentCacheTaskStartedResponseValidationError is the validation error returned by DownloadPersistentCacheTaskStartedResponse.Validate if the designated constraints aren't met.

func (DownloadPersistentCacheTaskStartedResponseValidationError) Cause added in v2.0.161 

func (e DownloadPersistentCacheTaskStartedResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadPersistentCacheTaskStartedResponseValidationError) Error added in v2.0.161 

func (e DownloadPersistentCacheTaskStartedResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPersistentCacheTaskStartedResponseValidationError) ErrorName added in v2.0.161 

func (e DownloadPersistentCacheTaskStartedResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPersistentCacheTaskStartedResponseValidationError) Field added in v2.0.161 

func (e DownloadPersistentCacheTaskStartedResponseValidationError) Field() string

Field function returns field value.

func (DownloadPersistentCacheTaskStartedResponseValidationError) Key added in v2.0.161 

func (e DownloadPersistentCacheTaskStartedResponseValidationError) Key() bool

Key function returns key value.

func (DownloadPersistentCacheTaskStartedResponseValidationError) Reason added in v2.0.161 

func (e DownloadPersistentCacheTaskStartedResponseValidationError) 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 StatPersistentCacheTaskRequest added in v2.0.161 

type StatPersistentCacheTaskRequest struct {

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

StatPersistentCacheTaskRequest represents request of StatPersistentCacheTask.

func (*StatPersistentCacheTaskRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use StatPersistentCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*StatPersistentCacheTaskRequest) GetTaskId added in v2.0.161 

func (x *StatPersistentCacheTaskRequest) GetTaskId() string

func (*StatPersistentCacheTaskRequest) ProtoMessage added in v2.0.161 

func (*StatPersistentCacheTaskRequest) ProtoMessage()

func (*StatPersistentCacheTaskRequest) ProtoReflect added in v2.0.161 

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

func (*StatPersistentCacheTaskRequest) Reset added in v2.0.161 

func (x *StatPersistentCacheTaskRequest) Reset()

func (*StatPersistentCacheTaskRequest) String added in v2.0.161 

func (x *StatPersistentCacheTaskRequest) String() string

func (*StatPersistentCacheTaskRequest) Validate added in v2.0.161 

func (m *StatPersistentCacheTaskRequest) Validate() error

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

func (m *StatPersistentCacheTaskRequest) ValidateAll() error

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

type StatPersistentCacheTaskRequestMultiError added in v2.0.161 

type StatPersistentCacheTaskRequestMultiError []error

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

func (StatPersistentCacheTaskRequestMultiError) AllErrors added in v2.0.161 

func (m StatPersistentCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatPersistentCacheTaskRequestMultiError) Error added in v2.0.161 

func (m StatPersistentCacheTaskRequestMultiError) Error() string

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

type StatPersistentCacheTaskRequestValidationError added in v2.0.161 

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

StatPersistentCacheTaskRequestValidationError is the validation error returned by StatPersistentCacheTaskRequest.Validate if the designated constraints aren't met.

func (StatPersistentCacheTaskRequestValidationError) Cause added in v2.0.161 

func (e StatPersistentCacheTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (StatPersistentCacheTaskRequestValidationError) Error added in v2.0.161 

func (e StatPersistentCacheTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatPersistentCacheTaskRequestValidationError) ErrorName added in v2.0.161 

func (e StatPersistentCacheTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatPersistentCacheTaskRequestValidationError) Field added in v2.0.161 

func (e StatPersistentCacheTaskRequestValidationError) Field() string

Field function returns field value.

func (StatPersistentCacheTaskRequestValidationError) Key added in v2.0.161 

func (e StatPersistentCacheTaskRequestValidationError) Key() bool

Key function returns key value.

func (StatPersistentCacheTaskRequestValidationError) Reason added in v2.0.161 

func (e StatPersistentCacheTaskRequestValidationError) 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) DeleteHost added in v2.0.118 

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

func (UnimplementedDfdaemonDownloadServer) DeletePersistentCacheTask added in v2.0.161 

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

func (UnimplementedDfdaemonDownloadServer) DeleteTask added in v2.0.63 

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

func (UnimplementedDfdaemonDownloadServer) DownloadPersistentCacheTask added in v2.0.161 

func (UnimplementedDfdaemonDownloadServer) DownloadPersistentCacheTask(*DownloadPersistentCacheTaskRequest, DfdaemonDownload_DownloadPersistentCacheTaskServer) error

func (UnimplementedDfdaemonDownloadServer) DownloadTask added in v2.0.63 

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

func (UnimplementedDfdaemonDownloadServer) StatPersistentCacheTask added in v2.0.161 

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

func (UnimplementedDfdaemonDownloadServer) StatTask added in v2.0.63 

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

func (UnimplementedDfdaemonDownloadServer) UploadPersistentCacheTask added in v2.0.161 

func (UnimplementedDfdaemonDownloadServer) UploadPersistentCacheTask(context.Context, *UploadPersistentCacheTaskRequest) (*v2.PersistentCacheTask, 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) DeletePersistentCacheTask added in v2.0.161 

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

func (UnimplementedDfdaemonUploadServer) DeleteTask added in v2.0.148 

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

func (UnimplementedDfdaemonUploadServer) DownloadPersistentCacheTask added in v2.0.161 

func (UnimplementedDfdaemonUploadServer) DownloadPersistentCacheTask(*DownloadPersistentCacheTaskRequest, DfdaemonUpload_DownloadPersistentCacheTaskServer) 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) StatPersistentCacheTask added in v2.0.161 

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

func (UnimplementedDfdaemonUploadServer) StatTask added in v2.0.148 

func (UnimplementedDfdaemonUploadServer) StatTask(context.Context, *StatTaskRequest) (*v2.Task, 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 UploadPersistentCacheTaskRequest added in v2.0.161 

type UploadPersistentCacheTaskRequest struct {

	// Upload file path of persistent cache task.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Replica count of the persistent persistent cache task.
	PersistentReplicaCount uint64 `` /* 130-byte string literal not displayed */
	// Tag is used to distinguish different persistent 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 persistent 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
}

UploadPersistentCacheTaskRequest represents request of UploadPersistentCacheTask.

func (*UploadPersistentCacheTaskRequest) Descriptor deprecated added in v2.0.161 

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

Deprecated: Use UploadPersistentCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*UploadPersistentCacheTaskRequest) GetApplication added in v2.0.161 

func (x *UploadPersistentCacheTaskRequest) GetApplication() string

func (*UploadPersistentCacheTaskRequest) GetPath added in v2.0.161 

func (x *UploadPersistentCacheTaskRequest) GetPath() string

func (*UploadPersistentCacheTaskRequest) GetPersistentReplicaCount added in v2.0.161 

func (x *UploadPersistentCacheTaskRequest) GetPersistentReplicaCount() uint64

func (*UploadPersistentCacheTaskRequest) GetTag added in v2.0.161 

func (x *UploadPersistentCacheTaskRequest) GetTag() string

func (*UploadPersistentCacheTaskRequest) GetTimeout added in v2.0.161 

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

func (*UploadPersistentCacheTaskRequest) GetTtl added in v2.0.161 

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

func (*UploadPersistentCacheTaskRequest) ProtoMessage added in v2.0.161 

func (*UploadPersistentCacheTaskRequest) ProtoMessage()

func (*UploadPersistentCacheTaskRequest) ProtoReflect added in v2.0.161 

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

func (*UploadPersistentCacheTaskRequest) Reset added in v2.0.161 

func (x *UploadPersistentCacheTaskRequest) Reset()

func (*UploadPersistentCacheTaskRequest) String added in v2.0.161 

func (x *UploadPersistentCacheTaskRequest) String() string

func (*UploadPersistentCacheTaskRequest) Validate added in v2.0.161 

func (m *UploadPersistentCacheTaskRequest) Validate() error

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

func (m *UploadPersistentCacheTaskRequest) ValidateAll() error

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

type UploadPersistentCacheTaskRequestMultiError added in v2.0.161 

type UploadPersistentCacheTaskRequestMultiError []error

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

func (UploadPersistentCacheTaskRequestMultiError) AllErrors added in v2.0.161 

func (m UploadPersistentCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UploadPersistentCacheTaskRequestMultiError) Error added in v2.0.161 

func (m UploadPersistentCacheTaskRequestMultiError) Error() string

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

type UploadPersistentCacheTaskRequestValidationError added in v2.0.161 

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

UploadPersistentCacheTaskRequestValidationError is the validation error returned by UploadPersistentCacheTaskRequest.Validate if the designated constraints aren't met.

func (UploadPersistentCacheTaskRequestValidationError) Cause added in v2.0.161 

func (e UploadPersistentCacheTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (UploadPersistentCacheTaskRequestValidationError) Error added in v2.0.161 

func (e UploadPersistentCacheTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (UploadPersistentCacheTaskRequestValidationError) ErrorName added in v2.0.161 

func (e UploadPersistentCacheTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (UploadPersistentCacheTaskRequestValidationError) Field added in v2.0.161 

func (e UploadPersistentCacheTaskRequestValidationError) Field() string

Field function returns field value.

func (UploadPersistentCacheTaskRequestValidationError) Key added in v2.0.161 

func (e UploadPersistentCacheTaskRequestValidationError) Key() bool

Key function returns key value.

func (UploadPersistentCacheTaskRequestValidationError) Reason added in v2.0.161 

func (e UploadPersistentCacheTaskRequestValidationError) 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.