Documentation ¶
Index ¶
- Variables
- func ContainerSize(s *Shard, cid *cid.ID) (uint64, error)
- func ListContainers(s *Shard) ([]*cid.ID, error)
- type ContainerSizePrm
- type ContainerSizeRes
- type Cursor
- type DeletePrm
- type DeleteRes
- type Event
- type ExistsPrm
- type ExistsRes
- type ExpiredObjectsCallback
- type GetPrm
- type GetRes
- type HeadPrm
- type HeadRes
- type ID
- type Info
- type InhumePrm
- type InhumeRes
- type ListContainersPrm
- type ListContainersRes
- type ListWithCursorPrm
- type ListWithCursorRes
- type Mode
- type Option
- func WithBlobStorOptions(opts ...blobstor.Option) Option
- func WithExpiredObjectsCallback(cb ExpiredObjectsCallback) Option
- func WithGCEventChannelInitializer(chInit func() <-chan Event) Option
- func WithGCRemoverSleepInterval(dur time.Duration) Option
- func WithGCWorkerPoolInitializer(wpInit func(int) util.WorkerPool) Option
- func WithID(id *ID) Option
- func WithLogger(l *logger.Logger) Option
- func WithMetaBaseOptions(opts ...meta.Option) Option
- func WithRefillMetabase(v bool) Option
- func WithRemoverBatchSize(sz int) Option
- func WithWriteCache(use bool) Option
- func WithWriteCacheOptions(opts ...writecache.Option) Option
- type PutPrm
- type PutRes
- type RngPrm
- type RngRes
- type SelectPrm
- type SelectRes
- type Shard
- func (s *Shard) Close() error
- func (s *Shard) ContainerSize(prm *ContainerSizePrm) (*ContainerSizeRes, error)
- func (s *Shard) Delete(prm *DeletePrm) (*DeleteRes, error)
- func (s *Shard) DumpInfo() Info
- func (s *Shard) Exists(prm *ExistsPrm) (*ExistsRes, error)
- func (s *Shard) Get(prm *GetPrm) (*GetRes, error)
- func (s *Shard) GetRange(prm *RngPrm) (*RngRes, error)
- func (s *Shard) HandleExpiredTombstones(tss map[string]struct{})
- func (s *Shard) Head(prm *HeadPrm) (*HeadRes, error)
- func (s *Shard) ID() *ID
- func (s *Shard) Inhume(prm *InhumePrm) (*InhumeRes, error)
- func (s *Shard) Init() error
- func (s *Shard) List() (*SelectRes, error)
- func (s *Shard) ListContainers(_ *ListContainersPrm) (*ListContainersRes, error)
- func (s *Shard) ListWithCursor(prm *ListWithCursorPrm) (*ListWithCursorRes, error)
- func (s *Shard) Open() error
- func (s *Shard) Put(prm *PutPrm) (*PutRes, error)
- func (s *Shard) Select(prm *SelectPrm) (*SelectRes, error)
- func (s *Shard) SetMode(m Mode) error
- func (s *Shard) ToMoveIt(prm *ToMoveItPrm) (*ToMoveItRes, error)
- func (s *Shard) WeightValues() WeightValues
- type ToMoveItPrm
- type ToMoveItRes
- type WeightValues
Constants ¶
This section is empty.
Variables ¶
var ErrEndOfListing = meta.ErrEndOfListing
ErrEndOfListing is returned from object listing with cursor when storage can't return any more objects after provided cursor. Use nil cursor object to start listing again.
Functions ¶
Types ¶
type ContainerSizePrm ¶ added in v0.15.0
type ContainerSizePrm struct {
// contains filtered or unexported fields
}
func (*ContainerSizePrm) WithContainerID ¶ added in v0.15.0
func (p *ContainerSizePrm) WithContainerID(cid *cid.ID) *ContainerSizePrm
type ContainerSizeRes ¶ added in v0.15.0
type ContainerSizeRes struct {
// contains filtered or unexported fields
}
func (*ContainerSizeRes) Size ¶ added in v0.15.0
func (r *ContainerSizeRes) Size() uint64
type Cursor ¶ added in v0.27.0
Cursor is a type for continuous object listing.
func ListWithCursor ¶ added in v0.27.0
ListWithCursor lists physical objects available in shard starting from cursor. Includes regular, tombstone and storage group objects. Does not include inhumed objects. Use cursor value from response for consecutive requests.
Returns ErrEndOfListing if there are no more objects to return or count parameter set to zero.
type DeletePrm ¶
type DeletePrm struct {
// contains filtered or unexported fields
}
DeletePrm groups the parameters of Delete operation.
type Event ¶ added in v0.16.0
type Event interface {
// contains filtered or unexported methods
}
Event represents class of external events.
func EventNewEpoch ¶ added in v0.16.0
EventNewEpoch returns new epoch event.
type ExistsPrm ¶
type ExistsPrm struct {
// contains filtered or unexported fields
}
ExistsPrm groups the parameters of Exists operation.
type ExistsRes ¶
type ExistsRes struct {
// contains filtered or unexported fields
}
ExistsRes groups resulting values of Exists operation.
type ExpiredObjectsCallback ¶ added in v0.16.0
ExpiredObjectsCallback is a callback handling list of expired objects.
type GetPrm ¶
type GetPrm struct {
// contains filtered or unexported fields
}
GetPrm groups the parameters of Get operation.
type GetRes ¶
type GetRes struct {
// contains filtered or unexported fields
}
GetRes groups resulting values of Get operation.
type HeadPrm ¶
type HeadPrm struct {
// contains filtered or unexported fields
}
HeadPrm groups the parameters of Head operation.
func (*HeadPrm) WithAddress ¶
WithAddress is a Head option to set the address of the requested object.
Option is required.
type HeadRes ¶
type HeadRes struct {
// contains filtered or unexported fields
}
HeadRes groups resulting values of Head operation.
type ID ¶
type ID []byte
ID represents Shard identifier.
Each shard should have the unique ID within a single instance of local storage.
func NewIDFromBytes ¶
NewIDFromBytes constructs ID from byte slice.
type Info ¶
type Info struct { // Identifier of the shard. ID *ID // Information about the metabase. MetaBaseInfo meta.Info // Information about the BLOB storage. BlobStorInfo blobstor.Info // Information about the Write Cache. WriteCacheInfo blobstor.Info // Weight parameters of the shard. WeightValues WeightValues }
Info groups the information about Shard.
type InhumePrm ¶
type InhumePrm struct {
// contains filtered or unexported fields
}
InhumePrm encapsulates parameters for inhume operation.
func (*InhumePrm) MarkAsGarbage ¶ added in v0.16.0
MarkAsGarbage marks object to be physically removed from shard.
Should not be called along with WithTarget.
func (*InhumePrm) WithTarget ¶
func (p *InhumePrm) WithTarget(tombstone *objectSDK.Address, addrs ...*objectSDK.Address) *InhumePrm
WithTarget sets list of objects that should be inhumed and tombstone address as the reason for inhume operation.
tombstone should not be nil, addr should not be empty. Should not be called along with MarkAsGarbage.
type ListContainersPrm ¶ added in v0.15.0
type ListContainersPrm struct{}
type ListContainersRes ¶ added in v0.15.0
type ListContainersRes struct {
// contains filtered or unexported fields
}
func (*ListContainersRes) Containers ¶ added in v0.15.0
func (r *ListContainersRes) Containers() []*cid.ID
type ListWithCursorPrm ¶ added in v0.27.0
type ListWithCursorPrm struct {
// contains filtered or unexported fields
}
ListWithCursorPrm contains parameters for ListWithCursor operation.
func (*ListWithCursorPrm) WithCount ¶ added in v0.27.0
func (p *ListWithCursorPrm) WithCount(count uint32) *ListWithCursorPrm
WithCount sets maximum amount of addresses that ListWithCursor should return.
func (*ListWithCursorPrm) WithCursor ¶ added in v0.27.0
func (p *ListWithCursorPrm) WithCursor(cursor *Cursor) *ListWithCursorPrm
WithCursor sets cursor for ListWithCursor operation. For initial request, ignore this param or use nil value. For consecutive requests, use value from ListWithCursorRes.
type ListWithCursorRes ¶ added in v0.27.0
type ListWithCursorRes struct {
// contains filtered or unexported fields
}
ListWithCursorRes contains values returned from ListWithCursor operation.
func (ListWithCursorRes) AddressList ¶ added in v0.27.0
func (r ListWithCursorRes) AddressList() []*object.Address
AddressList returns addresses selected by ListWithCursor operation.
func (ListWithCursorRes) Cursor ¶ added in v0.27.0
func (r ListWithCursorRes) Cursor() *Cursor
Cursor returns cursor for consecutive listing requests.
type Mode ¶
type Mode uint32
Mode represents enumeration of Shard work modes.
const ( // ModeActive is a Mode value for active shard. ModeActive Mode // ModeInactive is a Mode value for inactive shard. ModeInactive // ModeReadOnly is a Mode value for read-only shard. ModeReadOnly // ModeFault is a Mode value for faulty shard. ModeFault // ModeEvacuate is a Mode value for evacuating shard. ModeEvacuate )
type Option ¶
type Option func(*cfg)
Option represents Shard's constructor option.
func WithBlobStorOptions ¶
WithBlobStorOptions returns option to set internal BlobStor options.
func WithExpiredObjectsCallback ¶ added in v0.16.0
func WithExpiredObjectsCallback(cb ExpiredObjectsCallback) Option
WithExpiredObjectsCallback returns option to specify callback of the expired tombstones handler.
func WithGCEventChannelInitializer ¶ added in v0.16.0
WithGCEventChannelInitializer returns option to set set initializer of GC event channel.
func WithGCRemoverSleepInterval ¶ added in v0.16.0
WithGCRemoverSleepInterval returns option to specify sleep interval between object remover executions.
func WithGCWorkerPoolInitializer ¶ added in v0.16.0
func WithGCWorkerPoolInitializer(wpInit func(int) util.WorkerPool) Option
WithGCWorkerPoolInitializer returns option to set initializer of worker pool with specified worker number.
func WithLogger ¶
WithLogger returns option to set Shard's logger.
func WithMetaBaseOptions ¶
WithMetaBaseOptions returns option to set internal metabase options.
func WithRefillMetabase ¶ added in v0.25.0
WithRefillMetabase returns option to set flag to refill the Metabase on Shard's initialization step.
func WithRemoverBatchSize ¶ added in v0.16.0
WithRemoverBatchSize returns option to set batch size of single removal operation.
func WithWriteCache ¶
WithWriteCache returns option to toggle write cache usage.
func WithWriteCacheOptions ¶
func WithWriteCacheOptions(opts ...writecache.Option) Option
WithWriteCacheOptions returns option to set internal write cache options.
type PutPrm ¶
type PutPrm struct {
// contains filtered or unexported fields
}
PutPrm groups the parameters of Put operation.
type RngPrm ¶
type RngPrm struct {
// contains filtered or unexported fields
}
RngPrm groups the parameters of GetRange operation.
func (*RngPrm) WithAddress ¶
WithAddress is a Rng option to set the address of the requested object.
Option is required.
type RngRes ¶
type RngRes struct {
// contains filtered or unexported fields
}
RngRes groups resulting values of GetRange operation.
type SelectPrm ¶
type SelectPrm struct {
// contains filtered or unexported fields
}
SelectPrm groups the parameters of Select operation.
func (*SelectPrm) WithContainerID ¶
WithContainerID is a Select option to set the container id to search in.
func (*SelectPrm) WithFilters ¶
func (p *SelectPrm) WithFilters(fs objectSDK.SearchFilters) *SelectPrm
WithFilters is a Select option to set the object filters.
type SelectRes ¶
type SelectRes struct {
// contains filtered or unexported fields
}
SelectRes groups resulting values of Select operation.
func (*SelectRes) AddressList ¶
AddressList returns list of addresses of the selected objects.
type Shard ¶
type Shard struct {
// contains filtered or unexported fields
}
Shard represents single shard of NeoFS Local Storage Engine.
func (*Shard) ContainerSize ¶ added in v0.15.0
func (s *Shard) ContainerSize(prm *ContainerSizePrm) (*ContainerSizeRes, error)
func (*Shard) Exists ¶
Exists checks if object is presented in shard.
Returns any error encountered that does not allow to unambiguously determine the presence of an object.
func (*Shard) Get ¶
Get reads an object from shard.
Returns any error encountered that did not allow to completely read the object part.
Returns object.ErrNotFound if requested object is missing in shard.
func (*Shard) GetRange ¶
GetRange reads part of an object from shard.
Returns any error encountered that did not allow to completely read the object part.
Returns ErrRangeOutOfBounds if requested object range is out of bounds.
func (*Shard) HandleExpiredTombstones ¶ added in v0.16.0
HandleExpiredTombstones marks to be removed all objects that are protected by tombstones with string addresses from tss. If successful, marks tombstones themselves as garbage.
Does not modify tss.
func (*Shard) Inhume ¶
Inhume calls metabase. Inhume method to mark object as removed. It won't be removed physically from blobStor and metabase until `Delete` operation.
func (*Shard) ListContainers ¶ added in v0.15.0
func (s *Shard) ListContainers(_ *ListContainersPrm) (*ListContainersRes, error)
func (*Shard) ListWithCursor ¶ added in v0.27.0
func (s *Shard) ListWithCursor(prm *ListWithCursorPrm) (*ListWithCursorRes, error)
ListWithCursor lists physical objects available in shard starting from cursor. Includes regular, tombstone and storage group objects. Does not include inhumed objects. Use cursor value from response for consecutive requests.
Returns ErrEndOfListing if there are no more objects to return or count parameter set to zero.
func (*Shard) Put ¶
Put saves the object in shard.
Returns any error encountered that did not allow to completely save the object.
func (*Shard) Select ¶
Select selects the objects from shard that match select parameters.
Returns any error encountered that did not allow to completely select the objects.
func (*Shard) SetMode ¶
SetMode sets mode of the shard.
Returns any error encountered that did not allow to set shard mode.
func (*Shard) ToMoveIt ¶
func (s *Shard) ToMoveIt(prm *ToMoveItPrm) (*ToMoveItRes, error)
ToMoveIt calls metabase.ToMoveIt method to mark object as relocatable to another shard.
func (*Shard) WeightValues ¶
func (s *Shard) WeightValues() WeightValues
WeightValues returns current weight values of the Shard.
type ToMoveItPrm ¶
type ToMoveItPrm struct {
// contains filtered or unexported fields
}
ToMoveItPrm encapsulates parameters for ToMoveIt operation.
func (*ToMoveItPrm) WithAddress ¶
func (p *ToMoveItPrm) WithAddress(addr *objectSDK.Address) *ToMoveItPrm
WithAddress sets object address that should be marked to move into another shard.
type ToMoveItRes ¶
type ToMoveItRes struct{}
ToMoveItRes encapsulates results of ToMoveIt operation.
type WeightValues ¶
type WeightValues struct { // Amount of free disk space. Measured in kilobytes. FreeSpace uint64 }
WeightValues groups values of Shard weight parameters.