piecetransfer

package
v1.27.6 Latest Latest
Warning

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

Go to latest
Published: Apr 19, 2021 License: AGPL-3.0 Imports: 16 Imported by: 0

Documentation

Overview

Package piecetransfer contains code meant to deal with transferring pieces from one node to another. This does not happen under typical circumstances, but may happen when a node wants to become unavailable in a "clean" way. (Graceful exit, planned downtime)

Index

Constants

This section is empty.

Variables

View Source
var (
	// Error is the default error class for graceful exit package.
	Error = errs.Class("internode transfer")
)

Functions

This section is empty.

Types

type Service

type Service interface {
	// TransferPiece validates a transfer order, validates the locally stored
	// piece, and then (if appropriate) transfers the piece to the specified
	// destination node, obtaining a signed receipt. TransferPiece returns a
	// message appropriate for responding to the transfer order (whether the
	// transfer succeeded or failed).
	TransferPiece(ctx context.Context, satelliteID storj.NodeID, transferPiece *pb.TransferPiece) *pb.StorageNodeMessage
}

Service allows for transfer of pieces from one storage node to another, as directed by the satellite that owns the piece.

func NewService

func NewService(log *zap.Logger, store *pieces.Store, trust *trust.Pool, dialer rpc.Dialer, minDownloadTimeout time.Duration, minBytesPerSecond memory.Size) Service

NewService is a constructor for Service.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL