blobovnicza

package
v0.28.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 8, 2022 License: GPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrFull = errors.New("blobovnicza is full")

ErrFull is returned when trying to save an object to a filled blobovnicza.

Functions

func IsErrNotFound added in v0.28.0

func IsErrNotFound(err error) bool

IsErrNotFound checks if the error returned by Blobovnicza Get/Delete method corresponds to the missing object.

func IterateAddresses added in v0.26.0

func IterateAddresses(blz *Blobovnicza, f func(oid.Address) error) error

IterateAddresses is a helper function which iterates over Blobovnicza and passes addresses of the objects to f.

func IterateObjects added in v0.25.0

func IterateObjects(blz *Blobovnicza, f func([]byte) error) error

IterateObjects is a helper function which iterates over Blobovnicza and passes binary objects to f.

Types

type Blobovnicza

type Blobovnicza struct {
	// contains filtered or unexported fields
}

Blobovnicza represents the implementation of NeoFS Blobovnicza.

func New

func New(opts ...Option) *Blobovnicza

New creates and returns a new Blobovnicza instance.

func (*Blobovnicza) Close

func (b *Blobovnicza) Close() error

Close releases all internal database resources.

func (*Blobovnicza) Delete

func (b *Blobovnicza) Delete(prm DeletePrm) (DeleteRes, error)

Delete removes an object from Blobovnicza by address.

Returns any error encountered that did not allow to completely delete the object.

Returns an error of type apistatus.ObjectNotFound if the object to be deleted is not in blobovnicza.

Should not be called in read-only configuration.

func (*Blobovnicza) Get

func (b *Blobovnicza) Get(prm GetPrm) (GetRes, error)

Get reads an object from Blobovnicza by address.

Returns any error encountered that did not allow to completely read the object.

Returns an error of type apistatus.ObjectNotFound if the requested object is not presented in Blobovnicza.

func (*Blobovnicza) Init

func (b *Blobovnicza) Init() error

Init initializes internal database structure.

If Blobovnicza is already initialized, no action is taken.

Should not be called in read-only configuration.

func (*Blobovnicza) Iterate added in v0.25.0

func (b *Blobovnicza) Iterate(prm IteratePrm) (IterateRes, error)

Iterate goes through all stored objects, and passes IterationElement to parameterized handler until error return.

Decodes object addresses if DecodeAddresses was called. Don't read object data if WithoutData was called.

Returns handler's errors directly. Returns nil after iterating finish.

Handler should not retain object data. Handler must not be nil.

func (*Blobovnicza) Open

func (b *Blobovnicza) Open() error

Open opens an internal database at the configured path with the configured permissions.

If the database file does not exist, it will be created automatically.

func (*Blobovnicza) Put

func (b *Blobovnicza) Put(prm PutPrm) (PutRes, error)

Put saves an object in Blobovnicza.

If binary representation of the object is not set, it is calculated via Marshal method.

The size of the object MUST BE less that or equal to the size specified in WithObjectSizeLimit option.

Returns any error encountered that did not allow to completely save the object.

Returns ErrFull if blobovnicza is filled.

Should not be called in read-only configuration.

type DeletePrm

type DeletePrm struct {
	// contains filtered or unexported fields
}

DeletePrm groups the parameters of Delete operation.

func (*DeletePrm) SetAddress

func (p *DeletePrm) SetAddress(addr oid.Address)

SetAddress sets the address of the requested object.

type DeleteRes

type DeleteRes struct {
}

DeleteRes groups the resulting values of Delete operation.

type GetPrm

type GetPrm struct {
	// contains filtered or unexported fields
}

GetPrm groups the parameters of Get operation.

func (*GetPrm) SetAddress

func (p *GetPrm) SetAddress(addr oid.Address)

SetAddress sets the address of the requested object.

type GetRes

type GetRes struct {
	// contains filtered or unexported fields
}

GetRes groups the resulting values of Get operation.

func (GetRes) Object

func (p GetRes) Object() []byte

Object returns binary representation of the requested object.

type ID

type ID []byte

ID represents Blobovnicza identifier.

func NewIDFromBytes

func NewIDFromBytes(v []byte) *ID

NewIDFromBytes constructs an ID from a byte slice.

func (ID) String

func (id ID) String() string

type IteratePrm added in v0.25.0

type IteratePrm struct {
	// contains filtered or unexported fields
}

IteratePrm groups the parameters of Iterate operation.

func (*IteratePrm) DecodeAddresses added in v0.26.0

func (x *IteratePrm) DecodeAddresses()

DecodeAddresses sets flag to unmarshal object addresses.

func (*IteratePrm) IgnoreErrors added in v0.27.5

func (x *IteratePrm) IgnoreErrors()

IgnoreErrors makes all errors to be ignored.

func (*IteratePrm) SetHandler added in v0.25.0

func (x *IteratePrm) SetHandler(h IterationHandler)

SetHandler sets handler to be called iteratively.

func (*IteratePrm) WithoutData added in v0.26.0

func (x *IteratePrm) WithoutData()

WithoutData sets flag to not read data of the objects.

type IterateRes added in v0.25.0

type IterateRes struct {
}

IterateRes groups the resulting values of Iterate operation.

type IterationElement added in v0.25.0

type IterationElement struct {
	// contains filtered or unexported fields
}

IterationElement represents a unit of elements through which Iterate operation passes.

func (IterationElement) Address added in v0.26.0

func (x IterationElement) Address() oid.Address

Address returns address of the stored object.

func (IterationElement) ObjectData added in v0.25.0

func (x IterationElement) ObjectData() []byte

ObjectData returns stored object in a binary representation.

type IterationHandler added in v0.25.0

type IterationHandler func(IterationElement) error

IterationHandler is a generic processor of IterationElement.

type Option

type Option func(*cfg)

Option is an option of Blobovnicza's constructor.

func ReadOnly added in v0.26.0

func ReadOnly() Option

ReadOnly returns an option to open Blobovnicza in read-only mode.

func WithFullSizeLimit

func WithFullSizeLimit(lim uint64) Option

WithFullSizeLimit returns an option to set the maximum sum size of all stored objects.

func WithLogger

func WithLogger(l *logger.Logger) Option

WithLogger returns an option to specify Blobovnicza's logger.

func WithObjectSizeLimit

func WithObjectSizeLimit(lim uint64) Option

WithObjectSizeLimit returns an option to specify the maximum size of the objects stored in Blobovnicza.

func WithPath

func WithPath(path string) Option

WithPath returns option to set system path to Blobovnicza.

func WithPermissions

func WithPermissions(perm fs.FileMode) Option

WithPermissions returns an option to specify permission bits of Blobovnicza's system path.

type PutPrm

type PutPrm struct {
	// contains filtered or unexported fields
}

PutPrm groups the parameters of Put operation.

func (*PutPrm) SetAddress

func (p *PutPrm) SetAddress(addr oid.Address)

SetAddress sets the address of the saving object.

func (*PutPrm) SetMarshaledObject

func (p *PutPrm) SetMarshaledObject(data []byte)

SetMarshaledObject sets binary representation of the object.

type PutRes

type PutRes struct {
}

PutRes groups the resulting values of Put operation.

Jump to

Keyboard shortcuts

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