example

Documentation

Index

• type Ammo
• type Gun
  • func NewGun() *Gun
  • func (l *Gun) Bind(aggregator core.Aggregator)
  • func (l *Gun) Shoot(ctx context.Context, a core.Ammo)
• type Provider
  • func NewProvider(conf ProviderConfig) *Provider
  • func (p *Provider) Acquire() (ammo core.Ammo, ok bool)
  • func (p *Provider) Release(ammo core.Ammo)
  • func (p *Provider) Run(ctx context.Context) error
• type ProviderConfig
  • func NewDefaultProviderConfig() ProviderConfig

Types

type Ammo

type Ammo struct {
	Message string
}

type Gun

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

func NewGun

func NewGun() *Gun

func (*Gun) Bind

func (l *Gun) Bind(aggregator core.Aggregator)

func (*Gun) Shoot

func (l *Gun) Shoot(ctx context.Context, a core.Ammo)

type Provider

type Provider struct {
	ProviderConfig
	// contains filtered or unexported fields
}

func NewProvider

func NewProvider(conf ProviderConfig) *Provider

func (*Provider) Acquire

func (p *Provider) Acquire() (ammo core.Ammo, ok bool)

func (*Provider) Release

func (p *Provider) Release(ammo core.Ammo)

func (*Provider) Run

func (p *Provider) Run(ctx context.Context) error

type ProviderConfig

type ProviderConfig struct {
	AmmoLimit int `config:"limit"`
}

func NewDefaultProviderConfig

func NewDefaultProviderConfig() ProviderConfig