scenario

Documentation

Index

• type ProvAmmo
• type Provider
  • func (p *Provider[A]) Acquire() (core.Ammo, bool)
  • func (p *Provider[A]) Release(_ core.Ammo)
  • func (p *Provider[A]) Run(ctx context.Context, deps core.ProviderDeps) error
  • func (p *Provider[A]) SetAmmos(ammos []A)
  • func (p *Provider[A]) SetConfig(conf ProviderConfig)
  • func (p *Provider[A]) SetSink(sink chan A)
• type ProviderConfig

Types

type ProvAmmo

type ProvAmmo interface {
	SetID(id uint64)
	Clone() ProvAmmo
}

type Provider

type Provider[A ProvAmmo] struct {
	base.ProviderBase
	// contains filtered or unexported fields
}

func (*Provider[A]) Acquire

func (p *Provider[A]) Acquire() (core.Ammo, bool)

func (*Provider[A]) Release

func (p *Provider[A]) Release(_ core.Ammo)

func (*Provider[A]) Run

func (p *Provider[A]) Run(ctx context.Context, deps core.ProviderDeps) error

func (*Provider[A]) SetAmmos

func (p *Provider[A]) SetAmmos(ammos []A)

func (*Provider[A]) SetConfig

func (p *Provider[A]) SetConfig(conf ProviderConfig)

func (*Provider[A]) SetSink

func (p *Provider[A]) SetSink(sink chan A)

type ProviderConfig

type ProviderConfig struct {
	File            string
	Limit           uint
	Passes          uint
	ContinueOnError bool
	MaxAmmoSize     int
}