v2

package
v1.4.2 Latest Latest
Warning

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

Go to latest
Published: Jan 6, 2023 License: Apache-2.0 Imports: 25 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Dfdaemon_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dfdaemon.Dfdaemon",
	HandlerType: (*DfdaemonServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "TriggerTask",
			Handler:    _Dfdaemon_TriggerTask_Handler,
		},
		{
			MethodName: "StatTask",
			Handler:    _Dfdaemon_StatTask_Handler,
		},
		{
			MethodName: "ImportTask",
			Handler:    _Dfdaemon_ImportTask_Handler,
		},
		{
			MethodName: "ExportTask",
			Handler:    _Dfdaemon_ExportTask_Handler,
		},
		{
			MethodName: "DeleteTask",
			Handler:    _Dfdaemon_DeleteTask_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SyncPieces",
			Handler:       _Dfdaemon_SyncPieces_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/apis/dfdaemon/v2/dfdaemon.proto",
}

Dfdaemon_ServiceDesc is the grpc.ServiceDesc for Dfdaemon 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 RegisterDfdaemonServer

func RegisterDfdaemonServer(s grpc.ServiceRegistrar, srv DfdaemonServer)

Types

type DeleteTaskRequest

type DeleteTaskRequest struct {

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

DeleteTaskRequest represents request of DeleteTask.

func (*DeleteTaskRequest) Descriptor deprecated

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

Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskRequest) GetTaskId

func (x *DeleteTaskRequest) GetTaskId() string

func (*DeleteTaskRequest) ProtoMessage

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) ProtoReflect

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

func (*DeleteTaskRequest) Reset

func (x *DeleteTaskRequest) Reset()

func (*DeleteTaskRequest) String

func (x *DeleteTaskRequest) String() string

func (*DeleteTaskRequest) Validate

func (m *DeleteTaskRequest) Validate() error

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

func (*DeleteTaskRequest) ValidateAll

func (m *DeleteTaskRequest) ValidateAll() error

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

type DeleteTaskRequestMultiError

type DeleteTaskRequestMultiError []error

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

func (DeleteTaskRequestMultiError) AllErrors

func (m DeleteTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteTaskRequestMultiError) Error

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

Cause function returns cause value.

func (DeleteTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (DeleteTaskRequestValidationError) ErrorName

ErrorName returns error name.

func (DeleteTaskRequestValidationError) Field

Field function returns field value.

func (DeleteTaskRequestValidationError) Key

Key function returns key value.

func (DeleteTaskRequestValidationError) Reason

Reason function returns reason value.

type DfdaemonClient

type DfdaemonClient interface {
	// SyncPieces syncs pieces from the other peers.
	SyncPieces(ctx context.Context, opts ...grpc.CallOption) (Dfdaemon_SyncPiecesClient, error)
	// TriggerTask triggers task back-to-source download.
	TriggerTask(ctx context.Context, in *TriggerTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// StatTask stats task information.
	StatTask(ctx context.Context, in *StatTaskRequest, opts ...grpc.CallOption) (*v2.Task, error)
	// ImportTask imports task to p2p network.
	ImportTask(ctx context.Context, in *ImportTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// ExportTask exports task from p2p network.
	ExportTask(ctx context.Context, in *ExportTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// DeleteTask deletes task from p2p network.
	DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DfdaemonClient is the client API for Dfdaemon 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 NewDfdaemonClient

func NewDfdaemonClient(cc grpc.ClientConnInterface) DfdaemonClient

type DfdaemonServer

type DfdaemonServer interface {
	// SyncPieces syncs pieces from the other peers.
	SyncPieces(Dfdaemon_SyncPiecesServer) error
	// TriggerTask triggers task back-to-source download.
	TriggerTask(context.Context, *TriggerTaskRequest) (*emptypb.Empty, error)
	// StatTask stats task information.
	StatTask(context.Context, *StatTaskRequest) (*v2.Task, error)
	// ImportTask imports task to p2p network.
	ImportTask(context.Context, *ImportTaskRequest) (*emptypb.Empty, error)
	// ExportTask exports task from p2p network.
	ExportTask(context.Context, *ExportTaskRequest) (*emptypb.Empty, error)
	// DeleteTask deletes task from p2p network.
	DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)
}

DfdaemonServer is the server API for Dfdaemon service. All implementations should embed UnimplementedDfdaemonServer for forward compatibility

type Dfdaemon_SyncPiecesClient

type Dfdaemon_SyncPiecesClient interface {
	Send(*SyncPiecesRequest) error
	Recv() (*SyncPiecesResponse, error)
	grpc.ClientStream
}

type Dfdaemon_SyncPiecesServer

type Dfdaemon_SyncPiecesServer interface {
	Send(*SyncPiecesResponse) error
	Recv() (*SyncPiecesRequest, error)
	grpc.ServerStream
}

type ExportTaskRequest

type ExportTaskRequest struct {

	// Task metadata.
	Metadata *v2.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// File path to be exported.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Download timeout.
	Timeout *durationpb.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Download rate limit in bytes per second.
	DownloadRateLimit float64 `protobuf:"fixed64,4,opt,name=download_rate_limit,json=downloadRateLimit,proto3" json:"download_rate_limit,omitempty"`
	// User id.
	Uid uint64 `protobuf:"varint,5,opt,name=uid,proto3" json:"uid,omitempty"`
	// Group id.
	Gid uint64 `protobuf:"varint,6,opt,name=gid,proto3" json:"gid,omitempty"`
	// contains filtered or unexported fields
}

ExportTaskRequest represents request of ExportTask.

func (*ExportTaskRequest) Descriptor deprecated

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

Deprecated: Use ExportTaskRequest.ProtoReflect.Descriptor instead.

func (*ExportTaskRequest) GetDownloadRateLimit

func (x *ExportTaskRequest) GetDownloadRateLimit() float64

func (*ExportTaskRequest) GetGid

func (x *ExportTaskRequest) GetGid() uint64

func (*ExportTaskRequest) GetMetadata

func (x *ExportTaskRequest) GetMetadata() *v2.Metadata

func (*ExportTaskRequest) GetPath

func (x *ExportTaskRequest) GetPath() string

func (*ExportTaskRequest) GetTimeout

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

func (*ExportTaskRequest) GetUid

func (x *ExportTaskRequest) GetUid() uint64

func (*ExportTaskRequest) ProtoMessage

func (*ExportTaskRequest) ProtoMessage()

func (*ExportTaskRequest) ProtoReflect

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

func (*ExportTaskRequest) Reset

func (x *ExportTaskRequest) Reset()

func (*ExportTaskRequest) String

func (x *ExportTaskRequest) String() string

func (*ExportTaskRequest) Validate

func (m *ExportTaskRequest) Validate() error

Validate checks the field values on ExportTaskRequest 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 (*ExportTaskRequest) ValidateAll

func (m *ExportTaskRequest) ValidateAll() error

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

type ExportTaskRequestMultiError

type ExportTaskRequestMultiError []error

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

func (ExportTaskRequestMultiError) AllErrors

func (m ExportTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExportTaskRequestMultiError) Error

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

type ExportTaskRequestValidationError

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

ExportTaskRequestValidationError is the validation error returned by ExportTaskRequest.Validate if the designated constraints aren't met.

func (ExportTaskRequestValidationError) Cause

Cause function returns cause value.

func (ExportTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (ExportTaskRequestValidationError) ErrorName

ErrorName returns error name.

func (ExportTaskRequestValidationError) Field

Field function returns field value.

func (ExportTaskRequestValidationError) Key

Key function returns key value.

func (ExportTaskRequestValidationError) Reason

Reason function returns reason value.

type ImportTaskRequest

type ImportTaskRequest struct {

	// Task metadata.
	Metadata *v2.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// File path to be imported.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

ImportTaskRequest represents request of ImportTask.

func (*ImportTaskRequest) Descriptor deprecated

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

Deprecated: Use ImportTaskRequest.ProtoReflect.Descriptor instead.

func (*ImportTaskRequest) GetMetadata

func (x *ImportTaskRequest) GetMetadata() *v2.Metadata

func (*ImportTaskRequest) GetPath

func (x *ImportTaskRequest) GetPath() string

func (*ImportTaskRequest) ProtoMessage

func (*ImportTaskRequest) ProtoMessage()

func (*ImportTaskRequest) ProtoReflect

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

func (*ImportTaskRequest) Reset

func (x *ImportTaskRequest) Reset()

func (*ImportTaskRequest) String

func (x *ImportTaskRequest) String() string

func (*ImportTaskRequest) Validate

func (m *ImportTaskRequest) Validate() error

Validate checks the field values on ImportTaskRequest 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 (*ImportTaskRequest) ValidateAll

func (m *ImportTaskRequest) ValidateAll() error

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

type ImportTaskRequestMultiError

type ImportTaskRequestMultiError []error

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

func (ImportTaskRequestMultiError) AllErrors

func (m ImportTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ImportTaskRequestMultiError) Error

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

type ImportTaskRequestValidationError

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

ImportTaskRequestValidationError is the validation error returned by ImportTaskRequest.Validate if the designated constraints aren't met.

func (ImportTaskRequestValidationError) Cause

Cause function returns cause value.

func (ImportTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (ImportTaskRequestValidationError) ErrorName

ErrorName returns error name.

func (ImportTaskRequestValidationError) Field

Field function returns field value.

func (ImportTaskRequestValidationError) Key

Key function returns key value.

func (ImportTaskRequestValidationError) Reason

Reason function returns reason value.

type InterestedAllPiecesRequest

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

InterestedAllPiecesRequest represents interested all pieces request of SyncPiecesRequest.

func (*InterestedAllPiecesRequest) Descriptor deprecated

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

Deprecated: Use InterestedAllPiecesRequest.ProtoReflect.Descriptor instead.

func (*InterestedAllPiecesRequest) ProtoMessage

func (*InterestedAllPiecesRequest) ProtoMessage()

func (*InterestedAllPiecesRequest) ProtoReflect

func (*InterestedAllPiecesRequest) Reset

func (x *InterestedAllPiecesRequest) Reset()

func (*InterestedAllPiecesRequest) String

func (x *InterestedAllPiecesRequest) String() string

func (*InterestedAllPiecesRequest) Validate

func (m *InterestedAllPiecesRequest) Validate() error

Validate checks the field values on InterestedAllPiecesRequest 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 (*InterestedAllPiecesRequest) ValidateAll

func (m *InterestedAllPiecesRequest) ValidateAll() error

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

type InterestedAllPiecesRequestMultiError

type InterestedAllPiecesRequestMultiError []error

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

func (InterestedAllPiecesRequestMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (InterestedAllPiecesRequestMultiError) Error

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

type InterestedAllPiecesRequestValidationError

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

InterestedAllPiecesRequestValidationError is the validation error returned by InterestedAllPiecesRequest.Validate if the designated constraints aren't met.

func (InterestedAllPiecesRequestValidationError) Cause

Cause function returns cause value.

func (InterestedAllPiecesRequestValidationError) Error

Error satisfies the builtin error interface

func (InterestedAllPiecesRequestValidationError) ErrorName

ErrorName returns error name.

func (InterestedAllPiecesRequestValidationError) Field

Field function returns field value.

func (InterestedAllPiecesRequestValidationError) Key

Key function returns key value.

func (InterestedAllPiecesRequestValidationError) Reason

Reason function returns reason value.

type InterestedPiecesRequest

type InterestedPiecesRequest struct {

	// Interested piece numbers.
	PieceNumbers []uint32 `protobuf:"varint,1,rep,packed,name=piece_numbers,json=pieceNumbers,proto3" json:"piece_numbers,omitempty"`
	// contains filtered or unexported fields
}

InterestedPiecesRequest represents interested pieces request of SyncPiecesRequest.

func (*InterestedPiecesRequest) Descriptor deprecated

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

Deprecated: Use InterestedPiecesRequest.ProtoReflect.Descriptor instead.

func (*InterestedPiecesRequest) GetPieceNumbers

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

func (*InterestedPiecesRequest) ProtoMessage

func (*InterestedPiecesRequest) ProtoMessage()

func (*InterestedPiecesRequest) ProtoReflect

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

func (*InterestedPiecesRequest) Reset

func (x *InterestedPiecesRequest) Reset()

func (*InterestedPiecesRequest) String

func (x *InterestedPiecesRequest) String() string

func (*InterestedPiecesRequest) Validate

func (m *InterestedPiecesRequest) Validate() error

Validate checks the field values on InterestedPiecesRequest 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 (*InterestedPiecesRequest) ValidateAll

func (m *InterestedPiecesRequest) ValidateAll() error

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

type InterestedPiecesRequestMultiError

type InterestedPiecesRequestMultiError []error

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

func (InterestedPiecesRequestMultiError) AllErrors

func (m InterestedPiecesRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (InterestedPiecesRequestMultiError) Error

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

type InterestedPiecesRequestValidationError

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

InterestedPiecesRequestValidationError is the validation error returned by InterestedPiecesRequest.Validate if the designated constraints aren't met.

func (InterestedPiecesRequestValidationError) Cause

Cause function returns cause value.

func (InterestedPiecesRequestValidationError) Error

Error satisfies the builtin error interface

func (InterestedPiecesRequestValidationError) ErrorName

ErrorName returns error name.

func (InterestedPiecesRequestValidationError) Field

Field function returns field value.

func (InterestedPiecesRequestValidationError) Key

Key function returns key value.

func (InterestedPiecesRequestValidationError) Reason

Reason function returns reason value.

type InterestedPiecesResponse

type InterestedPiecesResponse struct {

	// Interested pieces of task.
	Pieces []*v2.Piece `protobuf:"bytes,1,rep,name=pieces,proto3" json:"pieces,omitempty"`
	// contains filtered or unexported fields
}

InterestedPiecesResponse represents interested pieces response of SyncPiecesResponse.

func (*InterestedPiecesResponse) Descriptor deprecated

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

Deprecated: Use InterestedPiecesResponse.ProtoReflect.Descriptor instead.

func (*InterestedPiecesResponse) GetPieces

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

func (*InterestedPiecesResponse) ProtoMessage

func (*InterestedPiecesResponse) ProtoMessage()

func (*InterestedPiecesResponse) ProtoReflect

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

func (*InterestedPiecesResponse) Reset

func (x *InterestedPiecesResponse) Reset()

func (*InterestedPiecesResponse) String

func (x *InterestedPiecesResponse) String() string

func (*InterestedPiecesResponse) Validate

func (m *InterestedPiecesResponse) Validate() error

Validate checks the field values on InterestedPiecesResponse 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 (*InterestedPiecesResponse) ValidateAll

func (m *InterestedPiecesResponse) ValidateAll() error

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

type InterestedPiecesResponseMultiError

type InterestedPiecesResponseMultiError []error

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

func (InterestedPiecesResponseMultiError) AllErrors

func (m InterestedPiecesResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (InterestedPiecesResponseMultiError) Error

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

type InterestedPiecesResponseValidationError

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

InterestedPiecesResponseValidationError is the validation error returned by InterestedPiecesResponse.Validate if the designated constraints aren't met.

func (InterestedPiecesResponseValidationError) Cause

Cause function returns cause value.

func (InterestedPiecesResponseValidationError) Error

Error satisfies the builtin error interface

func (InterestedPiecesResponseValidationError) ErrorName

ErrorName returns error name.

func (InterestedPiecesResponseValidationError) Field

Field function returns field value.

func (InterestedPiecesResponseValidationError) Key

Key function returns key value.

func (InterestedPiecesResponseValidationError) Reason

Reason function returns reason value.

type StatMetadataRequest

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

StatMetadata represents stat metadata request of SyncPiecesRequest.

func (*StatMetadataRequest) Descriptor deprecated

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

Deprecated: Use StatMetadataRequest.ProtoReflect.Descriptor instead.

func (*StatMetadataRequest) ProtoMessage

func (*StatMetadataRequest) ProtoMessage()

func (*StatMetadataRequest) ProtoReflect

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

func (*StatMetadataRequest) Reset

func (x *StatMetadataRequest) Reset()

func (*StatMetadataRequest) String

func (x *StatMetadataRequest) String() string

func (*StatMetadataRequest) Validate

func (m *StatMetadataRequest) Validate() error

Validate checks the field values on StatMetadataRequest 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 (*StatMetadataRequest) ValidateAll

func (m *StatMetadataRequest) ValidateAll() error

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

type StatMetadataRequestMultiError

type StatMetadataRequestMultiError []error

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

func (StatMetadataRequestMultiError) AllErrors

func (m StatMetadataRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatMetadataRequestMultiError) Error

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

type StatMetadataRequestValidationError

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

StatMetadataRequestValidationError is the validation error returned by StatMetadataRequest.Validate if the designated constraints aren't met.

func (StatMetadataRequestValidationError) Cause

Cause function returns cause value.

func (StatMetadataRequestValidationError) Error

Error satisfies the builtin error interface

func (StatMetadataRequestValidationError) ErrorName

ErrorName returns error name.

func (StatMetadataRequestValidationError) Field

Field function returns field value.

func (StatMetadataRequestValidationError) Key

Key function returns key value.

func (StatMetadataRequestValidationError) Reason

Reason function returns reason value.

type StatMetadataResponse

type StatMetadataResponse struct {

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

StatMetadata represents stat metadata request of SyncPiecesResponse.

func (*StatMetadataResponse) Descriptor deprecated

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

Deprecated: Use StatMetadataResponse.ProtoReflect.Descriptor instead.

func (*StatMetadataResponse) GetMetadata

func (x *StatMetadataResponse) GetMetadata() *v2.Metadata

func (*StatMetadataResponse) ProtoMessage

func (*StatMetadataResponse) ProtoMessage()

func (*StatMetadataResponse) ProtoReflect

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

func (*StatMetadataResponse) Reset

func (x *StatMetadataResponse) Reset()

func (*StatMetadataResponse) String

func (x *StatMetadataResponse) String() string

func (*StatMetadataResponse) Validate

func (m *StatMetadataResponse) Validate() error

Validate checks the field values on StatMetadataResponse 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 (*StatMetadataResponse) ValidateAll

func (m *StatMetadataResponse) ValidateAll() error

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

type StatMetadataResponseMultiError

type StatMetadataResponseMultiError []error

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

func (StatMetadataResponseMultiError) AllErrors

func (m StatMetadataResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatMetadataResponseMultiError) Error

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

type StatMetadataResponseValidationError

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

StatMetadataResponseValidationError is the validation error returned by StatMetadataResponse.Validate if the designated constraints aren't met.

func (StatMetadataResponseValidationError) Cause

Cause function returns cause value.

func (StatMetadataResponseValidationError) Error

Error satisfies the builtin error interface

func (StatMetadataResponseValidationError) ErrorName

ErrorName returns error name.

func (StatMetadataResponseValidationError) Field

Field function returns field value.

func (StatMetadataResponseValidationError) Key

Key function returns key value.

func (StatMetadataResponseValidationError) Reason

Reason function returns reason value.

type StatTaskRequest

type StatTaskRequest struct {

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

StatTaskRequest represents request of StatTask.

func (*StatTaskRequest) Descriptor deprecated

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

Deprecated: Use StatTaskRequest.ProtoReflect.Descriptor instead.

func (*StatTaskRequest) GetTaskId

func (x *StatTaskRequest) GetTaskId() string

func (*StatTaskRequest) ProtoMessage

func (*StatTaskRequest) ProtoMessage()

func (*StatTaskRequest) ProtoReflect

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

func (*StatTaskRequest) Reset

func (x *StatTaskRequest) Reset()

func (*StatTaskRequest) String

func (x *StatTaskRequest) String() string

func (*StatTaskRequest) Validate

func (m *StatTaskRequest) Validate() error

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

func (*StatTaskRequest) ValidateAll

func (m *StatTaskRequest) ValidateAll() error

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

type StatTaskRequestMultiError

type StatTaskRequestMultiError []error

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

func (StatTaskRequestMultiError) AllErrors

func (m StatTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatTaskRequestMultiError) Error

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

Cause function returns cause value.

func (StatTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (StatTaskRequestValidationError) ErrorName

func (e StatTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatTaskRequestValidationError) Field

Field function returns field value.

func (StatTaskRequestValidationError) Key

Key function returns key value.

func (StatTaskRequestValidationError) Reason

Reason function returns reason value.

type StatTaskResponse

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

StatTaskResponse represents response of StatTask.

func (*StatTaskResponse) Descriptor deprecated

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

Deprecated: Use StatTaskResponse.ProtoReflect.Descriptor instead.

func (*StatTaskResponse) GetTask

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

func (*StatTaskResponse) ProtoMessage

func (*StatTaskResponse) ProtoMessage()

func (*StatTaskResponse) ProtoReflect

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

func (*StatTaskResponse) Reset

func (x *StatTaskResponse) Reset()

func (*StatTaskResponse) String

func (x *StatTaskResponse) String() string

func (*StatTaskResponse) Validate

func (m *StatTaskResponse) Validate() error

Validate checks the field values on StatTaskResponse 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 (*StatTaskResponse) ValidateAll

func (m *StatTaskResponse) ValidateAll() error

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

type StatTaskResponseMultiError

type StatTaskResponseMultiError []error

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

func (StatTaskResponseMultiError) AllErrors

func (m StatTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatTaskResponseMultiError) Error

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

type StatTaskResponseValidationError

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

StatTaskResponseValidationError is the validation error returned by StatTaskResponse.Validate if the designated constraints aren't met.

func (StatTaskResponseValidationError) Cause

Cause function returns cause value.

func (StatTaskResponseValidationError) Error

Error satisfies the builtin error interface

func (StatTaskResponseValidationError) ErrorName

ErrorName returns error name.

func (StatTaskResponseValidationError) Field

Field function returns field value.

func (StatTaskResponseValidationError) Key

Key function returns key value.

func (StatTaskResponseValidationError) Reason

Reason function returns reason value.

type SyncPiecesRequest

type SyncPiecesRequest struct {

	// Types that are assignable to Request:
	//
	//	*SyncPiecesRequest_InterestedAllPiecesRequest
	//	*SyncPiecesRequest_InterestedPiecesRequest
	//	*SyncPiecesRequest_StatMetadataRequest
	Request isSyncPiecesRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

SyncPiecesRequest represents request of AnnouncePeer.

func (*SyncPiecesRequest) Descriptor deprecated

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

Deprecated: Use SyncPiecesRequest.ProtoReflect.Descriptor instead.

func (*SyncPiecesRequest) GetInterestedAllPiecesRequest

func (x *SyncPiecesRequest) GetInterestedAllPiecesRequest() *InterestedAllPiecesRequest

func (*SyncPiecesRequest) GetInterestedPiecesRequest

func (x *SyncPiecesRequest) GetInterestedPiecesRequest() *InterestedPiecesRequest

func (*SyncPiecesRequest) GetRequest

func (m *SyncPiecesRequest) GetRequest() isSyncPiecesRequest_Request

func (*SyncPiecesRequest) GetStatMetadataRequest

func (x *SyncPiecesRequest) GetStatMetadataRequest() *StatMetadataRequest

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

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

Cause function returns cause value.

func (SyncPiecesRequestValidationError) Error

Error satisfies the builtin error interface

func (SyncPiecesRequestValidationError) ErrorName

ErrorName returns error name.

func (SyncPiecesRequestValidationError) Field

Field function returns field value.

func (SyncPiecesRequestValidationError) Key

Key function returns key value.

func (SyncPiecesRequestValidationError) Reason

Reason function returns reason value.

type SyncPiecesRequest_InterestedAllPiecesRequest

type SyncPiecesRequest_InterestedAllPiecesRequest struct {
	InterestedAllPiecesRequest *InterestedAllPiecesRequest `protobuf:"bytes,1,opt,name=interested_all_pieces_request,json=interestedAllPiecesRequest,proto3,oneof"`
}

type SyncPiecesRequest_InterestedPiecesRequest

type SyncPiecesRequest_InterestedPiecesRequest struct {
	InterestedPiecesRequest *InterestedPiecesRequest `protobuf:"bytes,2,opt,name=interested_pieces_request,json=interestedPiecesRequest,proto3,oneof"`
}

type SyncPiecesRequest_StatMetadataRequest

type SyncPiecesRequest_StatMetadataRequest struct {
	StatMetadataRequest *StatMetadataRequest `protobuf:"bytes,3,opt,name=stat_metadata_request,json=statMetadataRequest,proto3,oneof"`
}

type SyncPiecesResponse

type SyncPiecesResponse struct {

	// Types that are assignable to Response:
	//
	//	*SyncPiecesResponse_InterestedPiecesResponse
	//	*SyncPiecesResponse_StatMetadataResponse
	Response isSyncPiecesResponse_Response `protobuf_oneof:"response"`
	// Types that are assignable to Errordetails:
	//
	//	*SyncPiecesResponse_SyncPiecesFailed
	//	*SyncPiecesResponse_StatMetadataFailed
	Errordetails isSyncPiecesResponse_Errordetails `protobuf_oneof:"errordetails"`
	// 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) GetErrordetails

func (m *SyncPiecesResponse) GetErrordetails() isSyncPiecesResponse_Errordetails

func (*SyncPiecesResponse) GetInterestedPiecesResponse

func (x *SyncPiecesResponse) GetInterestedPiecesResponse() *InterestedPiecesResponse

func (*SyncPiecesResponse) GetResponse

func (m *SyncPiecesResponse) GetResponse() isSyncPiecesResponse_Response

func (*SyncPiecesResponse) GetStatMetadataFailed

func (x *SyncPiecesResponse) GetStatMetadataFailed() *v21.StatMetadataFailed

func (*SyncPiecesResponse) GetStatMetadataResponse

func (x *SyncPiecesResponse) GetStatMetadataResponse() *StatMetadataResponse

func (*SyncPiecesResponse) GetSyncPiecesFailed

func (x *SyncPiecesResponse) GetSyncPiecesFailed() *v21.SyncPiecesFailed

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

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

Cause function returns cause value.

func (SyncPiecesResponseValidationError) Error

Error satisfies the builtin error interface

func (SyncPiecesResponseValidationError) ErrorName

ErrorName returns error name.

func (SyncPiecesResponseValidationError) Field

Field function returns field value.

func (SyncPiecesResponseValidationError) Key

Key function returns key value.

func (SyncPiecesResponseValidationError) Reason

Reason function returns reason value.

type SyncPiecesResponse_InterestedPiecesResponse

type SyncPiecesResponse_InterestedPiecesResponse struct {
	InterestedPiecesResponse *InterestedPiecesResponse `protobuf:"bytes,1,opt,name=interested_pieces_response,json=interestedPiecesResponse,proto3,oneof"`
}

type SyncPiecesResponse_StatMetadataFailed

type SyncPiecesResponse_StatMetadataFailed struct {
	StatMetadataFailed *v21.StatMetadataFailed `protobuf:"bytes,4,opt,name=stat_metadata_failed,json=statMetadataFailed,proto3,oneof"`
}

type SyncPiecesResponse_StatMetadataResponse

type SyncPiecesResponse_StatMetadataResponse struct {
	StatMetadataResponse *StatMetadataResponse `protobuf:"bytes,2,opt,name=stat_metadata_response,json=statMetadataResponse,proto3,oneof"`
}

type SyncPiecesResponse_SyncPiecesFailed

type SyncPiecesResponse_SyncPiecesFailed struct {
	SyncPiecesFailed *v21.SyncPiecesFailed `protobuf:"bytes,3,opt,name=sync_pieces_failed,json=syncPiecesFailed,proto3,oneof"`
}

type TriggerTaskRequest

type TriggerTaskRequest struct {

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

TriggerTaskRequest represents request of TriggerTask.

func (*TriggerTaskRequest) Descriptor deprecated

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

Deprecated: Use TriggerTaskRequest.ProtoReflect.Descriptor instead.

func (*TriggerTaskRequest) GetMetadata

func (x *TriggerTaskRequest) GetMetadata() *v2.Metadata

func (*TriggerTaskRequest) GetTaskId

func (x *TriggerTaskRequest) GetTaskId() string

func (*TriggerTaskRequest) ProtoMessage

func (*TriggerTaskRequest) ProtoMessage()

func (*TriggerTaskRequest) ProtoReflect

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

func (*TriggerTaskRequest) Reset

func (x *TriggerTaskRequest) Reset()

func (*TriggerTaskRequest) String

func (x *TriggerTaskRequest) String() string

func (*TriggerTaskRequest) Validate

func (m *TriggerTaskRequest) Validate() error

Validate checks the field values on TriggerTaskRequest 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 (*TriggerTaskRequest) ValidateAll

func (m *TriggerTaskRequest) ValidateAll() error

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

type TriggerTaskRequestMultiError

type TriggerTaskRequestMultiError []error

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

func (TriggerTaskRequestMultiError) AllErrors

func (m TriggerTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TriggerTaskRequestMultiError) Error

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

type TriggerTaskRequestValidationError

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

TriggerTaskRequestValidationError is the validation error returned by TriggerTaskRequest.Validate if the designated constraints aren't met.

func (TriggerTaskRequestValidationError) Cause

Cause function returns cause value.

func (TriggerTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (TriggerTaskRequestValidationError) ErrorName

ErrorName returns error name.

func (TriggerTaskRequestValidationError) Field

Field function returns field value.

func (TriggerTaskRequestValidationError) Key

Key function returns key value.

func (TriggerTaskRequestValidationError) Reason

Reason function returns reason value.

type UnimplementedDfdaemonServer

type UnimplementedDfdaemonServer struct {
}

UnimplementedDfdaemonServer should be embedded to have forward compatible implementations.

func (UnimplementedDfdaemonServer) DeleteTask

func (UnimplementedDfdaemonServer) ExportTask

func (UnimplementedDfdaemonServer) ImportTask

func (UnimplementedDfdaemonServer) StatTask

func (UnimplementedDfdaemonServer) SyncPieces

func (UnimplementedDfdaemonServer) TriggerTask

type UnsafeDfdaemonServer

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

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

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