prober

Documentation

Overview

Package prober provides a prober for running a set of probes.

Prober takes in a config proto which dictates what probes should be created with what configuration, and manages the asynchronous fan-in/fan-out of the metrics data from these probes.

Index

• type Prober
  • func (pr *Prober) AddProbe(ctx context.Context, req *pb.AddProbeRequest) (*pb.AddProbeResponse, error)
  • func (pr *Prober) Init(ctx context.Context, cfg *configpb.ProberConfig, l *logger.Logger) error
  • func (pr *Prober) ListProbes(ctx context.Context, req *pb.ListProbesRequest) (*pb.ListProbesResponse, error)
  • func (pr *Prober) RemoveProbe(ctx context.Context, req *pb.RemoveProbeRequest) (*pb.RemoveProbeResponse, error)
  • func (pr *Prober) Start(ctx context.Context)

Types

type Prober

type Prober struct {
	Probes  map[string]*probes.ProbeInfo
	Servers []*servers.ServerInfo

	Surfacers []*surfacers.SurfacerInfo

	// Used by GetConfig for /config handler.
	TextConfig string

	// Required for all gRPC server implementations.
	spb.UnimplementedCloudproberServer
	// contains filtered or unexported fields
}

Prober represents a collection of probes where each probe implements the Probe interface.

func (*Prober) AddProbe

func (pr *Prober) AddProbe(ctx context.Context, req *pb.AddProbeRequest) (*pb.AddProbeResponse, error)

AddProbe adds the given probe to cloudprober.

func (*Prober) Init

func (pr *Prober) Init(ctx context.Context, cfg *configpb.ProberConfig, l *logger.Logger) error

Init initialize prober with the given config file.

func (*Prober) ListProbes

func (pr *Prober) ListProbes(ctx context.Context, req *pb.ListProbesRequest) (*pb.ListProbesResponse, error)

ListProbes gRPC method returns the list of probes from the in-memory database.

func (*Prober) RemoveProbe

func (pr *Prober) RemoveProbe(ctx context.Context, req *pb.RemoveProbeRequest) (*pb.RemoveProbeResponse, error)

RemoveProbe gRPC method cancels the given probe and removes its from the prober's internal database.

func (*Prober) Start

func (pr *Prober) Start(ctx context.Context)

Start starts a previously initialized Cloudprober.