blocker

Documentation

Index

• type Blocker
  • func New(blocklister p2p.Blocklister, ...) *Blocker
  • func (b *Blocker) Close() error
  • func (b *Blocker) Flag(addr cluster.Address)
  • func (b *Blocker) PruneUnseen(seen []cluster.Address)
  • func (b *Blocker) Unflag(addr cluster.Address)

Types

type Blocker

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

func New

func New(blocklister p2p.Blocklister, flagTimeout, blockDuration, wakeUpTime time.Duration, callback func(cluster.Address), logger log.Logger) *Blocker

func (*Blocker) Close

func (b *Blocker) Close() error

Close will exit the worker loop. must be called only once.

func (*Blocker) Flag

func (b *Blocker) Flag(addr cluster.Address)

func (*Blocker) PruneUnseen

func (b *Blocker) PruneUnseen(seen []cluster.Address)

func (*Blocker) Unflag

func (b *Blocker) Unflag(addr cluster.Address)