Documentation
¶
Index ¶
- Variables
- type BufferedDownload
- type BufferedUpload
- type Client
- func (client *Client) Close() error
- func (client *Client) Delete(ctx context.Context, limit *pb.OrderLimit2) error
- func (client *Client) Download(ctx context.Context, limit *pb.OrderLimit2, offset, size int64) (Downloader, error)
- func (client *Client) Upload(ctx context.Context, limit *pb.OrderLimit2) (Uploader, error)
- func (client *Client) VerifyPieceHash(ctx context.Context, peer *identity.PeerIdentity, limit *pb.OrderLimit2, ...) error
- type Config
- type Download
- type Downloader
- type LockingDownload
- type LockingUpload
- type ReadBuffer
- type Upload
- type Uploader
Constants ¶
This section is empty.
Variables ¶
var ( // ErrInternal is an error class for internal errors. ErrInternal = errs.Class("internal") // ErrProtocol is an error class for unexpected protocol sequence. ErrProtocol = errs.Class("protocol") // ErrVerifyUntrusted is an error in case there is a trust issue. ErrVerifyUntrusted = errs.Class("untrusted") )
var DefaultConfig = Config{ UploadBufferSize: 256 * memory.KiB.Int64(), DownloadBufferSize: 256 * memory.KiB.Int64(), InitialStep: 64 * memory.KiB.Int64(), MaximumStep: 1 * memory.MiB.Int64(), }
DefaultConfig are the default params used for upload and download.
var Error = errs.Class("piecestore")
Error is the default error class for piecestore client.
Functions ¶
This section is empty.
Types ¶
type BufferedDownload ¶
type BufferedDownload struct {
// contains filtered or unexported fields
}
BufferedDownload implements buffering for download.
func (*BufferedDownload) Close ¶
func (download *BufferedDownload) Close() error
Close closes the buffered download.
type BufferedUpload ¶
type BufferedUpload struct {
// contains filtered or unexported fields
}
BufferedUpload implements buffering for an Upload.
func (*BufferedUpload) Cancel ¶
func (upload *BufferedUpload) Cancel() error
Cancel aborts the upload.
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client implements uploading, downloading and deleting content from a piecestore.
func NewClient ¶
func NewClient(log *zap.Logger, signer signing.Signer, conn *grpc.ClientConn, config Config) *Client
NewClient creates a new piecestore client from a grpc client connection.
func (*Client) Download ¶
func (client *Client) Download(ctx context.Context, limit *pb.OrderLimit2, offset, size int64) (Downloader, error)
Download starts a new download using the specified order limit at the specified offset and size.
func (*Client) VerifyPieceHash ¶
func (client *Client) VerifyPieceHash(ctx context.Context, peer *identity.PeerIdentity, limit *pb.OrderLimit2, hash *pb.PieceHash, expectedHash []byte) error
VerifyPieceHash verifies piece hash which is sent by peer.
type Config ¶
type Config struct {
UploadBufferSize int64
DownloadBufferSize int64
InitialStep int64
MaximumStep int64
}
Config defines piecestore client parameters fro upload and download.
type Download ¶
type Download struct {
// contains filtered or unexported fields
}
Download implements downloading from a piecestore.
type Downloader ¶
Downloader is interface that can be used for downloading content. It matches signature of `io.ReadCloser`.
func NewBufferedDownload ¶
func NewBufferedDownload(download *Download, size int) Downloader
NewBufferedDownload creates a buffered download with the specified size.
type LockingDownload ¶
type LockingDownload struct {
// contains filtered or unexported fields
}
LockingDownload adds a lock around download making it safe to use concurrently. TODO: this shouldn't be needed.
func (*LockingDownload) Close ¶
func (download *LockingDownload) Close() error
Close closes the deownload.
type LockingUpload ¶
type LockingUpload struct {
// contains filtered or unexported fields
}
LockingUpload adds a lock around upload making it safe to use concurrently. TODO: this shouldn't be needed.
func (*LockingUpload) Cancel ¶
func (upload *LockingUpload) Cancel() error
Cancel aborts the upload.
type ReadBuffer ¶
type ReadBuffer struct {
// contains filtered or unexported fields
}
ReadBuffer implements buffered reading with an error.
func (*ReadBuffer) Empty ¶
func (buffer *ReadBuffer) Empty() bool
Empty checks whether buffer needs to be filled.
func (*ReadBuffer) Error ¶
func (buffer *ReadBuffer) Error() error
Error returns an error if it was encountered.
func (*ReadBuffer) Errored ¶
func (buffer *ReadBuffer) Errored() bool
Errored returns whether the buffer contains an error.
func (*ReadBuffer) Fill ¶
func (buffer *ReadBuffer) Fill(data []byte)
Fill fills the buffer with the specified bytes.
func (*ReadBuffer) IncludeError ¶
func (buffer *ReadBuffer) IncludeError(err error)
IncludeError adds error at the end of the buffer.
type Upload ¶
type Upload struct {
// contains filtered or unexported fields
}
Upload implements uploading to the storage node.
type Uploader ¶
type Uploader interface {
// Write uploads data to the storage node.
Write([]byte) (int, error)
// Cancel cancels the upload.
Cancel() error
// Commit finalizes the upload.
Commit() (*pb.PieceHash, error)
}
Uploader defines the interface for uploading a piece.
func NewBufferedUpload ¶
NewBufferedUpload creates buffered upload with the specified size.
Source Files