waitnext

Documentation

Overview

Package metrics provides service for collecting various metrics about peers. It is intended to be used with the kademlia where the metrics are collected.

Index

• type WaitNext
  • func New() *WaitNext
  • func (r *WaitNext) Attempts(addr penguin.Address) int
  • func (r *WaitNext) Remove(addr penguin.Address)
  • func (r *WaitNext) Set(addr penguin.Address, tryAfter time.Time, attempts int)
  • func (r *WaitNext) SetTryAfter(addr penguin.Address, tryAfter time.Time)
  • func (r *WaitNext) Waiting(addr penguin.Address) bool

Types

type WaitNext

type WaitNext struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New() *WaitNext

func (*WaitNext) Attempts

func (r *WaitNext) Attempts(addr penguin.Address) int

func (*WaitNext) Remove

func (r *WaitNext) Remove(addr penguin.Address)

func (*WaitNext) Set

func (r *WaitNext) Set(addr penguin.Address, tryAfter time.Time, attempts int)

func (*WaitNext) SetTryAfter

func (r *WaitNext) SetTryAfter(addr penguin.Address, tryAfter time.Time)

func (*WaitNext) Waiting

func (r *WaitNext) Waiting(addr penguin.Address) bool