layer

Sep 13, 2024

Changes in this version

type Multipart

+ HomoHash hash.Hash

+ PayloadHash hash.Hash

Aug 20, 2024

Changes in this version

+ var ErrDecodeUserID = errors.New("decode user.ID failed")

type NeoFS

+ CurrentEpoch func() uint64

Jun 19, 2024

Changes in this version

type ListPartsInfo

+ OwnerPubKey keys.PublicKey

type Multipart

+ Link *object.Link

+ SplitFirstID *oid.ID

+ type Resolver interface

+ ResolveCID func(ctx context.Context, containerName string) (cid.ID, error)

type TreeService

+ GetPartByNumber func(ctx context.Context, bktInfo *data.BucketInfo, multipartNodeID uint64, ...) (*data.PartInfo, error)

type TreeServiceMock

+ func (t *TreeServiceMock) GetPartByNumber(ctx context.Context, bktInfo *data.BucketInfo, multipartNodeID uint64, ...) (*data.PartInfo, error)

type UploadInfo

+ OwnerPubKey keys.PublicKey

Mar 27, 2024

Changes in this version

+ const AttributeOwnerPublicKey

+ var ErrMetaEmptyParameterValue = errors.New("meta empty parameter value")

+ var ErrPartListIsEmpty = errors.New("part list is empty")

+ var ErrTooManyObjectForDeletion = errors.New("to many objects for deletion")

+ type Multipart struct

+ Children []oid.ID

+ HeaderObject *object.Object

+ MultipartHashes []hash.Hash

+ SplitID string

+ SplitPreviousID *oid.ID

type NeoFS

+ FinalizeObjectWithPayloadChecksums func(context.Context, object.Object, hash.Hash, hash.Hash, uint64) (*object.Object, error)

+ IsHomomorphicHashingEnabled func() bool

+ MaxObjectSize func() int64

type PrmContainerCreate

+ CreatorPubKey keys.PublicKey

type PrmObjectCreate

+ Multipart *Multipart

type TestNeoFS

+ func (t *TestNeoFS) FinalizeObjectWithPayloadChecksums(_ context.Context, header object.Object, metaChecksum hash.Hash, ...) (*object.Object, error)

+ func (t *TestNeoFS) IsHomomorphicHashingEnabled() bool

+ func (t *TestNeoFS) MaxObjectSize() int64

type TreeService

+ GetLastPart func(ctx context.Context, bktInfo *data.BucketInfo, multipartNodeID uint64) (*data.PartInfo, error)

+ GetPartsAfter func(ctx context.Context, bktInfo *data.BucketInfo, multipartNodeID uint64, ...) ([]*data.PartInfo, error)

type TreeServiceMock

+ func (t *TreeServiceMock) GetLastPart(ctx context.Context, bktInfo *data.BucketInfo, multipartNodeID uint64) (*data.PartInfo, error)

+ func (t *TreeServiceMock) GetPartsAfter(ctx context.Context, bktInfo *data.BucketInfo, multipartNodeID uint64, ...) ([]*data.PartInfo, error)

Aug 25, 2023

Changes in this version

type Config

+ Anonymous user.ID

+ GateKey *keys.PrivateKey

Dec 28, 2022

Changes in this version

+ func TimeNow(ctx context.Context) time.Time

type PrmContainerCreate

+ CreationTime time.Time

type PrmObjectCreate

+ CreationTime time.Time

Oct 31, 2022

Changes in this version

+ type BucketResolver interface

+ Resolve func(ctx context.Context, name string) (cid.ID, error)

+ type Cache struct

+ func NewCache(cfg *CachesConfig) *Cache

+ func (c *Cache) CleanListCacheEntriesContainingObject(objectName string, cnrID cid.ID)

+ func (c *Cache) DeleteBucket(name string)

+ func (c *Cache) DeleteCORS(bktInfo *data.BucketInfo)

+ func (c *Cache) DeleteObject(addr oid.Address)

+ func (c *Cache) DeleteObjectName(cnrID cid.ID, bktName, objName string)

+ func (c *Cache) DeleteTagging(key string)

+ func (c *Cache) GetBucket(name string) *data.BucketInfo

+ func (c *Cache) GetCORS(owner user.ID, bkt *data.BucketInfo) *data.CORSConfiguration

+ func (c *Cache) GetLastObject(owner user.ID, bktName, objName string) *data.ExtendedObjectInfo

+ func (c *Cache) GetList(owner user.ID, key cache.ObjectsListKey) []*data.NodeVersion

+ func (c *Cache) GetLockInfo(owner user.ID, key string) *data.LockInfo

+ func (c *Cache) GetNotificationConfiguration(owner user.ID, bktInfo *data.BucketInfo) *data.NotificationConfiguration

+ func (c *Cache) GetObject(owner user.ID, addr oid.Address) *data.ExtendedObjectInfo

+ func (c *Cache) GetSettings(owner user.ID, bktInfo *data.BucketInfo) *data.BucketSettings

+ func (c *Cache) GetTagging(owner user.ID, key string) map[string]string

+ func (c *Cache) PutBucket(bktInfo *data.BucketInfo)

+ func (c *Cache) PutCORS(owner user.ID, bkt *data.BucketInfo, cors *data.CORSConfiguration)

+ func (c *Cache) PutList(owner user.ID, key cache.ObjectsListKey, list []*data.NodeVersion)

+ func (c *Cache) PutLockInfo(owner user.ID, key string, lockInfo *data.LockInfo)

+ func (c *Cache) PutNotificationConfiguration(owner user.ID, bktInfo *data.BucketInfo, ...)

+ func (c *Cache) PutObject(owner user.ID, extObjInfo *data.ExtendedObjectInfo)

+ func (c *Cache) PutObjectWithName(owner user.ID, extObjInfo *data.ExtendedObjectInfo)

+ func (c *Cache) PutSettings(owner user.ID, bktInfo *data.BucketInfo, settings *data.BucketSettings)

+ func (c *Cache) PutTagging(owner user.ID, key string, tags map[string]string)

type CachesConfig

+ AccessControl *cache.Config

+ Logger *zap.Logger

+ type GetObjectTaggingParams struct

+ NodeVersion *data.NodeVersion

+ ObjectVersion *ObjectVersion

+ type PutObjectTaggingParams struct

+ NodeVersion *data.NodeVersion

+ ObjectVersion *ObjectVersion

+ TagSet map[string]string

Sep 14, 2022

Changes in this version

+ const AESEncryptionAlgorithm

+ const AESKeySize

+ const AttributeDecryptedSize

+ const AttributeEncryptionAlgorithm

+ const AttributeHMACKey

+ const AttributeHMACSalt

+ const AttributeNeofsCopiesNumber

+ var ErrNodeAccessDenied = errors.New("access denied")

+ func FormEncryptionInfo(headers map[string]string) encryption.ObjectEncryption

+ func MimeByFilePath(path string) string

type Client

+ GetExtendedObjectInfo func(ctx context.Context, p *HeadObjectParams) (*data.ExtendedObjectInfo, error)

type CopyObjectParams

+ CopiesNuber uint32

+ Encryption encryption.Params

type CreateMultipartParams

+ CopiesNumber uint32

+ type EncryptedPart struct

+ EncryptedSize int64

type GetObjectParams

+ Encryption encryption.Params

type Part

+ func ParseCompletedPartHeader(hdr string) (*Part, error)

type PrmObjectCreate

+ CopiesNumber uint32

+ Filepath string

type PutBucketNotificationConfigurationParams

+ CopiesNumber uint32

type PutCORSParams

+ CopiesNumber uint32

+ type PutLockInfoParams struct

+ CopiesNumber uint32

+ NewLock *data.ObjectLock

+ NodeVersion *data.NodeVersion

+ ObjVersion *ObjectVersion

type PutObjectParams

+ CopiesNumber uint32

+ Encryption encryption.Params

type TestNeoFS

+ func (t *TestNeoFS) AllObjects(cnrID cid.ID) []oid.ID

+ func (t *TestNeoFS) ContainerEACL(_ context.Context, cnrID cid.ID) (*eacl.Table, error)

+ func (t *TestNeoFS) SetContainerEACL(_ context.Context, table eacl.Table, _ *session.Container) error

type UploadInfoParams

+ Encryption encryption.Params

Jul 25, 2022

Changes in this version

+ const UnversionedObjectVersionID

+ var ErrNoNodeToRemove = errors.New("no node to remove")

+ var ErrNodeNotFound = errors.New("not found")

+ func MimeByFileName(name string) string

type Client

+ CreateMultipartUpload func(ctx context.Context, p *CreateMultipartParams) error

+ GetLockInfo func(ctx context.Context, obj *ObjectVersion) (*data.LockInfo, error)

+ GetObjectTaggingAndLock func(ctx context.Context, p *ObjectVersion, nodeVersion *data.NodeVersion) (map[string]string, *data.LockInfo, error)

+ PutLockInfo func(ctx context.Context, p *ObjectVersion, lock *data.ObjectLock) error

type Config

+ TreeService TreeService

type CopyObjectParams

+ ScrBktInfo *data.BucketInfo

type CreateBucketParams

+ SessionContainerCreation *session.Container

+ SessionEACL *session.Container

+ type CreateMultipartParams struct

+ Data *UploadData

+ Header map[string]string

+ Info *UploadInfoParams

type DeleteBucketParams

+ SessionToken *session.Container

type DeleteObjectParams

+ Settings *data.BucketSettings

type GetObjectParams

+ BucketInfo *data.BucketInfo

type NeoFS

+ TimeToEpoch func(context.Context, time.Time) (uint64, uint64, error)

+ type ObjectVersion struct

+ BktInfo *data.BucketInfo

+ NoErrorOnDeleteMarker bool

+ ObjectName string

+ VersionID string

type ObjectVersionInfo

+ IsUnversioned bool

type PrmContainerCreate

+ AdditionalAttributes [][2]string

type PrmObjectCreate

+ Locks []oid.ID

type PutBucketACLParams

+ SessionToken *session.Container

type PutSystemObjectParams

+ Size int64

+ type TestNeoFS struct

+ func NewTestNeoFS() *TestNeoFS

+ func (t *TestNeoFS) AddObject(key string, obj *object.Object)

+ func (t *TestNeoFS) Container(_ context.Context, id cid.ID) (*container.Container, error)

+ func (t *TestNeoFS) ContainerID(name string) (cid.ID, error)

+ func (t *TestNeoFS) CreateContainer(_ context.Context, prm PrmContainerCreate) (cid.ID, error)

+ func (t *TestNeoFS) CreateObject(_ context.Context, prm PrmObjectCreate) (oid.ID, error)

+ func (t *TestNeoFS) CurrentEpoch() uint64

+ func (t *TestNeoFS) DeleteContainer(_ context.Context, cnrID cid.ID, _ *session.Container) error

+ func (t *TestNeoFS) DeleteObject(_ context.Context, prm PrmObjectDelete) error

+ func (t *TestNeoFS) Objects() []*object.Object

+ func (t *TestNeoFS) ReadObject(_ context.Context, prm PrmObjectRead) (*ObjectPart, error)

+ func (t *TestNeoFS) SelectObjects(_ context.Context, prm PrmObjectSelect) ([]oid.ID, error)

+ func (t *TestNeoFS) TimeToEpoch(_ context.Context, futureTime time.Time) (uint64, uint64, error)

+ func (t *TestNeoFS) UserContainers(_ context.Context, _ user.ID) ([]cid.ID, error)

+ type TreeService interface

+ AddPart func(ctx context.Context, cnrID cid.ID, multipartNodeID uint64, info *data.PartInfo) (oldObjIDToDelete oid.ID, err error)

+ AddVersion func(ctx context.Context, cnrID cid.ID, newVersion *data.NodeVersion) error

+ CreateMultipartUpload func(ctx context.Context, cnrID cid.ID, info *data.MultipartInfo) error

+ DeleteBucketCORS func(ctx context.Context, cnrID cid.ID) (oid.ID, error)

+ DeleteBucketTagging func(ctx context.Context, cnrID cid.ID) error

+ DeleteMultipartUpload func(ctx context.Context, cnrID cid.ID, multipartNodeID uint64) error

+ DeleteObjectTagging func(ctx context.Context, cnrID cid.ID, objVersion *data.NodeVersion) error

+ GetAllVersionsByPrefix func(ctx context.Context, cnrID cid.ID, prefix string) ([]*data.NodeVersion, error)

+ GetBucketCORS func(ctx context.Context, cnrID cid.ID) (oid.ID, error)

+ GetBucketTagging func(ctx context.Context, cnrID cid.ID) (map[string]string, error)

+ GetLatestVersion func(ctx context.Context, cnrID cid.ID, objectName string) (*data.NodeVersion, error)

+ GetLatestVersionsByPrefix func(ctx context.Context, cnrID cid.ID, prefix string) ([]*data.NodeVersion, error)

+ GetLock func(ctx context.Context, cnrID cid.ID, nodeID uint64) (*data.LockInfo, error)

+ GetMultipartUpload func(ctx context.Context, cnrID cid.ID, objectName, uploadID string) (*data.MultipartInfo, error)

+ GetMultipartUploadsByPrefix func(ctx context.Context, cnrID cid.ID, prefix string) ([]*data.MultipartInfo, error)

+ GetNotificationConfigurationNode func(ctx context.Context, cnrID cid.ID) (oid.ID, error)

+ GetObjectTagging func(ctx context.Context, cnrID cid.ID, objVersion *data.NodeVersion) (map[string]string, error)

+ GetObjectTaggingAndLock func(ctx context.Context, cnrID cid.ID, objVersion *data.NodeVersion) (map[string]string, *data.LockInfo, error)

+ GetParts func(ctx context.Context, cnrID cid.ID, multipartNodeID uint64) ([]*data.PartInfo, error)

+ GetSettingsNode func(context.Context, cid.ID) (*data.BucketSettings, error)

+ GetUnversioned func(ctx context.Context, cnrID cid.ID, objectName string) (*data.NodeVersion, error)

+ GetVersions func(ctx context.Context, cnrID cid.ID, objectName string) ([]*data.NodeVersion, error)

+ PutBucketCORS func(ctx context.Context, cnrID cid.ID, objID oid.ID) (oid.ID, error)

+ PutBucketTagging func(ctx context.Context, cnrID cid.ID, tagSet map[string]string) error

+ PutLock func(ctx context.Context, cnrID cid.ID, nodeID uint64, lock *data.LockInfo) error

+ PutNotificationConfigurationNode func(ctx context.Context, cnrID cid.ID, objID oid.ID) (oid.ID, error)

+ PutObjectTagging func(ctx context.Context, cnrID cid.ID, objVersion *data.NodeVersion, ...) error

+ PutSettingsNode func(context.Context, cid.ID, *data.BucketSettings) error

+ RemoveVersion func(ctx context.Context, cnrID cid.ID, nodeID uint64) error

+ type TreeServiceMock struct

+ func NewTreeService() *TreeServiceMock

+ func (t *TreeServiceMock) AddPart(ctx context.Context, cnrID cid.ID, multipartNodeID uint64, info *data.PartInfo) (oldObjIDToDelete oid.ID, err error)

+ func (t *TreeServiceMock) AddVersion(_ context.Context, cnrID cid.ID, newVersion *data.NodeVersion) error

+ func (t *TreeServiceMock) CreateMultipartUpload(_ context.Context, cnrID cid.ID, info *data.MultipartInfo) error

+ func (t *TreeServiceMock) DeleteBucketCORS(ctx context.Context, cnrID cid.ID) (oid.ID, error)

+ func (t *TreeServiceMock) DeleteBucketTagging(ctx context.Context, cnrID cid.ID) error

+ func (t *TreeServiceMock) DeleteMultipartUpload(_ context.Context, cnrID cid.ID, multipartNodeID uint64) error

+ func (t *TreeServiceMock) DeleteObjectTagging(ctx context.Context, cnrID cid.ID, objVersion *data.NodeVersion) error

+ func (t *TreeServiceMock) GetAllVersionsByPrefix(_ context.Context, cnrID cid.ID, prefix string) ([]*data.NodeVersion, error)

+ func (t *TreeServiceMock) GetBucketCORS(ctx context.Context, cnrID cid.ID) (oid.ID, error)

+ func (t *TreeServiceMock) GetBucketTagging(ctx context.Context, cnrID cid.ID) (map[string]string, error)

+ func (t *TreeServiceMock) GetLatestVersion(_ context.Context, cnrID cid.ID, objectName string) (*data.NodeVersion, error)

+ func (t *TreeServiceMock) GetLatestVersionsByPrefix(_ context.Context, cnrID cid.ID, prefix string) ([]*data.NodeVersion, error)

+ func (t *TreeServiceMock) GetLock(ctx context.Context, cnrID cid.ID, nodeID uint64) (*data.LockInfo, error)

+ func (t *TreeServiceMock) GetMultipartUpload(_ context.Context, cnrID cid.ID, objectName, uploadID string) (*data.MultipartInfo, error)

+ func (t *TreeServiceMock) GetMultipartUploadsByPrefix(ctx context.Context, cnrID cid.ID, prefix string) ([]*data.MultipartInfo, error)

+ func (t *TreeServiceMock) GetNotificationConfigurationNode(ctx context.Context, cnrID cid.ID) (oid.ID, error)

+ func (t *TreeServiceMock) GetObjectTagging(ctx context.Context, cnrID cid.ID, objVersion *data.NodeVersion) (map[string]string, error)

+ func (t *TreeServiceMock) GetObjectTaggingAndLock(ctx context.Context, cnrID cid.ID, objVersion *data.NodeVersion) (map[string]string, *data.LockInfo, error)

+ func (t *TreeServiceMock) GetParts(_ context.Context, cnrID cid.ID, multipartNodeID uint64) ([]*data.PartInfo, error)

+ func (t *TreeServiceMock) GetSettingsNode(_ context.Context, id cid.ID) (*data.BucketSettings, error)

+ func (t *TreeServiceMock) GetUnversioned(_ context.Context, cnrID cid.ID, objectName string) (*data.NodeVersion, error)

+ func (t *TreeServiceMock) GetVersions(_ context.Context, cnrID cid.ID, objectName string) ([]*data.NodeVersion, error)

+ func (t *TreeServiceMock) PutBucketCORS(ctx context.Context, cnrID cid.ID, objID oid.ID) (oid.ID, error)

+ func (t *TreeServiceMock) PutBucketTagging(ctx context.Context, cnrID cid.ID, tagSet map[string]string) error

+ func (t *TreeServiceMock) PutLock(ctx context.Context, cnrID cid.ID, nodeID uint64, lock *data.LockInfo) error

+ func (t *TreeServiceMock) PutNotificationConfigurationNode(ctx context.Context, cnrID cid.ID, objID oid.ID) (oid.ID, error)

+ func (t *TreeServiceMock) PutObjectTagging(ctx context.Context, cnrID cid.ID, objVersion *data.NodeVersion, ...) error

+ func (t *TreeServiceMock) PutSettingsNode(_ context.Context, id cid.ID, settings *data.BucketSettings) error

+ func (t *TreeServiceMock) RemoveVersion(_ context.Context, cnrID cid.ID, nodeID uint64) error

type UploadCopyParams

+ SrcBktInfo *data.BucketInfo

+ type UploadData struct

+ ACLHeaders map[string]string

+ TagSet map[string]string

May 13, 2022

Changes in this version

+ const UploadCompletedParts

+ type EventListener interface

+ Listen func(context.Context)

+ Subscribe func(context.Context, string, MsgHandler) error

type PutBucketNotificationConfigurationParams

+ Configuration *data.NotificationConfiguration

Apr 29, 2022

Changes in this version

+ const AttributeComplianceMode

+ const AttributeExpirationEpoch

+ const AttributeLockEnabled

+ const AttributeRetainUntil

+ const AttributeSysTickEpoch

+ const AttributeSysTickTopic

+ const EventIntelligentTiering

+ const EventLifecycleExpiration

+ const EventLifecycleExpirationDelete

+ const EventLifecycleExpirationDeleteMarkerCreated

+ const EventLifecycleTransition

+ const EventObjectACLPut

+ const EventObjectCreated

+ const EventObjectCreatedCompleteMultipartUpload

+ const EventObjectCreatedCopy

+ const EventObjectCreatedPost

+ const EventObjectCreatedPut

+ const EventObjectRemoved

+ const EventObjectRemovedDelete

+ const EventObjectRemovedDeleteMarkerCreated

+ const EventObjectRestore

+ const EventObjectRestoreCompleted

+ const EventObjectRestoreDelete

+ const EventObjectRestorePost

+ const EventObjectTagging

+ const EventObjectTaggingDelete

+ const EventObjectTaggingPut

+ const EventReducedRedundancyLostObject

+ const EventReplication

+ const EventReplicationOperationFailedReplication

+ const EventReplicationOperationMissedThreshold

+ const EventReplicationOperationNotTracked

+ const EventReplicationOperationReplicatedAfterThreshold

+ func FormUploadPartName(uploadID, key string, partNumber int) string

type Client

+ DeleteSystemObject func(ctx context.Context, bktInfo *data.BucketInfo, name string) error

+ GetBucketSettings func(ctx context.Context, bktInfo *data.BucketInfo) (*data.BucketSettings, error)

+ HeadSystemObject func(ctx context.Context, bktInfo *data.BucketInfo, name string) (*data.ObjectInfo, error)

+ Initialize func(ctx context.Context, c Notificator) error

+ PutBucketSettings func(ctx context.Context, p *PutSettingsParams) error

+ PutSystemObject func(ctx context.Context, p *PutSystemObjectParams) (*data.ObjectInfo, error)

+ SendNotifications func(ctx context.Context, p *SendNotificationParams) error

type CopyObjectParams

+ DstBktInfo *data.BucketInfo

+ Lock *data.ObjectLock

type CreateBucketParams

+ ObjectLockEnabled bool

type DeleteBucketParams

+ BktInfo *data.BucketInfo

+ type DeleteObjectParams struct

+ BktInfo *data.BucketInfo

+ BktSettings *data.BucketSettings

+ Objects []*VersionedObject

type HeadObjectParams

+ BktInfo *data.BucketInfo

type ListObjectVersionsParams

+ BktInfo *data.BucketInfo

type ListObjectsParamsCommon

+ BktInfo *data.BucketInfo

+ type MsgHandler interface

+ HandleMessage func(context.Context, *nats.Msg) error

+ type MsgHandlerFunc func(context.Context, *nats.Msg) error

+ func (f MsgHandlerFunc) HandleMessage(ctx context.Context, msg *nats.Msg) error

+ type Notificator interface

+ Listen func(context.Context)

+ SendNotifications func(topics map[string]string, p *SendNotificationParams) error

+ SendTestNotification func(topic, bucketName, requestID, HostID string) error

+ Subscribe func(context.Context, string, MsgHandler) error

type PutBucketACLParams

+ BktInfo *data.BucketInfo

type PutBucketNotificationConfigurationParams

+ RequestInfo *api.ReqInfo

type PutObjectParams

+ BktInfo *data.BucketInfo

+ Lock *data.ObjectLock

+ type PutSettingsParams struct

+ BktInfo *data.BucketInfo

+ Settings *data.BucketSettings

type PutSystemObjectParams

+ Lock *data.ObjectLock

+ type SendNotificationParams struct

+ BktInfo *data.BucketInfo

+ Event string

+ ObjInfo *data.ObjectInfo

+ ReqInfo *api.ReqInfo

+ User string

type VersionedObject

+ DeleteMarkerEtag string

Mar 16, 2022

Changes in this version

+ var ErrAccessDenied = stderrors.New("access denied")

+ func IsAuthenticatedRequest(ctx context.Context) bool

+ func IsSystemHeader(key string) bool

type Client

+ GetBucketNotificationConfiguration func(ctx context.Context, bktInfo *data.BucketInfo) (*data.NotificationConfiguration, error)

+ PutBucketNotificationConfiguration func(ctx context.Context, p *PutBucketNotificationConfigurationParams) error

type Config

+ NotificationController *notifications.Controller

+ Resolver *resolver.BucketResolver

type CreateBucketParams

+ LocationConstraint string

type NeoFS

+ Container func(context.Context, cid.ID) (*container.Container, error)

+ ContainerEACL func(context.Context, cid.ID) (*eacl.Table, error)

+ CreateContainer func(context.Context, PrmContainerCreate) (*cid.ID, error)

+ CreateObject func(context.Context, PrmObjectCreate) (*oid.ID, error)

+ DeleteContainer func(context.Context, cid.ID, *session.Token) error

+ DeleteObject func(context.Context, PrmObjectDelete) error

+ ReadObject func(context.Context, PrmObjectRead) (*ObjectPart, error)

+ SelectObjects func(context.Context, PrmObjectSelect) ([]oid.ID, error)

+ SetContainerEACL func(context.Context, eacl.Table) error

+ UserContainers func(context.Context, owner.ID) ([]cid.ID, error)

+ type ObjectPart struct

+ Head *object.Object

+ Payload io.ReadCloser

+ type PrmAuth struct

+ BearerToken *token.BearerToken

+ PrivateKey *ecdsa.PrivateKey

+ type PrmContainerCreate struct

+ BasicACL acl.BasicACL

+ Creator owner.ID

+ LocationConstraintAttribute *container.Attribute

+ Name string

+ Policy netmap.PlacementPolicy

+ SessionToken *session.Token

+ Time time.Time

+ type PrmObjectCreate struct

+ Attributes [][2]string

+ Container cid.ID

+ Creator owner.ID

+ Filename string

+ Payload io.Reader

+ PayloadSize uint64

+ type PrmObjectDelete struct

+ Container cid.ID

+ Object oid.ID

+ type PrmObjectRead struct

+ Container cid.ID

+ Object oid.ID

+ PayloadRange [2]uint64

+ WithHeader bool

+ WithPayload bool

+ type PrmObjectSelect struct

+ Container cid.ID

+ ExactAttribute [2]string

+ FilePrefix string

+ type PutBucketNotificationConfigurationParams struct

+ BktInfo *data.BucketInfo

+ Reader io.Reader

+ type VersionOption func(*versionOptions)

+ func FromUnversioned() VersionOption

Dec 16, 2021

Changes in this version

+ const DelMarkFullObject

+ const MaxSizePartsList

+ const MaxSizeUploadsList

+ const UploadIDAttributeName

+ const UploadKeyAttributeName

+ const UploadMaxPartNumber

+ const UploadMinPartNumber

+ const UploadPartKeyPrefix

+ const UploadPartNumberAttributeName

+ const VersionsDeleteMarkAttr

+ type AnonymousKey struct

+ Key *keys.PrivateKey

type Client

+ AbortMultipartUpload func(ctx context.Context, p *UploadInfoParams) error

+ CompleteMultipartUpload func(ctx context.Context, p *CompleteMultipartParams) (*data.ObjectInfo, error)

+ DeleteBucketCORS func(ctx context.Context, bktInfo *data.BucketInfo) error

+ EphemeralKey func() *keys.PublicKey

+ GetBucketCORS func(ctx context.Context, bktInfo *data.BucketInfo) (*data.CORSConfiguration, error)

+ GetUploadInitInfo func(ctx context.Context, p *UploadInfoParams) (*data.ObjectInfo, error)

+ ListMultipartUploads func(ctx context.Context, p *ListMultipartUploadsParams) (*ListMultipartUploadsInfo, error)

+ ListParts func(ctx context.Context, p *ListPartsParams) (*ListPartsInfo, error)

+ PutBucketCORS func(ctx context.Context, p *PutCORSParams) error

+ UploadPart func(ctx context.Context, p *UploadPartParams) (*data.ObjectInfo, error)

+ UploadPartCopy func(ctx context.Context, p *UploadCopyParams) (*data.ObjectInfo, error)

+ type CompleteMultipartParams struct

+ Info *UploadInfoParams

+ Parts []*CompletedPart

+ type CompletedPart struct

+ ETag string

+ PartNumber int

+ type Config struct

+ AnonKey AnonymousKey

+ Caches *CachesConfig

+ ChainAddress string

type CopyObjectParams

+ Range *RangeParams

type CreateBucketParams

+ SessionToken *session.Token

+ type ListMultipartUploadsInfo struct

+ IsTruncated bool

+ NextKeyMarker string

+ NextUploadIDMarker string

+ Prefixes []string

+ Uploads []*UploadInfo

+ type ListMultipartUploadsParams struct

+ Bkt *data.BucketInfo

+ Delimiter string

+ EncodingType string

+ KeyMarker string

+ MaxUploads int

+ Prefix string

+ UploadIDMarker string

+ type ListPartsInfo struct

+ IsTruncated bool

+ NextPartNumberMarker int

+ Owner *owner.ID

+ Parts []*Part

+ type ListPartsParams struct

+ Info *UploadInfoParams

+ MaxParts int

+ PartNumberMarker int

+ type Part struct

+ ETag string

+ LastModified string

+ PartNumber int

+ Size int64

+ type PutCORSParams struct

+ BktInfo *data.BucketInfo

+ Reader io.Reader

+ type PutSystemObjectParams struct

+ BktInfo *data.BucketInfo

+ Metadata map[string]string

+ ObjName string

+ Prefix string

+ Reader io.Reader

+ type UploadCopyParams struct

+ Info *UploadInfoParams

+ PartNumber int

+ Range *RangeParams

+ SrcObjInfo *data.ObjectInfo

+ type UploadInfo struct

+ Created time.Time

+ IsDir bool

+ Key string

+ Owner *owner.ID

+ UploadID string

+ type UploadInfoParams struct

+ Bkt *data.BucketInfo

+ Key string

+ UploadID string

+ type UploadPartParams struct

+ Header map[string]string

+ Info *UploadInfoParams

+ PartNumber int

+ Reader io.Reader

+ Size int64

Sep 24, 2021

Changes in this version

+ func GetBoxData(ctx context.Context) (*accessbox.Box, error)

+ type BucketACL struct

+ EACL *eacl.Table

+ Info *data.BucketInfo

+ type BucketSettings struct

+ VersioningEnabled bool

+ type CachesConfig struct

+ Buckets *cache.Config

+ Names *cache.Config

+ Objects *cache.Config

+ ObjectsList *cache.Config

+ System *cache.Config

+ func DefaultCachesConfigs() *CachesConfig

type Client

+ DeleteBucketTagging func(ctx context.Context, bucket string) error

+ DeleteObjectTagging func(ctx context.Context, p *data.ObjectInfo) error

+ GetBucketACL func(ctx context.Context, name string) (*BucketACL, error)

+ GetBucketTagging func(ctx context.Context, bucket string) (map[string]string, error)

+ GetBucketVersioning func(ctx context.Context, name string) (*BucketSettings, error)

+ GetObjectTagging func(ctx context.Context, p *data.ObjectInfo) (map[string]string, error)

+ ListObjectsV1 func(ctx context.Context, p *ListObjectsParamsV1) (*ListObjectsInfoV1, error)

+ ListObjectsV2 func(ctx context.Context, p *ListObjectsParamsV2) (*ListObjectsInfoV2, error)

+ PutBucketACL func(ctx context.Context, p *PutBucketACLParams) error

+ PutBucketTagging func(ctx context.Context, bucket string, tagSet map[string]string) error

+ PutBucketVersioning func(ctx context.Context, p *PutVersioningParams) (*data.ObjectInfo, error)

+ PutObjectTagging func(ctx context.Context, p *PutTaggingParams) error

type CreateBucketParams

+ BoxData *accessbox.Box

+ EACL *eacl.Table

type GetObjectParams

+ ObjectInfo *data.ObjectInfo

+ VersionID string

+ type HeadObjectParams struct

+ Bucket string

+ Object string

+ VersionID string

+ type ListObjectsInfoV1 struct

+ NextMarker string

+ type ListObjectsInfoV2 struct

+ NextContinuationToken string

+ type ListObjectsParamsCommon struct

+ Bucket string

+ Delimiter string

+ Encode string

+ MaxKeys int

+ Prefix string

+ type ListObjectsParamsV1 struct

+ Marker string

+ type ListObjectsParamsV2 struct

+ ContinuationToken string

+ FetchOwner bool

+ StartAfter string

+ type PutBucketACLParams struct

+ EACL *eacl.Table

+ Name string

+ type PutTaggingParams struct

+ ObjectInfo *data.ObjectInfo

+ TagSet map[string]string

+ type PutVersioningParams struct

+ Bucket string

+ Settings *BucketSettings

+ type VersionedObject struct

+ DeleteMarkVersion string

+ Error error

+ Name string

+ VersionID string

+ func (t *VersionedObject) String() string

Jul 16, 2021

Changes in this version

+ var ErrBucketAlreadyExists = errors.New("bucket exists")

+ var ErrBucketNotFound = errors.New("bucket not found")

type Client

+ CreateBucket func(ctx context.Context, p *CreateBucketParams) (*cid.ID, error)

+ DeleteBucket func(ctx context.Context, p *DeleteBucketParams) error

+ ListObjectVersions func(ctx context.Context, p *ListObjectVersionsParams) (*ListObjectVersionsInfo, error)

type CopyObjectParams

+ SrcSize int64

+ type CreateBucketParams struct

+ ACL uint32

+ Name string

+ Policy *netmap.PlacementPolicy

+ type DeleteBucketParams struct

+ Name string

+ type DeletedObjectInfo struct

+ IsLatest bool

+ Key string

+ LastModified string

+ Owner *owner.ID

+ VersionID string

type GetObjectParams

+ Range *RangeParams

+ type ListObjectVersionsInfo struct

+ CommonPrefixes []*string

+ DeleteMarker []*DeletedObjectInfo

+ IsTruncated bool

+ KeyMarker string

+ NextKeyMarker string

+ NextVersionIDMarker string

+ Version []*ObjectVersionInfo

+ VersionIDMarker string

+ type ListObjectVersionsParams struct

+ Bucket string

+ Delimiter string

+ Encode string

+ KeyMarker string

+ MaxKeys int

+ Prefix string

+ VersionIDMarker string

type ListObjectsInfo

+ NextMarker string

type ListObjectsParams

+ Marker string

+ Version int

type ObjectInfo

+ HashSum string

+ type ObjectVersionInfo struct

+ IsLatest bool

+ Object *ObjectInfo

+ VersionID string

+ type RangeParams struct

+ End uint64

+ Start uint64

Jun 10, 2021

Changes in this version

+ const PathSeparator

+ var ErrObjectExists = errors.New("object exists")

+ var ErrObjectNotExists = errors.New("object not exists")

+ func NameFromString(name string) (string, string)

+ type BucketInfo struct

+ CID *cid.ID

+ Created time.Time

+ Name string

+ Owner *owner.ID

+ type Client interface

+ CopyObject func(ctx context.Context, p *CopyObjectParams) (*ObjectInfo, error)

+ DeleteObject func(ctx context.Context, bucket, object string) error

+ DeleteObjects func(ctx context.Context, bucket string, objects []string) []error

+ GetBucketInfo func(ctx context.Context, name string) (*BucketInfo, error)

+ GetObject func(ctx context.Context, p *GetObjectParams) error

+ GetObjectInfo func(ctx context.Context, bucketName, objectName string) (*ObjectInfo, error)

+ ListBuckets func(ctx context.Context) ([]*BucketInfo, error)

+ ListObjects func(ctx context.Context, p *ListObjectsParams) (*ListObjectsInfo, error)

+ PutObject func(ctx context.Context, p *PutObjectParams) (*ObjectInfo, error)

+ func NewLayer(log *zap.Logger, conns pool.Pool) Client

+ type CopyObjectParams struct

+ DstBucket string

+ DstObject string

+ Header map[string]string

+ SrcBucket string

+ SrcObject string

+ type GetObjectParams struct

+ Bucket string

+ Length int64

+ Object string

+ Offset int64

+ Writer io.Writer

+ type ListObjectsInfo struct

+ ContinuationToken string

+ IsTruncated bool

+ NextContinuationToken string

+ Objects []*ObjectInfo

+ Prefixes []string

+ type ListObjectsParams struct

+ Bucket string

+ Delimiter string

+ MaxKeys int

+ Prefix string

+ Token string

+ type NeoFS interface

+ Get func(ctx context.Context, address *object.Address) (*object.Object, error)

+ type ObjectInfo struct

+ Bucket string

+ ContentType string

+ Created time.Time

+ Headers map[string]string

+ Name string

+ Owner *owner.ID

+ Size int64

+ func (o *ObjectInfo) ID() *object.ID

+ func (o *ObjectInfo) IsDir() bool

+ type Params struct

+ Key *ecdsa.PrivateKey

+ Logger *zap.Logger

+ Pool pool.Pool

+ Timeout time.Duration

+ type PutObjectParams struct

+ Bucket string

+ Header map[string]string

+ Object string

+ Reader io.Reader

+ Size int64