metainfo

package

Go to main page

Versions in this module

v1

v1.5.0-rc.1

Apr 22, 2021

v1.4.6

Apr 14, 2021

Changes in this version

+ const After

+ const Backward

+ const Before

+ const Forward

+ var ErrBucket = storj.ErrBucket

+ var ErrBucketNotFound = storj.ErrBucketNotFound

+ var ErrNoBucket = storj.ErrNoBucket

+ var ErrNoPath = storj.ErrNoPath

+ var ErrObjectNotFound = storj.ErrObjectNotFound

type BeginDeleteObjectParams

+ Status int32

+ StreamID storj.StreamID

type BeginSegmentResponse

+ RedundancyStrategy eestream.RedundancyStrategy

+ type Bucket = storj.Bucket

+ type BucketList = storj.BucketList

+ type BucketListOptions = storj.BucketListOptions

type Client

+ func (client *Client) DownloadObject(ctx context.Context, params DownloadObjectParams) (_ DownloadObjectResponse, err error)

+ func (client *Client) DownloadSegmentWithRS(ctx context.Context, params DownloadSegmentParams) (_ DownloadSegmentWithRSResponse, err error)

+ func (client *Client) ListPendingObjectStreams(ctx context.Context, params ListPendingObjectStreamsParams) (_ ListPendingObjectStreamsResponse, err error)

type CommitObjectParams

+ EncryptedMetadataEncryptedKey []byte

type CommitSegmentParams

+ EncryptedTag []byte

+ PlainSize int64

type DB

+ func (db *DB) DownloadObject(ctx context.Context, bucket, key string, options DownloadOptions) (info DownloadInfo, err error)

+ func (db *DB) ListPendingObjectStreams(ctx context.Context, bucket string, options ListOptions) (list ObjectList, err error)

+ type DownloadInfo struct

+ DownloadedSegments []DownloadSegmentWithRSResponse

+ ListSegments ListSegmentsResponse

+ Object storj.Object

+ Range StreamRange

+ type DownloadObjectParams struct

+ Bucket []byte

+ EncryptedObjectKey []byte

+ Range StreamRange

+ func (params *DownloadObjectParams) BatchItem() *pb.BatchRequestItem

+ type DownloadObjectResponse struct

+ DownloadedSegments []DownloadSegmentWithRSResponse

+ ListSegments ListSegmentsResponse

+ Object RawObjectItem

+ type DownloadOptions struct

+ Range StreamRange

+ type DownloadSegmentWithRSResponse struct

+ Info SegmentDownloadInfo

+ Limits []*pb.AddressedOrderLimit

+ type GetObjectIPsParams struct

+ Bucket []byte

+ EncryptedPath []byte

+ Version int32

+ type GetObjectIPsResponse struct

+ IPPorts [][]byte

+ PieceCount int64

+ ReliablePieceCount int64

+ SegmentCount int64

type GetObjectParams

+ RedundancySchemePerSegment bool

+ type LastSegment = storj.LastSegment

+ type ListDirection = storj.ListDirection

type ListObjectsParams

+ Status int32

+ type ListOptions = storj.ListOptions

+ type ListPendingObjectStreamsParams struct

+ Bucket []byte

+ EncryptedCursor []byte

+ EncryptedPath []byte

+ Limit int32

+ func (params *ListPendingObjectStreamsParams) BatchItem() *pb.BatchRequestItem

+ type ListPendingObjectStreamsResponse struct

+ Items []RawObjectListItem

+ More bool

type ListSegmentsParams

+ Cursor SegmentPosition

+ Range StreamRange

type ListSegmentsResponse

+ EncryptionParameters storj.EncryptionParameters

type MakeInlineSegmentParams

+ EncryptedTag []byte

+ PlainSize int64

+ type Object = storj.Object

+ type ObjectInfo = storj.ObjectInfo

+ type ObjectList = storj.ObjectList

+ type ObjectListItem = storj.ObjectListItem

+ type Piece = storj.Piece

type RawObjectItem

+ PlainSize int64

+ type Segment = storj.Segment

+ type SegmentDownloadInfo struct

+ EncryptedInlineData []byte

+ EncryptedSize int64

+ PiecePrivateKey storj.PiecePrivateKey

+ PlainOffset int64

+ PlainSize int64

+ Position *storj.SegmentPosition

+ RedundancyScheme storj.RedundancyScheme

+ SegmentEncryption SegmentEncryption

+ SegmentID storj.SegmentID

+ type SegmentDownloadResponseInfo struct

+ EncryptedInlineData []byte

+ EncryptedSize int64

+ Next SegmentPosition

+ PiecePrivateKey storj.PiecePrivateKey

+ Position SegmentPosition

+ SegmentEncryption SegmentEncryption

+ SegmentID storj.SegmentID

+ type SegmentEncryption = storj.SegmentEncryption

+ type SegmentListItem struct

+ CreatedAt time.Time

+ EncryptedETag []byte

+ EncryptedKey []byte

+ EncryptedKeyNonce storj.Nonce

+ PlainOffset int64

+ PlainSize int64

+ Position SegmentPosition

+ type SegmentPosition = storj.SegmentPosition

+ type Stream = storj.Stream

+ type StreamRange struct

+ Limit int64

+ Mode StreamRangeMode

+ Start int64

+ Suffix int64

+ func (streamRange StreamRange) Normalize(plainSize int64) StreamRange

+ type StreamRangeMode byte

+ const StreamRangeAll

+ const StreamRangeStart

+ const StreamRangeStartLimit

+ const StreamRangeSuffix

v1.4.5

Jan 12, 2021

v1.4.4

Jan 5, 2021

v1.4.3

Dec 21, 2020

v1.4.2

Dec 10, 2020

v1.4.1

Dec 4, 2020

v1.4.0

Dec 1, 2020

Changes in this version

type DB

+ func (db *DB) Close() error

type MutableObject

+ func (object *MutableObject) CreateDynamicStream(ctx context.Context, metadata SerializableMeta, expires time.Time) (_ *MutableStream, err error)

type MutableStream

+ func (stream *MutableStream) Info() storj.Object

+ type RawObjectItem struct

+ Bucket string

+ Created time.Time

+ EncryptedMetadata []byte

+ EncryptedMetadataNonce storj.Nonce

+ EncryptedPath []byte

+ EncryptionParameters storj.EncryptionParameters

+ Expires time.Time

+ Modified time.Time

+ RedundancyScheme storj.RedundancyScheme

+ StreamID storj.StreamID

+ Version uint32

+ type RawObjectListItem struct

+ CreatedAt time.Time

+ EncryptedMetadata []byte

+ EncryptedMetadataNonce storj.Nonce

+ EncryptedPath []byte

+ ExpiresAt time.Time

+ IsPrefix bool

+ PlainSize int64

+ Status int32

+ StatusAt time.Time

+ StreamID storj.StreamID

+ Version int32

+ type SerializableMeta interface

+ Metadata func() ([]byte, error)

v1.3.1

Oct 12, 2020

v1.3.0

Sep 1, 2020

Changes in this version

type Client

+ func (client *Client) GetObjectIPs(ctx context.Context, params GetObjectIPParams) (ips []net.IP, err error)

type DB

+ func (db *DB) GetObjectIPs(ctx context.Context, bucket storj.Bucket, path storj.Path) (ips []net.IP, err error)

type DeleteBucketParams

+ DeleteAll bool

+ type GetObjectIPParams struct

+ Bucket []byte

+ EncryptedPath []byte

+ Version int32

v1.2.0

Aug 3, 2020

Changes in this version

type Client

+ func (client *Client) RevokeAPIKey(ctx context.Context, params RevokeAPIKeyParams) (err error)

+ type RevokeAPIKeyParams struct

+ APIKey []byte

v1.1.2

Jun 16, 2020

Changes in this version

+ func PathForKey(raw string) paths.Unencrypted

+ func TypedDecryptStreamInfo(ctx context.Context, bucket string, unencryptedKey paths.Unencrypted, ...) (_ *pb.StreamInfo, streamMeta pb.StreamMeta, err error)

type Client

+ func NewClient(client pb.DRPCMetainfoClient, apiKey *macaroon.APIKey, userAgent string) *Client

+ type CreateObject struct

+ ContentType string

+ Expires time.Time

+ Metadata map[string]string

+ func (create CreateObject) Object(bucket storj.Bucket, path storj.Path) storj.Object

+ type DB struct

+ func (db *DB) CreateBucket(ctx context.Context, bucketName string) (newBucket storj.Bucket, err error)

+ func (db *DB) CreateObject(ctx context.Context, bucket storj.Bucket, path storj.Path, ...) (object MutableObject, err error)

+ func (db *DB) DeleteBucket(ctx context.Context, bucketName string) (bucket storj.Bucket, err error)

+ func (db *DB) DeleteObject(ctx context.Context, bucket storj.Bucket, path storj.Path) (_ storj.Object, err error)

+ func (db *DB) GetBucket(ctx context.Context, bucketName string) (bucket storj.Bucket, err error)

+ func (db *DB) GetObject(ctx context.Context, bucket storj.Bucket, path storj.Path) (info storj.Object, err error)

+ func (db *DB) GetObjectStream(ctx context.Context, bucket storj.Bucket, object storj.Object) (stream ReadOnlyStream, err error)

+ func (db *DB) ListBuckets(ctx context.Context, options storj.BucketListOptions) (bucketList storj.BucketList, err error)

+ func (db *DB) ListObjects(ctx context.Context, bucket storj.Bucket, options storj.ListOptions) (list storj.ObjectList, err error)

+ func (db *DB) ListPendingObjects(ctx context.Context, bucket storj.Bucket, options storj.ListOptions) (list storj.ObjectList, err error)

+ func (db *DB) ModifyObject(ctx context.Context, bucket storj.Bucket, path storj.Path) (object MutableObject, err error)

+ func (db *DB) ModifyPendingObject(ctx context.Context, bucket storj.Bucket, path storj.Path) (object MutableObject, err error)

+ type Meta struct

+ Data []byte

+ Expiration time.Time

+ Modified time.Time

+ Size int64

+ type MutableObject interface

+ Commit func(ctx context.Context) error

+ ContinueStream func(ctx context.Context) (MutableStream, error)

+ CreateStream func(ctx context.Context) (MutableStream, error)

+ DeleteStream func(ctx context.Context) error

+ Info func() storj.Object

+ type MutableStream interface

+ AddSegments func(ctx context.Context, segments ...storj.Segment) error

+ BucketName func() string

+ Expires func() time.Time

+ Metadata func() ([]byte, error)

+ Path func() string

+ UpdateSegments func(ctx context.Context, segments ...storj.Segment) error

+ type ReadOnlyStream interface

+ Info func() storj.Object

+ Segments func(ctx context.Context, index int64, limit int64) (infos []storj.Segment, more bool, err error)

+ SegmentsAt func(ctx context.Context, byteOffset int64, limit int64) (infos []storj.Segment, more bool, err error)

v1.1.1

Jun 12, 2020

v1.1.0

Jun 3, 2020

v1.0.7

Jun 3, 2020

v1.0.6

May 25, 2020

v1.0.5

Apr 29, 2020

v1.0.4

Apr 23, 2020

v1.0.3

Mar 31, 2020

v1.0.2

Mar 27, 2020

v1.0.1

Mar 25, 2020

v1.0.0

Mar 19, 2020

Changes in this version

+ var ErrInvalidType = errs.New("invalid response type")

+ var Error = errs.Class("metainfo error")

+ type BatchItem interface

+ BatchItem func() *pb.BatchRequestItem

+ type BatchResponse struct

+ func (resp *BatchResponse) BeginDeleteObject() (BeginDeleteObjectResponse, error)

+ func (resp *BatchResponse) BeginDeleteSegment() (BeginDeleteSegmentResponse, error)

+ func (resp *BatchResponse) BeginObject() (BeginObjectResponse, error)

+ func (resp *BatchResponse) BeginSegment() (BeginSegmentResponse, error)

+ func (resp *BatchResponse) CreateBucket() (CreateBucketResponse, error)

+ func (resp *BatchResponse) DownloadSegment() (DownloadSegmentResponse, error)

+ func (resp *BatchResponse) GetBucket() (GetBucketResponse, error)

+ func (resp *BatchResponse) GetObject() (GetObjectResponse, error)

+ func (resp *BatchResponse) ListBuckets() (ListBucketsResponse, error)

+ func (resp *BatchResponse) ListObjects() (ListObjectsResponse, error)

+ func (resp *BatchResponse) ListSegment() (ListSegmentsResponse, error)

+ type BeginDeleteObjectParams struct

+ Bucket []byte

+ EncryptedPath []byte

+ Version int32

+ func (params *BeginDeleteObjectParams) BatchItem() *pb.BatchRequestItem

+ type BeginDeleteObjectResponse struct

+ StreamID storj.StreamID

+ type BeginDeleteSegmentParams struct

+ Position storj.SegmentPosition

+ StreamID storj.StreamID

+ func (params *BeginDeleteSegmentParams) BatchItem() *pb.BatchRequestItem

+ type BeginDeleteSegmentResponse struct

+ Limits []*pb.AddressedOrderLimit

+ PiecePrivateKey storj.PiecePrivateKey

+ SegmentID storj.SegmentID

+ type BeginObjectParams struct

+ Bucket []byte

+ EncryptedPath []byte

+ EncryptionParameters storj.EncryptionParameters

+ ExpiresAt time.Time

+ Redundancy storj.RedundancyScheme

+ Version int32

+ func (params *BeginObjectParams) BatchItem() *pb.BatchRequestItem

+ type BeginObjectResponse struct

+ EncryptionParameters storj.EncryptionParameters

+ RedundancyStrategy eestream.RedundancyStrategy

+ StreamID storj.StreamID

+ type BeginSegmentParams struct

+ MaxOrderLimit int64

+ Position storj.SegmentPosition

+ StreamID storj.StreamID

+ func (params *BeginSegmentParams) BatchItem() *pb.BatchRequestItem

+ type BeginSegmentResponse struct

+ Limits []*pb.AddressedOrderLimit

+ PiecePrivateKey storj.PiecePrivateKey

+ SegmentID storj.SegmentID

+ type Client struct

+ func Dial(ctx context.Context, dialer rpc.Dialer, address string, ...) (*Client, error)

+ func DialNodeURL(ctx context.Context, dialer rpc.Dialer, nodeURL string, ...) (*Client, error)

+ func New(client pb.DRPCMetainfoClient, apiKey *macaroon.APIKey, userAgent string) *Client

+ func (client *Client) Batch(ctx context.Context, requests ...BatchItem) (resp []BatchResponse, err error)

+ func (client *Client) BeginDeleteObject(ctx context.Context, params BeginDeleteObjectParams) (_ storj.StreamID, _ storj.ObjectInfo, err error)

+ func (client *Client) BeginDeleteSegment(ctx context.Context, params BeginDeleteSegmentParams) (_ storj.SegmentID, limits []*pb.AddressedOrderLimit, _ storj.PiecePrivateKey, ...)

+ func (client *Client) BeginObject(ctx context.Context, params BeginObjectParams) (_ BeginObjectResponse, err error)

+ func (client *Client) BeginSegment(ctx context.Context, params BeginSegmentParams) (_ storj.SegmentID, limits []*pb.AddressedOrderLimit, ...)

+ func (client *Client) Close() error

+ func (client *Client) CommitObject(ctx context.Context, params CommitObjectParams) (err error)

+ func (client *Client) CommitSegment(ctx context.Context, params CommitSegmentParams) (err error)

+ func (client *Client) CommitSegmentOld(ctx context.Context, bucket string, path storj.Path, segmentIndex int64, ...) (savedPointer *pb.Pointer, err error)

+ func (client *Client) CreateBucket(ctx context.Context, params CreateBucketParams) (respBucket storj.Bucket, err error)

+ func (client *Client) CreateSegmentOld(ctx context.Context, bucket string, path storj.Path, segmentIndex int64, ...) (limits []*pb.AddressedOrderLimit, rootPieceID storj.PieceID, ...)

+ func (client *Client) DeleteBucket(ctx context.Context, params DeleteBucketParams) (_ storj.Bucket, err error)

+ func (client *Client) DeleteSegmentOld(ctx context.Context, bucket string, path storj.Path, segmentIndex int64) (limits []*pb.AddressedOrderLimit, piecePrivateKey storj.PiecePrivateKey, ...)

+ func (client *Client) DownloadSegment(ctx context.Context, params DownloadSegmentParams) (_ storj.SegmentDownloadInfo, _ []*pb.AddressedOrderLimit, err error)

+ func (client *Client) FinishDeleteObject(ctx context.Context, params FinishDeleteObjectParams) (err error)

+ func (client *Client) FinishDeleteSegment(ctx context.Context, params FinishDeleteSegmentParams) (err error)

+ func (client *Client) GetBucket(ctx context.Context, params GetBucketParams) (respBucket storj.Bucket, err error)

+ func (client *Client) GetObject(ctx context.Context, params GetObjectParams) (_ storj.ObjectInfo, err error)

+ func (client *Client) GetProjectInfo(ctx context.Context) (resp *pb.ProjectInfoResponse, err error)

+ func (client *Client) ListBuckets(ctx context.Context, params ListBucketsParams) (_ storj.BucketList, err error)

+ func (client *Client) ListObjects(ctx context.Context, params ListObjectsParams) (_ []storj.ObjectListItem, more bool, err error)

+ func (client *Client) ListSegments(ctx context.Context, params ListSegmentsParams) (_ []storj.SegmentListItem, more bool, err error)

+ func (client *Client) ListSegmentsOld(ctx context.Context, bucket string, ...) (items []ListItem, more bool, err error)

+ func (client *Client) MakeInlineSegment(ctx context.Context, params MakeInlineSegmentParams) (err error)

+ func (client *Client) ReadSegmentOld(ctx context.Context, bucket string, path storj.Path, segmentIndex int64) (pointer *pb.Pointer, limits []*pb.AddressedOrderLimit, ...)

+ func (client *Client) SegmentInfoOld(ctx context.Context, bucket string, path storj.Path, segmentIndex int64) (pointer *pb.Pointer, err error)

+ func (client *Client) SetAttributionOld(ctx context.Context, bucket string, partnerID uuid.UUID) (err error)

+ func (client *Client) SetBucketAttribution(ctx context.Context, params SetBucketAttributionParams) (err error)

+ func (client *Client) SetRawAPIKey(key []byte)

+ type CommitObjectParams struct

+ EncryptedMetadata []byte

+ EncryptedMetadataNonce storj.Nonce

+ StreamID storj.StreamID

+ func (params *CommitObjectParams) BatchItem() *pb.BatchRequestItem

+ type CommitSegmentParams struct

+ Encryption storj.SegmentEncryption

+ SegmentID storj.SegmentID

+ SizeEncryptedData int64

+ UploadResult []*pb.SegmentPieceUploadResult

+ func (params *CommitSegmentParams) BatchItem() *pb.BatchRequestItem

+ type CreateBucketParams struct

+ DefaultEncryptionParameters storj.EncryptionParameters

+ DefaultRedundancyScheme storj.RedundancyScheme

+ DefaultSegmentsSize int64

+ Name []byte

+ PartnerID []byte

+ PathCipher storj.CipherSuite

+ func (params *CreateBucketParams) BatchItem() *pb.BatchRequestItem

+ type CreateBucketResponse struct

+ Bucket storj.Bucket

+ type DeleteBucketParams struct

+ Name []byte

+ func (params *DeleteBucketParams) BatchItem() *pb.BatchRequestItem

+ type DownloadSegmentParams struct

+ Position storj.SegmentPosition

+ StreamID storj.StreamID

+ func (params *DownloadSegmentParams) BatchItem() *pb.BatchRequestItem

+ type DownloadSegmentResponse struct

+ Info storj.SegmentDownloadInfo

+ Limits []*pb.AddressedOrderLimit

+ type FinishDeleteObjectParams struct

+ StreamID storj.StreamID

+ func (params *FinishDeleteObjectParams) BatchItem() *pb.BatchRequestItem

+ type FinishDeleteSegmentParams struct

+ DeleteResults []*pb.SegmentPieceDeleteResult

+ SegmentID storj.SegmentID

+ func (params *FinishDeleteSegmentParams) BatchItem() *pb.BatchRequestItem

+ type GetBucketParams struct

+ Name []byte

+ func (params *GetBucketParams) BatchItem() *pb.BatchRequestItem

+ type GetBucketResponse struct

+ Bucket storj.Bucket

+ type GetObjectParams struct

+ Bucket []byte

+ EncryptedPath []byte

+ Version int32

+ func (params *GetObjectParams) BatchItem() *pb.BatchRequestItem

+ type GetObjectResponse struct

+ Info storj.ObjectInfo

+ type ListBucketsParams struct

+ ListOpts storj.BucketListOptions

+ func (params *ListBucketsParams) BatchItem() *pb.BatchRequestItem

+ type ListBucketsResponse struct

+ BucketList storj.BucketList

+ type ListItem struct

+ IsPrefix bool

+ Path storj.Path

+ Pointer *pb.Pointer

+ type ListObjectsParams struct

+ Bucket []byte

+ EncryptedCursor []byte

+ EncryptedPrefix []byte

+ IncludeMetadata bool

+ Limit int32

+ Recursive bool

+ func (params *ListObjectsParams) BatchItem() *pb.BatchRequestItem

+ type ListObjectsResponse struct

+ Items []storj.ObjectListItem

+ More bool

+ type ListSegmentsParams struct

+ CursorPosition storj.SegmentPosition

+ Limit int32

+ StreamID storj.StreamID

+ func (params *ListSegmentsParams) BatchItem() *pb.BatchRequestItem

+ type ListSegmentsResponse struct

+ Items []storj.SegmentListItem

+ More bool

+ type MakeInlineSegmentParams struct

+ EncryptedInlineData []byte

+ Encryption storj.SegmentEncryption

+ Position storj.SegmentPosition

+ StreamID storj.StreamID

+ func (params *MakeInlineSegmentParams) BatchItem() *pb.BatchRequestItem

+ type SetBucketAttributionParams struct

+ Bucket string

+ PartnerID uuid.UUID

+ func (params *SetBucketAttributionParams) BatchItem() *pb.BatchRequestItem

v1.0.0-rc.5

Mar 11, 2020

v1.0.0-rc.4

Mar 10, 2020

v1.0.0-rc.3

Mar 6, 2020

v1.0.0-rc.2

Feb 26, 2020

v1.0.0-rc.1

Feb 25, 2020

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