dfdaemon

package
v2.3.0 Latest Latest
Warning

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

 Go to latest Published: Aug 5, 2026 License: Apache-2.0 Imports: 25 Imported by: 10

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: "StatTask",
			Handler:    _DfdaemonDownload_StatTask_Handler,
		},
		{
			MethodName: "StatLocalTask",
			Handler:    _DfdaemonDownload_StatLocalTask_Handler,
		},
		{
			MethodName: "ListLocalTasks",
			Handler:    _DfdaemonDownload_ListLocalTasks_Handler,
		},
		{
			MethodName: "ListTaskEntries",
			Handler:    _DfdaemonDownload_ListTaskEntries_Handler,
		},
		{
			MethodName: "DeleteTask",
			Handler:    _DfdaemonDownload_DeleteTask_Handler,
		},
		{
			MethodName: "DeleteLocalTask",
			Handler:    _DfdaemonDownload_DeleteLocalTask_Handler,
		},
		{
			MethodName: "DeleteHost",
			Handler:    _DfdaemonDownload_DeleteHost_Handler,
		},
		{
			MethodName: "StatCacheTask",
			Handler:    _DfdaemonDownload_StatCacheTask_Handler,
		},
		{
			MethodName: "DeleteCacheTask",
			Handler:    _DfdaemonDownload_DeleteCacheTask_Handler,
		},
		{
			MethodName: "UploadPersistentTask",
			Handler:    _DfdaemonDownload_UploadPersistentTask_Handler,
		},
		{
			MethodName: "StatPersistentTask",
			Handler:    _DfdaemonDownload_StatPersistentTask_Handler,
		},
		{
			MethodName: "StatLocalPersistentTask",
			Handler:    _DfdaemonDownload_StatLocalPersistentTask_Handler,
		},
		{
			MethodName: "ListLocalPersistentTasks",
			Handler:    _DfdaemonDownload_ListLocalPersistentTasks_Handler,
		},
		{
			MethodName: "UploadPersistentCacheTask",
			Handler:    _DfdaemonDownload_UploadPersistentCacheTask_Handler,
		},
		{
			MethodName: "StatPersistentCacheTask",
			Handler:    _DfdaemonDownload_StatPersistentCacheTask_Handler,
		},
		{
			MethodName: "StatLocalPersistentCacheTask",
			Handler:    _DfdaemonDownload_StatLocalPersistentCacheTask_Handler,
		},
		{
			MethodName: "ListLocalPersistentCacheTasks",
			Handler:    _DfdaemonDownload_ListLocalPersistentCacheTasks_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "DownloadTask",
			Handler:       _DfdaemonDownload_DownloadTask_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DownloadCacheTask",
			Handler:       _DfdaemonDownload_DownloadCacheTask_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DownloadPersistentTask",
			Handler:       _DfdaemonDownload_DownloadPersistentTask_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: "StatLocalTask",
			Handler:    _DfdaemonUpload_StatLocalTask_Handler,
		},
		{
			MethodName: "ListTaskEntries",
			Handler:    _DfdaemonUpload_ListTaskEntries_Handler,
		},
		{
			MethodName: "DeleteTask",
			Handler:    _DfdaemonUpload_DeleteTask_Handler,
		},
		{
			MethodName: "StatCacheTask",
			Handler:    _DfdaemonUpload_StatCacheTask_Handler,
		},
		{
			MethodName: "DeleteCacheTask",
			Handler:    _DfdaemonUpload_DeleteCacheTask_Handler,
		},
		{
			MethodName: "DownloadCachePiece",
			Handler:    _DfdaemonUpload_DownloadCachePiece_Handler,
		},
		{
			MethodName: "UpdatePersistentTask",
			Handler:    _DfdaemonUpload_UpdatePersistentTask_Handler,
		},
		{
			MethodName: "StatPersistentTask",
			Handler:    _DfdaemonUpload_StatPersistentTask_Handler,
		},
		{
			MethodName: "DeletePersistentTask",
			Handler:    _DfdaemonUpload_DeletePersistentTask_Handler,
		},
		{
			MethodName: "UpdatePersistentCacheTask",
			Handler:    _DfdaemonUpload_UpdatePersistentCacheTask_Handler,
		},
		{
			MethodName: "StatPersistentCacheTask",
			Handler:    _DfdaemonUpload_StatPersistentCacheTask_Handler,
		},
		{
			MethodName: "DeletePersistentCacheTask",
			Handler:    _DfdaemonUpload_DeletePersistentCacheTask_Handler,
		},
		{
			MethodName: "ExchangeIBVerbsQueuePairEndpoint",
			Handler:    _DfdaemonUpload_ExchangeIBVerbsQueuePairEndpoint_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,
		},
		{
			StreamName:    "SyncCachePieces",
			Handler:       _DfdaemonUpload_SyncCachePieces_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DownloadPersistentTask",
			Handler:       _DfdaemonUpload_DownloadPersistentTask_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SyncPersistentPieces",
			Handler:       _DfdaemonUpload_SyncPersistentPieces_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DownloadPersistentCacheTask",
			Handler:       _DfdaemonUpload_DownloadPersistentCacheTask_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SyncPersistentCachePieces",
			Handler:       _DfdaemonUpload_SyncPersistentCachePieces_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SyncHost",
			Handler:       _DfdaemonUpload_SyncHost_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"`
	// Remote IP represents the IP address of the client initiating the delete request.
	RemoteIp *string `protobuf:"bytes,2,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,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) GetRemoteIp added in v2.1.55 

func (x *DeleteCacheTaskRequest) GetRemoteIp() string

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

type DeleteLocalTaskRequest struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Remote IP represents the IP address of the client initiating the delete request.
	RemoteIp *string `protobuf:"bytes,2,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,omitempty"`
	// contains filtered or unexported fields
}

DeleteLocalTaskRequest represents request of DeleteLocalTask.

func (*DeleteLocalTaskRequest) Descriptor deprecated added in v2.2.27 

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

Deprecated: Use DeleteLocalTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteLocalTaskRequest) GetRemoteIp added in v2.2.27 

func (x *DeleteLocalTaskRequest) GetRemoteIp() string

func (*DeleteLocalTaskRequest) GetTaskId added in v2.2.27 

func (x *DeleteLocalTaskRequest) GetTaskId() string

func (*DeleteLocalTaskRequest) ProtoMessage added in v2.2.27 

func (*DeleteLocalTaskRequest) ProtoMessage()

func (*DeleteLocalTaskRequest) ProtoReflect added in v2.2.27 

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

func (*DeleteLocalTaskRequest) Reset added in v2.2.27 

func (x *DeleteLocalTaskRequest) Reset()

func (*DeleteLocalTaskRequest) String added in v2.2.27 

func (x *DeleteLocalTaskRequest) String() string

func (*DeleteLocalTaskRequest) Validate added in v2.2.27 

func (m *DeleteLocalTaskRequest) Validate() error

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

func (m *DeleteLocalTaskRequest) ValidateAll() error

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

type DeleteLocalTaskRequestMultiError added in v2.2.27 

type DeleteLocalTaskRequestMultiError []error

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

func (DeleteLocalTaskRequestMultiError) AllErrors added in v2.2.27 

func (m DeleteLocalTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteLocalTaskRequestMultiError) Error added in v2.2.27 

func (m DeleteLocalTaskRequestMultiError) Error() string

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

type DeleteLocalTaskRequestValidationError added in v2.2.27 

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

DeleteLocalTaskRequestValidationError is the validation error returned by DeleteLocalTaskRequest.Validate if the designated constraints aren't met.

func (DeleteLocalTaskRequestValidationError) Cause added in v2.2.27 

func (e DeleteLocalTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (DeleteLocalTaskRequestValidationError) Error added in v2.2.27 

func (e DeleteLocalTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DeleteLocalTaskRequestValidationError) ErrorName added in v2.2.27 

func (e DeleteLocalTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DeleteLocalTaskRequestValidationError) Field added in v2.2.27 

func (e DeleteLocalTaskRequestValidationError) Field() string

Field function returns field value.

func (DeleteLocalTaskRequestValidationError) Key added in v2.2.27 

func (e DeleteLocalTaskRequestValidationError) Key() bool

Key function returns key value.

func (DeleteLocalTaskRequestValidationError) Reason added in v2.2.27 

func (e DeleteLocalTaskRequestValidationError) Reason() string

Reason function returns reason value.

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"`
	// Remote IP represents the IP address of the client initiating the delete request.
	RemoteIp *string `protobuf:"bytes,2,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,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) GetRemoteIp added in v2.1.46 

func (x *DeletePersistentCacheTaskRequest) GetRemoteIp() string

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

type DeletePersistentTaskRequest struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Remote IP represents the IP address of the client initiating the delete request.
	RemoteIp *string `protobuf:"bytes,2,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,omitempty"`
	// contains filtered or unexported fields
}

DeletePersistentTaskRequest represents request of DeletePersistentTask.

func (*DeletePersistentTaskRequest) Descriptor deprecated added in v2.1.86 

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

Deprecated: Use DeletePersistentTaskRequest.ProtoReflect.Descriptor instead.

func (*DeletePersistentTaskRequest) GetRemoteIp added in v2.1.86 

func (x *DeletePersistentTaskRequest) GetRemoteIp() string

func (*DeletePersistentTaskRequest) GetTaskId added in v2.1.86 

func (x *DeletePersistentTaskRequest) GetTaskId() string

func (*DeletePersistentTaskRequest) ProtoMessage added in v2.1.86 

func (*DeletePersistentTaskRequest) ProtoMessage()

func (*DeletePersistentTaskRequest) ProtoReflect added in v2.1.86 

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

func (*DeletePersistentTaskRequest) Reset added in v2.1.86 

func (x *DeletePersistentTaskRequest) Reset()

func (*DeletePersistentTaskRequest) String added in v2.1.86 

func (x *DeletePersistentTaskRequest) String() string

func (*DeletePersistentTaskRequest) Validate added in v2.1.86 

func (m *DeletePersistentTaskRequest) Validate() error

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

func (m *DeletePersistentTaskRequest) ValidateAll() error

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

type DeletePersistentTaskRequestMultiError added in v2.1.86 

type DeletePersistentTaskRequestMultiError []error

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

func (DeletePersistentTaskRequestMultiError) AllErrors added in v2.1.86 

func (m DeletePersistentTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeletePersistentTaskRequestMultiError) Error added in v2.1.86 

func (m DeletePersistentTaskRequestMultiError) Error() string

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

type DeletePersistentTaskRequestValidationError added in v2.1.86 

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

DeletePersistentTaskRequestValidationError is the validation error returned by DeletePersistentTaskRequest.Validate if the designated constraints aren't met.

func (DeletePersistentTaskRequestValidationError) Cause added in v2.1.86 

func (e DeletePersistentTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (DeletePersistentTaskRequestValidationError) Error added in v2.1.86 

func (e DeletePersistentTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DeletePersistentTaskRequestValidationError) ErrorName added in v2.1.86 

func (e DeletePersistentTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DeletePersistentTaskRequestValidationError) Field added in v2.1.86 

func (e DeletePersistentTaskRequestValidationError) Field() string

Field function returns field value.

func (DeletePersistentTaskRequestValidationError) Key added in v2.1.86 

func (e DeletePersistentTaskRequestValidationError) Key() bool

Key function returns key value.

func (DeletePersistentTaskRequestValidationError) Reason added in v2.1.86 

func (e DeletePersistentTaskRequestValidationError) 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"`
	// Remote IP represents the IP address of the client initiating the delete request.
	RemoteIp *string `protobuf:"bytes,2,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,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) GetRemoteIp added in v2.1.46 

func (x *DeleteTaskRequest) GetRemoteIp() string

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)
	// StatTask stats task information.
	StatTask(ctx context.Context, in *StatTaskRequest, opts ...grpc.CallOption) (*v2.Task, error)
	// StatLocalTask stats local task information from peer.
	StatLocalTask(ctx context.Context, in *StatLocalTaskRequest, opts ...grpc.CallOption) (*StatLocalTaskResponse, error)
	// ListLocalTasks lists local tasks from peer.
	ListLocalTasks(ctx context.Context, in *ListLocalTasksRequest, opts ...grpc.CallOption) (*ListLocalTasksResponse, error)
	// ListTaskEntries lists task entries for downloading directory.
	ListTaskEntries(ctx context.Context, in *ListTaskEntriesRequest, opts ...grpc.CallOption) (*ListTaskEntriesResponse, error)
	// DeleteTask deletes task from p2p network.
	DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// DeleteLocalTask deletes local task from peer.
	DeleteLocalTask(ctx context.Context, in *DeleteLocalTaskRequest, 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)
	// 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)
	// DownloadPersistentTask downloads persistent task from p2p network.
	DownloadPersistentTask(ctx context.Context, in *DownloadPersistentTaskRequest, opts ...grpc.CallOption) (DfdaemonDownload_DownloadPersistentTaskClient, error)
	// UploadPersistentTask uploads persistent task to p2p network.
	UploadPersistentTask(ctx context.Context, in *UploadPersistentTaskRequest, opts ...grpc.CallOption) (*v2.PersistentTask, error)
	// StatPersistentTask stats persistent task information.
	StatPersistentTask(ctx context.Context, in *StatPersistentTaskRequest, opts ...grpc.CallOption) (*v2.PersistentTask, error)
	// StatLocalPersistentTask stats local persistent task information from peer.
	StatLocalPersistentTask(ctx context.Context, in *StatLocalPersistentTaskRequest, opts ...grpc.CallOption) (*StatLocalPersistentTaskResponse, error)
	// ListLocalPersistentTasks lists local persistent tasks from peer.
	ListLocalPersistentTasks(ctx context.Context, in *ListLocalPersistentTasksRequest, opts ...grpc.CallOption) (*ListLocalPersistentTasksResponse, 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)
	// StatLocalPersistentCacheTask stats local persistent cache task information from peer.
	StatLocalPersistentCacheTask(ctx context.Context, in *StatLocalPersistentCacheTaskRequest, opts ...grpc.CallOption) (*StatLocalPersistentCacheTaskResponse, error)
	// ListLocalPersistentCacheTasks lists local persistent cache tasks from peer.
	ListLocalPersistentCacheTasks(ctx context.Context, in *ListLocalPersistentCacheTasksRequest, opts ...grpc.CallOption) (*ListLocalPersistentCacheTasksResponse, 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
	// StatTask stats task information.
	StatTask(context.Context, *StatTaskRequest) (*v2.Task, error)
	// StatLocalTask stats local task information from peer.
	StatLocalTask(context.Context, *StatLocalTaskRequest) (*StatLocalTaskResponse, error)
	// ListLocalTasks lists local tasks from peer.
	ListLocalTasks(context.Context, *ListLocalTasksRequest) (*ListLocalTasksResponse, error)
	// ListTaskEntries lists task entries for downloading directory.
	ListTaskEntries(context.Context, *ListTaskEntriesRequest) (*ListTaskEntriesResponse, error)
	// DeleteTask deletes task from p2p network.
	DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)
	// DeleteLocalTask deletes local task from peer.
	DeleteLocalTask(context.Context, *DeleteLocalTaskRequest) (*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
	// 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)
	// DownloadPersistentTask downloads persistent task from p2p network.
	DownloadPersistentTask(*DownloadPersistentTaskRequest, DfdaemonDownload_DownloadPersistentTaskServer) error
	// UploadPersistentTask uploads persistent task to p2p network.
	UploadPersistentTask(context.Context, *UploadPersistentTaskRequest) (*v2.PersistentTask, error)
	// StatPersistentTask stats persistent task information.
	StatPersistentTask(context.Context, *StatPersistentTaskRequest) (*v2.PersistentTask, error)
	// StatLocalPersistentTask stats local persistent task information from peer.
	StatLocalPersistentTask(context.Context, *StatLocalPersistentTaskRequest) (*StatLocalPersistentTaskResponse, error)
	// ListLocalPersistentTasks lists local persistent tasks from peer.
	ListLocalPersistentTasks(context.Context, *ListLocalPersistentTasksRequest) (*ListLocalPersistentTasksResponse, 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)
	// StatLocalPersistentCacheTask stats local persistent cache task information from peer.
	StatLocalPersistentCacheTask(context.Context, *StatLocalPersistentCacheTaskRequest) (*StatLocalPersistentCacheTaskResponse, error)
	// ListLocalPersistentCacheTasks lists local persistent cache tasks from peer.
	ListLocalPersistentCacheTasks(context.Context, *ListLocalPersistentCacheTasksRequest) (*ListLocalPersistentCacheTasksResponse, 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_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_DownloadPersistentTaskClient added in v2.1.86 

type DfdaemonDownload_DownloadPersistentTaskClient interface {
	Recv() (*DownloadPersistentTaskResponse, error)
	grpc.ClientStream
}

type DfdaemonDownload_DownloadPersistentTaskServer added in v2.1.86 

type DfdaemonDownload_DownloadPersistentTaskServer interface {
	Send(*DownloadPersistentTaskResponse) 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)
	// StatLocalTask stats local task information from peer.
	StatLocalTask(ctx context.Context, in *StatLocalTaskRequest, opts ...grpc.CallOption) (*StatLocalTaskResponse, error)
	// ListTaskEntries lists task entries for downloading directory.
	ListTaskEntries(ctx context.Context, in *ListTaskEntriesRequest, opts ...grpc.CallOption) (*ListTaskEntriesResponse, 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)
	// 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)
	// SyncCachePieces syncs cache piece metadatas from remote peer.
	SyncCachePieces(ctx context.Context, in *SyncCachePiecesRequest, opts ...grpc.CallOption) (DfdaemonUpload_SyncCachePiecesClient, error)
	// DownloadCachePiece downloads cache piece from the remote peer.
	DownloadCachePiece(ctx context.Context, in *DownloadCachePieceRequest, opts ...grpc.CallOption) (*DownloadCachePieceResponse, error)
	// DownloadPersistentTask downloads persistent task from p2p network.
	DownloadPersistentTask(ctx context.Context, in *DownloadPersistentTaskRequest, opts ...grpc.CallOption) (DfdaemonUpload_DownloadPersistentTaskClient, error)
	// SyncPersistentPieces syncs persistent pieces from remote peer.
	SyncPersistentPieces(ctx context.Context, in *SyncPersistentPiecesRequest, opts ...grpc.CallOption) (DfdaemonUpload_SyncPersistentPiecesClient, error)
	// UpdatePersistentTask updates metadate of thr persistent task in p2p network.
	UpdatePersistentTask(ctx context.Context, in *UpdatePersistentTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// StatPersistentTask stats persistent task information.
	StatPersistentTask(ctx context.Context, in *StatPersistentTaskRequest, opts ...grpc.CallOption) (*v2.PersistentTask, error)
	// DeletePersistentTask deletes persistent task from p2p network.
	DeletePersistentTask(ctx context.Context, in *DeletePersistentTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// DownloadPersistentCacheTask downloads persistent cache task from p2p network.
	DownloadPersistentCacheTask(ctx context.Context, in *DownloadPersistentCacheTaskRequest, opts ...grpc.CallOption) (DfdaemonUpload_DownloadPersistentCacheTaskClient, error)
	// UpdatePersistentCacheTask updates metadate of thr persistent cache task in p2p network.
	UpdatePersistentCacheTask(ctx context.Context, in *UpdatePersistentCacheTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, 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)
	// SyncPersistentCachePieces syncs persistent cache pieces from remote peer.
	SyncPersistentCachePieces(ctx context.Context, in *SyncPersistentCachePiecesRequest, opts ...grpc.CallOption) (DfdaemonUpload_SyncPersistentCachePiecesClient, error)
	// SyncHost sync host info from parents.
	SyncHost(ctx context.Context, in *SyncHostRequest, opts ...grpc.CallOption) (DfdaemonUpload_SyncHostClient, error)
	// ExchangeIBVerbsQueuePairEndpoint exchanges queue pair endpoint of IBVerbs with remote peer.
	ExchangeIBVerbsQueuePairEndpoint(ctx context.Context, in *ExchangeIBVerbsQueuePairEndpointRequest, opts ...grpc.CallOption) (*ExchangeIBVerbsQueuePairEndpointResponse, 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)
	// StatLocalTask stats local task information from peer.
	StatLocalTask(context.Context, *StatLocalTaskRequest) (*StatLocalTaskResponse, error)
	// ListTaskEntries lists task entries for downloading directory.
	ListTaskEntries(context.Context, *ListTaskEntriesRequest) (*ListTaskEntriesResponse, 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
	// 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)
	// SyncCachePieces syncs cache piece metadatas from remote peer.
	SyncCachePieces(*SyncCachePiecesRequest, DfdaemonUpload_SyncCachePiecesServer) error
	// DownloadCachePiece downloads cache piece from the remote peer.
	DownloadCachePiece(context.Context, *DownloadCachePieceRequest) (*DownloadCachePieceResponse, error)
	// DownloadPersistentTask downloads persistent task from p2p network.
	DownloadPersistentTask(*DownloadPersistentTaskRequest, DfdaemonUpload_DownloadPersistentTaskServer) error
	// SyncPersistentPieces syncs persistent pieces from remote peer.
	SyncPersistentPieces(*SyncPersistentPiecesRequest, DfdaemonUpload_SyncPersistentPiecesServer) error
	// UpdatePersistentTask updates metadate of thr persistent task in p2p network.
	UpdatePersistentTask(context.Context, *UpdatePersistentTaskRequest) (*emptypb.Empty, error)
	// StatPersistentTask stats persistent task information.
	StatPersistentTask(context.Context, *StatPersistentTaskRequest) (*v2.PersistentTask, error)
	// DeletePersistentTask deletes persistent task from p2p network.
	DeletePersistentTask(context.Context, *DeletePersistentTaskRequest) (*emptypb.Empty, error)
	// DownloadPersistentCacheTask downloads persistent cache task from p2p network.
	DownloadPersistentCacheTask(*DownloadPersistentCacheTaskRequest, DfdaemonUpload_DownloadPersistentCacheTaskServer) error
	// UpdatePersistentCacheTask updates metadate of thr persistent cache task in p2p network.
	UpdatePersistentCacheTask(context.Context, *UpdatePersistentCacheTaskRequest) (*emptypb.Empty, 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)
	// SyncPersistentCachePieces syncs persistent cache pieces from remote peer.
	SyncPersistentCachePieces(*SyncPersistentCachePiecesRequest, DfdaemonUpload_SyncPersistentCachePiecesServer) error
	// SyncHost sync host info from parents.
	SyncHost(*SyncHostRequest, DfdaemonUpload_SyncHostServer) error
	// ExchangeIBVerbsQueuePairEndpoint exchanges queue pair endpoint of IBVerbs with remote peer.
	ExchangeIBVerbsQueuePairEndpoint(context.Context, *ExchangeIBVerbsQueuePairEndpointRequest) (*ExchangeIBVerbsQueuePairEndpointResponse, 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_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_DownloadPersistentTaskClient added in v2.1.86 

type DfdaemonUpload_DownloadPersistentTaskClient interface {
	Recv() (*DownloadPersistentTaskResponse, error)
	grpc.ClientStream
}

type DfdaemonUpload_DownloadPersistentTaskServer added in v2.1.86 

type DfdaemonUpload_DownloadPersistentTaskServer interface {
	Send(*DownloadPersistentTaskResponse) 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_SyncCachePiecesClient added in v2.1.50 

type DfdaemonUpload_SyncCachePiecesClient interface {
	Recv() (*SyncCachePiecesResponse, error)
	grpc.ClientStream
}

type DfdaemonUpload_SyncCachePiecesServer added in v2.1.50 

type DfdaemonUpload_SyncCachePiecesServer interface {
	Send(*SyncCachePiecesResponse) error
	grpc.ServerStream
}

type DfdaemonUpload_SyncHostClient added in v2.1.1 

type DfdaemonUpload_SyncHostClient interface {
	Recv() (*v2.Host, error)
	grpc.ClientStream
}

type DfdaemonUpload_SyncHostServer added in v2.1.1 

type DfdaemonUpload_SyncHostServer interface {
	Send(*v2.Host) error
	grpc.ServerStream
}

type DfdaemonUpload_SyncPersistentCachePiecesClient added in v2.1.10 

type DfdaemonUpload_SyncPersistentCachePiecesClient interface {
	Recv() (*SyncPersistentCachePiecesResponse, error)
	grpc.ClientStream
}

type DfdaemonUpload_SyncPersistentCachePiecesServer added in v2.1.10 

type DfdaemonUpload_SyncPersistentCachePiecesServer interface {
	Send(*SyncPersistentCachePiecesResponse) error
	grpc.ServerStream
}

type DfdaemonUpload_SyncPersistentPiecesClient added in v2.1.86 

type DfdaemonUpload_SyncPersistentPiecesClient interface {
	Recv() (*SyncPersistentPiecesResponse, error)
	grpc.ClientStream
}

type DfdaemonUpload_SyncPersistentPiecesServer added in v2.1.86 

type DfdaemonUpload_SyncPersistentPiecesServer interface {
	Send(*SyncPersistentPiecesResponse) 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 DownloadCachePieceRequest added in v2.1.50 

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

DownloadCachePieceRequest represents request of DownloadCachePiece.

func (*DownloadCachePieceRequest) Descriptor deprecated added in v2.1.50 

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

Deprecated: Use DownloadCachePieceRequest.ProtoReflect.Descriptor instead.

func (*DownloadCachePieceRequest) GetHostId added in v2.1.50 

func (x *DownloadCachePieceRequest) GetHostId() string

func (*DownloadCachePieceRequest) GetPieceNumber added in v2.1.50 

func (x *DownloadCachePieceRequest) GetPieceNumber() uint32

func (*DownloadCachePieceRequest) GetTaskId added in v2.1.50 

func (x *DownloadCachePieceRequest) GetTaskId() string

func (*DownloadCachePieceRequest) ProtoMessage added in v2.1.50 

func (*DownloadCachePieceRequest) ProtoMessage()

func (*DownloadCachePieceRequest) ProtoReflect added in v2.1.50 

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

func (*DownloadCachePieceRequest) Reset added in v2.1.50 

func (x *DownloadCachePieceRequest) Reset()

func (*DownloadCachePieceRequest) String added in v2.1.50 

func (x *DownloadCachePieceRequest) String() string

func (*DownloadCachePieceRequest) Validate added in v2.1.50 

func (m *DownloadCachePieceRequest) Validate() error

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

func (m *DownloadCachePieceRequest) ValidateAll() error

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

type DownloadCachePieceRequestMultiError added in v2.1.50 

type DownloadCachePieceRequestMultiError []error

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

func (DownloadCachePieceRequestMultiError) AllErrors added in v2.1.50 

func (m DownloadCachePieceRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadCachePieceRequestMultiError) Error added in v2.1.50 

func (m DownloadCachePieceRequestMultiError) Error() string

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

type DownloadCachePieceRequestValidationError added in v2.1.50 

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

DownloadCachePieceRequestValidationError is the validation error returned by DownloadCachePieceRequest.Validate if the designated constraints aren't met.

func (DownloadCachePieceRequestValidationError) Cause added in v2.1.50 

func (e DownloadCachePieceRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadCachePieceRequestValidationError) Error added in v2.1.50 

func (e DownloadCachePieceRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadCachePieceRequestValidationError) ErrorName added in v2.1.50 

func (e DownloadCachePieceRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadCachePieceRequestValidationError) Field added in v2.1.50 

func (e DownloadCachePieceRequestValidationError) Field() string

Field function returns field value.

func (DownloadCachePieceRequestValidationError) Key added in v2.1.50 

func (e DownloadCachePieceRequestValidationError) Key() bool

Key function returns key value.

func (DownloadCachePieceRequestValidationError) Reason added in v2.1.50 

func (e DownloadCachePieceRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadCachePieceResponse added in v2.1.50 

type DownloadCachePieceResponse struct {

	// Piece information.
	Piece *v2.Piece `protobuf:"bytes,1,opt,name=piece,proto3" json:"piece,omitempty"`
	// Piece metadata digest, it is used to verify the integrity of the piece metadata.
	Digest *string `protobuf:"bytes,2,opt,name=digest,proto3,oneof" json:"digest,omitempty"`
	// contains filtered or unexported fields
}

DownloadCachePieceResponse represents response of DownloadCachePieces.

func (*DownloadCachePieceResponse) Descriptor deprecated added in v2.1.50 

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

Deprecated: Use DownloadCachePieceResponse.ProtoReflect.Descriptor instead.

func (*DownloadCachePieceResponse) GetDigest added in v2.1.50 

func (x *DownloadCachePieceResponse) GetDigest() string

func (*DownloadCachePieceResponse) GetPiece added in v2.1.50 

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

func (*DownloadCachePieceResponse) ProtoMessage added in v2.1.50 

func (*DownloadCachePieceResponse) ProtoMessage()

func (*DownloadCachePieceResponse) ProtoReflect added in v2.1.50 

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

func (*DownloadCachePieceResponse) Reset added in v2.1.50 

func (x *DownloadCachePieceResponse) Reset()

func (*DownloadCachePieceResponse) String added in v2.1.50 

func (x *DownloadCachePieceResponse) String() string

func (*DownloadCachePieceResponse) Validate added in v2.1.50 

func (m *DownloadCachePieceResponse) Validate() error

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

func (m *DownloadCachePieceResponse) ValidateAll() error

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

type DownloadCachePieceResponseMultiError added in v2.1.50 

type DownloadCachePieceResponseMultiError []error

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

func (DownloadCachePieceResponseMultiError) AllErrors added in v2.1.50 

func (m DownloadCachePieceResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadCachePieceResponseMultiError) Error added in v2.1.50 

func (m DownloadCachePieceResponseMultiError) Error() string

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

type DownloadCachePieceResponseValidationError added in v2.1.50 

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

DownloadCachePieceResponseValidationError is the validation error returned by DownloadCachePieceResponse.Validate if the designated constraints aren't met.

func (DownloadCachePieceResponseValidationError) Cause added in v2.1.50 

func (e DownloadCachePieceResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadCachePieceResponseValidationError) Error added in v2.1.50 

func (e DownloadCachePieceResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadCachePieceResponseValidationError) ErrorName added in v2.1.50 

func (e DownloadCachePieceResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadCachePieceResponseValidationError) Field added in v2.1.50 

func (e DownloadCachePieceResponseValidationError) Field() string

Field function returns field value.

func (DownloadCachePieceResponseValidationError) Key added in v2.1.50 

func (e DownloadCachePieceResponseValidationError) Key() bool

Key function returns key value.

func (DownloadCachePieceResponseValidationError) Reason added in v2.1.50 

func (e DownloadCachePieceResponseValidationError) Reason() string

Reason function returns reason value.

type DownloadCacheTaskRequest added in v2.0.116 

type DownloadCacheTaskRequest struct {

	// Download url.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// Digest of the task digest, for example blake3:xxx or sha256:yyy.
	Digest *string `protobuf:"bytes,2,opt,name=digest,proto3,oneof" json:"digest,omitempty"`
	// Range is url range of request. If protocol is http, range
	// will set in request header. If protocol is others, range
	// will set in range field.
	Range *v2.Range `protobuf:"bytes,3,opt,name=range,proto3,oneof" json:"range,omitempty"`
	// Task type.
	Type v2.TaskType `protobuf:"varint,4,opt,name=type,proto3,enum=common.v2.TaskType" json:"type,omitempty"`
	// URL tag identifies different task for same url.
	Tag *string `protobuf:"bytes,5,opt,name=tag,proto3,oneof" json:"tag,omitempty"`
	// Application of task.
	Application *string `protobuf:"bytes,6,opt,name=application,proto3,oneof" json:"application,omitempty"`
	// Peer priority.
	Priority v2.Priority `protobuf:"varint,7,opt,name=priority,proto3,enum=common.v2.Priority" json:"priority,omitempty"`
	// Filtered query params to generate the task id.
	// When filter is ["Signature", "Expires", "ns"], for example:
	// http://example.com/xyz?Expires=e1&Signature=s1&ns=docker.io and http://example.com/xyz?Expires=e2&Signature=s2&ns=docker.io
	// will generate the same task id.
	// Default value includes the filtered query params of s3, gcs, oss, obs, cos.
	FilteredQueryParams []string `protobuf:"bytes,8,rep,name=filtered_query_params,json=filteredQueryParams,proto3" json:"filtered_query_params,omitempty"`
	// Task request headers.
	RequestHeader map[string]string `` /* 188-byte string literal not displayed */
	// Task piece length, the value needs to be greater than or equal to 4194304(4MiB).
	PieceLength *uint64 `protobuf:"varint,10,opt,name=piece_length,json=pieceLength,proto3,oneof" json:"piece_length,omitempty"`
	// File path to be downloaded. If output_path is set, the downloaded file will be saved to the specified path.
	// Dfdaemon will try to create hard link to the output path before starting the download. If hard link creation fails,
	// it will copy the file to the output path after the download is completed.
	// For more details refer to https://github.com/dragonflyoss/design/blob/main/systems-analysis/file-download-workflow-with-hard-link/README.md.
	OutputPath *string `protobuf:"bytes,11,opt,name=output_path,json=outputPath,proto3,oneof" json:"output_path,omitempty"`
	// Download timeout.
	Timeout *durationpb.Duration `protobuf:"bytes,12,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
	// Dfdaemon cannot download the task from the source if disable_back_to_source is true.
	DisableBackToSource bool `protobuf:"varint,13,opt,name=disable_back_to_source,json=disableBackToSource,proto3" json:"disable_back_to_source,omitempty"`
	// Scheduler needs to schedule the task downloads from the source if need_back_to_source is true.
	NeedBackToSource bool `protobuf:"varint,14,opt,name=need_back_to_source,json=needBackToSource,proto3" json:"need_back_to_source,omitempty"`
	// certificate_chain is the client certs with DER format for the backend client to download back-to-source.
	CertificateChain [][]byte `protobuf:"bytes,15,rep,name=certificate_chain,json=certificateChain,proto3" json:"certificate_chain,omitempty"`
	// Prefetch pre-downloads all pieces of the task when the download task request is a range request.
	Prefetch bool `protobuf:"varint,16,opt,name=prefetch,proto3" json:"prefetch,omitempty"`
	// Object storage protocol information.
	ObjectStorage *v2.ObjectStorage `protobuf:"bytes,17,opt,name=object_storage,json=objectStorage,proto3,oneof" json:"object_storage,omitempty"`
	// HDFS protocol information.
	Hdfs *v2.HDFS `protobuf:"bytes,18,opt,name=hdfs,proto3,oneof" json:"hdfs,omitempty"`
	// is_prefetch is the flag to indicate whether the request is a prefetch request.
	IsPrefetch bool `protobuf:"varint,19,opt,name=is_prefetch,json=isPrefetch,proto3" json:"is_prefetch,omitempty"`
	// need_piece_content is the flag to indicate whether the response needs to return piece content.
	NeedPieceContent bool `protobuf:"varint,20,opt,name=need_piece_content,json=needPieceContent,proto3" json:"need_piece_content,omitempty"`
	// content_for_calculating_task_id is the content used to calculate the task id.
	// If content_for_calculating_task_id is set, use its value to calculate the task ID.
	// Otherwise, calculate the task ID based on url, piece_length, tag, application, and filtered_query_params.
	ContentForCalculatingTaskId *string `` /* 155-byte string literal not displayed */
	// remote_ip represents the IP address of the client initiating the download request.
	// For proxy requests, it is set to the IP address of the request source.
	// For dfget requests, it is set to the IP address of the dfget.
	RemoteIp *string `protobuf:"bytes,22,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,omitempty"`
	// Overwrite indicates whether to overwrite the existing file at output path.
	Overwrite bool `protobuf:"varint,23,opt,name=overwrite,proto3" json:"overwrite,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) GetCertificateChain added in v2.1.50 

func (x *DownloadCacheTaskRequest) GetCertificateChain() [][]byte

func (*DownloadCacheTaskRequest) GetContentForCalculatingTaskId added in v2.1.50 

func (x *DownloadCacheTaskRequest) GetContentForCalculatingTaskId() string

func (*DownloadCacheTaskRequest) GetDigest added in v2.1.50 

func (x *DownloadCacheTaskRequest) GetDigest() string

func (*DownloadCacheTaskRequest) GetDisableBackToSource added in v2.1.50 

func (x *DownloadCacheTaskRequest) GetDisableBackToSource() bool

func (*DownloadCacheTaskRequest) GetFilteredQueryParams added in v2.1.50 

func (x *DownloadCacheTaskRequest) GetFilteredQueryParams() []string

func (*DownloadCacheTaskRequest) GetHdfs added in v2.1.50 

func (x *DownloadCacheTaskRequest) GetHdfs() *v2.HDFS

func (*DownloadCacheTaskRequest) GetIsPrefetch added in v2.1.50 

func (x *DownloadCacheTaskRequest) GetIsPrefetch() bool

func (*DownloadCacheTaskRequest) GetNeedBackToSource added in v2.1.50 

func (x *DownloadCacheTaskRequest) GetNeedBackToSource() bool

func (*DownloadCacheTaskRequest) GetNeedPieceContent added in v2.1.50 

func (x *DownloadCacheTaskRequest) GetNeedPieceContent() bool

func (*DownloadCacheTaskRequest) GetObjectStorage added in v2.1.50 

func (x *DownloadCacheTaskRequest) GetObjectStorage() *v2.ObjectStorage

func (*DownloadCacheTaskRequest) GetOutputPath added in v2.0.116 

func (x *DownloadCacheTaskRequest) GetOutputPath() string

func (*DownloadCacheTaskRequest) GetOverwrite added in v2.1.70 

func (x *DownloadCacheTaskRequest) GetOverwrite() bool

func (*DownloadCacheTaskRequest) GetPieceLength added in v2.0.116 

func (x *DownloadCacheTaskRequest) GetPieceLength() uint64

func (*DownloadCacheTaskRequest) GetPrefetch added in v2.1.50 

func (x *DownloadCacheTaskRequest) GetPrefetch() bool

func (*DownloadCacheTaskRequest) GetPriority added in v2.1.50 

func (x *DownloadCacheTaskRequest) GetPriority() v2.Priority

func (*DownloadCacheTaskRequest) GetRange added in v2.1.50 

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

func (*DownloadCacheTaskRequest) GetRemoteIp added in v2.1.50 

func (x *DownloadCacheTaskRequest) GetRemoteIp() string

func (*DownloadCacheTaskRequest) GetRequestHeader added in v2.1.50 

func (x *DownloadCacheTaskRequest) GetRequestHeader() map[string]string

func (*DownloadCacheTaskRequest) GetTag added in v2.0.116 

func (x *DownloadCacheTaskRequest) GetTag() string

func (*DownloadCacheTaskRequest) GetTimeout added in v2.0.116 

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

func (*DownloadCacheTaskRequest) GetType added in v2.1.50 

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

func (*DownloadCacheTaskRequest) GetUrl added in v2.1.50 

func (x *DownloadCacheTaskRequest) GetUrl() string

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"`
	// 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"`
	// is_finished indicates whether the download task is finished.
	IsFinished bool `protobuf:"varint,5,opt,name=is_finished,json=isFinished,proto3" json:"is_finished,omitempty"`
	// contains filtered or unexported fields
}

DownloadCacheTaskStartedResponse represents cache 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) GetIsFinished added in v2.1.50 

func (x *DownloadCacheTaskStartedResponse) GetIsFinished() bool

func (*DownloadCacheTaskStartedResponse) GetPieces added in v2.1.50 

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

func (*DownloadCacheTaskStartedResponse) GetRange added in v2.1.50 

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

func (*DownloadCacheTaskStartedResponse) GetResponseHeader added in v2.1.50 

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

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 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. If output_path is set, the exported file will be saved to the specified path.
	// Dfdaemon will try to create hard link to the output path before starting the export. If hard link creation fails,
	// it will copy the file to the output path after the export is completed.
	// For more details refer to https://github.com/dragonflyoss/design/blob/main/systems-analysis/file-download-workflow-with-hard-link/README.md.
	OutputPath *string `protobuf:"bytes,5,opt,name=output_path,json=outputPath,proto3,oneof" json:"output_path,omitempty"`
	// Download timeout.
	Timeout *durationpb.Duration `protobuf:"bytes,6,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
	// need_piece_content is the flag to indicate whether the response needs to return piece content.
	NeedPieceContent bool `protobuf:"varint,7,opt,name=need_piece_content,json=needPieceContent,proto3" json:"need_piece_content,omitempty"`
	// force_hard_link is the flag to indicate whether the exported file must be hard linked to the output path.
	// For more details refer to https://github.com/dragonflyoss/design/blob/main/systems-analysis/file-download-workflow-with-hard-link/README.md.
	ForceHardLink bool `protobuf:"varint,8,opt,name=force_hard_link,json=forceHardLink,proto3" json:"force_hard_link,omitempty"`
	// Verifies task data integrity after download using a digest. Supports CRC32, SHA256, and SHA512 algorithms.
	// Format: `<algorithm>:<hash>`, e.g., `crc32:xxx`, `sha256:yyy`, `sha512:zzz`.
	// Returns an error if the computed digest mismatches the expected value.
	//
	// Performance
	// Digest calculation increases processing time. Enable only when data integrity verification is critical.
	Digest *string `protobuf:"bytes,9,opt,name=digest,proto3,oneof" json:"digest,omitempty"`
	// Remote IP represents the IP address of the client initiating the download request.
	RemoteIp *string `protobuf:"bytes,10,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,omitempty"`
	// Overwrite indicates whether to overwrite the existing file at output path.
	Overwrite bool `protobuf:"varint,11,opt,name=overwrite,proto3" json:"overwrite,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) GetDigest added in v2.1.40 

func (x *DownloadPersistentCacheTaskRequest) GetDigest() string
func (x *DownloadPersistentCacheTaskRequest) GetForceHardLink() bool

func (*DownloadPersistentCacheTaskRequest) GetNeedPieceContent added in v2.1.2 

func (x *DownloadPersistentCacheTaskRequest) GetNeedPieceContent() bool

func (*DownloadPersistentCacheTaskRequest) GetOutputPath added in v2.0.161 

func (x *DownloadPersistentCacheTaskRequest) GetOutputPath() string

func (*DownloadPersistentCacheTaskRequest) GetOverwrite added in v2.1.70 

func (x *DownloadPersistentCacheTaskRequest) GetOverwrite() bool

func (*DownloadPersistentCacheTaskRequest) GetPersistent added in v2.0.161 

func (x *DownloadPersistentCacheTaskRequest) GetPersistent() bool

func (*DownloadPersistentCacheTaskRequest) GetRemoteIp added in v2.1.45 

func (x *DownloadPersistentCacheTaskRequest) GetRemoteIp() string

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

type DownloadPersistentTaskRequest struct {

	// This is the url of the object storage protocal where the persistent task will be stored,
	// for example: `s3://<bucket>/path`, `gcs://<bucket>/path`. The combination of url,
	// object_storage.endpoint and object_storage.region must be unique, because
	// the persistent task cannot be overwritten once it is uploaded.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// Object storage protocol information.
	ObjectStorage *v2.ObjectStorage `protobuf:"bytes,2,opt,name=object_storage,json=objectStorage,proto3" json:"object_storage,omitempty"`
	// Persistent represents whether the persistent task is persistent.
	// If the persistent task is persistent, the persistent peer will
	// not be deleted when dfdaemon runs garbage collection.
	Persistent bool `protobuf:"varint,3,opt,name=persistent,proto3" json:"persistent,omitempty"`
	// File path to be exported. If output_path is set, the exported file will be saved to the specified path.
	// Dfdaemon will try to create hard link to the output path before starting the export. If hard link creation fails,
	// it will copy the file to the output path after the export is completed.
	// For more details refer to https://github.com/dragonflyoss/design/blob/main/systems-analysis/file-download-workflow-with-hard-link/README.md.
	OutputPath *string `protobuf:"bytes,4,opt,name=output_path,json=outputPath,proto3,oneof" json:"output_path,omitempty"`
	// Download timeout.
	Timeout *durationpb.Duration `protobuf:"bytes,5,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
	// need_piece_content is the flag to indicate whether the response needs to return piece content.
	NeedPieceContent bool `protobuf:"varint,6,opt,name=need_piece_content,json=needPieceContent,proto3" json:"need_piece_content,omitempty"`
	// force_hard_link is the flag to indicate whether the exported file must be hard linked to the output path.
	// For more details refer to https://github.com/dragonflyoss/design/blob/main/systems-analysis/file-download-workflow-with-hard-link/README.md.
	ForceHardLink bool `protobuf:"varint,7,opt,name=force_hard_link,json=forceHardLink,proto3" json:"force_hard_link,omitempty"`
	// Verifies task data integrity after download using a digest. Supports CRC32, SHA256, and SHA512 algorithms.
	// Format: `<algorithm>:<hash>`, e.g., `crc32:xxx`, `sha256:yyy`, `sha512:zzz`.
	// Returns an error if the computed digest mismatches the expected value.
	//
	// Performance
	// Digest calculation increases processing time. Enable only when data integrity verification is critical.
	Digest *string `protobuf:"bytes,8,opt,name=digest,proto3,oneof" json:"digest,omitempty"`
	// Remote IP represents the IP address of the client initiating the download request.
	RemoteIp *string `protobuf:"bytes,9,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,omitempty"`
	// Overwrite indicates whether to overwrite the existing file at output path.
	Overwrite bool `protobuf:"varint,10,opt,name=overwrite,proto3" json:"overwrite,omitempty"`
	// contains filtered or unexported fields
}

DownloadPersistentTaskRequest represents request of DownloadPersistentTask.

func (*DownloadPersistentTaskRequest) Descriptor deprecated added in v2.1.86 

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

Deprecated: Use DownloadPersistentTaskRequest.ProtoReflect.Descriptor instead.

func (*DownloadPersistentTaskRequest) GetDigest added in v2.1.86 

func (x *DownloadPersistentTaskRequest) GetDigest() string
func (x *DownloadPersistentTaskRequest) GetForceHardLink() bool

func (*DownloadPersistentTaskRequest) GetNeedPieceContent added in v2.1.86 

func (x *DownloadPersistentTaskRequest) GetNeedPieceContent() bool

func (*DownloadPersistentTaskRequest) GetObjectStorage added in v2.1.86 

func (x *DownloadPersistentTaskRequest) GetObjectStorage() *v2.ObjectStorage

func (*DownloadPersistentTaskRequest) GetOutputPath added in v2.1.86 

func (x *DownloadPersistentTaskRequest) GetOutputPath() string

func (*DownloadPersistentTaskRequest) GetOverwrite added in v2.1.86 

func (x *DownloadPersistentTaskRequest) GetOverwrite() bool

func (*DownloadPersistentTaskRequest) GetPersistent added in v2.1.86 

func (x *DownloadPersistentTaskRequest) GetPersistent() bool

func (*DownloadPersistentTaskRequest) GetRemoteIp added in v2.1.86 

func (x *DownloadPersistentTaskRequest) GetRemoteIp() string

func (*DownloadPersistentTaskRequest) GetTimeout added in v2.1.86 

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

func (*DownloadPersistentTaskRequest) GetUrl added in v2.2.0 

func (x *DownloadPersistentTaskRequest) GetUrl() string

func (*DownloadPersistentTaskRequest) ProtoMessage added in v2.1.86 

func (*DownloadPersistentTaskRequest) ProtoMessage()

func (*DownloadPersistentTaskRequest) ProtoReflect added in v2.1.86 

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

func (*DownloadPersistentTaskRequest) Reset added in v2.1.86 

func (x *DownloadPersistentTaskRequest) Reset()

func (*DownloadPersistentTaskRequest) String added in v2.1.86 

func (x *DownloadPersistentTaskRequest) String() string

func (*DownloadPersistentTaskRequest) Validate added in v2.1.86 

func (m *DownloadPersistentTaskRequest) Validate() error

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

func (m *DownloadPersistentTaskRequest) ValidateAll() error

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

type DownloadPersistentTaskRequestMultiError added in v2.1.86 

type DownloadPersistentTaskRequestMultiError []error

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

func (DownloadPersistentTaskRequestMultiError) AllErrors added in v2.1.86 

func (m DownloadPersistentTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPersistentTaskRequestMultiError) Error added in v2.1.86 

func (m DownloadPersistentTaskRequestMultiError) Error() string

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

type DownloadPersistentTaskRequestValidationError added in v2.1.86 

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

DownloadPersistentTaskRequestValidationError is the validation error returned by DownloadPersistentTaskRequest.Validate if the designated constraints aren't met.

func (DownloadPersistentTaskRequestValidationError) Cause added in v2.1.86 

func (e DownloadPersistentTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (DownloadPersistentTaskRequestValidationError) Error added in v2.1.86 

func (e DownloadPersistentTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPersistentTaskRequestValidationError) ErrorName added in v2.1.86 

func (e DownloadPersistentTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPersistentTaskRequestValidationError) Field added in v2.1.86 

func (e DownloadPersistentTaskRequestValidationError) Field() string

Field function returns field value.

func (DownloadPersistentTaskRequestValidationError) Key added in v2.1.86 

func (e DownloadPersistentTaskRequestValidationError) Key() bool

Key function returns key value.

func (DownloadPersistentTaskRequestValidationError) Reason added in v2.1.86 

func (e DownloadPersistentTaskRequestValidationError) Reason() string

Reason function returns reason value.

type DownloadPersistentTaskResponse added in v2.1.86 

type DownloadPersistentTaskResponse 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:
	//
	//	*DownloadPersistentTaskResponse_DownloadPersistentTaskStartedResponse
	//	*DownloadPersistentTaskResponse_DownloadPieceFinishedResponse
	Response isDownloadPersistentTaskResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

DownloadPersistentTaskResponse represents response of DownloadPersistentTask.

func (*DownloadPersistentTaskResponse) Descriptor deprecated added in v2.1.86 

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

Deprecated: Use DownloadPersistentTaskResponse.ProtoReflect.Descriptor instead.

func (*DownloadPersistentTaskResponse) GetDownloadPersistentTaskStartedResponse added in v2.1.86 

func (x *DownloadPersistentTaskResponse) GetDownloadPersistentTaskStartedResponse() *DownloadPersistentTaskStartedResponse

func (*DownloadPersistentTaskResponse) GetDownloadPieceFinishedResponse added in v2.1.86 

func (x *DownloadPersistentTaskResponse) GetDownloadPieceFinishedResponse() *DownloadPieceFinishedResponse

func (*DownloadPersistentTaskResponse) GetHostId added in v2.1.86 

func (x *DownloadPersistentTaskResponse) GetHostId() string

func (*DownloadPersistentTaskResponse) GetPeerId added in v2.1.86 

func (x *DownloadPersistentTaskResponse) GetPeerId() string

func (*DownloadPersistentTaskResponse) GetResponse added in v2.1.86 

func (m *DownloadPersistentTaskResponse) GetResponse() isDownloadPersistentTaskResponse_Response

func (*DownloadPersistentTaskResponse) GetTaskId added in v2.1.86 

func (x *DownloadPersistentTaskResponse) GetTaskId() string

func (*DownloadPersistentTaskResponse) ProtoMessage added in v2.1.86 

func (*DownloadPersistentTaskResponse) ProtoMessage()

func (*DownloadPersistentTaskResponse) ProtoReflect added in v2.1.86 

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

func (*DownloadPersistentTaskResponse) Reset added in v2.1.86 

func (x *DownloadPersistentTaskResponse) Reset()

func (*DownloadPersistentTaskResponse) String added in v2.1.86 

func (x *DownloadPersistentTaskResponse) String() string

func (*DownloadPersistentTaskResponse) Validate added in v2.1.86 

func (m *DownloadPersistentTaskResponse) Validate() error

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

func (m *DownloadPersistentTaskResponse) ValidateAll() error

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

type DownloadPersistentTaskResponseMultiError added in v2.1.86 

type DownloadPersistentTaskResponseMultiError []error

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

func (DownloadPersistentTaskResponseMultiError) AllErrors added in v2.1.86 

func (m DownloadPersistentTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPersistentTaskResponseMultiError) Error added in v2.1.86 

func (m DownloadPersistentTaskResponseMultiError) Error() string

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

type DownloadPersistentTaskResponseValidationError added in v2.1.86 

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

DownloadPersistentTaskResponseValidationError is the validation error returned by DownloadPersistentTaskResponse.Validate if the designated constraints aren't met.

func (DownloadPersistentTaskResponseValidationError) Cause added in v2.1.86 

func (e DownloadPersistentTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadPersistentTaskResponseValidationError) Error added in v2.1.86 

func (e DownloadPersistentTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPersistentTaskResponseValidationError) ErrorName added in v2.1.86 

func (e DownloadPersistentTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPersistentTaskResponseValidationError) Field added in v2.1.86 

func (e DownloadPersistentTaskResponseValidationError) Field() string

Field function returns field value.

func (DownloadPersistentTaskResponseValidationError) Key added in v2.1.86 

func (e DownloadPersistentTaskResponseValidationError) Key() bool

Key function returns key value.

func (DownloadPersistentTaskResponseValidationError) Reason added in v2.1.86 

func (e DownloadPersistentTaskResponseValidationError) Reason() string

Reason function returns reason value.

type DownloadPersistentTaskResponse_DownloadPersistentTaskStartedResponse added in v2.1.86 

type DownloadPersistentTaskResponse_DownloadPersistentTaskStartedResponse struct {
	DownloadPersistentTaskStartedResponse *DownloadPersistentTaskStartedResponse `protobuf:"bytes,4,opt,name=download_persistent_task_started_response,json=downloadPersistentTaskStartedResponse,proto3,oneof"`
}

type DownloadPersistentTaskResponse_DownloadPieceFinishedResponse added in v2.1.86 

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

type DownloadPersistentTaskStartedResponse added in v2.1.86 

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

DownloadPersistentTaskStartedResponse represents task download started response of DownloadPersistentTaskResponse.

func (*DownloadPersistentTaskStartedResponse) Descriptor deprecated added in v2.1.86 

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

Deprecated: Use DownloadPersistentTaskStartedResponse.ProtoReflect.Descriptor instead.

func (*DownloadPersistentTaskStartedResponse) GetContentLength added in v2.1.86 

func (x *DownloadPersistentTaskStartedResponse) GetContentLength() uint64

func (*DownloadPersistentTaskStartedResponse) ProtoMessage added in v2.1.86 

func (*DownloadPersistentTaskStartedResponse) ProtoMessage()

func (*DownloadPersistentTaskStartedResponse) ProtoReflect added in v2.1.86 

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

func (*DownloadPersistentTaskStartedResponse) Reset added in v2.1.86 

func (x *DownloadPersistentTaskStartedResponse) Reset()

func (*DownloadPersistentTaskStartedResponse) String added in v2.1.86 

func (x *DownloadPersistentTaskStartedResponse) String() string

func (*DownloadPersistentTaskStartedResponse) Validate added in v2.1.86 

func (m *DownloadPersistentTaskStartedResponse) Validate() error

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

func (m *DownloadPersistentTaskStartedResponse) ValidateAll() error

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

type DownloadPersistentTaskStartedResponseMultiError added in v2.1.86 

type DownloadPersistentTaskStartedResponseMultiError []error

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

func (DownloadPersistentTaskStartedResponseMultiError) AllErrors added in v2.1.86 

func (m DownloadPersistentTaskStartedResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DownloadPersistentTaskStartedResponseMultiError) Error added in v2.1.86 

func (m DownloadPersistentTaskStartedResponseMultiError) Error() string

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

type DownloadPersistentTaskStartedResponseValidationError added in v2.1.86 

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

DownloadPersistentTaskStartedResponseValidationError is the validation error returned by DownloadPersistentTaskStartedResponse.Validate if the designated constraints aren't met.

func (DownloadPersistentTaskStartedResponseValidationError) Cause added in v2.1.86 

func (e DownloadPersistentTaskStartedResponseValidationError) Cause() error

Cause function returns cause value.

func (DownloadPersistentTaskStartedResponseValidationError) Error added in v2.1.86 

func (e DownloadPersistentTaskStartedResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DownloadPersistentTaskStartedResponseValidationError) ErrorName added in v2.1.86 

func (e DownloadPersistentTaskStartedResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DownloadPersistentTaskStartedResponseValidationError) Field added in v2.1.86 

func (e DownloadPersistentTaskStartedResponseValidationError) Field() string

Field function returns field value.

func (DownloadPersistentTaskStartedResponseValidationError) Key added in v2.1.86 

func (e DownloadPersistentTaskStartedResponseValidationError) Key() bool

Key function returns key value.

func (DownloadPersistentTaskStartedResponseValidationError) Reason added in v2.1.86 

func (e DownloadPersistentTaskStartedResponseValidationError) 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 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"`
	// is_finished indicates whether the download task is finished.
	IsFinished bool `protobuf:"varint,5,opt,name=is_finished,json=isFinished,proto3" json:"is_finished,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) GetIsFinished added in v2.1.49 

func (x *DownloadTaskStartedResponse) GetIsFinished() bool

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

type Entry struct {

	// URL of the entry.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// Size of the entry.
	ContentLength uint64 `protobuf:"varint,2,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// Is directory or not.
	IsDir bool `protobuf:"varint,3,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	// contains filtered or unexported fields
}

Entry represents an entry in a directory.

func (*Entry) Descriptor deprecated added in v2.1.41 

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

Deprecated: Use Entry.ProtoReflect.Descriptor instead.

func (*Entry) GetContentLength added in v2.1.41 

func (x *Entry) GetContentLength() uint64

func (*Entry) GetIsDir added in v2.1.41 

func (x *Entry) GetIsDir() bool

func (*Entry) GetUrl added in v2.1.41 

func (x *Entry) GetUrl() string

func (*Entry) ProtoMessage added in v2.1.41 

func (*Entry) ProtoMessage()

func (*Entry) ProtoReflect added in v2.1.41 

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

func (*Entry) Reset added in v2.1.41 

func (x *Entry) Reset()

func (*Entry) String added in v2.1.41 

func (x *Entry) String() string

func (*Entry) Validate added in v2.1.41 

func (m *Entry) Validate() error

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

func (m *Entry) ValidateAll() error

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

type EntryMultiError added in v2.1.41 

type EntryMultiError []error

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

func (EntryMultiError) AllErrors added in v2.1.41 

func (m EntryMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EntryMultiError) Error added in v2.1.41 

func (m EntryMultiError) Error() string

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

type EntryValidationError added in v2.1.41 

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

EntryValidationError is the validation error returned by Entry.Validate if the designated constraints aren't met.

func (EntryValidationError) Cause added in v2.1.41 

func (e EntryValidationError) Cause() error

Cause function returns cause value.

func (EntryValidationError) Error added in v2.1.41 

func (e EntryValidationError) Error() string

Error satisfies the builtin error interface

func (EntryValidationError) ErrorName added in v2.1.41 

func (e EntryValidationError) ErrorName() string

ErrorName returns error name.

func (EntryValidationError) Field added in v2.1.41 

func (e EntryValidationError) Field() string

Field function returns field value.

func (EntryValidationError) Key added in v2.1.41 

func (e EntryValidationError) Key() bool

Key function returns key value.

func (EntryValidationError) Reason added in v2.1.41 

func (e EntryValidationError) Reason() string

Reason function returns reason value.

type ExchangeIBVerbsQueuePairEndpointRequest added in v2.1.34 

type ExchangeIBVerbsQueuePairEndpointRequest struct {

	// Information of the source's queue pair endpoint of IBVerbs.
	Endpoint *IBVerbsQueuePairEndpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

ExchangeIBVerbsQueuePairEndpointRequest represents request of ExchangeIBVerbsQueuePairEndpoint.

func (*ExchangeIBVerbsQueuePairEndpointRequest) Descriptor deprecated added in v2.1.34 

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

Deprecated: Use ExchangeIBVerbsQueuePairEndpointRequest.ProtoReflect.Descriptor instead.

func (*ExchangeIBVerbsQueuePairEndpointRequest) GetEndpoint added in v2.1.34 

func (x *ExchangeIBVerbsQueuePairEndpointRequest) GetEndpoint() *IBVerbsQueuePairEndpoint

func (*ExchangeIBVerbsQueuePairEndpointRequest) ProtoMessage added in v2.1.34 

func (*ExchangeIBVerbsQueuePairEndpointRequest) ProtoMessage()

func (*ExchangeIBVerbsQueuePairEndpointRequest) ProtoReflect added in v2.1.34 

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

func (*ExchangeIBVerbsQueuePairEndpointRequest) Reset added in v2.1.34 

func (x *ExchangeIBVerbsQueuePairEndpointRequest) Reset()

func (*ExchangeIBVerbsQueuePairEndpointRequest) String added in v2.1.34 

func (x *ExchangeIBVerbsQueuePairEndpointRequest) String() string

func (*ExchangeIBVerbsQueuePairEndpointRequest) Validate added in v2.1.34 

func (m *ExchangeIBVerbsQueuePairEndpointRequest) Validate() error

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

func (m *ExchangeIBVerbsQueuePairEndpointRequest) ValidateAll() error

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

type ExchangeIBVerbsQueuePairEndpointRequestMultiError added in v2.1.34 

type ExchangeIBVerbsQueuePairEndpointRequestMultiError []error

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

func (ExchangeIBVerbsQueuePairEndpointRequestMultiError) AllErrors added in v2.1.34 

func (m ExchangeIBVerbsQueuePairEndpointRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExchangeIBVerbsQueuePairEndpointRequestMultiError) Error added in v2.1.34 

func (m ExchangeIBVerbsQueuePairEndpointRequestMultiError) Error() string

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

type ExchangeIBVerbsQueuePairEndpointRequestValidationError added in v2.1.34 

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

ExchangeIBVerbsQueuePairEndpointRequestValidationError is the validation error returned by ExchangeIBVerbsQueuePairEndpointRequest.Validate if the designated constraints aren't met.

func (ExchangeIBVerbsQueuePairEndpointRequestValidationError) Cause added in v2.1.34 

func (e ExchangeIBVerbsQueuePairEndpointRequestValidationError) Cause() error

Cause function returns cause value.

func (ExchangeIBVerbsQueuePairEndpointRequestValidationError) Error added in v2.1.34 

func (e ExchangeIBVerbsQueuePairEndpointRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ExchangeIBVerbsQueuePairEndpointRequestValidationError) ErrorName added in v2.1.34 

func (e ExchangeIBVerbsQueuePairEndpointRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ExchangeIBVerbsQueuePairEndpointRequestValidationError) Field added in v2.1.34 

func (e ExchangeIBVerbsQueuePairEndpointRequestValidationError) Field() string

Field function returns field value.

func (ExchangeIBVerbsQueuePairEndpointRequestValidationError) Key added in v2.1.34 

func (e ExchangeIBVerbsQueuePairEndpointRequestValidationError) Key() bool

Key function returns key value.

func (ExchangeIBVerbsQueuePairEndpointRequestValidationError) Reason added in v2.1.34 

func (e ExchangeIBVerbsQueuePairEndpointRequestValidationError) Reason() string

Reason function returns reason value.

type ExchangeIBVerbsQueuePairEndpointResponse added in v2.1.34 

type ExchangeIBVerbsQueuePairEndpointResponse struct {

	// Information of the destination's queue pair endpoint of IBVerbs.
	Endpoint *IBVerbsQueuePairEndpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

ExchangeIBVerbsQueuePairEndpointResponse represents response of ExchangeIBVerbsQueuePairEndpoint.

func (*ExchangeIBVerbsQueuePairEndpointResponse) Descriptor deprecated added in v2.1.34 

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

Deprecated: Use ExchangeIBVerbsQueuePairEndpointResponse.ProtoReflect.Descriptor instead.

func (*ExchangeIBVerbsQueuePairEndpointResponse) GetEndpoint added in v2.1.34 

func (x *ExchangeIBVerbsQueuePairEndpointResponse) GetEndpoint() *IBVerbsQueuePairEndpoint

func (*ExchangeIBVerbsQueuePairEndpointResponse) ProtoMessage added in v2.1.34 

func (*ExchangeIBVerbsQueuePairEndpointResponse) ProtoMessage()

func (*ExchangeIBVerbsQueuePairEndpointResponse) ProtoReflect added in v2.1.34 

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

func (*ExchangeIBVerbsQueuePairEndpointResponse) Reset added in v2.1.34 

func (x *ExchangeIBVerbsQueuePairEndpointResponse) Reset()

func (*ExchangeIBVerbsQueuePairEndpointResponse) String added in v2.1.34 

func (x *ExchangeIBVerbsQueuePairEndpointResponse) String() string

func (*ExchangeIBVerbsQueuePairEndpointResponse) Validate added in v2.1.34 

func (m *ExchangeIBVerbsQueuePairEndpointResponse) Validate() error

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

func (m *ExchangeIBVerbsQueuePairEndpointResponse) ValidateAll() error

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

type ExchangeIBVerbsQueuePairEndpointResponseMultiError added in v2.1.34 

type ExchangeIBVerbsQueuePairEndpointResponseMultiError []error

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

func (ExchangeIBVerbsQueuePairEndpointResponseMultiError) AllErrors added in v2.1.34 

func (m ExchangeIBVerbsQueuePairEndpointResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExchangeIBVerbsQueuePairEndpointResponseMultiError) Error added in v2.1.34 

func (m ExchangeIBVerbsQueuePairEndpointResponseMultiError) Error() string

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

type ExchangeIBVerbsQueuePairEndpointResponseValidationError added in v2.1.34 

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

ExchangeIBVerbsQueuePairEndpointResponseValidationError is the validation error returned by ExchangeIBVerbsQueuePairEndpointResponse.Validate if the designated constraints aren't met.

func (ExchangeIBVerbsQueuePairEndpointResponseValidationError) Cause added in v2.1.34 

func (e ExchangeIBVerbsQueuePairEndpointResponseValidationError) Cause() error

Cause function returns cause value.

func (ExchangeIBVerbsQueuePairEndpointResponseValidationError) Error added in v2.1.34 

func (e ExchangeIBVerbsQueuePairEndpointResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ExchangeIBVerbsQueuePairEndpointResponseValidationError) ErrorName added in v2.1.34 

func (e ExchangeIBVerbsQueuePairEndpointResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ExchangeIBVerbsQueuePairEndpointResponseValidationError) Field added in v2.1.34 

func (e ExchangeIBVerbsQueuePairEndpointResponseValidationError) Field() string

Field function returns field value.

func (ExchangeIBVerbsQueuePairEndpointResponseValidationError) Key added in v2.1.34 

func (e ExchangeIBVerbsQueuePairEndpointResponseValidationError) Key() bool

Key function returns key value.

func (ExchangeIBVerbsQueuePairEndpointResponseValidationError) Reason added in v2.1.34 

func (e ExchangeIBVerbsQueuePairEndpointResponseValidationError) Reason() string

Reason function returns reason value.

type IBVerbsQueuePairEndpoint added in v2.1.34 

type IBVerbsQueuePairEndpoint struct {

	// Number of the queue pair.
	Num uint32 `protobuf:"varint,1,opt,name=num,proto3" json:"num,omitempty"`
	// Local identifier of the context.
	Lid uint32 `protobuf:"varint,2,opt,name=lid,proto3" json:"lid,omitempty"`
	// Global identifier of the context.
	Gid []byte `protobuf:"bytes,3,opt,name=gid,proto3" json:"gid,omitempty"`
	// contains filtered or unexported fields
}

IBVerbsQueuePairEndpoint represents queue pair endpoint of IBVerbs.

func (*IBVerbsQueuePairEndpoint) Descriptor deprecated added in v2.1.34 

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

Deprecated: Use IBVerbsQueuePairEndpoint.ProtoReflect.Descriptor instead.

func (*IBVerbsQueuePairEndpoint) GetGid added in v2.1.34 

func (x *IBVerbsQueuePairEndpoint) GetGid() []byte

func (*IBVerbsQueuePairEndpoint) GetLid added in v2.1.34 

func (x *IBVerbsQueuePairEndpoint) GetLid() uint32

func (*IBVerbsQueuePairEndpoint) GetNum added in v2.1.34 

func (x *IBVerbsQueuePairEndpoint) GetNum() uint32

func (*IBVerbsQueuePairEndpoint) ProtoMessage added in v2.1.34 

func (*IBVerbsQueuePairEndpoint) ProtoMessage()

func (*IBVerbsQueuePairEndpoint) ProtoReflect added in v2.1.34 

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

func (*IBVerbsQueuePairEndpoint) Reset added in v2.1.34 

func (x *IBVerbsQueuePairEndpoint) Reset()

func (*IBVerbsQueuePairEndpoint) String added in v2.1.34 

func (x *IBVerbsQueuePairEndpoint) String() string

func (*IBVerbsQueuePairEndpoint) Validate added in v2.1.34 

func (m *IBVerbsQueuePairEndpoint) Validate() error

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

func (m *IBVerbsQueuePairEndpoint) ValidateAll() error

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

type IBVerbsQueuePairEndpointMultiError added in v2.1.34 

type IBVerbsQueuePairEndpointMultiError []error

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

func (IBVerbsQueuePairEndpointMultiError) AllErrors added in v2.1.34 

func (m IBVerbsQueuePairEndpointMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (IBVerbsQueuePairEndpointMultiError) Error added in v2.1.34 

func (m IBVerbsQueuePairEndpointMultiError) Error() string

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

type IBVerbsQueuePairEndpointValidationError added in v2.1.34 

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

IBVerbsQueuePairEndpointValidationError is the validation error returned by IBVerbsQueuePairEndpoint.Validate if the designated constraints aren't met.

func (IBVerbsQueuePairEndpointValidationError) Cause added in v2.1.34 

func (e IBVerbsQueuePairEndpointValidationError) Cause() error

Cause function returns cause value.

func (IBVerbsQueuePairEndpointValidationError) Error added in v2.1.34 

func (e IBVerbsQueuePairEndpointValidationError) Error() string

Error satisfies the builtin error interface

func (IBVerbsQueuePairEndpointValidationError) ErrorName added in v2.1.34 

func (e IBVerbsQueuePairEndpointValidationError) ErrorName() string

ErrorName returns error name.

func (IBVerbsQueuePairEndpointValidationError) Field added in v2.1.34 

func (e IBVerbsQueuePairEndpointValidationError) Field() string

Field function returns field value.

func (IBVerbsQueuePairEndpointValidationError) Key added in v2.1.34 

func (e IBVerbsQueuePairEndpointValidationError) Key() bool

Key function returns key value.

func (IBVerbsQueuePairEndpointValidationError) Reason added in v2.1.34 

func (e IBVerbsQueuePairEndpointValidationError) Reason() string

Reason function returns reason value.

type ListLocalPersistentCacheTasksRequest added in v2.2.27 

type ListLocalPersistentCacheTasksRequest struct {

	// Remote IP represents the IP address of the client initiating the list request.
	RemoteIp *string `protobuf:"bytes,1,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,omitempty"`
	// contains filtered or unexported fields
}

ListLocalPersistentCacheTasksRequest represents request of ListLocalPersistentCacheTasks.

func (*ListLocalPersistentCacheTasksRequest) Descriptor deprecated added in v2.2.27 

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

Deprecated: Use ListLocalPersistentCacheTasksRequest.ProtoReflect.Descriptor instead.

func (*ListLocalPersistentCacheTasksRequest) GetRemoteIp added in v2.2.28 

func (x *ListLocalPersistentCacheTasksRequest) GetRemoteIp() string

func (*ListLocalPersistentCacheTasksRequest) ProtoMessage added in v2.2.27 

func (*ListLocalPersistentCacheTasksRequest) ProtoMessage()

func (*ListLocalPersistentCacheTasksRequest) ProtoReflect added in v2.2.27 

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

func (*ListLocalPersistentCacheTasksRequest) Reset added in v2.2.27 

func (x *ListLocalPersistentCacheTasksRequest) Reset()

func (*ListLocalPersistentCacheTasksRequest) String added in v2.2.27 

func (x *ListLocalPersistentCacheTasksRequest) String() string

func (*ListLocalPersistentCacheTasksRequest) Validate added in v2.2.27 

func (m *ListLocalPersistentCacheTasksRequest) Validate() error

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

func (m *ListLocalPersistentCacheTasksRequest) ValidateAll() error

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

type ListLocalPersistentCacheTasksRequestMultiError added in v2.2.27 

type ListLocalPersistentCacheTasksRequestMultiError []error

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

func (ListLocalPersistentCacheTasksRequestMultiError) AllErrors added in v2.2.27 

func (m ListLocalPersistentCacheTasksRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListLocalPersistentCacheTasksRequestMultiError) Error added in v2.2.27 

func (m ListLocalPersistentCacheTasksRequestMultiError) Error() string

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

type ListLocalPersistentCacheTasksRequestValidationError added in v2.2.27 

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

ListLocalPersistentCacheTasksRequestValidationError is the validation error returned by ListLocalPersistentCacheTasksRequest.Validate if the designated constraints aren't met.

func (ListLocalPersistentCacheTasksRequestValidationError) Cause added in v2.2.27 

func (e ListLocalPersistentCacheTasksRequestValidationError) Cause() error

Cause function returns cause value.

func (ListLocalPersistentCacheTasksRequestValidationError) Error added in v2.2.27 

func (e ListLocalPersistentCacheTasksRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ListLocalPersistentCacheTasksRequestValidationError) ErrorName added in v2.2.27 

func (e ListLocalPersistentCacheTasksRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ListLocalPersistentCacheTasksRequestValidationError) Field added in v2.2.27 

func (e ListLocalPersistentCacheTasksRequestValidationError) Field() string

Field function returns field value.

func (ListLocalPersistentCacheTasksRequestValidationError) Key added in v2.2.27 

func (e ListLocalPersistentCacheTasksRequestValidationError) Key() bool

Key function returns key value.

func (ListLocalPersistentCacheTasksRequestValidationError) Reason added in v2.2.27 

func (e ListLocalPersistentCacheTasksRequestValidationError) Reason() string

Reason function returns reason value.

type ListLocalPersistentCacheTasksResponse added in v2.2.27 

type ListLocalPersistentCacheTasksResponse struct {

	// Task ids of the local tasks.
	Tasks []*StatLocalPersistentCacheTaskResponse `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

ListLocalPersistentTasksResponse represents response of ListLocalPersistentTasks.

func (*ListLocalPersistentCacheTasksResponse) Descriptor deprecated added in v2.2.27 

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

Deprecated: Use ListLocalPersistentCacheTasksResponse.ProtoReflect.Descriptor instead.

func (*ListLocalPersistentCacheTasksResponse) GetTasks added in v2.2.27 

func (x *ListLocalPersistentCacheTasksResponse) GetTasks() []*StatLocalPersistentCacheTaskResponse

func (*ListLocalPersistentCacheTasksResponse) ProtoMessage added in v2.2.27 

func (*ListLocalPersistentCacheTasksResponse) ProtoMessage()

func (*ListLocalPersistentCacheTasksResponse) ProtoReflect added in v2.2.27 

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

func (*ListLocalPersistentCacheTasksResponse) Reset added in v2.2.27 

func (x *ListLocalPersistentCacheTasksResponse) Reset()

func (*ListLocalPersistentCacheTasksResponse) String added in v2.2.27 

func (x *ListLocalPersistentCacheTasksResponse) String() string

func (*ListLocalPersistentCacheTasksResponse) Validate added in v2.2.27 

func (m *ListLocalPersistentCacheTasksResponse) Validate() error

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

func (m *ListLocalPersistentCacheTasksResponse) ValidateAll() error

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

type ListLocalPersistentCacheTasksResponseMultiError added in v2.2.27 

type ListLocalPersistentCacheTasksResponseMultiError []error

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

func (ListLocalPersistentCacheTasksResponseMultiError) AllErrors added in v2.2.27 

func (m ListLocalPersistentCacheTasksResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListLocalPersistentCacheTasksResponseMultiError) Error added in v2.2.27 

func (m ListLocalPersistentCacheTasksResponseMultiError) Error() string

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

type ListLocalPersistentCacheTasksResponseValidationError added in v2.2.27 

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

ListLocalPersistentCacheTasksResponseValidationError is the validation error returned by ListLocalPersistentCacheTasksResponse.Validate if the designated constraints aren't met.

func (ListLocalPersistentCacheTasksResponseValidationError) Cause added in v2.2.27 

func (e ListLocalPersistentCacheTasksResponseValidationError) Cause() error

Cause function returns cause value.

func (ListLocalPersistentCacheTasksResponseValidationError) Error added in v2.2.27 

func (e ListLocalPersistentCacheTasksResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ListLocalPersistentCacheTasksResponseValidationError) ErrorName added in v2.2.27 

func (e ListLocalPersistentCacheTasksResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ListLocalPersistentCacheTasksResponseValidationError) Field added in v2.2.27 

func (e ListLocalPersistentCacheTasksResponseValidationError) Field() string

Field function returns field value.

func (ListLocalPersistentCacheTasksResponseValidationError) Key added in v2.2.27 

func (e ListLocalPersistentCacheTasksResponseValidationError) Key() bool

Key function returns key value.

func (ListLocalPersistentCacheTasksResponseValidationError) Reason added in v2.2.27 

func (e ListLocalPersistentCacheTasksResponseValidationError) Reason() string

Reason function returns reason value.

type ListLocalPersistentTasksRequest added in v2.2.27 

type ListLocalPersistentTasksRequest struct {

	// Remote IP represents the IP address of the client initiating the list request.
	RemoteIp *string `protobuf:"bytes,1,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,omitempty"`
	// contains filtered or unexported fields
}

ListLocalPersistentTasksRequest represents request of ListLocalPersistentTasks.

func (*ListLocalPersistentTasksRequest) Descriptor deprecated added in v2.2.27 

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

Deprecated: Use ListLocalPersistentTasksRequest.ProtoReflect.Descriptor instead.

func (*ListLocalPersistentTasksRequest) GetRemoteIp added in v2.2.28 

func (x *ListLocalPersistentTasksRequest) GetRemoteIp() string

func (*ListLocalPersistentTasksRequest) ProtoMessage added in v2.2.27 

func (*ListLocalPersistentTasksRequest) ProtoMessage()

func (*ListLocalPersistentTasksRequest) ProtoReflect added in v2.2.27 

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

func (*ListLocalPersistentTasksRequest) Reset added in v2.2.27 

func (x *ListLocalPersistentTasksRequest) Reset()

func (*ListLocalPersistentTasksRequest) String added in v2.2.27 

func (x *ListLocalPersistentTasksRequest) String() string

func (*ListLocalPersistentTasksRequest) Validate added in v2.2.27 

func (m *ListLocalPersistentTasksRequest) Validate() error

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

func (m *ListLocalPersistentTasksRequest) ValidateAll() error

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

type ListLocalPersistentTasksRequestMultiError added in v2.2.27 

type ListLocalPersistentTasksRequestMultiError []error

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

func (ListLocalPersistentTasksRequestMultiError) AllErrors added in v2.2.27 

func (m ListLocalPersistentTasksRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListLocalPersistentTasksRequestMultiError) Error added in v2.2.27 

func (m ListLocalPersistentTasksRequestMultiError) Error() string

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

type ListLocalPersistentTasksRequestValidationError added in v2.2.27 

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

ListLocalPersistentTasksRequestValidationError is the validation error returned by ListLocalPersistentTasksRequest.Validate if the designated constraints aren't met.

func (ListLocalPersistentTasksRequestValidationError) Cause added in v2.2.27 

func (e ListLocalPersistentTasksRequestValidationError) Cause() error

Cause function returns cause value.

func (ListLocalPersistentTasksRequestValidationError) Error added in v2.2.27 

func (e ListLocalPersistentTasksRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ListLocalPersistentTasksRequestValidationError) ErrorName added in v2.2.27 

func (e ListLocalPersistentTasksRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ListLocalPersistentTasksRequestValidationError) Field added in v2.2.27 

func (e ListLocalPersistentTasksRequestValidationError) Field() string

Field function returns field value.

func (ListLocalPersistentTasksRequestValidationError) Key added in v2.2.27 

func (e ListLocalPersistentTasksRequestValidationError) Key() bool

Key function returns key value.

func (ListLocalPersistentTasksRequestValidationError) Reason added in v2.2.27 

func (e ListLocalPersistentTasksRequestValidationError) Reason() string

Reason function returns reason value.

type ListLocalPersistentTasksResponse added in v2.2.27 

type ListLocalPersistentTasksResponse struct {

	// Task ids of the local tasks.
	Tasks []*StatLocalPersistentTaskResponse `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

ListLocalPersistentTasksResponse represents response of ListLocalPersistentTasks.

func (*ListLocalPersistentTasksResponse) Descriptor deprecated added in v2.2.27 

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

Deprecated: Use ListLocalPersistentTasksResponse.ProtoReflect.Descriptor instead.

func (*ListLocalPersistentTasksResponse) GetTasks added in v2.2.27 

func (x *ListLocalPersistentTasksResponse) GetTasks() []*StatLocalPersistentTaskResponse

func (*ListLocalPersistentTasksResponse) ProtoMessage added in v2.2.27 

func (*ListLocalPersistentTasksResponse) ProtoMessage()

func (*ListLocalPersistentTasksResponse) ProtoReflect added in v2.2.27 

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

func (*ListLocalPersistentTasksResponse) Reset added in v2.2.27 

func (x *ListLocalPersistentTasksResponse) Reset()

func (*ListLocalPersistentTasksResponse) String added in v2.2.27 

func (x *ListLocalPersistentTasksResponse) String() string

func (*ListLocalPersistentTasksResponse) Validate added in v2.2.27 

func (m *ListLocalPersistentTasksResponse) Validate() error

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

func (m *ListLocalPersistentTasksResponse) ValidateAll() error

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

type ListLocalPersistentTasksResponseMultiError added in v2.2.27 

type ListLocalPersistentTasksResponseMultiError []error

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

func (ListLocalPersistentTasksResponseMultiError) AllErrors added in v2.2.27 

func (m ListLocalPersistentTasksResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListLocalPersistentTasksResponseMultiError) Error added in v2.2.27 

func (m ListLocalPersistentTasksResponseMultiError) Error() string

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

type ListLocalPersistentTasksResponseValidationError added in v2.2.27 

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

ListLocalPersistentTasksResponseValidationError is the validation error returned by ListLocalPersistentTasksResponse.Validate if the designated constraints aren't met.

func (ListLocalPersistentTasksResponseValidationError) Cause added in v2.2.27 

func (e ListLocalPersistentTasksResponseValidationError) Cause() error

Cause function returns cause value.

func (ListLocalPersistentTasksResponseValidationError) Error added in v2.2.27 

func (e ListLocalPersistentTasksResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ListLocalPersistentTasksResponseValidationError) ErrorName added in v2.2.27 

func (e ListLocalPersistentTasksResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ListLocalPersistentTasksResponseValidationError) Field added in v2.2.27 

func (e ListLocalPersistentTasksResponseValidationError) Field() string

Field function returns field value.

func (ListLocalPersistentTasksResponseValidationError) Key added in v2.2.27 

func (e ListLocalPersistentTasksResponseValidationError) Key() bool

Key function returns key value.

func (ListLocalPersistentTasksResponseValidationError) Reason added in v2.2.27 

func (e ListLocalPersistentTasksResponseValidationError) Reason() string

Reason function returns reason value.

type ListLocalTasksRequest added in v2.2.27 

type ListLocalTasksRequest struct {

	// Remote IP represents the IP address of the client initiating the list request.
	RemoteIp *string `protobuf:"bytes,1,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,omitempty"`
	// contains filtered or unexported fields
}

ListLocalTasksRequest represents request of ListLocalTasks.

func (*ListLocalTasksRequest) Descriptor deprecated added in v2.2.27 

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

Deprecated: Use ListLocalTasksRequest.ProtoReflect.Descriptor instead.

func (*ListLocalTasksRequest) GetRemoteIp added in v2.2.28 

func (x *ListLocalTasksRequest) GetRemoteIp() string

func (*ListLocalTasksRequest) ProtoMessage added in v2.2.27 

func (*ListLocalTasksRequest) ProtoMessage()

func (*ListLocalTasksRequest) ProtoReflect added in v2.2.27 

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

func (*ListLocalTasksRequest) Reset added in v2.2.27 

func (x *ListLocalTasksRequest) Reset()

func (*ListLocalTasksRequest) String added in v2.2.27 

func (x *ListLocalTasksRequest) String() string

func (*ListLocalTasksRequest) Validate added in v2.2.27 

func (m *ListLocalTasksRequest) Validate() error

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

func (m *ListLocalTasksRequest) ValidateAll() error

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

type ListLocalTasksRequestMultiError added in v2.2.27 

type ListLocalTasksRequestMultiError []error

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

func (ListLocalTasksRequestMultiError) AllErrors added in v2.2.27 

func (m ListLocalTasksRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListLocalTasksRequestMultiError) Error added in v2.2.27 

func (m ListLocalTasksRequestMultiError) Error() string

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

type ListLocalTasksRequestValidationError added in v2.2.27 

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

ListLocalTasksRequestValidationError is the validation error returned by ListLocalTasksRequest.Validate if the designated constraints aren't met.

func (ListLocalTasksRequestValidationError) Cause added in v2.2.27 

func (e ListLocalTasksRequestValidationError) Cause() error

Cause function returns cause value.

func (ListLocalTasksRequestValidationError) Error added in v2.2.27 

func (e ListLocalTasksRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ListLocalTasksRequestValidationError) ErrorName added in v2.2.27 

func (e ListLocalTasksRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ListLocalTasksRequestValidationError) Field added in v2.2.27 

func (e ListLocalTasksRequestValidationError) Field() string

Field function returns field value.

func (ListLocalTasksRequestValidationError) Key added in v2.2.27 

func (e ListLocalTasksRequestValidationError) Key() bool

Key function returns key value.

func (ListLocalTasksRequestValidationError) Reason added in v2.2.27 

func (e ListLocalTasksRequestValidationError) Reason() string

Reason function returns reason value.

type ListLocalTasksResponse added in v2.2.27 

type ListLocalTasksResponse struct {

	// Task ids of the local tasks.
	Tasks []*StatLocalTaskResponse `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

ListLocalTasksResponse represents response of ListLocalTasks.

func (*ListLocalTasksResponse) Descriptor deprecated added in v2.2.27 

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

Deprecated: Use ListLocalTasksResponse.ProtoReflect.Descriptor instead.

func (*ListLocalTasksResponse) GetTasks added in v2.2.27 

func (x *ListLocalTasksResponse) GetTasks() []*StatLocalTaskResponse

func (*ListLocalTasksResponse) ProtoMessage added in v2.2.27 

func (*ListLocalTasksResponse) ProtoMessage()

func (*ListLocalTasksResponse) ProtoReflect added in v2.2.27 

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

func (*ListLocalTasksResponse) Reset added in v2.2.27 

func (x *ListLocalTasksResponse) Reset()

func (*ListLocalTasksResponse) String added in v2.2.27 

func (x *ListLocalTasksResponse) String() string

func (*ListLocalTasksResponse) Validate added in v2.2.27 

func (m *ListLocalTasksResponse) Validate() error

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

func (m *ListLocalTasksResponse) ValidateAll() error

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

type ListLocalTasksResponseMultiError added in v2.2.27 

type ListLocalTasksResponseMultiError []error

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

func (ListLocalTasksResponseMultiError) AllErrors added in v2.2.27 

func (m ListLocalTasksResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListLocalTasksResponseMultiError) Error added in v2.2.27 

func (m ListLocalTasksResponseMultiError) Error() string

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

type ListLocalTasksResponseValidationError added in v2.2.27 

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

ListLocalTasksResponseValidationError is the validation error returned by ListLocalTasksResponse.Validate if the designated constraints aren't met.

func (ListLocalTasksResponseValidationError) Cause added in v2.2.27 

func (e ListLocalTasksResponseValidationError) Cause() error

Cause function returns cause value.

func (ListLocalTasksResponseValidationError) Error added in v2.2.27 

func (e ListLocalTasksResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ListLocalTasksResponseValidationError) ErrorName added in v2.2.27 

func (e ListLocalTasksResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ListLocalTasksResponseValidationError) Field added in v2.2.27 

func (e ListLocalTasksResponseValidationError) Field() string

Field function returns field value.

func (ListLocalTasksResponseValidationError) Key added in v2.2.27 

func (e ListLocalTasksResponseValidationError) Key() bool

Key function returns key value.

func (ListLocalTasksResponseValidationError) Reason added in v2.2.27 

func (e ListLocalTasksResponseValidationError) Reason() string

Reason function returns reason value.

type ListTaskEntriesRequest added in v2.1.41 

type ListTaskEntriesRequest struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// URL to be listed the entries.
	Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// HTTP header to be sent with the request.
	RequestHeader map[string]string `` /* 188-byte string literal not displayed */
	// List timeout.
	Timeout *durationpb.Duration `protobuf:"bytes,4,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
	// certificate_chain is the client certs with DER format for the backend client to list the entries.
	CertificateChain [][]byte `protobuf:"bytes,5,rep,name=certificate_chain,json=certificateChain,proto3" json:"certificate_chain,omitempty"`
	// Object storage protocol information.
	ObjectStorage *v2.ObjectStorage `protobuf:"bytes,6,opt,name=object_storage,json=objectStorage,proto3,oneof" json:"object_storage,omitempty"`
	// HDFS protocol information.
	Hdfs *v2.HDFS `protobuf:"bytes,7,opt,name=hdfs,proto3,oneof" json:"hdfs,omitempty"`
	// Remote IP represents the IP address of the client initiating the list request.
	RemoteIp *string `protobuf:"bytes,8,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,omitempty"`
	// HuggingFace protocol information.
	HuggingFace *v2.HuggingFace `protobuf:"bytes,9,opt,name=hugging_face,json=huggingFace,proto3,oneof" json:"hugging_face,omitempty"`
	// ModelScope protocol information.
	ModelScope *v2.ModelScope `protobuf:"bytes,10,opt,name=model_scope,json=modelScope,proto3,oneof" json:"model_scope,omitempty"`
	// contains filtered or unexported fields
}

ListTaskEntriesRequest represents request of ListTaskEntries.

func (*ListTaskEntriesRequest) Descriptor deprecated added in v2.1.41 

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

Deprecated: Use ListTaskEntriesRequest.ProtoReflect.Descriptor instead.

func (*ListTaskEntriesRequest) GetCertificateChain added in v2.1.41 

func (x *ListTaskEntriesRequest) GetCertificateChain() [][]byte

func (*ListTaskEntriesRequest) GetHdfs added in v2.1.41 

func (x *ListTaskEntriesRequest) GetHdfs() *v2.HDFS

func (*ListTaskEntriesRequest) GetHuggingFace added in v2.2.19 

func (x *ListTaskEntriesRequest) GetHuggingFace() *v2.HuggingFace

func (*ListTaskEntriesRequest) GetModelScope added in v2.2.24 

func (x *ListTaskEntriesRequest) GetModelScope() *v2.ModelScope

func (*ListTaskEntriesRequest) GetObjectStorage added in v2.1.41 

func (x *ListTaskEntriesRequest) GetObjectStorage() *v2.ObjectStorage

func (*ListTaskEntriesRequest) GetRemoteIp added in v2.1.46 

func (x *ListTaskEntriesRequest) GetRemoteIp() string

func (*ListTaskEntriesRequest) GetRequestHeader added in v2.1.41 

func (x *ListTaskEntriesRequest) GetRequestHeader() map[string]string

func (*ListTaskEntriesRequest) GetTaskId added in v2.1.41 

func (x *ListTaskEntriesRequest) GetTaskId() string

func (*ListTaskEntriesRequest) GetTimeout added in v2.1.41 

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

func (*ListTaskEntriesRequest) GetUrl added in v2.1.41 

func (x *ListTaskEntriesRequest) GetUrl() string

func (*ListTaskEntriesRequest) ProtoMessage added in v2.1.41 

func (*ListTaskEntriesRequest) ProtoMessage()

func (*ListTaskEntriesRequest) ProtoReflect added in v2.1.41 

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

func (*ListTaskEntriesRequest) Reset added in v2.1.41 

func (x *ListTaskEntriesRequest) Reset()

func (*ListTaskEntriesRequest) String added in v2.1.41 

func (x *ListTaskEntriesRequest) String() string

func (*ListTaskEntriesRequest) Validate added in v2.1.41 

func (m *ListTaskEntriesRequest) Validate() error

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

func (m *ListTaskEntriesRequest) ValidateAll() error

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

type ListTaskEntriesRequestMultiError added in v2.1.41 

type ListTaskEntriesRequestMultiError []error

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

func (ListTaskEntriesRequestMultiError) AllErrors added in v2.1.41 

func (m ListTaskEntriesRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListTaskEntriesRequestMultiError) Error added in v2.1.41 

func (m ListTaskEntriesRequestMultiError) Error() string

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

type ListTaskEntriesRequestValidationError added in v2.1.41 

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

ListTaskEntriesRequestValidationError is the validation error returned by ListTaskEntriesRequest.Validate if the designated constraints aren't met.

func (ListTaskEntriesRequestValidationError) Cause added in v2.1.41 

func (e ListTaskEntriesRequestValidationError) Cause() error

Cause function returns cause value.

func (ListTaskEntriesRequestValidationError) Error added in v2.1.41 

func (e ListTaskEntriesRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ListTaskEntriesRequestValidationError) ErrorName added in v2.1.41 

func (e ListTaskEntriesRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ListTaskEntriesRequestValidationError) Field added in v2.1.41 

func (e ListTaskEntriesRequestValidationError) Field() string

Field function returns field value.

func (ListTaskEntriesRequestValidationError) Key added in v2.1.41 

func (e ListTaskEntriesRequestValidationError) Key() bool

Key function returns key value.

func (ListTaskEntriesRequestValidationError) Reason added in v2.1.41 

func (e ListTaskEntriesRequestValidationError) Reason() string

Reason function returns reason value.

type ListTaskEntriesResponse added in v2.1.41 

type ListTaskEntriesResponse struct {

	// Content length is the content length of the response
	ContentLength uint64 `protobuf:"varint,1,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// HTTP header to be sent with the request.
	ResponseHeader map[string]string `` /* 191-byte string literal not displayed */
	// Backend HTTP status code.
	StatusCode *int32 `protobuf:"varint,3,opt,name=status_code,json=statusCode,proto3,oneof" json:"status_code,omitempty"`
	// / Entries is the information of the entries in the directory.
	Entries []*Entry `protobuf:"bytes,4,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

ListTaskEntriesResponse represents response of ListTaskEntries.

func (*ListTaskEntriesResponse) Descriptor deprecated added in v2.1.41 

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

Deprecated: Use ListTaskEntriesResponse.ProtoReflect.Descriptor instead.

func (*ListTaskEntriesResponse) GetContentLength added in v2.1.41 

func (x *ListTaskEntriesResponse) GetContentLength() uint64

func (*ListTaskEntriesResponse) GetEntries added in v2.1.41 

func (x *ListTaskEntriesResponse) GetEntries() []*Entry

func (*ListTaskEntriesResponse) GetResponseHeader added in v2.1.41 

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

func (*ListTaskEntriesResponse) GetStatusCode added in v2.1.41 

func (x *ListTaskEntriesResponse) GetStatusCode() int32

func (*ListTaskEntriesResponse) ProtoMessage added in v2.1.41 

func (*ListTaskEntriesResponse) ProtoMessage()

func (*ListTaskEntriesResponse) ProtoReflect added in v2.1.41 

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

func (*ListTaskEntriesResponse) Reset added in v2.1.41 

func (x *ListTaskEntriesResponse) Reset()

func (*ListTaskEntriesResponse) String added in v2.1.41 

func (x *ListTaskEntriesResponse) String() string

func (*ListTaskEntriesResponse) Validate added in v2.1.41 

func (m *ListTaskEntriesResponse) Validate() error

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

func (m *ListTaskEntriesResponse) ValidateAll() error

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

type ListTaskEntriesResponseMultiError added in v2.1.41 

type ListTaskEntriesResponseMultiError []error

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

func (ListTaskEntriesResponseMultiError) AllErrors added in v2.1.41 

func (m ListTaskEntriesResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListTaskEntriesResponseMultiError) Error added in v2.1.41 

func (m ListTaskEntriesResponseMultiError) Error() string

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

type ListTaskEntriesResponseValidationError added in v2.1.41 

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

ListTaskEntriesResponseValidationError is the validation error returned by ListTaskEntriesResponse.Validate if the designated constraints aren't met.

func (ListTaskEntriesResponseValidationError) Cause added in v2.1.41 

func (e ListTaskEntriesResponseValidationError) Cause() error

Cause function returns cause value.

func (ListTaskEntriesResponseValidationError) Error added in v2.1.41 

func (e ListTaskEntriesResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ListTaskEntriesResponseValidationError) ErrorName added in v2.1.41 

func (e ListTaskEntriesResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ListTaskEntriesResponseValidationError) Field added in v2.1.41 

func (e ListTaskEntriesResponseValidationError) Field() string

Field function returns field value.

func (ListTaskEntriesResponseValidationError) Key added in v2.1.41 

func (e ListTaskEntriesResponseValidationError) Key() bool

Key function returns key value.

func (ListTaskEntriesResponseValidationError) Reason added in v2.1.41 

func (e ListTaskEntriesResponseValidationError) 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"`
	// Remote IP represents the IP address of the client initiating the stat request.
	RemoteIp *string `protobuf:"bytes,2,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,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) GetRemoteIp added in v2.1.50 

func (x *StatCacheTaskRequest) GetRemoteIp() string

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

type StatLocalPersistentCacheTaskRequest struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Remote IP represents the IP address of the client initiating the stat request.
	RemoteIp *string `protobuf:"bytes,2,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,omitempty"`
	// contains filtered or unexported fields
}

StatLocalPersistentCacheTaskRequest represents request of StatLocalPersistentCacheTask.

func (*StatLocalPersistentCacheTaskRequest) Descriptor deprecated added in v2.2.27 

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

Deprecated: Use StatLocalPersistentCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*StatLocalPersistentCacheTaskRequest) GetRemoteIp added in v2.2.27 

func (x *StatLocalPersistentCacheTaskRequest) GetRemoteIp() string

func (*StatLocalPersistentCacheTaskRequest) GetTaskId added in v2.2.27 

func (x *StatLocalPersistentCacheTaskRequest) GetTaskId() string

func (*StatLocalPersistentCacheTaskRequest) ProtoMessage added in v2.2.27 

func (*StatLocalPersistentCacheTaskRequest) ProtoMessage()

func (*StatLocalPersistentCacheTaskRequest) ProtoReflect added in v2.2.27 

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

func (*StatLocalPersistentCacheTaskRequest) Reset added in v2.2.27 

func (x *StatLocalPersistentCacheTaskRequest) Reset()

func (*StatLocalPersistentCacheTaskRequest) String added in v2.2.27 

func (x *StatLocalPersistentCacheTaskRequest) String() string

func (*StatLocalPersistentCacheTaskRequest) Validate added in v2.2.27 

func (m *StatLocalPersistentCacheTaskRequest) Validate() error

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

func (m *StatLocalPersistentCacheTaskRequest) ValidateAll() error

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

type StatLocalPersistentCacheTaskRequestMultiError added in v2.2.27 

type StatLocalPersistentCacheTaskRequestMultiError []error

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

func (StatLocalPersistentCacheTaskRequestMultiError) AllErrors added in v2.2.27 

func (m StatLocalPersistentCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatLocalPersistentCacheTaskRequestMultiError) Error added in v2.2.27 

func (m StatLocalPersistentCacheTaskRequestMultiError) Error() string

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

type StatLocalPersistentCacheTaskRequestValidationError added in v2.2.27 

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

StatLocalPersistentCacheTaskRequestValidationError is the validation error returned by StatLocalPersistentCacheTaskRequest.Validate if the designated constraints aren't met.

func (StatLocalPersistentCacheTaskRequestValidationError) Cause added in v2.2.27 

func (e StatLocalPersistentCacheTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (StatLocalPersistentCacheTaskRequestValidationError) Error added in v2.2.27 

func (e StatLocalPersistentCacheTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatLocalPersistentCacheTaskRequestValidationError) ErrorName added in v2.2.27 

func (e StatLocalPersistentCacheTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatLocalPersistentCacheTaskRequestValidationError) Field added in v2.2.27 

func (e StatLocalPersistentCacheTaskRequestValidationError) Field() string

Field function returns field value.

func (StatLocalPersistentCacheTaskRequestValidationError) Key added in v2.2.27 

func (e StatLocalPersistentCacheTaskRequestValidationError) Key() bool

Key function returns key value.

func (StatLocalPersistentCacheTaskRequestValidationError) Reason added in v2.2.27 

func (e StatLocalPersistentCacheTaskRequestValidationError) Reason() string

Reason function returns reason value.

type StatLocalPersistentCacheTaskResponse added in v2.2.27 

type StatLocalPersistentCacheTaskResponse 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 dfdamon runs garbage collection.
	Persistent bool `protobuf:"varint,2,opt,name=persistent,proto3" json:"persistent,omitempty"`
	// TTL of the persistent cache task.
	Ttl *durationpb.Duration `protobuf:"bytes,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// Task piece length.
	PieceLength *uint64 `protobuf:"varint,4,opt,name=piece_length,json=pieceLength,proto3,oneof" json:"piece_length,omitempty"`
	// Task content length.
	ContentLength *uint64 `protobuf:"varint,5,opt,name=content_length,json=contentLength,proto3,oneof" json:"content_length,omitempty"`
	// Uploading count is the count of the task being uploaded by other peers.
	UploadingCount uint64 `protobuf:"varint,6,opt,name=uploading_count,json=uploadingCount,proto3" json:"uploading_count,omitempty"`
	// Uploaded count is the count of the task has been uploaded by other peers.
	UploadedCount uint64 `protobuf:"varint,7,opt,name=uploaded_count,json=uploadedCount,proto3" json:"uploaded_count,omitempty"`
	// Task create time.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Task update time.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// Task fail time.
	FailedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=failed_at,json=failedAt,proto3,oneof" json:"failed_at,omitempty"`
	// Task finish time.
	FinishedAt *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=finished_at,json=finishedAt,proto3,oneof" json:"finished_at,omitempty"`
	// contains filtered or unexported fields
}

StatLocalPersistentTaskResponse represents response of StatLocalPersistentTask.

func (*StatLocalPersistentCacheTaskResponse) Descriptor deprecated added in v2.2.27 

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

Deprecated: Use StatLocalPersistentCacheTaskResponse.ProtoReflect.Descriptor instead.

func (*StatLocalPersistentCacheTaskResponse) GetContentLength added in v2.2.27 

func (x *StatLocalPersistentCacheTaskResponse) GetContentLength() uint64

func (*StatLocalPersistentCacheTaskResponse) GetCreatedAt added in v2.2.27 

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

func (*StatLocalPersistentCacheTaskResponse) GetFailedAt added in v2.2.27 

func (x *StatLocalPersistentCacheTaskResponse) GetFailedAt() *timestamppb.Timestamp

func (*StatLocalPersistentCacheTaskResponse) GetFinishedAt added in v2.2.27 

func (x *StatLocalPersistentCacheTaskResponse) GetFinishedAt() *timestamppb.Timestamp

func (*StatLocalPersistentCacheTaskResponse) GetPersistent added in v2.2.27 

func (x *StatLocalPersistentCacheTaskResponse) GetPersistent() bool

func (*StatLocalPersistentCacheTaskResponse) GetPieceLength added in v2.2.27 

func (x *StatLocalPersistentCacheTaskResponse) GetPieceLength() uint64

func (*StatLocalPersistentCacheTaskResponse) GetTaskId added in v2.2.27 

func (x *StatLocalPersistentCacheTaskResponse) GetTaskId() string

func (*StatLocalPersistentCacheTaskResponse) GetTtl added in v2.2.27 

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

func (*StatLocalPersistentCacheTaskResponse) GetUpdatedAt added in v2.2.27 

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

func (*StatLocalPersistentCacheTaskResponse) GetUploadedCount added in v2.2.27 

func (x *StatLocalPersistentCacheTaskResponse) GetUploadedCount() uint64

func (*StatLocalPersistentCacheTaskResponse) GetUploadingCount added in v2.2.27 

func (x *StatLocalPersistentCacheTaskResponse) GetUploadingCount() uint64

func (*StatLocalPersistentCacheTaskResponse) ProtoMessage added in v2.2.27 

func (*StatLocalPersistentCacheTaskResponse) ProtoMessage()

func (*StatLocalPersistentCacheTaskResponse) ProtoReflect added in v2.2.27 

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

func (*StatLocalPersistentCacheTaskResponse) Reset added in v2.2.27 

func (x *StatLocalPersistentCacheTaskResponse) Reset()

func (*StatLocalPersistentCacheTaskResponse) String added in v2.2.27 

func (x *StatLocalPersistentCacheTaskResponse) String() string

func (*StatLocalPersistentCacheTaskResponse) Validate added in v2.2.27 

func (m *StatLocalPersistentCacheTaskResponse) Validate() error

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

func (m *StatLocalPersistentCacheTaskResponse) ValidateAll() error

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

type StatLocalPersistentCacheTaskResponseMultiError added in v2.2.27 

type StatLocalPersistentCacheTaskResponseMultiError []error

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

func (StatLocalPersistentCacheTaskResponseMultiError) AllErrors added in v2.2.27 

func (m StatLocalPersistentCacheTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatLocalPersistentCacheTaskResponseMultiError) Error added in v2.2.27 

func (m StatLocalPersistentCacheTaskResponseMultiError) Error() string

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

type StatLocalPersistentCacheTaskResponseValidationError added in v2.2.27 

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

StatLocalPersistentCacheTaskResponseValidationError is the validation error returned by StatLocalPersistentCacheTaskResponse.Validate if the designated constraints aren't met.

func (StatLocalPersistentCacheTaskResponseValidationError) Cause added in v2.2.27 

func (e StatLocalPersistentCacheTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (StatLocalPersistentCacheTaskResponseValidationError) Error added in v2.2.27 

func (e StatLocalPersistentCacheTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (StatLocalPersistentCacheTaskResponseValidationError) ErrorName added in v2.2.27 

func (e StatLocalPersistentCacheTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (StatLocalPersistentCacheTaskResponseValidationError) Field added in v2.2.27 

func (e StatLocalPersistentCacheTaskResponseValidationError) Field() string

Field function returns field value.

func (StatLocalPersistentCacheTaskResponseValidationError) Key added in v2.2.27 

func (e StatLocalPersistentCacheTaskResponseValidationError) Key() bool

Key function returns key value.

func (StatLocalPersistentCacheTaskResponseValidationError) Reason added in v2.2.27 

func (e StatLocalPersistentCacheTaskResponseValidationError) Reason() string

Reason function returns reason value.

type StatLocalPersistentTaskRequest added in v2.2.27 

type StatLocalPersistentTaskRequest struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Remote IP represents the IP address of the client initiating the stat request.
	RemoteIp *string `protobuf:"bytes,2,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,omitempty"`
	// contains filtered or unexported fields
}

StatLocalPersistentTaskRequest represents request of StatLocalPersistentTask.

func (*StatLocalPersistentTaskRequest) Descriptor deprecated added in v2.2.27 

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

Deprecated: Use StatLocalPersistentTaskRequest.ProtoReflect.Descriptor instead.

func (*StatLocalPersistentTaskRequest) GetRemoteIp added in v2.2.27 

func (x *StatLocalPersistentTaskRequest) GetRemoteIp() string

func (*StatLocalPersistentTaskRequest) GetTaskId added in v2.2.27 

func (x *StatLocalPersistentTaskRequest) GetTaskId() string

func (*StatLocalPersistentTaskRequest) ProtoMessage added in v2.2.27 

func (*StatLocalPersistentTaskRequest) ProtoMessage()

func (*StatLocalPersistentTaskRequest) ProtoReflect added in v2.2.27 

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

func (*StatLocalPersistentTaskRequest) Reset added in v2.2.27 

func (x *StatLocalPersistentTaskRequest) Reset()

func (*StatLocalPersistentTaskRequest) String added in v2.2.27 

func (x *StatLocalPersistentTaskRequest) String() string

func (*StatLocalPersistentTaskRequest) Validate added in v2.2.27 

func (m *StatLocalPersistentTaskRequest) Validate() error

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

func (m *StatLocalPersistentTaskRequest) ValidateAll() error

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

type StatLocalPersistentTaskRequestMultiError added in v2.2.27 

type StatLocalPersistentTaskRequestMultiError []error

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

func (StatLocalPersistentTaskRequestMultiError) AllErrors added in v2.2.27 

func (m StatLocalPersistentTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatLocalPersistentTaskRequestMultiError) Error added in v2.2.27 

func (m StatLocalPersistentTaskRequestMultiError) Error() string

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

type StatLocalPersistentTaskRequestValidationError added in v2.2.27 

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

StatLocalPersistentTaskRequestValidationError is the validation error returned by StatLocalPersistentTaskRequest.Validate if the designated constraints aren't met.

func (StatLocalPersistentTaskRequestValidationError) Cause added in v2.2.27 

func (e StatLocalPersistentTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (StatLocalPersistentTaskRequestValidationError) Error added in v2.2.27 

func (e StatLocalPersistentTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatLocalPersistentTaskRequestValidationError) ErrorName added in v2.2.27 

func (e StatLocalPersistentTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatLocalPersistentTaskRequestValidationError) Field added in v2.2.27 

func (e StatLocalPersistentTaskRequestValidationError) Field() string

Field function returns field value.

func (StatLocalPersistentTaskRequestValidationError) Key added in v2.2.27 

func (e StatLocalPersistentTaskRequestValidationError) Key() bool

Key function returns key value.

func (StatLocalPersistentTaskRequestValidationError) Reason added in v2.2.27 

func (e StatLocalPersistentTaskRequestValidationError) Reason() string

Reason function returns reason value.

type StatLocalPersistentTaskResponse added in v2.2.27 

type StatLocalPersistentTaskResponse struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Persistent represents whether the persistent task is persistent.
	// If the persistent task is persistent, the persistent peer will
	// not be deleted when dfdamon runs garbage collection.
	Persistent bool `protobuf:"varint,2,opt,name=persistent,proto3" json:"persistent,omitempty"`
	// TTL of the persistent task.
	Ttl *durationpb.Duration `protobuf:"bytes,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// Task piece length.
	PieceLength *uint64 `protobuf:"varint,4,opt,name=piece_length,json=pieceLength,proto3,oneof" json:"piece_length,omitempty"`
	// Task content length.
	ContentLength *uint64 `protobuf:"varint,5,opt,name=content_length,json=contentLength,proto3,oneof" json:"content_length,omitempty"`
	// Uploading count is the count of the task being uploaded by other peers.
	UploadingCount uint64 `protobuf:"varint,6,opt,name=uploading_count,json=uploadingCount,proto3" json:"uploading_count,omitempty"`
	// Uploaded count is the count of the task has been uploaded by other peers.
	UploadedCount uint64 `protobuf:"varint,7,opt,name=uploaded_count,json=uploadedCount,proto3" json:"uploaded_count,omitempty"`
	// Task create time.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Task update time.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// Task fail time.
	FailedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=failed_at,json=failedAt,proto3,oneof" json:"failed_at,omitempty"`
	// Task finish time.
	FinishedAt *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=finished_at,json=finishedAt,proto3,oneof" json:"finished_at,omitempty"`
	// contains filtered or unexported fields
}

StatLocalPersistentTaskResponse represents response of StatLocalPersistentTask.

func (*StatLocalPersistentTaskResponse) Descriptor deprecated added in v2.2.27 

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

Deprecated: Use StatLocalPersistentTaskResponse.ProtoReflect.Descriptor instead.

func (*StatLocalPersistentTaskResponse) GetContentLength added in v2.2.27 

func (x *StatLocalPersistentTaskResponse) GetContentLength() uint64

func (*StatLocalPersistentTaskResponse) GetCreatedAt added in v2.2.27 

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

func (*StatLocalPersistentTaskResponse) GetFailedAt added in v2.2.27 

func (x *StatLocalPersistentTaskResponse) GetFailedAt() *timestamppb.Timestamp

func (*StatLocalPersistentTaskResponse) GetFinishedAt added in v2.2.27 

func (x *StatLocalPersistentTaskResponse) GetFinishedAt() *timestamppb.Timestamp

func (*StatLocalPersistentTaskResponse) GetPersistent added in v2.2.27 

func (x *StatLocalPersistentTaskResponse) GetPersistent() bool

func (*StatLocalPersistentTaskResponse) GetPieceLength added in v2.2.27 

func (x *StatLocalPersistentTaskResponse) GetPieceLength() uint64

func (*StatLocalPersistentTaskResponse) GetTaskId added in v2.2.27 

func (x *StatLocalPersistentTaskResponse) GetTaskId() string

func (*StatLocalPersistentTaskResponse) GetTtl added in v2.2.27 

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

func (*StatLocalPersistentTaskResponse) GetUpdatedAt added in v2.2.27 

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

func (*StatLocalPersistentTaskResponse) GetUploadedCount added in v2.2.27 

func (x *StatLocalPersistentTaskResponse) GetUploadedCount() uint64

func (*StatLocalPersistentTaskResponse) GetUploadingCount added in v2.2.27 

func (x *StatLocalPersistentTaskResponse) GetUploadingCount() uint64

func (*StatLocalPersistentTaskResponse) ProtoMessage added in v2.2.27 

func (*StatLocalPersistentTaskResponse) ProtoMessage()

func (*StatLocalPersistentTaskResponse) ProtoReflect added in v2.2.27 

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

func (*StatLocalPersistentTaskResponse) Reset added in v2.2.27 

func (x *StatLocalPersistentTaskResponse) Reset()

func (*StatLocalPersistentTaskResponse) String added in v2.2.27 

func (x *StatLocalPersistentTaskResponse) String() string

func (*StatLocalPersistentTaskResponse) Validate added in v2.2.27 

func (m *StatLocalPersistentTaskResponse) Validate() error

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

func (m *StatLocalPersistentTaskResponse) ValidateAll() error

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

type StatLocalPersistentTaskResponseMultiError added in v2.2.27 

type StatLocalPersistentTaskResponseMultiError []error

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

func (StatLocalPersistentTaskResponseMultiError) AllErrors added in v2.2.27 

func (m StatLocalPersistentTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatLocalPersistentTaskResponseMultiError) Error added in v2.2.27 

func (m StatLocalPersistentTaskResponseMultiError) Error() string

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

type StatLocalPersistentTaskResponseValidationError added in v2.2.27 

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

StatLocalPersistentTaskResponseValidationError is the validation error returned by StatLocalPersistentTaskResponse.Validate if the designated constraints aren't met.

func (StatLocalPersistentTaskResponseValidationError) Cause added in v2.2.27 

func (e StatLocalPersistentTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (StatLocalPersistentTaskResponseValidationError) Error added in v2.2.27 

func (e StatLocalPersistentTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (StatLocalPersistentTaskResponseValidationError) ErrorName added in v2.2.27 

func (e StatLocalPersistentTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (StatLocalPersistentTaskResponseValidationError) Field added in v2.2.27 

func (e StatLocalPersistentTaskResponseValidationError) Field() string

Field function returns field value.

func (StatLocalPersistentTaskResponseValidationError) Key added in v2.2.27 

func (e StatLocalPersistentTaskResponseValidationError) Key() bool

Key function returns key value.

func (StatLocalPersistentTaskResponseValidationError) Reason added in v2.2.27 

func (e StatLocalPersistentTaskResponseValidationError) Reason() string

Reason function returns reason value.

type StatLocalTaskRequest added in v2.1.93 

type StatLocalTaskRequest struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Remote IP represents the IP address of the client initiating the stat request.
	RemoteIp *string `protobuf:"bytes,2,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,omitempty"`
	// contains filtered or unexported fields
}

StatLocalTaskRequest represents request of StatLocalTask.

func (*StatLocalTaskRequest) Descriptor deprecated added in v2.1.93 

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

Deprecated: Use StatLocalTaskRequest.ProtoReflect.Descriptor instead.

func (*StatLocalTaskRequest) GetRemoteIp added in v2.1.93 

func (x *StatLocalTaskRequest) GetRemoteIp() string

func (*StatLocalTaskRequest) GetTaskId added in v2.1.93 

func (x *StatLocalTaskRequest) GetTaskId() string

func (*StatLocalTaskRequest) ProtoMessage added in v2.1.93 

func (*StatLocalTaskRequest) ProtoMessage()

func (*StatLocalTaskRequest) ProtoReflect added in v2.1.93 

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

func (*StatLocalTaskRequest) Reset added in v2.1.93 

func (x *StatLocalTaskRequest) Reset()

func (*StatLocalTaskRequest) String added in v2.1.93 

func (x *StatLocalTaskRequest) String() string

func (*StatLocalTaskRequest) Validate added in v2.1.93 

func (m *StatLocalTaskRequest) Validate() error

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

func (m *StatLocalTaskRequest) ValidateAll() error

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

type StatLocalTaskRequestMultiError added in v2.1.93 

type StatLocalTaskRequestMultiError []error

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

func (StatLocalTaskRequestMultiError) AllErrors added in v2.1.93 

func (m StatLocalTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatLocalTaskRequestMultiError) Error added in v2.1.93 

func (m StatLocalTaskRequestMultiError) Error() string

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

type StatLocalTaskRequestValidationError added in v2.1.93 

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

StatLocalTaskRequestValidationError is the validation error returned by StatLocalTaskRequest.Validate if the designated constraints aren't met.

func (StatLocalTaskRequestValidationError) Cause added in v2.1.93 

func (e StatLocalTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (StatLocalTaskRequestValidationError) Error added in v2.1.93 

func (e StatLocalTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatLocalTaskRequestValidationError) ErrorName added in v2.1.93 

func (e StatLocalTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatLocalTaskRequestValidationError) Field added in v2.1.93 

func (e StatLocalTaskRequestValidationError) Field() string

Field function returns field value.

func (StatLocalTaskRequestValidationError) Key added in v2.1.93 

func (e StatLocalTaskRequestValidationError) Key() bool

Key function returns key value.

func (StatLocalTaskRequestValidationError) Reason added in v2.1.93 

func (e StatLocalTaskRequestValidationError) Reason() string

Reason function returns reason value.

type StatLocalTaskResponse added in v2.1.94 

type StatLocalTaskResponse struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Task piece length.
	PieceLength *uint64 `protobuf:"varint,2,opt,name=piece_length,json=pieceLength,proto3,oneof" json:"piece_length,omitempty"`
	// Task content length.
	ContentLength *uint64 `protobuf:"varint,3,opt,name=content_length,json=contentLength,proto3,oneof" json:"content_length,omitempty"`
	// Task response headers.
	ResponseHeader map[string]string `` /* 191-byte string literal not displayed */
	// Uploading count is the count of the task being uploaded by other peers.
	UploadingCount uint64 `protobuf:"varint,5,opt,name=uploading_count,json=uploadingCount,proto3" json:"uploading_count,omitempty"`
	// Uploaded count is the count of the task has been uploaded by other peers.
	UploadedCount uint64 `protobuf:"varint,6,opt,name=uploaded_count,json=uploadedCount,proto3" json:"uploaded_count,omitempty"`
	// Task create time.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Task update time.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// Task prefetch time.
	PrefetchedAt *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=prefetched_at,json=prefetchedAt,proto3,oneof" json:"prefetched_at,omitempty"`
	// Task fail time.
	FailedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=failed_at,json=failedAt,proto3,oneof" json:"failed_at,omitempty"`
	// Task finish time.
	FinishedAt *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=finished_at,json=finishedAt,proto3,oneof" json:"finished_at,omitempty"`
	// contains filtered or unexported fields
}

StatLocalTaskResponse represents response of StatLocalTask.

func (*StatLocalTaskResponse) Descriptor deprecated added in v2.1.94 

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

Deprecated: Use StatLocalTaskResponse.ProtoReflect.Descriptor instead.

func (*StatLocalTaskResponse) GetContentLength added in v2.1.94 

func (x *StatLocalTaskResponse) GetContentLength() uint64

func (*StatLocalTaskResponse) GetCreatedAt added in v2.1.94 

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

func (*StatLocalTaskResponse) GetFailedAt added in v2.1.94 

func (x *StatLocalTaskResponse) GetFailedAt() *timestamppb.Timestamp

func (*StatLocalTaskResponse) GetFinishedAt added in v2.1.94 

func (x *StatLocalTaskResponse) GetFinishedAt() *timestamppb.Timestamp

func (*StatLocalTaskResponse) GetPieceLength added in v2.1.94 

func (x *StatLocalTaskResponse) GetPieceLength() uint64

func (*StatLocalTaskResponse) GetPrefetchedAt added in v2.1.94 

func (x *StatLocalTaskResponse) GetPrefetchedAt() *timestamppb.Timestamp

func (*StatLocalTaskResponse) GetResponseHeader added in v2.1.94 

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

func (*StatLocalTaskResponse) GetTaskId added in v2.1.94 

func (x *StatLocalTaskResponse) GetTaskId() string

func (*StatLocalTaskResponse) GetUpdatedAt added in v2.1.94 

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

func (*StatLocalTaskResponse) GetUploadedCount added in v2.1.94 

func (x *StatLocalTaskResponse) GetUploadedCount() uint64

func (*StatLocalTaskResponse) GetUploadingCount added in v2.1.94 

func (x *StatLocalTaskResponse) GetUploadingCount() uint64

func (*StatLocalTaskResponse) ProtoMessage added in v2.1.94 

func (*StatLocalTaskResponse) ProtoMessage()

func (*StatLocalTaskResponse) ProtoReflect added in v2.1.94 

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

func (*StatLocalTaskResponse) Reset added in v2.1.94 

func (x *StatLocalTaskResponse) Reset()

func (*StatLocalTaskResponse) String added in v2.1.94 

func (x *StatLocalTaskResponse) String() string

func (*StatLocalTaskResponse) Validate added in v2.1.94 

func (m *StatLocalTaskResponse) Validate() error

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

func (m *StatLocalTaskResponse) ValidateAll() error

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

type StatLocalTaskResponseMultiError added in v2.1.94 

type StatLocalTaskResponseMultiError []error

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

func (StatLocalTaskResponseMultiError) AllErrors added in v2.1.94 

func (m StatLocalTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatLocalTaskResponseMultiError) Error added in v2.1.94 

func (m StatLocalTaskResponseMultiError) Error() string

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

type StatLocalTaskResponseValidationError added in v2.1.94 

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

StatLocalTaskResponseValidationError is the validation error returned by StatLocalTaskResponse.Validate if the designated constraints aren't met.

func (StatLocalTaskResponseValidationError) Cause added in v2.1.94 

func (e StatLocalTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (StatLocalTaskResponseValidationError) Error added in v2.1.94 

func (e StatLocalTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (StatLocalTaskResponseValidationError) ErrorName added in v2.1.94 

func (e StatLocalTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (StatLocalTaskResponseValidationError) Field added in v2.1.94 

func (e StatLocalTaskResponseValidationError) Field() string

Field function returns field value.

func (StatLocalTaskResponseValidationError) Key added in v2.1.94 

func (e StatLocalTaskResponseValidationError) Key() bool

Key function returns key value.

func (StatLocalTaskResponseValidationError) Reason added in v2.1.94 

func (e StatLocalTaskResponseValidationError) 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"`
	// Remote IP represents the IP address of the client initiating the stat request.
	RemoteIp *string `protobuf:"bytes,2,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,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) GetRemoteIp added in v2.1.45 

func (x *StatPersistentCacheTaskRequest) GetRemoteIp() string

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

type StatPersistentTaskRequest struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Remote IP represents the IP address of the client initiating the stat request.
	RemoteIp *string `protobuf:"bytes,2,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,omitempty"`
	// contains filtered or unexported fields
}

StatPersistentTaskRequest represents request of StatPersistentTask.

func (*StatPersistentTaskRequest) Descriptor deprecated added in v2.1.86 

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

Deprecated: Use StatPersistentTaskRequest.ProtoReflect.Descriptor instead.

func (*StatPersistentTaskRequest) GetRemoteIp added in v2.1.86 

func (x *StatPersistentTaskRequest) GetRemoteIp() string

func (*StatPersistentTaskRequest) GetTaskId added in v2.1.86 

func (x *StatPersistentTaskRequest) GetTaskId() string

func (*StatPersistentTaskRequest) ProtoMessage added in v2.1.86 

func (*StatPersistentTaskRequest) ProtoMessage()

func (*StatPersistentTaskRequest) ProtoReflect added in v2.1.86 

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

func (*StatPersistentTaskRequest) Reset added in v2.1.86 

func (x *StatPersistentTaskRequest) Reset()

func (*StatPersistentTaskRequest) String added in v2.1.86 

func (x *StatPersistentTaskRequest) String() string

func (*StatPersistentTaskRequest) Validate added in v2.1.86 

func (m *StatPersistentTaskRequest) Validate() error

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

func (m *StatPersistentTaskRequest) ValidateAll() error

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

type StatPersistentTaskRequestMultiError added in v2.1.86 

type StatPersistentTaskRequestMultiError []error

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

func (StatPersistentTaskRequestMultiError) AllErrors added in v2.1.86 

func (m StatPersistentTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatPersistentTaskRequestMultiError) Error added in v2.1.86 

func (m StatPersistentTaskRequestMultiError) Error() string

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

type StatPersistentTaskRequestValidationError added in v2.1.86 

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

StatPersistentTaskRequestValidationError is the validation error returned by StatPersistentTaskRequest.Validate if the designated constraints aren't met.

func (StatPersistentTaskRequestValidationError) Cause added in v2.1.86 

func (e StatPersistentTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (StatPersistentTaskRequestValidationError) Error added in v2.1.86 

func (e StatPersistentTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatPersistentTaskRequestValidationError) ErrorName added in v2.1.86 

func (e StatPersistentTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatPersistentTaskRequestValidationError) Field added in v2.1.86 

func (e StatPersistentTaskRequestValidationError) Field() string

Field function returns field value.

func (StatPersistentTaskRequestValidationError) Key added in v2.1.86 

func (e StatPersistentTaskRequestValidationError) Key() bool

Key function returns key value.

func (StatPersistentTaskRequestValidationError) Reason added in v2.1.86 

func (e StatPersistentTaskRequestValidationError) 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"`
	// Remote IP represents the IP address of the client initiating the stat request.
	RemoteIp *string `protobuf:"bytes,2,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,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) GetRemoteIp added in v2.1.46 

func (x *StatTaskRequest) GetRemoteIp() string

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

type SyncCachePiecesRequest 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.
	InterestedCachePieceNumbers []uint32 `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

SyncCachePiecesRequest represents request of SyncCachePieces.

func (*SyncCachePiecesRequest) Descriptor deprecated added in v2.1.50 

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

Deprecated: Use SyncCachePiecesRequest.ProtoReflect.Descriptor instead.

func (*SyncCachePiecesRequest) GetHostId added in v2.1.50 

func (x *SyncCachePiecesRequest) GetHostId() string

func (*SyncCachePiecesRequest) GetInterestedCachePieceNumbers added in v2.1.50 

func (x *SyncCachePiecesRequest) GetInterestedCachePieceNumbers() []uint32

func (*SyncCachePiecesRequest) GetTaskId added in v2.1.50 

func (x *SyncCachePiecesRequest) GetTaskId() string

func (*SyncCachePiecesRequest) ProtoMessage added in v2.1.50 

func (*SyncCachePiecesRequest) ProtoMessage()

func (*SyncCachePiecesRequest) ProtoReflect added in v2.1.50 

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

func (*SyncCachePiecesRequest) Reset added in v2.1.50 

func (x *SyncCachePiecesRequest) Reset()

func (*SyncCachePiecesRequest) String added in v2.1.50 

func (x *SyncCachePiecesRequest) String() string

func (*SyncCachePiecesRequest) Validate added in v2.1.50 

func (m *SyncCachePiecesRequest) Validate() error

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

func (m *SyncCachePiecesRequest) ValidateAll() error

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

type SyncCachePiecesRequestMultiError added in v2.1.50 

type SyncCachePiecesRequestMultiError []error

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

func (SyncCachePiecesRequestMultiError) AllErrors added in v2.1.50 

func (m SyncCachePiecesRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncCachePiecesRequestMultiError) Error added in v2.1.50 

func (m SyncCachePiecesRequestMultiError) Error() string

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

type SyncCachePiecesRequestValidationError added in v2.1.50 

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

SyncCachePiecesRequestValidationError is the validation error returned by SyncCachePiecesRequest.Validate if the designated constraints aren't met.

func (SyncCachePiecesRequestValidationError) Cause added in v2.1.50 

func (e SyncCachePiecesRequestValidationError) Cause() error

Cause function returns cause value.

func (SyncCachePiecesRequestValidationError) Error added in v2.1.50 

func (e SyncCachePiecesRequestValidationError) Error() string

Error satisfies the builtin error interface

func (SyncCachePiecesRequestValidationError) ErrorName added in v2.1.50 

func (e SyncCachePiecesRequestValidationError) ErrorName() string

ErrorName returns error name.

func (SyncCachePiecesRequestValidationError) Field added in v2.1.50 

func (e SyncCachePiecesRequestValidationError) Field() string

Field function returns field value.

func (SyncCachePiecesRequestValidationError) Key added in v2.1.50 

func (e SyncCachePiecesRequestValidationError) Key() bool

Key function returns key value.

func (SyncCachePiecesRequestValidationError) Reason added in v2.1.50 

func (e SyncCachePiecesRequestValidationError) Reason() string

Reason function returns reason value.

type SyncCachePiecesResponse added in v2.1.50 

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

SyncCachePiecesResponse represents response of SyncCachePieces.

func (*SyncCachePiecesResponse) Descriptor deprecated added in v2.1.50 

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

Deprecated: Use SyncCachePiecesResponse.ProtoReflect.Descriptor instead.

func (*SyncCachePiecesResponse) GetLength added in v2.1.50 

func (x *SyncCachePiecesResponse) GetLength() uint64

func (*SyncCachePiecesResponse) GetNumber added in v2.1.50 

func (x *SyncCachePiecesResponse) GetNumber() uint32

func (*SyncCachePiecesResponse) GetOffset added in v2.1.50 

func (x *SyncCachePiecesResponse) GetOffset() uint64

func (*SyncCachePiecesResponse) ProtoMessage added in v2.1.50 

func (*SyncCachePiecesResponse) ProtoMessage()

func (*SyncCachePiecesResponse) ProtoReflect added in v2.1.50 

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

func (*SyncCachePiecesResponse) Reset added in v2.1.50 

func (x *SyncCachePiecesResponse) Reset()

func (*SyncCachePiecesResponse) String added in v2.1.50 

func (x *SyncCachePiecesResponse) String() string

func (*SyncCachePiecesResponse) Validate added in v2.1.50 

func (m *SyncCachePiecesResponse) Validate() error

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

func (m *SyncCachePiecesResponse) ValidateAll() error

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

type SyncCachePiecesResponseMultiError added in v2.1.50 

type SyncCachePiecesResponseMultiError []error

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

func (SyncCachePiecesResponseMultiError) AllErrors added in v2.1.50 

func (m SyncCachePiecesResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncCachePiecesResponseMultiError) Error added in v2.1.50 

func (m SyncCachePiecesResponseMultiError) Error() string

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

type SyncCachePiecesResponseValidationError added in v2.1.50 

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

SyncCachePiecesResponseValidationError is the validation error returned by SyncCachePiecesResponse.Validate if the designated constraints aren't met.

func (SyncCachePiecesResponseValidationError) Cause added in v2.1.50 

func (e SyncCachePiecesResponseValidationError) Cause() error

Cause function returns cause value.

func (SyncCachePiecesResponseValidationError) Error added in v2.1.50 

func (e SyncCachePiecesResponseValidationError) Error() string

Error satisfies the builtin error interface

func (SyncCachePiecesResponseValidationError) ErrorName added in v2.1.50 

func (e SyncCachePiecesResponseValidationError) ErrorName() string

ErrorName returns error name.

func (SyncCachePiecesResponseValidationError) Field added in v2.1.50 

func (e SyncCachePiecesResponseValidationError) Field() string

Field function returns field value.

func (SyncCachePiecesResponseValidationError) Key added in v2.1.50 

func (e SyncCachePiecesResponseValidationError) Key() bool

Key function returns key value.

func (SyncCachePiecesResponseValidationError) Reason added in v2.1.50 

func (e SyncCachePiecesResponseValidationError) Reason() string

Reason function returns reason value.

type SyncHostRequest added in v2.1.1 

type SyncHostRequest struct {

	// Host id.
	HostId string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// Peer id.
	PeerId string `protobuf:"bytes,2,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// contains filtered or unexported fields
}

SyncHostRequest represents request of SyncHost.

func (*SyncHostRequest) Descriptor deprecated added in v2.1.1 

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

Deprecated: Use SyncHostRequest.ProtoReflect.Descriptor instead.

func (*SyncHostRequest) GetHostId added in v2.1.1 

func (x *SyncHostRequest) GetHostId() string

func (*SyncHostRequest) GetPeerId added in v2.1.1 

func (x *SyncHostRequest) GetPeerId() string

func (*SyncHostRequest) ProtoMessage added in v2.1.1 

func (*SyncHostRequest) ProtoMessage()

func (*SyncHostRequest) ProtoReflect added in v2.1.1 

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

func (*SyncHostRequest) Reset added in v2.1.1 

func (x *SyncHostRequest) Reset()

func (*SyncHostRequest) String added in v2.1.1 

func (x *SyncHostRequest) String() string

func (*SyncHostRequest) Validate added in v2.1.1 

func (m *SyncHostRequest) Validate() error

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

func (m *SyncHostRequest) ValidateAll() error

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

type SyncHostRequestMultiError added in v2.1.1 

type SyncHostRequestMultiError []error

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

func (SyncHostRequestMultiError) AllErrors added in v2.1.1 

func (m SyncHostRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncHostRequestMultiError) Error added in v2.1.1 

func (m SyncHostRequestMultiError) Error() string

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

type SyncHostRequestValidationError added in v2.1.1 

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

SyncHostRequestValidationError is the validation error returned by SyncHostRequest.Validate if the designated constraints aren't met.

func (SyncHostRequestValidationError) Cause added in v2.1.1 

func (e SyncHostRequestValidationError) Cause() error

Cause function returns cause value.

func (SyncHostRequestValidationError) Error added in v2.1.1 

func (e SyncHostRequestValidationError) Error() string

Error satisfies the builtin error interface

func (SyncHostRequestValidationError) ErrorName added in v2.1.1 

func (e SyncHostRequestValidationError) ErrorName() string

ErrorName returns error name.

func (SyncHostRequestValidationError) Field added in v2.1.1 

func (e SyncHostRequestValidationError) Field() string

Field function returns field value.

func (SyncHostRequestValidationError) Key added in v2.1.1 

func (e SyncHostRequestValidationError) Key() bool

Key function returns key value.

func (SyncHostRequestValidationError) Reason added in v2.1.1 

func (e SyncHostRequestValidationError) Reason() string

Reason function returns reason value.

type SyncPersistentCachePiecesRequest added in v2.1.10 

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

SyncPersistentCachePiecesRequest represents request of SyncPersistentCachePieces.

func (*SyncPersistentCachePiecesRequest) Descriptor deprecated added in v2.1.10 

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

Deprecated: Use SyncPersistentCachePiecesRequest.ProtoReflect.Descriptor instead.

func (*SyncPersistentCachePiecesRequest) GetHostId added in v2.1.10 

func (x *SyncPersistentCachePiecesRequest) GetHostId() string

func (*SyncPersistentCachePiecesRequest) GetInterestedPieceNumbers added in v2.1.10 

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

func (*SyncPersistentCachePiecesRequest) GetTaskId added in v2.1.10 

func (x *SyncPersistentCachePiecesRequest) GetTaskId() string

func (*SyncPersistentCachePiecesRequest) ProtoMessage added in v2.1.10 

func (*SyncPersistentCachePiecesRequest) ProtoMessage()

func (*SyncPersistentCachePiecesRequest) ProtoReflect added in v2.1.10 

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

func (*SyncPersistentCachePiecesRequest) Reset added in v2.1.10 

func (x *SyncPersistentCachePiecesRequest) Reset()

func (*SyncPersistentCachePiecesRequest) String added in v2.1.10 

func (x *SyncPersistentCachePiecesRequest) String() string

func (*SyncPersistentCachePiecesRequest) Validate added in v2.1.10 

func (m *SyncPersistentCachePiecesRequest) Validate() error

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

func (m *SyncPersistentCachePiecesRequest) ValidateAll() error

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

type SyncPersistentCachePiecesRequestMultiError added in v2.1.10 

type SyncPersistentCachePiecesRequestMultiError []error

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

func (SyncPersistentCachePiecesRequestMultiError) AllErrors added in v2.1.10 

func (m SyncPersistentCachePiecesRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncPersistentCachePiecesRequestMultiError) Error added in v2.1.10 

func (m SyncPersistentCachePiecesRequestMultiError) Error() string

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

type SyncPersistentCachePiecesRequestValidationError added in v2.1.10 

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

SyncPersistentCachePiecesRequestValidationError is the validation error returned by SyncPersistentCachePiecesRequest.Validate if the designated constraints aren't met.

func (SyncPersistentCachePiecesRequestValidationError) Cause added in v2.1.10 

func (e SyncPersistentCachePiecesRequestValidationError) Cause() error

Cause function returns cause value.

func (SyncPersistentCachePiecesRequestValidationError) Error added in v2.1.10 

func (e SyncPersistentCachePiecesRequestValidationError) Error() string

Error satisfies the builtin error interface

func (SyncPersistentCachePiecesRequestValidationError) ErrorName added in v2.1.10 

func (e SyncPersistentCachePiecesRequestValidationError) ErrorName() string

ErrorName returns error name.

func (SyncPersistentCachePiecesRequestValidationError) Field added in v2.1.10 

func (e SyncPersistentCachePiecesRequestValidationError) Field() string

Field function returns field value.

func (SyncPersistentCachePiecesRequestValidationError) Key added in v2.1.10 

func (e SyncPersistentCachePiecesRequestValidationError) Key() bool

Key function returns key value.

func (SyncPersistentCachePiecesRequestValidationError) Reason added in v2.1.10 

func (e SyncPersistentCachePiecesRequestValidationError) Reason() string

Reason function returns reason value.

type SyncPersistentCachePiecesResponse added in v2.1.10 

type SyncPersistentCachePiecesResponse 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"`
	// IP is used to indicate the IP address of the peer. If protocol is rdma,
	// the IP is used to exchange the queue pair endpoint of IBVerbs.
	Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"`
	// TCP port is used to indicate the tcp server port of the peer.
	TcpPort *int32 `protobuf:"varint,5,opt,name=tcp_port,json=tcpPort,proto3,oneof" json:"tcp_port,omitempty"`
	// QUIC port is used to indicate the quic server port of the peer.
	QuicPort *int32 `protobuf:"varint,6,opt,name=quic_port,json=quicPort,proto3,oneof" json:"quic_port,omitempty"`
	// contains filtered or unexported fields
}

SyncPersistentCachePiecesResponse represents response of SyncPersistentCachePieces.

func (*SyncPersistentCachePiecesResponse) Descriptor deprecated added in v2.1.10 

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

Deprecated: Use SyncPersistentCachePiecesResponse.ProtoReflect.Descriptor instead.

func (*SyncPersistentCachePiecesResponse) GetIp added in v2.1.68 

func (x *SyncPersistentCachePiecesResponse) GetIp() string

func (*SyncPersistentCachePiecesResponse) GetLength added in v2.1.10 

func (x *SyncPersistentCachePiecesResponse) GetLength() uint64

func (*SyncPersistentCachePiecesResponse) GetNumber added in v2.1.10 

func (x *SyncPersistentCachePiecesResponse) GetNumber() uint32

func (*SyncPersistentCachePiecesResponse) GetOffset added in v2.1.10 

func (x *SyncPersistentCachePiecesResponse) GetOffset() uint64

func (*SyncPersistentCachePiecesResponse) GetQuicPort added in v2.1.68 

func (x *SyncPersistentCachePiecesResponse) GetQuicPort() int32

func (*SyncPersistentCachePiecesResponse) GetTcpPort added in v2.1.68 

func (x *SyncPersistentCachePiecesResponse) GetTcpPort() int32

func (*SyncPersistentCachePiecesResponse) ProtoMessage added in v2.1.10 

func (*SyncPersistentCachePiecesResponse) ProtoMessage()

func (*SyncPersistentCachePiecesResponse) ProtoReflect added in v2.1.10 

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

func (*SyncPersistentCachePiecesResponse) Reset added in v2.1.10 

func (x *SyncPersistentCachePiecesResponse) Reset()

func (*SyncPersistentCachePiecesResponse) String added in v2.1.10 

func (x *SyncPersistentCachePiecesResponse) String() string

func (*SyncPersistentCachePiecesResponse) Validate added in v2.1.10 

func (m *SyncPersistentCachePiecesResponse) Validate() error

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

func (m *SyncPersistentCachePiecesResponse) ValidateAll() error

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

type SyncPersistentCachePiecesResponseMultiError added in v2.1.10 

type SyncPersistentCachePiecesResponseMultiError []error

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

func (SyncPersistentCachePiecesResponseMultiError) AllErrors added in v2.1.10 

func (m SyncPersistentCachePiecesResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncPersistentCachePiecesResponseMultiError) Error added in v2.1.10 

func (m SyncPersistentCachePiecesResponseMultiError) Error() string

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

type SyncPersistentCachePiecesResponseValidationError added in v2.1.10 

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

SyncPersistentCachePiecesResponseValidationError is the validation error returned by SyncPersistentCachePiecesResponse.Validate if the designated constraints aren't met.

func (SyncPersistentCachePiecesResponseValidationError) Cause added in v2.1.10 

func (e SyncPersistentCachePiecesResponseValidationError) Cause() error

Cause function returns cause value.

func (SyncPersistentCachePiecesResponseValidationError) Error added in v2.1.10 

func (e SyncPersistentCachePiecesResponseValidationError) Error() string

Error satisfies the builtin error interface

func (SyncPersistentCachePiecesResponseValidationError) ErrorName added in v2.1.10 

func (e SyncPersistentCachePiecesResponseValidationError) ErrorName() string

ErrorName returns error name.

func (SyncPersistentCachePiecesResponseValidationError) Field added in v2.1.10 

func (e SyncPersistentCachePiecesResponseValidationError) Field() string

Field function returns field value.

func (SyncPersistentCachePiecesResponseValidationError) Key added in v2.1.10 

func (e SyncPersistentCachePiecesResponseValidationError) Key() bool

Key function returns key value.

func (SyncPersistentCachePiecesResponseValidationError) Reason added in v2.1.10 

func (e SyncPersistentCachePiecesResponseValidationError) Reason() string

Reason function returns reason value.

type SyncPersistentPiecesRequest added in v2.1.86 

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

SyncPersistentPiecesRequest represents request of SyncPersistentPieces.

func (*SyncPersistentPiecesRequest) Descriptor deprecated added in v2.1.86 

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

Deprecated: Use SyncPersistentPiecesRequest.ProtoReflect.Descriptor instead.

func (*SyncPersistentPiecesRequest) GetHostId added in v2.1.86 

func (x *SyncPersistentPiecesRequest) GetHostId() string

func (*SyncPersistentPiecesRequest) GetInterestedPieceNumbers added in v2.1.86 

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

func (*SyncPersistentPiecesRequest) GetTaskId added in v2.1.86 

func (x *SyncPersistentPiecesRequest) GetTaskId() string

func (*SyncPersistentPiecesRequest) ProtoMessage added in v2.1.86 

func (*SyncPersistentPiecesRequest) ProtoMessage()

func (*SyncPersistentPiecesRequest) ProtoReflect added in v2.1.86 

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

func (*SyncPersistentPiecesRequest) Reset added in v2.1.86 

func (x *SyncPersistentPiecesRequest) Reset()

func (*SyncPersistentPiecesRequest) String added in v2.1.86 

func (x *SyncPersistentPiecesRequest) String() string

func (*SyncPersistentPiecesRequest) Validate added in v2.1.86 

func (m *SyncPersistentPiecesRequest) Validate() error

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

func (m *SyncPersistentPiecesRequest) ValidateAll() error

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

type SyncPersistentPiecesRequestMultiError added in v2.1.86 

type SyncPersistentPiecesRequestMultiError []error

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

func (SyncPersistentPiecesRequestMultiError) AllErrors added in v2.1.86 

func (m SyncPersistentPiecesRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncPersistentPiecesRequestMultiError) Error added in v2.1.86 

func (m SyncPersistentPiecesRequestMultiError) Error() string

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

type SyncPersistentPiecesRequestValidationError added in v2.1.86 

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

SyncPersistentPiecesRequestValidationError is the validation error returned by SyncPersistentPiecesRequest.Validate if the designated constraints aren't met.

func (SyncPersistentPiecesRequestValidationError) Cause added in v2.1.86 

func (e SyncPersistentPiecesRequestValidationError) Cause() error

Cause function returns cause value.

func (SyncPersistentPiecesRequestValidationError) Error added in v2.1.86 

func (e SyncPersistentPiecesRequestValidationError) Error() string

Error satisfies the builtin error interface

func (SyncPersistentPiecesRequestValidationError) ErrorName added in v2.1.86 

func (e SyncPersistentPiecesRequestValidationError) ErrorName() string

ErrorName returns error name.

func (SyncPersistentPiecesRequestValidationError) Field added in v2.1.86 

func (e SyncPersistentPiecesRequestValidationError) Field() string

Field function returns field value.

func (SyncPersistentPiecesRequestValidationError) Key added in v2.1.86 

func (e SyncPersistentPiecesRequestValidationError) Key() bool

Key function returns key value.

func (SyncPersistentPiecesRequestValidationError) Reason added in v2.1.86 

func (e SyncPersistentPiecesRequestValidationError) Reason() string

Reason function returns reason value.

type SyncPersistentPiecesResponse added in v2.1.86 

type SyncPersistentPiecesResponse 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"`
	// IP is used to indicate the IP address of the peer. If protocol is rdma,
	// the IP is used to exchange the queue pair endpoint of IBVerbs.
	Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"`
	// TCP port is used to indicate the tcp server port of the peer.
	TcpPort *int32 `protobuf:"varint,5,opt,name=tcp_port,json=tcpPort,proto3,oneof" json:"tcp_port,omitempty"`
	// QUIC port is used to indicate the quic server port of the peer.
	QuicPort *int32 `protobuf:"varint,6,opt,name=quic_port,json=quicPort,proto3,oneof" json:"quic_port,omitempty"`
	// contains filtered or unexported fields
}

SyncPersistentPiecesResponse represents response of SyncPersistentPieces.

func (*SyncPersistentPiecesResponse) Descriptor deprecated added in v2.1.86 

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

Deprecated: Use SyncPersistentPiecesResponse.ProtoReflect.Descriptor instead.

func (*SyncPersistentPiecesResponse) GetIp added in v2.1.86 

func (x *SyncPersistentPiecesResponse) GetIp() string

func (*SyncPersistentPiecesResponse) GetLength added in v2.1.86 

func (x *SyncPersistentPiecesResponse) GetLength() uint64

func (*SyncPersistentPiecesResponse) GetNumber added in v2.1.86 

func (x *SyncPersistentPiecesResponse) GetNumber() uint32

func (*SyncPersistentPiecesResponse) GetOffset added in v2.1.86 

func (x *SyncPersistentPiecesResponse) GetOffset() uint64

func (*SyncPersistentPiecesResponse) GetQuicPort added in v2.1.86 

func (x *SyncPersistentPiecesResponse) GetQuicPort() int32

func (*SyncPersistentPiecesResponse) GetTcpPort added in v2.1.86 

func (x *SyncPersistentPiecesResponse) GetTcpPort() int32

func (*SyncPersistentPiecesResponse) ProtoMessage added in v2.1.86 

func (*SyncPersistentPiecesResponse) ProtoMessage()

func (*SyncPersistentPiecesResponse) ProtoReflect added in v2.1.86 

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

func (*SyncPersistentPiecesResponse) Reset added in v2.1.86 

func (x *SyncPersistentPiecesResponse) Reset()

func (*SyncPersistentPiecesResponse) String added in v2.1.86 

func (x *SyncPersistentPiecesResponse) String() string

func (*SyncPersistentPiecesResponse) Validate added in v2.1.86 

func (m *SyncPersistentPiecesResponse) Validate() error

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

func (m *SyncPersistentPiecesResponse) ValidateAll() error

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

type SyncPersistentPiecesResponseMultiError added in v2.1.86 

type SyncPersistentPiecesResponseMultiError []error

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

func (SyncPersistentPiecesResponseMultiError) AllErrors added in v2.1.86 

func (m SyncPersistentPiecesResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SyncPersistentPiecesResponseMultiError) Error added in v2.1.86 

func (m SyncPersistentPiecesResponseMultiError) Error() string

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

type SyncPersistentPiecesResponseValidationError added in v2.1.86 

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

SyncPersistentPiecesResponseValidationError is the validation error returned by SyncPersistentPiecesResponse.Validate if the designated constraints aren't met.

func (SyncPersistentPiecesResponseValidationError) Cause added in v2.1.86 

func (e SyncPersistentPiecesResponseValidationError) Cause() error

Cause function returns cause value.

func (SyncPersistentPiecesResponseValidationError) Error added in v2.1.86 

func (e SyncPersistentPiecesResponseValidationError) Error() string

Error satisfies the builtin error interface

func (SyncPersistentPiecesResponseValidationError) ErrorName added in v2.1.86 

func (e SyncPersistentPiecesResponseValidationError) ErrorName() string

ErrorName returns error name.

func (SyncPersistentPiecesResponseValidationError) Field added in v2.1.86 

func (e SyncPersistentPiecesResponseValidationError) Field() string

Field function returns field value.

func (SyncPersistentPiecesResponseValidationError) Key added in v2.1.86 

func (e SyncPersistentPiecesResponseValidationError) Key() bool

Key function returns key value.

func (SyncPersistentPiecesResponseValidationError) Reason added in v2.1.86 

func (e SyncPersistentPiecesResponseValidationError) 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"`
	// IP is used to indicate the IP address of the peer. If protocol is rdma,
	// the IP is used to exchange the queue pair endpoint of IBVerbs.
	Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"`
	// TCP port is used to indicate the tcp server port of the peer.
	TcpPort *int32 `protobuf:"varint,5,opt,name=tcp_port,json=tcpPort,proto3,oneof" json:"tcp_port,omitempty"`
	// QUIC port is used to indicate the quic server port of the peer.
	QuicPort *int32 `protobuf:"varint,6,opt,name=quic_port,json=quicPort,proto3,oneof" json:"quic_port,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) GetIp added in v2.1.68 

func (x *SyncPiecesResponse) GetIp() string

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) GetQuicPort added in v2.1.68 

func (x *SyncPiecesResponse) GetQuicPort() int32

func (*SyncPiecesResponse) GetTcpPort added in v2.1.68 

func (x *SyncPiecesResponse) GetTcpPort() int32

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) DeleteLocalTask added in v2.2.27 

func (UnimplementedDfdaemonDownloadServer) DeleteLocalTask(context.Context, *DeleteLocalTaskRequest) (*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) DownloadPersistentCacheTask added in v2.0.161 

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

func (UnimplementedDfdaemonDownloadServer) DownloadPersistentTask added in v2.1.86 

func (UnimplementedDfdaemonDownloadServer) DownloadPersistentTask(*DownloadPersistentTaskRequest, DfdaemonDownload_DownloadPersistentTaskServer) error

func (UnimplementedDfdaemonDownloadServer) DownloadTask added in v2.0.63 

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

func (UnimplementedDfdaemonDownloadServer) ListLocalPersistentCacheTasks added in v2.2.27 

func (UnimplementedDfdaemonDownloadServer) ListLocalPersistentCacheTasks(context.Context, *ListLocalPersistentCacheTasksRequest) (*ListLocalPersistentCacheTasksResponse, error)

func (UnimplementedDfdaemonDownloadServer) ListLocalPersistentTasks added in v2.2.27 

func (UnimplementedDfdaemonDownloadServer) ListLocalPersistentTasks(context.Context, *ListLocalPersistentTasksRequest) (*ListLocalPersistentTasksResponse, error)

func (UnimplementedDfdaemonDownloadServer) ListLocalTasks added in v2.2.27 

func (UnimplementedDfdaemonDownloadServer) ListLocalTasks(context.Context, *ListLocalTasksRequest) (*ListLocalTasksResponse, error)

func (UnimplementedDfdaemonDownloadServer) ListTaskEntries added in v2.1.41 

func (UnimplementedDfdaemonDownloadServer) ListTaskEntries(context.Context, *ListTaskEntriesRequest) (*ListTaskEntriesResponse, error)

func (UnimplementedDfdaemonDownloadServer) StatCacheTask added in v2.0.116 

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

func (UnimplementedDfdaemonDownloadServer) StatLocalPersistentCacheTask added in v2.2.27 

func (UnimplementedDfdaemonDownloadServer) StatLocalPersistentCacheTask(context.Context, *StatLocalPersistentCacheTaskRequest) (*StatLocalPersistentCacheTaskResponse, error)

func (UnimplementedDfdaemonDownloadServer) StatLocalPersistentTask added in v2.2.27 

func (UnimplementedDfdaemonDownloadServer) StatLocalPersistentTask(context.Context, *StatLocalPersistentTaskRequest) (*StatLocalPersistentTaskResponse, error)

func (UnimplementedDfdaemonDownloadServer) StatLocalTask added in v2.1.93 

func (UnimplementedDfdaemonDownloadServer) StatLocalTask(context.Context, *StatLocalTaskRequest) (*StatLocalTaskResponse, error)

func (UnimplementedDfdaemonDownloadServer) StatPersistentCacheTask added in v2.0.161 

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

func (UnimplementedDfdaemonDownloadServer) StatPersistentTask added in v2.2.27 

func (UnimplementedDfdaemonDownloadServer) StatPersistentTask(context.Context, *StatPersistentTaskRequest) (*v2.PersistentTask, 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) UploadPersistentTask added in v2.1.86 

func (UnimplementedDfdaemonDownloadServer) UploadPersistentTask(context.Context, *UploadPersistentTaskRequest) (*v2.PersistentTask, 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) DeletePersistentCacheTask added in v2.0.161 

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

func (UnimplementedDfdaemonUploadServer) DeletePersistentTask added in v2.1.86 

func (UnimplementedDfdaemonUploadServer) DeletePersistentTask(context.Context, *DeletePersistentTaskRequest) (*emptypb.Empty, error)

func (UnimplementedDfdaemonUploadServer) DeleteTask added in v2.0.148 

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

func (UnimplementedDfdaemonUploadServer) DownloadCachePiece added in v2.1.50 

func (UnimplementedDfdaemonUploadServer) DownloadCachePiece(context.Context, *DownloadCachePieceRequest) (*DownloadCachePieceResponse, error)

func (UnimplementedDfdaemonUploadServer) DownloadCacheTask added in v2.0.116 

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

func (UnimplementedDfdaemonUploadServer) DownloadPersistentCacheTask added in v2.0.161 

func (UnimplementedDfdaemonUploadServer) DownloadPersistentCacheTask(*DownloadPersistentCacheTaskRequest, DfdaemonUpload_DownloadPersistentCacheTaskServer) error

func (UnimplementedDfdaemonUploadServer) DownloadPersistentTask added in v2.1.86 

func (UnimplementedDfdaemonUploadServer) DownloadPersistentTask(*DownloadPersistentTaskRequest, DfdaemonUpload_DownloadPersistentTaskServer) error

func (UnimplementedDfdaemonUploadServer) DownloadTask added in v2.0.64 

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

func (UnimplementedDfdaemonUploadServer) ExchangeIBVerbsQueuePairEndpoint added in v2.1.35 

func (UnimplementedDfdaemonUploadServer) ExchangeIBVerbsQueuePairEndpoint(context.Context, *ExchangeIBVerbsQueuePairEndpointRequest) (*ExchangeIBVerbsQueuePairEndpointResponse, error)

func (UnimplementedDfdaemonUploadServer) ListTaskEntries added in v2.1.72 

func (UnimplementedDfdaemonUploadServer) ListTaskEntries(context.Context, *ListTaskEntriesRequest) (*ListTaskEntriesResponse, error)

func (UnimplementedDfdaemonUploadServer) StatCacheTask added in v2.0.116 

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

func (UnimplementedDfdaemonUploadServer) StatLocalTask added in v2.1.93 

func (UnimplementedDfdaemonUploadServer) StatLocalTask(context.Context, *StatLocalTaskRequest) (*StatLocalTaskResponse, error)

func (UnimplementedDfdaemonUploadServer) StatPersistentCacheTask added in v2.0.161 

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

func (UnimplementedDfdaemonUploadServer) StatPersistentTask added in v2.1.86 

func (UnimplementedDfdaemonUploadServer) StatPersistentTask(context.Context, *StatPersistentTaskRequest) (*v2.PersistentTask, error)

func (UnimplementedDfdaemonUploadServer) StatTask added in v2.0.148 

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

func (UnimplementedDfdaemonUploadServer) SyncCachePieces added in v2.1.50 

func (UnimplementedDfdaemonUploadServer) SyncCachePieces(*SyncCachePiecesRequest, DfdaemonUpload_SyncCachePiecesServer) error

func (UnimplementedDfdaemonUploadServer) SyncHost added in v2.1.1 

func (UnimplementedDfdaemonUploadServer) SyncHost(*SyncHostRequest, DfdaemonUpload_SyncHostServer) error

func (UnimplementedDfdaemonUploadServer) SyncPersistentCachePieces added in v2.1.10 

func (UnimplementedDfdaemonUploadServer) SyncPersistentCachePieces(*SyncPersistentCachePiecesRequest, DfdaemonUpload_SyncPersistentCachePiecesServer) error

func (UnimplementedDfdaemonUploadServer) SyncPersistentPieces added in v2.1.86 

func (UnimplementedDfdaemonUploadServer) SyncPersistentPieces(*SyncPersistentPiecesRequest, DfdaemonUpload_SyncPersistentPiecesServer) error

func (UnimplementedDfdaemonUploadServer) SyncPieces added in v2.0.63 

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

func (UnimplementedDfdaemonUploadServer) UpdatePersistentCacheTask added in v2.1.14 

func (UnimplementedDfdaemonUploadServer) UpdatePersistentCacheTask(context.Context, *UpdatePersistentCacheTaskRequest) (*emptypb.Empty, error)

func (UnimplementedDfdaemonUploadServer) UpdatePersistentTask added in v2.1.86 

func (UnimplementedDfdaemonUploadServer) UpdatePersistentTask(context.Context, *UpdatePersistentTaskRequest) (*emptypb.Empty, 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 UpdatePersistentCacheTaskRequest added in v2.1.13 

type UpdatePersistentCacheTaskRequest 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 peer is persistent.
	// If the persistent cache peer is persistent, the persistent cache peer will
	// not be deleted when dfdaemon runs garbage collection. It only be deleted
	// when the task is deleted by the user.
	Persistent bool `protobuf:"varint,2,opt,name=persistent,proto3" json:"persistent,omitempty"`
	// Remote IP represents the IP address of the client initiating the update request.
	RemoteIp *string `protobuf:"bytes,3,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,omitempty"`
	// contains filtered or unexported fields
}

UpdatePersistentCacheTaskRequest represents request of UpdatePersistentCacheTask.

func (*UpdatePersistentCacheTaskRequest) Descriptor deprecated added in v2.1.13 

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

Deprecated: Use UpdatePersistentCacheTaskRequest.ProtoReflect.Descriptor instead.

func (*UpdatePersistentCacheTaskRequest) GetPersistent added in v2.1.13 

func (x *UpdatePersistentCacheTaskRequest) GetPersistent() bool

func (*UpdatePersistentCacheTaskRequest) GetRemoteIp added in v2.1.46 

func (x *UpdatePersistentCacheTaskRequest) GetRemoteIp() string

func (*UpdatePersistentCacheTaskRequest) GetTaskId added in v2.1.13 

func (x *UpdatePersistentCacheTaskRequest) GetTaskId() string

func (*UpdatePersistentCacheTaskRequest) ProtoMessage added in v2.1.13 

func (*UpdatePersistentCacheTaskRequest) ProtoMessage()

func (*UpdatePersistentCacheTaskRequest) ProtoReflect added in v2.1.13 

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

func (*UpdatePersistentCacheTaskRequest) Reset added in v2.1.13 

func (x *UpdatePersistentCacheTaskRequest) Reset()

func (*UpdatePersistentCacheTaskRequest) String added in v2.1.13 

func (x *UpdatePersistentCacheTaskRequest) String() string

func (*UpdatePersistentCacheTaskRequest) Validate added in v2.1.13 

func (m *UpdatePersistentCacheTaskRequest) Validate() error

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

func (m *UpdatePersistentCacheTaskRequest) ValidateAll() error

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

type UpdatePersistentCacheTaskRequestMultiError added in v2.1.13 

type UpdatePersistentCacheTaskRequestMultiError []error

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

func (UpdatePersistentCacheTaskRequestMultiError) AllErrors added in v2.1.13 

func (m UpdatePersistentCacheTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UpdatePersistentCacheTaskRequestMultiError) Error added in v2.1.13 

func (m UpdatePersistentCacheTaskRequestMultiError) Error() string

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

type UpdatePersistentCacheTaskRequestValidationError added in v2.1.13 

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

UpdatePersistentCacheTaskRequestValidationError is the validation error returned by UpdatePersistentCacheTaskRequest.Validate if the designated constraints aren't met.

func (UpdatePersistentCacheTaskRequestValidationError) Cause added in v2.1.13 

func (e UpdatePersistentCacheTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (UpdatePersistentCacheTaskRequestValidationError) Error added in v2.1.13 

func (e UpdatePersistentCacheTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (UpdatePersistentCacheTaskRequestValidationError) ErrorName added in v2.1.13 

func (e UpdatePersistentCacheTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (UpdatePersistentCacheTaskRequestValidationError) Field added in v2.1.13 

func (e UpdatePersistentCacheTaskRequestValidationError) Field() string

Field function returns field value.

func (UpdatePersistentCacheTaskRequestValidationError) Key added in v2.1.13 

func (e UpdatePersistentCacheTaskRequestValidationError) Key() bool

Key function returns key value.

func (UpdatePersistentCacheTaskRequestValidationError) Reason added in v2.1.13 

func (e UpdatePersistentCacheTaskRequestValidationError) Reason() string

Reason function returns reason value.

type UpdatePersistentTaskRequest added in v2.1.86 

type UpdatePersistentTaskRequest struct {

	// Task id.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Persistent represents whether the persistent peer is persistent.
	// If the persistent peer is persistent, the persistent peer will
	// not be deleted when dfdaemon runs garbage collection. It only be deleted
	// when the task is deleted by the user.
	Persistent bool `protobuf:"varint,2,opt,name=persistent,proto3" json:"persistent,omitempty"`
	// Remote IP represents the IP address of the client initiating the list request.
	RemoteIp *string `protobuf:"bytes,3,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,omitempty"`
	// contains filtered or unexported fields
}

UpdatePersistentTaskRequest represents request of UpdatePersistentTask.

func (*UpdatePersistentTaskRequest) Descriptor deprecated added in v2.1.86 

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

Deprecated: Use UpdatePersistentTaskRequest.ProtoReflect.Descriptor instead.

func (*UpdatePersistentTaskRequest) GetPersistent added in v2.1.86 

func (x *UpdatePersistentTaskRequest) GetPersistent() bool

func (*UpdatePersistentTaskRequest) GetRemoteIp added in v2.1.86 

func (x *UpdatePersistentTaskRequest) GetRemoteIp() string

func (*UpdatePersistentTaskRequest) GetTaskId added in v2.1.86 

func (x *UpdatePersistentTaskRequest) GetTaskId() string

func (*UpdatePersistentTaskRequest) ProtoMessage added in v2.1.86 

func (*UpdatePersistentTaskRequest) ProtoMessage()

func (*UpdatePersistentTaskRequest) ProtoReflect added in v2.1.86 

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

func (*UpdatePersistentTaskRequest) Reset added in v2.1.86 

func (x *UpdatePersistentTaskRequest) Reset()

func (*UpdatePersistentTaskRequest) String added in v2.1.86 

func (x *UpdatePersistentTaskRequest) String() string

func (*UpdatePersistentTaskRequest) Validate added in v2.1.86 

func (m *UpdatePersistentTaskRequest) Validate() error

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

func (m *UpdatePersistentTaskRequest) ValidateAll() error

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

type UpdatePersistentTaskRequestMultiError added in v2.1.86 

type UpdatePersistentTaskRequestMultiError []error

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

func (UpdatePersistentTaskRequestMultiError) AllErrors added in v2.1.86 

func (m UpdatePersistentTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UpdatePersistentTaskRequestMultiError) Error added in v2.1.86 

func (m UpdatePersistentTaskRequestMultiError) Error() string

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

type UpdatePersistentTaskRequestValidationError added in v2.1.86 

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

UpdatePersistentTaskRequestValidationError is the validation error returned by UpdatePersistentTaskRequest.Validate if the designated constraints aren't met.

func (UpdatePersistentTaskRequestValidationError) Cause added in v2.1.86 

func (e UpdatePersistentTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (UpdatePersistentTaskRequestValidationError) Error added in v2.1.86 

func (e UpdatePersistentTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (UpdatePersistentTaskRequestValidationError) ErrorName added in v2.1.86 

func (e UpdatePersistentTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (UpdatePersistentTaskRequestValidationError) Field added in v2.1.86 

func (e UpdatePersistentTaskRequestValidationError) Field() string

Field function returns field value.

func (UpdatePersistentTaskRequestValidationError) Key added in v2.1.86 

func (e UpdatePersistentTaskRequestValidationError) Key() bool

Key function returns key value.

func (UpdatePersistentTaskRequestValidationError) Reason added in v2.1.86 

func (e UpdatePersistentTaskRequestValidationError) Reason() string

Reason function returns reason value.

type UploadPersistentCacheTaskRequest added in v2.0.161 

type UploadPersistentCacheTaskRequest struct {

	// content_for_calculating_task_id is the content used to calculate the task id.
	// If content_for_calculating_task_id is set, use its value to calculate the task ID.
	// Otherwise, calculate the task ID based on the file content, tag and application by blake3 algorithm`.
	ContentForCalculatingTaskId *string `` /* 154-byte string literal not displayed */
	// Upload file path of persistent cache task.
	Path string `protobuf:"bytes,2,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,4,opt,name=tag,proto3,oneof" json:"tag,omitempty"`
	// Application of the persistent cache task.
	Application *string `protobuf:"bytes,5,opt,name=application,proto3,oneof" json:"application,omitempty"`
	// Piece length of the persistent cache task, the value needs to be greater than or equal to 4194304(4MiB).
	PieceLength *uint64 `protobuf:"varint,6,opt,name=piece_length,json=pieceLength,proto3,oneof" json:"piece_length,omitempty"`
	// TTL of the persistent cache task.
	Ttl *durationpb.Duration `protobuf:"bytes,7,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// Download timeout.
	Timeout *durationpb.Duration `protobuf:"bytes,8,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
	// Remote IP represents the IP address of the client initiating the upload request.
	RemoteIp *string `protobuf:"bytes,9,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,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) GetContentForCalculatingTaskId added in v2.1.39 

func (x *UploadPersistentCacheTaskRequest) GetContentForCalculatingTaskId() 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) GetPieceLength added in v2.1.28 

func (x *UploadPersistentCacheTaskRequest) GetPieceLength() uint64

func (*UploadPersistentCacheTaskRequest) GetRemoteIp added in v2.1.45 

func (x *UploadPersistentCacheTaskRequest) GetRemoteIp() string

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

type UploadPersistentTaskRequest struct {

	// This is the url of the object storage protocal where the persistent task will be stored,
	// for example: `s3://<bucket>/path`, `gcs://<bucket>/path`. The combination of url,
	// object_storage.endpoint and object_storage.region must be unique, because
	// the persistent task cannot be overwritten once it is uploaded.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// Object storage protocol information.
	ObjectStorage *v2.ObjectStorage `protobuf:"bytes,2,opt,name=object_storage,json=objectStorage,proto3" json:"object_storage,omitempty"`
	// Source file path of the persistent task.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// Replica count of the persistent persistent task.
	PersistentReplicaCount uint64 `` /* 130-byte string literal not displayed */
	// TTL of the persistent task.
	Ttl *durationpb.Duration `protobuf:"bytes,5,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// Download timeout.
	Timeout *durationpb.Duration `protobuf:"bytes,6,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
	// Remote IP represents the IP address of the client initiating the upload request.
	RemoteIp *string `protobuf:"bytes,7,opt,name=remote_ip,json=remoteIp,proto3,oneof" json:"remote_ip,omitempty"`
	// contains filtered or unexported fields
}

UploadPersistentTaskRequest represents request of UploadPersistentTask.

func (*UploadPersistentTaskRequest) Descriptor deprecated added in v2.1.86 

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

Deprecated: Use UploadPersistentTaskRequest.ProtoReflect.Descriptor instead.

func (*UploadPersistentTaskRequest) GetObjectStorage added in v2.1.86 

func (x *UploadPersistentTaskRequest) GetObjectStorage() *v2.ObjectStorage

func (*UploadPersistentTaskRequest) GetPath added in v2.1.86 

func (x *UploadPersistentTaskRequest) GetPath() string

func (*UploadPersistentTaskRequest) GetPersistentReplicaCount added in v2.1.86 

func (x *UploadPersistentTaskRequest) GetPersistentReplicaCount() uint64

func (*UploadPersistentTaskRequest) GetRemoteIp added in v2.1.86 

func (x *UploadPersistentTaskRequest) GetRemoteIp() string

func (*UploadPersistentTaskRequest) GetTimeout added in v2.1.86 

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

func (*UploadPersistentTaskRequest) GetTtl added in v2.1.86 

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

func (*UploadPersistentTaskRequest) GetUrl added in v2.2.0 

func (x *UploadPersistentTaskRequest) GetUrl() string

func (*UploadPersistentTaskRequest) ProtoMessage added in v2.1.86 

func (*UploadPersistentTaskRequest) ProtoMessage()

func (*UploadPersistentTaskRequest) ProtoReflect added in v2.1.86 

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

func (*UploadPersistentTaskRequest) Reset added in v2.1.86 

func (x *UploadPersistentTaskRequest) Reset()

func (*UploadPersistentTaskRequest) String added in v2.1.86 

func (x *UploadPersistentTaskRequest) String() string

func (*UploadPersistentTaskRequest) Validate added in v2.1.86 

func (m *UploadPersistentTaskRequest) Validate() error

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

func (m *UploadPersistentTaskRequest) ValidateAll() error

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

type UploadPersistentTaskRequestMultiError added in v2.1.86 

type UploadPersistentTaskRequestMultiError []error

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

func (UploadPersistentTaskRequestMultiError) AllErrors added in v2.1.86 

func (m UploadPersistentTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UploadPersistentTaskRequestMultiError) Error added in v2.1.86 

func (m UploadPersistentTaskRequestMultiError) Error() string

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

type UploadPersistentTaskRequestValidationError added in v2.1.86 

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

UploadPersistentTaskRequestValidationError is the validation error returned by UploadPersistentTaskRequest.Validate if the designated constraints aren't met.

func (UploadPersistentTaskRequestValidationError) Cause added in v2.1.86 

func (e UploadPersistentTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (UploadPersistentTaskRequestValidationError) Error added in v2.1.86 

func (e UploadPersistentTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (UploadPersistentTaskRequestValidationError) ErrorName added in v2.1.86 

func (e UploadPersistentTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (UploadPersistentTaskRequestValidationError) Field added in v2.1.86 

func (e UploadPersistentTaskRequestValidationError) Field() string

Field function returns field value.

func (UploadPersistentTaskRequestValidationError) Key added in v2.1.86 

func (e UploadPersistentTaskRequestValidationError) Key() bool

Key function returns key value.

func (UploadPersistentTaskRequestValidationError) Reason added in v2.1.86 

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