straynodes

Documentation

Index

• type Chore
  • func NewChore(log *zap.Logger, cache *overlay.Service, config Config) *Chore
  • func (chore *Chore) Close() error
  • func (chore *Chore) Run(ctx context.Context) (err error)
• type Config

Types

type Chore

type Chore struct {
	Loop *sync2.Cycle
	// contains filtered or unexported fields
}

Chore disqualifies stray nodes.

func NewChore

func NewChore(log *zap.Logger, cache *overlay.Service, config Config) *Chore

NewChore creates a new stray nodes Chore.

func (*Chore) Close

func (chore *Chore) Close() error

Close closes chore.

func (*Chore) Run

func (chore *Chore) Run(ctx context.Context) (err error)

Run runs the chore.

type Config

type Config struct {
	EnableDQ                  bool          `` /* 126-byte string literal not displayed */
	Interval                  time.Duration `help:"how often to check for and DQ stray nodes" releaseDefault:"168h" devDefault:"5m" testDefault:"1m"`
	MaxDurationWithoutContact time.Duration `` /* 148-byte string literal not displayed */
	Limit                     int           `` /* 153-byte string literal not displayed */
}

Config contains configurable values for stray nodes chore.