prober

Documentation

Index

• Variables
• func Run(stop chan struct{}, stopped chan struct{}, logger *zerolog.Logger, ...)
• type Prober
  • func New(lc fx.Lifecycle, wp *proberunner.Runner, logger *zerolog.Logger) *Prober

Variables

var Module = fx.Module("prober",
	fx.Provide(
		fx.Private,
		func(cfg config.Config) proberunner.RunnerOpts {
			return proberunner.RunnerOpts{
				PollInterval: cfg.ProbePollSchedule,
				Concurrency:  cfg.ProbeConcurrency,
				ProbeTimeout: cfg.ProbeTimeout,
			}
		},
		func(cfg config.Config) portprober.Opts {
			return portprober.Opts{
				Offsets: cfg.DiscoveryRevivalPorts,
			}
		},
	),
	fx.Provide(
		portprober.New,
		detailsprober.New,
	),
	fx.Provide(
		fx.Private,
		proberunner.New,
	),
	fx.Provide(
		func(portProber portprober.PortProber, detailsProber detailsprober.DetailsProber) probers.ForGoal {
			return probers.ForGoal{
				probe.GoalPort:    portProber,
				probe.GoalDetails: detailsProber,
			}
		},
	),
	fx.Provide(New),
)

Functions

func Run

func Run(
	stop chan struct{},
	stopped chan struct{},
	logger *zerolog.Logger,
	wp *proberunner.Runner,
)

Types

type Prober

type Prober struct{}

func New

func New(
	lc fx.Lifecycle,
	wp *proberunner.Runner,
	logger *zerolog.Logger,
) *Prober