prober

Documentation

Index

• func MultipleICMP(ctx context.Context, module config.Module, logger log.Logger, ...) (rtt float32, ttl int, loss int, jitter float32, success bool)
• func ProbeDNS(ctx context.Context, target string, module config.Module, ...) bool
• func ProbeGRPC(ctx context.Context, target string, module config.Module, ...) (success bool)
• func ProbeHTTP(ctx context.Context, target string, module config.Module, ...) (success bool)
• func ProbeICMP(ctx context.Context, target string, module config.Module, ...) (isSuccess bool)
• func ProbeSingleICMP(ctx context.Context, module config.Module, logger log.Logger, ...)
• func ProbeTCP(ctx context.Context, target string, module config.Module, ...) bool
• type GRPCHealthCheck
  • func NewGrpcHealthCheckClient(conn *grpc.ClientConn) GRPCHealthCheck
• type ProbeFn

Functions

func MultipleICMP

func MultipleICMP(ctx context.Context, module config.Module, logger log.Logger, dstIPAddr *net.IPAddr) (rtt float32, ttl int, loss int, jitter float32, success bool)

Handle few icmp probes concurrently and count packet loss percent

func ProbeDNS

func ProbeDNS(ctx context.Context, target string, module config.Module, registry *prometheus.Registry, logger log.Logger) bool

func ProbeGRPC

func ProbeGRPC(ctx context.Context, target string, module config.Module, registry *prometheus.Registry, logger log.Logger) (success bool)

func ProbeHTTP

func ProbeHTTP(ctx context.Context, target string, module config.Module, registry *prometheus.Registry, logger log.Logger) (success bool)

func ProbeICMP

func ProbeICMP(ctx context.Context, target string, module config.Module, result config.JSONstruct, logger log.Logger) (isSuccess bool)

Main func to initiate icmp probe or probes - depends on "packets" value.

func ProbeSingleICMP

func ProbeSingleICMP(ctx context.Context, module config.Module, logger log.Logger, dstIPAddr *net.IPAddr, rtt chan float32, ttl chan int, success chan int)

Run single icmp probe

func ProbeTCP

func ProbeTCP(ctx context.Context, target string, module config.Module, registry *prometheus.Registry, logger log.Logger) bool

Types

type GRPCHealthCheck

type GRPCHealthCheck interface {
	Check(c context.Context, service string) (bool, codes.Code, *peer.Peer, string, error)
}

func NewGrpcHealthCheckClient

func NewGrpcHealthCheckClient(conn *grpc.ClientConn) GRPCHealthCheck

type ProbeFn

type ProbeFn func(ctx context.Context, target string, config config.Module, some_json config.JSONstruct, logger log.Logger) bool