probes

Documentation

Index

• Variables
• type Goal
  • func (goal Goal) String() string
• type Repository
• type Target
  • func New(addr addr.Addr, port int, goal Goal) Target
  • func (t *Target) GetAddr() addr.Addr
  • func (t *Target) GetDottedIP() string
  • func (t *Target) GetGoal() Goal
  • func (t *Target) GetPort() int
  • func (t *Target) GetRetries() int
  • func (t *Target) IncRetries(maxRetries int) (int, bool)

Variables

var ErrQueueIsEmpty = errors.New("queue is empty")

var ErrTargetHasExpired = errors.New("target item has expired")

var ErrTargetIsNotReady = errors.New("queue has waiting targets")

var NC = time.Time{} // no constraint

Types

type Goal

type Goal int

const (
	GoalDetails Goal = iota
	GoalPort
)

func (Goal) String

func (goal Goal) String() string

type Repository

type Repository interface {
	Add(context.Context, Target) error
	AddBetween(context.Context, Target, time.Time, time.Time) error
	Pop(context.Context) (Target, error)
	PopAny(context.Context) (Target, error)
	PopMany(context.Context, int) ([]Target, int, error)
	Count(context.Context) (int, error)
}

type Target

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

var Blank Target // nolint: gochecknoglobals

func New

func New(addr addr.Addr, port int, goal Goal) Target

func (*Target) GetAddr

func (t *Target) GetAddr() addr.Addr

func (*Target) GetDottedIP

func (t *Target) GetDottedIP() string

func (*Target) GetGoal

func (t *Target) GetGoal() Goal

func (*Target) GetPort

func (t *Target) GetPort() int

func (*Target) GetRetries

func (t *Target) GetRetries() int

func (*Target) IncRetries

func (t *Target) IncRetries(maxRetries int) (int, bool)