metaclient

package

Go to main page

Versions in this module

v1

v1.13.1

Aug 14, 2024

Changes in this version

+ var ErrRetentionNotFound = errs.Class("object retention not found")

type BeginObjectParams

+ Retention Retention

type Client

+ func (client *Client) GetBucketObjectLockConfiguration(ctx context.Context, params GetBucketObjectLockConfigurationParams) (_ GetBucketObjectLockConfigurationResponse, err error)

+ func (client *Client) GetObjectRetention(ctx context.Context, params GetObjectRetentionParams) (r *Retention, err error)

+ func (client *Client) SetObjectRetention(ctx context.Context, params SetObjectRetentionParams) (err error)

+ type CopyObjectOptions struct

+ Retention Retention

type CreateBucketParams

+ ObjectLockEnabled bool

type DB

+ func (db *DB) GetObjectRetention(ctx context.Context, bucket, key string, version []byte) (retention *Retention, err error)

+ func (db *DB) SetObjectRetention(ctx context.Context, bucket, key string, version []byte, retention Retention) (err error)

type FinishCopyObjectParams

+ Retention Retention

+ type GetBucketObjectLockConfigurationParams struct

+ Name []byte

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

+ type GetBucketObjectLockConfigurationResponse struct

+ Enabled bool

+ type GetObjectRetentionParams struct

+ Bucket []byte

+ EncryptedObjectKey []byte

+ ObjectVersion []byte

+ type SetObjectRetentionParams struct

+ Bucket []byte

+ EncryptedObjectKey []byte

+ ObjectVersion []byte

+ Retention Retention

+ type UploadOptions struct

+ Expires time.Time

+ Retention Retention

v1.13.0

May 7, 2024

Changes in this version

+ var ErrUploadIDInvalid = errs.Class("upload ID invalid")

type BatchResponse

+ func (resp *BatchResponse) CommitObject() (CommitObjectResponse, error)

+ func (resp *BatchResponse) IsCommitObject() bool

type BeginCopyObjectParams

+ Version []byte

type Client

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

+ func (client *Client) GetBucketVersioning(ctx context.Context, params GetBucketVersioningParams) (_ GetBucketVersioningResponse, err error)

+ func (client *Client) SetBucketVersioning(ctx context.Context, params SetBucketVersioningParams) (err error)

+ type CommitObjectResponse struct

+ Object RawObjectItem

type DB

+ func (db *DB) CommitObject(ctx context.Context, bucket, key, uploadID string, ...) (info Object, err error)

+ func (db *DB) CopyObject(ctx context.Context, sourceBucket, sourceKey string, sourceVersion []byte, ...) (_ *Object, err error)

type DownloadObjectParams

+ Version []byte

+ type GetBucketVersioningParams struct

+ Name []byte

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

+ type GetBucketVersioningResponse struct

+ Versioning int32

type ListObjectsParams

+ IncludeAllVersions bool

+ VersionCursor []byte

type ListOptions

+ IncludeAllVersions bool

+ VersionCursor []byte

type Object

+ IsDeleteMarker bool

+ Retention *Retention

type ObjectList

+ VersionCursor []byte

type RawObjectItem

+ Retention *Retention

+ Status int32

+ func (r RawObjectItem) IsDeleteMarker() bool

+ func (r RawObjectItem) IsPrefix() bool

type RawObjectListItem

+ Bucket string

+ func (r RawObjectListItem) IsDeleteMarker() bool

+ type Retention struct

+ Mode storj.RetentionMode

+ RetainUntil time.Time

+ type SetBucketVersioningParams struct

+ Name []byte

+ Versioning bool

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

v1.12.2

Nov 8, 2023

v1.12.1

Oct 5, 2023

v1.12.0

Sep 13, 2023

Changes in this version

type Client

+ func (client *Client) GetBucketLocation(ctx context.Context, params GetBucketLocationParams) (_ GetBucketLocationResponse, err error)

+ type GetBucketLocationParams struct

+ Name []byte

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

+ type GetBucketLocationResponse struct

+ Location []byte

v1.11.0

Jul 20, 2023

Changes in this version

type BatchResponse

+ func MakeBatchResponse(req *pb.BatchRequestItem, resp *pb.BatchResponseItem) BatchResponse

+ type Batcher interface

+ Batch func(ctx context.Context, items ...BatchItem) ([]BatchResponse, error)

type Client

+ func (client *Client) RetryBeginSegmentPieces(ctx context.Context, params RetryBeginSegmentPiecesParams) (_ RetryBeginSegmentPiecesResponse, err error)

type ListOptions

+ CursorEnc []byte

type ObjectList

+ Cursor []byte

+ type RetryBeginSegmentPiecesParams struct

+ RetryPieceNumbers []int

+ SegmentID storj.SegmentID

+ type RetryBeginSegmentPiecesResponse struct

+ Limits []*pb.AddressedOrderLimit

+ SegmentID storj.SegmentID

v1.10.0

Dec 1, 2022

Changes in this version

type Bucket

+ Attribution string

+ Created time.Time

+ Name string

+ type BucketIterator struct

+ func IterateBuckets(ctx context.Context, options IterateBucketsOptions) *BucketIterator

+ func (buckets *BucketIterator) Err() error

+ func (buckets *BucketIterator) Item() *Bucket

+ func (buckets *BucketIterator) Next() bool

type BucketList

+ Items []Bucket

+ More bool

type BucketListOptions

+ Cursor string

+ Direction ListDirection

+ Limit int

+ func (opts BucketListOptions) NextPage(list BucketList) BucketListOptions

type DownloadInfo

+ EncPath paths.Encrypted

+ type IterateBucketsOptions struct

+ Cursor string

+ DialClientFunc func() (*Client, error)

+ Limit int

type LastSegment

+ EncryptedKey storj.EncryptedPrivateKey

+ EncryptedKeyNonce storj.Nonce

+ Size int64

type Object

+ Bucket Bucket

+ ContentType string

+ Created time.Time

+ Expires time.Time

+ IsPrefix bool

+ Metadata map[string]string

+ Modified time.Time

+ Path string

+ Version uint32

type ObjectList

+ Bucket string

+ Items []Object

+ More bool

+ Prefix string

type SegmentEncryption

+ EncryptedKey storj.EncryptedPrivateKey

+ EncryptedKeyNonce storj.Nonce

type SegmentPosition

+ Index int32

+ PartNumber int32

type Stream

+ FixedSegmentSize int64

+ ID storj.StreamID

+ LastSegment LastSegment

+ SegmentCount int64

+ Size int64

v1.9.0

May 9, 2022

Changes in this version

type BeginObjectParams

+ EncryptedMetadata []byte

+ EncryptedMetadataEncryptedKey []byte

+ EncryptedMetadataNonce storj.Nonce

v1.8.2

Apr 6, 2022

v1.8.1

Mar 18, 2022

Changes in this version

+ type BeginCopyObjectParams struct

+ Bucket []byte

+ EncryptedObjectKey []byte

+ NewBucket []byte

+ NewEncryptedObjectKey []byte

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

+ type BeginCopyObjectResponse struct

+ EncryptedMetadataKey []byte

+ EncryptedMetadataKeyNonce storj.Nonce

+ SegmentKeys []EncryptedKeyAndNonce

+ StreamID storj.StreamID

type BeginMoveObjectResponse

+ SegmentKeys []EncryptedKeyAndNonce

type Client

+ func (client *Client) BeginCopyObject(ctx context.Context, params BeginCopyObjectParams) (_ BeginCopyObjectResponse, err error)

+ func (client *Client) FinishCopyObject(ctx context.Context, params FinishCopyObjectParams) (_ FinishCopyObjectResponse, err error)

type DB

+ func (db *DB) ObjectFromRawObjectItem(ctx context.Context, bucket, key string, objectInfo RawObjectItem) (Object, error)

+ type FinishCopyObjectParams struct

+ NewBucket []byte

+ NewEncryptedMetadataKey []byte

+ NewEncryptedMetadataKeyNonce storj.Nonce

+ NewEncryptedObjectKey []byte

+ NewSegmentKeys []EncryptedKeyAndNonce

+ StreamID storj.StreamID

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

+ type FinishCopyObjectResponse struct

+ Info RawObjectItem

v1.8.0

Feb 17, 2022

Changes in this version

type BeginDeleteObjectParams

+ EncryptedObjectKey []byte

type BeginObjectParams

+ EncryptedObjectKey []byte

type GetObjectParams

+ EncryptedObjectKey []byte

type ListPendingObjectStreamsParams

+ EncryptedObjectKey []byte

type RawObjectItem

+ EncryptedObjectKey []byte

type RawObjectListItem

+ EncryptedMetadataEncryptedKey []byte

+ EncryptedObjectKey []byte

v1.7.1

Dec 13, 2021

Changes in this version

type GetObjectIPsParams

+ EncryptedObjectKey []byte

type ListObjectsParams

+ IncludeCustomMetadata bool

+ IncludeSystemMetadata bool

type ListOptions

+ IncludeCustomMetadata bool

+ IncludeSystemMetadata bool

v1.7.0

Oct 6, 2021

Changes in this version

type BeginMoveObjectParams

+ NewBucket []byte

+ NewEncryptedObjectKey []byte

type FinishMoveObjectParams

+ NewBucket []byte

type RawObjectItem

+ EncryptedMetadataEncryptedKey []byte

v1.6.0

Sep 20, 2021

Changes in this version

+ const After

+ const Backward

+ const Before

+ const Forward

+ var ErrBucket = storj.ErrBucket

+ var ErrBucketNotFound = storj.ErrBucketNotFound

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

+ var ErrNoBucket = storj.ErrNoBucket

+ var ErrNoPath = storj.ErrNoPath

+ var ErrObjectNotFound = storj.ErrObjectNotFound

+ var Error = errs.Class("metaclient")

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

+ func WithRetry(ctx context.Context, fn func(ctx context.Context) error) (err error)

+ type BatchItem interface

+ BatchItem func() *pb.BatchRequestItem

+ type BatchResponse struct

+ func (resp *BatchResponse) BeginDeleteObject() (BeginDeleteObjectResponse, 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)

+ type BeginDeleteObjectParams struct

+ Bucket []byte

+ EncryptedPath []byte

+ Status int32

+ StreamID storj.StreamID

+ Version int32

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

+ type BeginDeleteObjectResponse struct

+ type BeginMoveObjectParams struct

+ Bucket []byte

+ EncryptedObjectKey []byte

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

+ type BeginMoveObjectResponse struct

+ EncryptedMetadataKey []byte

+ EncryptedMetadataKeyNonce storj.Nonce

+ Keys []EncryptedKeyAndNonce

+ StreamID storj.StreamID

+ 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 SegmentPosition

+ StreamID storj.StreamID

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

+ type BeginSegmentResponse struct

+ Limits []*pb.AddressedOrderLimit

+ PiecePrivateKey storj.PiecePrivateKey

+ RedundancyStrategy eestream.RedundancyStrategy

+ SegmentID storj.SegmentID

+ type Bucket = storj.Bucket

+ type BucketList = storj.BucketList

+ type BucketListOptions = storj.BucketListOptions

+ type Client struct

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

+ func NewClient(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) (_ RawObjectItem, err error)

+ func (client *Client) BeginMoveObject(ctx context.Context, params BeginMoveObjectParams) (_ BeginMoveObjectResponse, err error)

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

+ func (client *Client) BeginSegment(ctx context.Context, params BeginSegmentParams) (_ BeginSegmentResponse, err error)

+ 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) CreateBucket(ctx context.Context, params CreateBucketParams) (respBucket Bucket, err error)

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

+ func (client *Client) DeletePart(ctx context.Context, params DeletePartParams) (err error)

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

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

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

+ func (client *Client) FinishMoveObject(ctx context.Context, params FinishMoveObjectParams) (err error)

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

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

+ func (client *Client) GetObjectIPs(ctx context.Context, params GetObjectIPsParams) (r *GetObjectIPsResponse, err error)

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

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

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

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

+ func (client *Client) ListSegments(ctx context.Context, params ListSegmentsParams) (_ ListSegmentsResponse, err error)

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

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

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

+ func (client *Client) UpdateObjectMetadata(ctx context.Context, params UpdateObjectMetadataParams) (err error)

+ type CommitObjectParams struct

+ EncryptedMetadata []byte

+ EncryptedMetadataEncryptedKey []byte

+ EncryptedMetadataNonce storj.Nonce

+ StreamID storj.StreamID

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

+ type CommitSegmentParams struct

+ EncryptedTag []byte

+ Encryption SegmentEncryption

+ PlainSize int64

+ 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 Bucket

+ type CreateObject struct

+ ContentType string

+ Expires time.Time

+ Metadata map[string]string

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

+ type DB struct

+ func New(metainfo *Client, encStore *encryption.Store) *DB

+ func (db *DB) Close() error

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

+ func (db *DB) CreateObject(ctx context.Context, bucket, key string, createInfo *CreateObject) (object *MutableObject, err error)

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

+ func (db *DB) DeleteObject(ctx context.Context, bucket, key string) (_ Object, err error)

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

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

+ func (db *DB) GetObject(ctx context.Context, bucket, key string) (info Object, err error)

+ func (db *DB) GetObjectIPs(ctx context.Context, bucket Bucket, key string) (_ *GetObjectIPsResponse, err error)

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

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

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

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

+ func (db *DB) ListSegments(ctx context.Context, params ListSegmentsParams) (response ListSegmentsResponse, err error)

+ func (db *DB) ModifyObject(ctx context.Context, bucket, key string) (object *MutableObject, err error)

+ func (db *DB) ModifyPendingObject(ctx context.Context, bucket, key string) (object *MutableObject, err error)

+ func (db *DB) UpdateObjectMetadata(ctx context.Context, bucket, key string, newMetadata map[string]string) (err error)

+ type DeleteBucketParams struct

+ DeleteAll bool

+ Name []byte

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

+ type DeletePartParams struct

+ PartNumber uint32

+ StreamID storj.StreamID

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

+ 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 DownloadSegmentParams struct

+ Position SegmentPosition

+ StreamID storj.StreamID

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

+ type DownloadSegmentResponse struct

+ Info SegmentDownloadResponseInfo

+ Limits []*pb.AddressedOrderLimit

+ type DownloadSegmentWithRSResponse struct

+ Info SegmentDownloadInfo

+ Limits []*pb.AddressedOrderLimit

+ type EncryptedKeyAndNonce struct

+ EncryptedKey []byte

+ EncryptedKeyNonce storj.Nonce

+ Position SegmentPosition

+ type ExponentialBackoff struct

+ Max time.Duration

+ Min time.Duration

+ func (e *ExponentialBackoff) Maxed() bool

+ func (e *ExponentialBackoff) Wait()

+ type FinishMoveObjectParams struct

+ NewEncryptedMetadataKey []byte

+ NewEncryptedMetadataKeyNonce storj.Nonce

+ NewEncryptedObjectKey []byte

+ NewSegmentKeys []EncryptedKeyAndNonce

+ StreamID storj.StreamID

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

+ type GetBucketParams struct

+ Name []byte

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

+ type GetBucketResponse struct

+ Bucket Bucket

+ type GetObjectIPsParams struct

+ Bucket []byte

+ EncryptedPath []byte

+ Version int32

+ type GetObjectIPsResponse struct

+ IPPorts [][]byte

+ PieceCount int64

+ ReliablePieceCount int64

+ SegmentCount int64

+ type GetObjectParams struct

+ Bucket []byte

+ EncryptedPath []byte

+ RedundancySchemePerSegment bool

+ Version int32

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

+ type GetObjectResponse struct

+ Info RawObjectItem

+ type LastSegment = storj.LastSegment

+ type ListBucketsParams struct

+ ListOpts BucketListOptions

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

+ type ListBucketsResponse struct

+ BucketList BucketList

+ type ListDirection = storj.ListDirection

+ 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

+ Status int32

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

+ type ListObjectsResponse struct

+ Items []RawObjectListItem

+ More bool

+ type ListOptions struct

+ Cursor storj.Path

+ Delimiter rune

+ Direction ListDirection

+ IncludeMetadata bool

+ Limit int

+ Prefix storj.Path

+ Recursive bool

+ Status int32

+ func (opts ListOptions) NextPage(list ObjectList) 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 struct

+ Cursor SegmentPosition

+ Limit int32

+ Range StreamRange

+ StreamID []byte

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

+ type ListSegmentsResponse struct

+ EncryptionParameters storj.EncryptionParameters

+ Items []SegmentListItem

+ More bool

+ type MakeInlineSegmentParams struct

+ EncryptedInlineData []byte

+ EncryptedTag []byte

+ Encryption SegmentEncryption

+ PlainSize int64

+ Position SegmentPosition

+ StreamID storj.StreamID

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

+ type Meta struct

+ Data []byte

+ Expiration time.Time

+ Modified time.Time

+ Size int64

+ type MutableObject struct

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

+ func (object *MutableObject) CreateStream(ctx context.Context) (_ *MutableStream, err error)

+ func (object *MutableObject) Info() Object

+ type MutableStream struct

+ func (stream *MutableStream) BucketName() string

+ func (stream *MutableStream) Expires() time.Time

+ func (stream *MutableStream) Info() Object

+ func (stream *MutableStream) Metadata() ([]byte, error)

+ func (stream *MutableStream) Path() string

+ type Object = storj.Object

+ type ObjectInfo = storj.ObjectInfo

+ type ObjectList = storj.ObjectList

+ type ObjectListItem = storj.ObjectListItem

+ type Piece = storj.Piece

+ type RawObjectItem struct

+ Bucket string

+ Created time.Time

+ EncryptedMetadata []byte

+ EncryptedMetadataNonce storj.Nonce

+ EncryptedPath []byte

+ EncryptionParameters storj.EncryptionParameters

+ Expires time.Time

+ Modified time.Time

+ PlainSize int64

+ 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 RevokeAPIKeyParams struct

+ APIKey []byte

+ 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 SerializableMeta interface

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

+ 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

+ type UpdateObjectMetadataParams struct

+ Bucket []byte

+ EncryptedMetadata []byte

+ EncryptedMetadataEncryptedKey []byte

+ EncryptedMetadataNonce storj.Nonce

+ EncryptedObjectKey []byte

+ StreamID storj.StreamID

+ Version int32

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