blocker

Documentation

Index

• type Blocker
  • func New(skydClient *api.SkydClient, db *database.DB, logger *logrus.Logger) (*Blocker, error)
  • func (bl *Blocker) BlockHashes(hashes []database.Hash) (int, int, error)
  • func (bl *Blocker) Start() error
  • func (bl *Blocker) Stop() error

Types

type Blocker

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

Blocker scans the database for skylinks that should be blocked and calls skyd to block them.

func New

func New(skydClient *api.SkydClient, db *database.DB, logger *logrus.Logger) (*Blocker, error)

New returns a new Blocker with the given parameters.

func (*Blocker) BlockHashes

func (bl *Blocker) BlockHashes(hashes []database.Hash) (int, int, error)

BlockHashes blocks the given list of hashes. It returns the amount of hashes which were blocked successfully, the amount that were invalid, and a potential error.

func (*Blocker) Start

func (bl *Blocker) Start() error

Start launches the two backgrounds that periodically scan for new hashes to block or retry hashes that failed to get blocked the first time around.

func (*Blocker) Stop

func (bl *Blocker) Stop() error

Stop waits for the blocker's waitgroup and times out after one minute.