piecetransfer

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

• Variables
• type Service
  • func NewService(log *zap.Logger, store *pieces.Store, trust *trust.Pool, dialer rpc.Dialer, ...) Service

Variables

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

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.