observatory

Documentation

Index

• func RunClient(ctx context.Context, cfg *config.Client, logger logr.Logger)
• type Collector
  • func NewCollector(listen string, handshakeTimeout time.Duration, logger logr.Logger, ...) *Collector
  • func (c *Collector) Run(ctx context.Context) error
• type Communicator
  • func (c *Communicator) Run(ctx context.Context)
• type Observer
• type Pinger
  • func (p *Pinger) Run(ctx context.Context)
  • func (p *Pinger) UpdateTargets(targets []protocol.Target)

Functions

func RunClient

func RunClient(ctx context.Context, cfg *config.Client, logger logr.Logger)

Types

type Collector

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

func NewCollector

func NewCollector(
	listen string,
	handshakeTimeout time.Duration,
	logger logr.Logger,
	token string,
	targets []config.Target,
) *Collector

func (*Collector) Run

func (c *Collector) Run(ctx context.Context) error

type Communicator

type Communicator struct {
	ServerAddr        string
	ConnectTimeout    time.Duration
	ReconnectInterval time.Duration
	Token             string
	ObserverID        string
	Logger            logr.Logger
	ConfigUpdate      chan<- *protocol.ServerPushInfo
	StateReport       <-chan *protocol.Observation
	// contains filtered or unexported fields
}

func (*Communicator) Run

func (c *Communicator) Run(ctx context.Context)

Run blocks until StateReport or ctx is closed

type Observer

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

type Pinger

type Pinger struct {
	Logger   logr.Logger
	Output   chan<- *protocol.Observation
	Interval time.Duration
	// contains filtered or unexported fields
}

func (*Pinger) Run

func (p *Pinger) Run(ctx context.Context)

func (*Pinger) UpdateTargets

func (p *Pinger) UpdateTargets(targets []protocol.Target)