layer

package

Go to main page

Versions in this module

v0

v0.30.0-rc.1

May 27, 2024

v0.29.0

May 27, 2024

Changes in this version

+ var EncryptionMetadata = map[string]struct

type Cache

+ func (c *Cache) DeleteListSession(owner user.ID, key cache.ListSessionKey)

+ func (c *Cache) GetListSession(owner user.ID, key cache.ListSessionKey) *data.ListSession

+ func (c *Cache) PutListSession(owner user.ID, key cache.ListSessionKey, session *data.ListSession)

type CachesConfig

+ SessionList *cache.Config

type Client

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

type Config

+ Cache *Cache

+ type ContainerCreateResult struct

+ ContainerID cid.ID

+ HomomorphicHashDisabled bool

type CopyObjectParams

+ DstEncryption encryption.Params

+ DstSize uint64

+ SrcEncryption encryption.Params

type CreateBucketParams

+ APEEnabled bool

+ Namespace string

+ type DeleteMarkerError struct

+ ErrorCode apiErrors.ErrorCode

+ func (e DeleteMarkerError) Error() string

type DeleteObjectParams

+ IsMultiple bool

type FeatureSettings

+ BufferMaxSizeForPut func() uint64

+ FormContainerZone func(ns string) (zone string, isDefault bool)

type FeatureSettingsMock

+ func (k *FeatureSettingsMock) BufferMaxSizeForPut() uint64

+ func (k *FeatureSettingsMock) FormContainerZone(ns string) (zone string, isDefault bool)

+ type ListType int

+ const ListObjectsV1Type

+ const ListObjectsV2Type

+ type PrmContainer struct

+ ContainerID cid.ID

+ SessionToken *session.Container

type PrmContainerCreate

+ Zone string

+ type PrmContainerEACL struct

+ ContainerID cid.ID

+ SessionToken *session.Container

type PrmObjectCreate

+ BufferMaxSize uint64

+ WithoutHomomorphicHash bool

+ type PrmUserContainers struct

+ SessionToken *session.Container

+ UserID user.ID

type PutCORSParams

+ NewDecoder func(io.Reader) *xml.Decoder

type PutObjectParams

+ ContentSHA256Hash string

type TestFrostFS

+ func (t *TestFrostFS) SetContainer(cnrID cid.ID, cnr *container.Container)

type TreeService

+ InitVersionsByPrefixStream func(ctx context.Context, bktInfo *data.BucketInfo, prefix string, latestOnly bool) (data.VersionsStream, error)

type TreeServiceMock

+ func (t *TreeServiceMock) InitVersionsByPrefixStream(_ context.Context, bktInfo *data.BucketInfo, prefix string, latestOnly bool) (data.VersionsStream, error)

type UploadCopyParams

+ SrcEncryption encryption.Params

type UploadPartParams

+ ContentSHA256Hash string

+ type VersionsByPrefixStreamMock struct

+ func (s *VersionsByPrefixStreamMock) Next(context.Context) (*data.NodeVersion, error)

v0.29.0-rc.11

May 17, 2024

v0.29.0-rc.10

May 7, 2024

v0.29.0-rc.9

Apr 26, 2024

v0.29.0-rc.8

Apr 19, 2024

v0.29.0-rc.7

Apr 12, 2024

v0.29.0-rc.6

Apr 10, 2024

v0.29.0-rc.5

Apr 3, 2024

v0.29.0-rc.4

Apr 2, 2024

v0.29.0-rc.3

Mar 19, 2024

v0.29.0-rc.2

Mar 15, 2024

v0.29.0-rc.1

Mar 4, 2024

v0.28.2

May 27, 2024

v0.28.1

Jan 24, 2024

Changes in this version

type FeatureSettings

+ MD5Enabled func() bool

type FeatureSettingsMock

+ func (k *FeatureSettingsMock) MD5Enabled() bool

+ func (k *FeatureSettingsMock) SetMD5Enabled(md5Enabled bool)

type PutObjectParams

+ CompleteMD5Hash string

+ ContentMD5 string

type UploadPartParams

+ ContentMD5 string

v0.28.0

Dec 7, 2023

Changes in this version

+ const MultipartObjectSize

+ const UploadMaxSize

+ const UploadMinSize

+ var ErrGatewayTimeout = errors.New("gateway timeout")

+ func GetObjectSize(objInfo *data.ObjectInfo) (uint64, error)

type Config

+ Features FeatureSettings

+ GateOwner user.ID

type CopyObjectParams

+ CopiesNumbers []uint32

+ SrcVersioned bool

type CreateMultipartParams

+ CopiesNumbers []uint32

+ type FeatureSettings interface

+ ClientCut func() bool

+ type FeatureSettingsMock struct

+ func (k *FeatureSettingsMock) ClientCut() bool

+ func (k *FeatureSettingsMock) SetClientCut(clientCut bool)

type FrostFS

+ SearchObjects func(context.Context, PrmObjectSearch) ([]oid.ID, error)

type GetObjectParams

+ Versioned bool

type HeadObjectParams

+ func (p HeadObjectParams) Versioned() bool

+ type ObjectPayload struct

+ func (o *ObjectPayload) Read(p []byte) (int, error)

+ func (o *ObjectPayload) StreamTo(w io.Writer) error

type PrmObjectCreate

+ ClientCut bool

+ type PrmObjectSearch struct

+ Container cid.ID

+ ExactAttribute [2]string

+ FilePrefix string

type PutBucketNotificationConfigurationParams

+ CopiesNumbers []uint32

type PutCORSParams

+ CopiesNumbers []uint32

+ type PutCombinedObjectParams struct

+ BktInfo *data.BucketInfo

+ Encryption encryption.Params

+ Header map[string]string

+ Lock *data.ObjectLock

+ Object string

+ Size uint64

type PutLockInfoParams

+ CopiesNumbers []uint32

type PutObjectParams

+ CopiesNumbers []uint32

type TestFrostFS

+ func (t *TestFrostFS) SetObjectError(addr oid.Address, err error)

+ func (t *TestFrostFS) SetObjectPutError(fileName string, err error)

type UploadCopyParams

+ Versioned bool

v0.28.0-rc.1

Sep 7, 2023

v0.27.0

Jul 12, 2023

Changes in this version

+ const AESEncryptionAlgorithm

+ const AESKeySize

+ const AttributeComplianceMode

+ const AttributeDecryptedSize

+ const AttributeEncryptionAlgorithm

+ const AttributeFrostfsCopiesNumber

+ const AttributeHMACKey

+ const AttributeHMACSalt

+ const AttributeLockEnabled

+ const MaxSizePartsList

+ const MaxSizeUploadsList

+ const PathSeparator

+ const UploadCompletedParts

+ const UploadIDAttributeName

+ const UploadMaxPartNumber

+ const UploadMinPartNumber

+ const UploadPartNumberAttributeName

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

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

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

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

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

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

+ func IsAuthenticatedRequest(ctx context.Context) bool

+ func IsSystemHeader(key string) bool

+ func MimeByFilePath(path string) string

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

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

+ type AnonymousKey struct

+ Key *keys.PrivateKey

+ type BucketACL struct

+ EACL *eacl.Table

+ Info *data.BucketInfo

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

+ AccessControl *cache.Config

+ Buckets *cache.Config

+ Logger *zap.Logger

+ Names *cache.Config

+ Objects *cache.Config

+ ObjectsList *cache.Config

+ System *cache.Config

+ func DefaultCachesConfigs(logger *zap.Logger) *CachesConfig

+ type Client interface

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

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

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

+ CreateBucket func(ctx context.Context, p *CreateBucketParams) (*data.BucketInfo, error)

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

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

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

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

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

+ DeleteObjects func(ctx context.Context, p *DeleteObjectParams) []*VersionedObject

+ EphemeralKey func() *keys.PublicKey

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

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

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

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

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

+ GetBucketTagging func(ctx context.Context, bktInfo *data.BucketInfo) (map[string]string, error)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ PutBucketTagging func(ctx context.Context, bktInfo *data.BucketInfo, tagSet map[string]string) error

+ PutLockInfo func(ctx context.Context, p *PutLockInfoParams) error

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

+ PutObjectTagging func(ctx context.Context, p *PutObjectTaggingParams) (*data.NodeVersion, error)

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

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

+ func NewLayer(log *zap.Logger, frostFS FrostFS, config *Config) Client

+ type CompleteMultipartParams struct

+ Info *UploadInfoParams

+ Parts []*CompletedPart

+ type CompletedPart struct

+ ETag string

+ PartNumber int

+ type Config struct

+ AnonKey AnonymousKey

+ Caches *CachesConfig

+ ChainAddress string

+ Resolver BucketResolver

+ TreeService TreeService

+ type CopyObjectParams struct

+ CopiesNuber uint32

+ DstBktInfo *data.BucketInfo

+ DstObject string

+ Encryption encryption.Params

+ Header map[string]string

+ Lock *data.ObjectLock

+ Range *RangeParams

+ ScrBktInfo *data.BucketInfo

+ SrcObject *data.ObjectInfo

+ SrcSize int64

+ type CreateBucketParams struct

+ EACL *eacl.Table

+ LocationConstraint string

+ Name string

+ ObjectLockEnabled bool

+ Policy netmap.PlacementPolicy

+ SessionContainerCreation *session.Container

+ SessionEACL *session.Container

+ type CreateMultipartParams struct

+ CopiesNumber uint32

+ Data *UploadData

+ Header map[string]string

+ Info *UploadInfoParams

+ type DeleteBucketParams struct

+ BktInfo *data.BucketInfo

+ SessionToken *session.Container

+ type DeleteObjectParams struct

+ BktInfo *data.BucketInfo

+ Objects []*VersionedObject

+ Settings *data.BucketSettings

+ type EncryptedPart struct

+ EncryptedSize int64

+ type EventListener interface

+ Listen func(context.Context)

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

+ type FrostFS interface

+ 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.Container) error

+ DeleteObject func(context.Context, PrmObjectDelete) error

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

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

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

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

+ type GetObjectParams struct

+ BucketInfo *data.BucketInfo

+ Encryption encryption.Params

+ ObjectInfo *data.ObjectInfo

+ Range *RangeParams

+ Writer io.Writer

+ type GetObjectTaggingParams struct

+ NodeVersion *data.NodeVersion

+ ObjectVersion *ObjectVersion

+ type HeadObjectParams struct

+ BktInfo *data.BucketInfo

+ Object string

+ VersionID string

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

+ CommonPrefixes []string

+ DeleteMarker []*data.ExtendedObjectInfo

+ IsTruncated bool

+ KeyMarker string

+ NextKeyMarker string

+ NextVersionIDMarker string

+ Version []*data.ExtendedObjectInfo

+ VersionIDMarker string

+ type ListObjectVersionsParams struct

+ BktInfo *data.BucketInfo

+ Delimiter string

+ Encode string

+ KeyMarker string

+ MaxKeys int

+ Prefix string

+ VersionIDMarker string

+ type ListObjectsInfo struct

+ IsTruncated bool

+ Objects []*data.ObjectInfo

+ Prefixes []string

+ type ListObjectsInfoV1 struct

+ NextMarker string

+ type ListObjectsInfoV2 struct

+ NextContinuationToken string

+ type ListObjectsParamsCommon struct

+ BktInfo *data.BucketInfo

+ Delimiter string

+ Encode string

+ MaxKeys int

+ Prefix string

+ type ListObjectsParamsV1 struct

+ Marker string

+ type ListObjectsParamsV2 struct

+ ContinuationToken string

+ FetchOwner bool

+ StartAfter string

+ type ListPartsInfo struct

+ IsTruncated bool

+ NextPartNumberMarker int

+ Owner user.ID

+ Parts []*Part

+ type ListPartsParams struct

+ Info *UploadInfoParams

+ MaxParts int

+ PartNumberMarker int

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

+ Head *object.Object

+ Payload io.ReadCloser

+ type ObjectVersion struct

+ BktInfo *data.BucketInfo

+ NoErrorOnDeleteMarker bool

+ ObjectName string

+ VersionID string

+ type Part struct

+ ETag string

+ LastModified string

+ PartNumber int

+ Size int64

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

+ type PrmAuth struct

+ BearerToken *bearer.Token

+ PrivateKey *ecdsa.PrivateKey

+ type PrmContainerCreate struct

+ AdditionalAttributes [][2]string

+ BasicACL acl.Basic

+ CreationTime time.Time

+ Creator user.ID

+ Name string

+ Policy netmap.PlacementPolicy

+ SessionToken *session.Container

+ type PrmObjectCreate struct

+ Attributes [][2]string

+ Container cid.ID

+ CopiesNumber uint32

+ CreationTime time.Time

+ Creator user.ID

+ Filepath string

+ Locks []oid.ID

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

+ BktInfo *data.BucketInfo

+ EACL *eacl.Table

+ SessionToken *session.Container

+ type PutBucketNotificationConfigurationParams struct

+ BktInfo *data.BucketInfo

+ Configuration *data.NotificationConfiguration

+ CopiesNumber uint32

+ RequestInfo *api.ReqInfo

+ type PutCORSParams struct

+ BktInfo *data.BucketInfo

+ CopiesNumber uint32

+ Reader io.Reader

+ type PutLockInfoParams struct

+ CopiesNumber uint32

+ NewLock *data.ObjectLock

+ NodeVersion *data.NodeVersion

+ ObjVersion *ObjectVersion

+ type PutObjectParams struct

+ BktInfo *data.BucketInfo

+ CopiesNumber uint32

+ Encryption encryption.Params

+ Header map[string]string

+ Lock *data.ObjectLock

+ Object string

+ Reader io.Reader

+ Size int64

+ type PutObjectTaggingParams struct

+ NodeVersion *data.NodeVersion

+ ObjectVersion *ObjectVersion

+ TagSet map[string]string

+ type PutSettingsParams struct

+ BktInfo *data.BucketInfo

+ Settings *data.BucketSettings

+ type RangeParams struct

+ End uint64

+ Start uint64

+ type TestFrostFS struct

+ func NewTestFrostFS() *TestFrostFS

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

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

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

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

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

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

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

+ func (t *TestFrostFS) CurrentEpoch() uint64

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

+ func (t *TestFrostFS) DeleteObject(ctx context.Context, prm PrmObjectDelete) error

+ func (t *TestFrostFS) ObjectExists(objID oid.ID) bool

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

+ func (t *TestFrostFS) ReadObject(ctx context.Context, prm PrmObjectRead) (*ObjectPart, error)

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

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

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

+ type TreeService interface

+ AddPart func(ctx context.Context, bktInfo *data.BucketInfo, multipartNodeID uint64, ...) (oldObjIDToDelete oid.ID, err error)

+ AddVersion func(ctx context.Context, bktInfo *data.BucketInfo, newVersion *data.NodeVersion) (uint64, error)

+ CreateMultipartUpload func(ctx context.Context, bktInfo *data.BucketInfo, info *data.MultipartInfo) error

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

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

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

+ DeleteObjectTagging func(ctx context.Context, bktInfo *data.BucketInfo, objVersion *data.NodeVersion) error

+ GetAllVersionsByPrefix func(ctx context.Context, bktInfo *data.BucketInfo, prefix string) ([]*data.NodeVersion, error)

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

+ GetBucketTagging func(ctx context.Context, bktInfo *data.BucketInfo) (map[string]string, error)

+ GetLatestVersion func(ctx context.Context, bktInfo *data.BucketInfo, objectName string) (*data.NodeVersion, error)

+ GetLatestVersionsByPrefix func(ctx context.Context, bktInfo *data.BucketInfo, prefix string) ([]*data.NodeVersion, error)

+ GetLock func(ctx context.Context, bktInfo *data.BucketInfo, nodeID uint64) (*data.LockInfo, error)

+ GetMultipartUpload func(ctx context.Context, bktInfo *data.BucketInfo, objectName, uploadID string) (*data.MultipartInfo, error)

+ GetMultipartUploadsByPrefix func(ctx context.Context, bktInfo *data.BucketInfo, prefix string) ([]*data.MultipartInfo, error)

+ GetNotificationConfigurationNode func(ctx context.Context, bktInfo *data.BucketInfo) (oid.ID, error)

+ GetObjectTagging func(ctx context.Context, bktInfo *data.BucketInfo, objVersion *data.NodeVersion) (map[string]string, error)

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

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

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

+ GetUnversioned func(ctx context.Context, bktInfo *data.BucketInfo, objectName string) (*data.NodeVersion, error)

+ GetVersions func(ctx context.Context, bktInfo *data.BucketInfo, objectName string) ([]*data.NodeVersion, error)

+ PutBucketCORS func(ctx context.Context, bktInfo *data.BucketInfo, objID oid.ID) (oid.ID, error)

+ PutBucketTagging func(ctx context.Context, bktInfo *data.BucketInfo, tagSet map[string]string) error

+ PutLock func(ctx context.Context, bktInfo *data.BucketInfo, nodeID uint64, ...) error

+ PutNotificationConfigurationNode func(ctx context.Context, bktInfo *data.BucketInfo, objID oid.ID) (oid.ID, error)

+ PutObjectTagging func(ctx context.Context, bktInfo *data.BucketInfo, objVersion *data.NodeVersion, ...) error

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

+ RemoveVersion func(ctx context.Context, bktInfo *data.BucketInfo, nodeID uint64) error

+ type TreeServiceMock struct

+ func NewTreeService() *TreeServiceMock

+ func (t *TreeServiceMock) AddPart(ctx context.Context, bktInfo *data.BucketInfo, multipartNodeID uint64, ...) (oldObjIDToDelete oid.ID, err error)

+ func (t *TreeServiceMock) AddVersion(_ context.Context, bktInfo *data.BucketInfo, newVersion *data.NodeVersion) (uint64, error)

+ func (t *TreeServiceMock) CreateMultipartUpload(_ context.Context, bktInfo *data.BucketInfo, info *data.MultipartInfo) error

+ func (t *TreeServiceMock) DeleteBucketCORS(ctx context.Context, bktInfo *data.BucketInfo) (oid.ID, error)

+ func (t *TreeServiceMock) DeleteBucketTagging(ctx context.Context, bktInfo *data.BucketInfo) error

+ func (t *TreeServiceMock) DeleteMultipartUpload(_ context.Context, bktInfo *data.BucketInfo, multipartNodeID uint64) error

+ func (t *TreeServiceMock) DeleteObjectTagging(_ context.Context, bktInfo *data.BucketInfo, objVersion *data.NodeVersion) error

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

+ func (t *TreeServiceMock) GetBucketCORS(ctx context.Context, bktInfo *data.BucketInfo) (oid.ID, error)

+ func (t *TreeServiceMock) GetBucketTagging(ctx context.Context, bktInfo *data.BucketInfo) (map[string]string, error)

+ func (t *TreeServiceMock) GetLatestVersion(_ context.Context, bktInfo *data.BucketInfo, objectName string) (*data.NodeVersion, error)

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

+ func (t *TreeServiceMock) GetLock(ctx context.Context, bktInfo *data.BucketInfo, nodeID uint64) (*data.LockInfo, error)

+ func (t *TreeServiceMock) GetMultipartUpload(_ context.Context, bktInfo *data.BucketInfo, objectName, uploadID string) (*data.MultipartInfo, error)

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

+ func (t *TreeServiceMock) GetNotificationConfigurationNode(ctx context.Context, bktInfo *data.BucketInfo) (oid.ID, error)

+ func (t *TreeServiceMock) GetObjectTagging(_ context.Context, bktInfo *data.BucketInfo, nodeVersion *data.NodeVersion) (map[string]string, error)

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

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

+ func (t *TreeServiceMock) GetSettingsNode(_ context.Context, bktInfo *data.BucketInfo) (*data.BucketSettings, error)

+ func (t *TreeServiceMock) GetUnversioned(_ context.Context, bktInfo *data.BucketInfo, objectName string) (*data.NodeVersion, error)

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

+ func (t *TreeServiceMock) PutBucketCORS(ctx context.Context, bktInfo *data.BucketInfo, objID oid.ID) (oid.ID, error)

+ func (t *TreeServiceMock) PutBucketTagging(ctx context.Context, bktInfo *data.BucketInfo, tagSet map[string]string) error

+ func (t *TreeServiceMock) PutLock(ctx context.Context, bktInfo *data.BucketInfo, nodeID uint64, ...) error

+ func (t *TreeServiceMock) PutNotificationConfigurationNode(ctx context.Context, bktInfo *data.BucketInfo, objID oid.ID) (oid.ID, error)

+ func (t *TreeServiceMock) PutObjectTagging(_ context.Context, bktInfo *data.BucketInfo, nodeVersion *data.NodeVersion, ...) error

+ func (t *TreeServiceMock) PutSettingsNode(_ context.Context, bktInfo *data.BucketInfo, settings *data.BucketSettings) error

+ func (t *TreeServiceMock) RemoveVersion(_ context.Context, bktInfo *data.BucketInfo, nodeID uint64) error

+ type UploadCopyParams struct

+ Info *UploadInfoParams

+ PartNumber int

+ Range *RangeParams

+ SrcBktInfo *data.BucketInfo

+ SrcObjInfo *data.ObjectInfo

+ type UploadData struct

+ ACLHeaders map[string]string

+ TagSet map[string]string

+ type UploadInfo struct

+ Created time.Time

+ IsDir bool

+ Key string

+ Owner user.ID

+ UploadID string

+ type UploadInfoParams struct

+ Bkt *data.BucketInfo

+ Encryption encryption.Params

+ Key string

+ UploadID string

+ type UploadPartParams struct

+ Info *UploadInfoParams

+ PartNumber int

+ Reader io.Reader

+ Size int64

+ type VersionedObject struct

+ DeleteMarkVersion string

+ DeleteMarkerEtag string

+ Error error

+ Name string

+ VersionID string

+ func (t *VersionedObject) String() string

v0.27.0-rc.2

Apr 21, 2023

v0.27.0-rc.1

Apr 4, 2023

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