policer

Documentation

Index

• type Option
  • func WithContainerSource(v container.Source) Option
  • func WithHeadTimeout(v time.Duration) Option
  • func WithLocalStorage(v *engine.StorageEngine) Option
  • func WithLogger(v *logger.Logger) Option
  • func WithMaxCapacity(capacity int) Option
  • func WithNetmapKeys(v netmap.AnnouncedKeys) Option
  • func WithNodeLoader(l nodeLoader) Option
  • func WithPlacementBuilder(v placement.Builder) Option
  • func WithPool(p *ants.Pool) Option
  • func WithRedundantCopyCallback(cb RedundantCopyCallback) Option
  • func WithRemoteHeader(v *headsvc.RemoteHeader) Option
  • func WithReplicator(v *replicator.Replicator) Option
• type Policer
  • func New(opts ...Option) *Policer
  • func (p *Policer) Run(ctx context.Context)
• type RedundantCopyCallback

Types

type Option

type Option func(*cfg)

Option is an option for Policer constructor.

func WithContainerSource

func WithContainerSource(v container.Source) Option

WithContainerSource returns option to set container source of Policer.

func WithHeadTimeout

func WithHeadTimeout(v time.Duration) Option

WithHeadTimeout returns option to set Head timeout of Policer.

func WithLocalStorage

func WithLocalStorage(v *engine.StorageEngine) Option

WithLocalStorage returns option to set local object storage of Policer.

func WithLogger

func WithLogger(v *logger.Logger) Option

WithLogger returns option to set Logger of Policer.

func WithMaxCapacity

func WithMaxCapacity(capacity int) Option

WithMaxCapacity returns option to set max capacity that can be set to the pool.

func WithNetmapKeys

func WithNetmapKeys(v netmap.AnnouncedKeys) Option

WithNetmapKeys returns option to set tool to work with announced public keys.

func WithNodeLoader

func WithNodeLoader(l nodeLoader) Option

WithNodeLoader returns option to set FrostFS node load source.

func WithPlacementBuilder

func WithPlacementBuilder(v placement.Builder) Option

WithPlacementBuilder returns option to set object placement builder of Policer.

func WithPool

func WithPool(p *ants.Pool) Option

WithPool returns option to set pool for policy and replication operations.

func WithRedundantCopyCallback

func WithRedundantCopyCallback(cb RedundantCopyCallback) Option

WithRedundantCopyCallback returns option to set callback to pass redundant local object copies detected by Policer.

func WithRemoteHeader

func WithRemoteHeader(v *headsvc.RemoteHeader) Option

WithRemoteHeader returns option to set object header receiver of Policer.

func WithReplicator

func WithReplicator(v *replicator.Replicator) Option

WithReplicator returns option to set object replicator of Policer.

type Policer

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

Policer represents the utility that verifies compliance with the object storage policy.

func New

func New(opts ...Option) *Policer

New creates, initializes and returns Policer instance.

func (*Policer) Run

func (p *Policer) Run(ctx context.Context)

type RedundantCopyCallback

type RedundantCopyCallback func(context.Context, oid.Address)

RedundantCopyCallback is a callback to pass the redundant local copy of the object.