probe

Documentation

Overview

Code generated by go run github.com/nfx/slrp/ql/generator/main.go Foo. DO NOT EDIT.

Code generated by go run github.com/nfx/slrp/ql/generator/main.go Foo. DO NOT EDIT.

*

Per source, we can have the following state transitions

```mermaid # https://mermaid.live/ stateDiagram

direction LR
Idle --> Running
Running --> Failed
Running --> Idle
Failed --> Running
state Running {
	direction LR
	[*] --> Scheduled
	Scheduled --> New
	Scheduled --> Ignored
	New --> Probing
	Probing --> Found
	Probing --> Timeout
	Probing --> Blacklisted
	Timeout --> Reverify
	Reverify --> Scheduled
	Found --> [*]
	Blacklisted --> [*]
}

````

Index

• Constants
• func NewBlacklistApi(probe *Probe, info *ipinfo.Lookup) *blacklistDashboard
• func NewReverifyApi(probe *Probe, info *ipinfo.Lookup) *reverifyDashboard
• type Probe
  • func NewProbe(stats *stats.Stats, p *pool.Pool, c checker.Checker) *Probe
  • func (p *Probe) Configure(c app.Config) error
  • func (p *Probe) Forget(ctx context.Context, proxy pmux.Proxy, err error) bool
  • func (p *Probe) HttpDeletetByID(id string, r *http.Request) (interface{}, error)
  • func (p *Probe) HttpGet(_ *http.Request) (interface{}, error)
  • func (p *Probe) MarshalBinary() ([]byte, error)
  • func (p *Probe) Schedule(ctx context.Context, proxy pmux.Proxy, source int) bool
  • func (p *Probe) Snapshot() internal
  • func (p *Probe) Start(ctx app.Context)
  • func (p *Probe) UnmarshalBinary(data []byte) error
• type Stats2

Constants

const Reverify int = 0

Functions

func NewBlacklistApi

func NewBlacklistApi(probe *Probe, info *ipinfo.Lookup) *blacklistDashboard

func NewReverifyApi

func NewReverifyApi(probe *Probe, info *ipinfo.Lookup) *reverifyDashboard

Types

type Probe

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

func NewProbe

func NewProbe(stats *stats.Stats, p *pool.Pool, c checker.Checker) *Probe

func (*Probe) Configure

func (p *Probe) Configure(c app.Config) error

func (*Probe) Forget

func (p *Probe) Forget(ctx context.Context, proxy pmux.Proxy, err error) bool

func (*Probe) HttpDeletetByID

func (p *Probe) HttpDeletetByID(id string, r *http.Request) (interface{}, error)

func (*Probe) HttpGet

func (p *Probe) HttpGet(_ *http.Request) (interface{}, error)

func (*Probe) MarshalBinary

func (p *Probe) MarshalBinary() ([]byte, error)

func (*Probe) Schedule

func (p *Probe) Schedule(ctx context.Context, proxy pmux.Proxy, source int) bool

func (*Probe) Snapshot

func (p *Probe) Snapshot() internal

func (*Probe) Start

func (p *Probe) Start(ctx app.Context)

func (*Probe) UnmarshalBinary

func (p *Probe) UnmarshalBinary(data []byte) error

type Stats2

type Stats2 struct {
	Reverify             int
	Blacklist            int
	Seen                 int
	AverageVerifyAttempt int64
	ReverifyAttempts     []int
	Contribution         map[string]int
	Exclusive            map[string]int
	Dirty                map[string]int
}