exporter

Documentation

Index

• func Forward(res *outputs.Response) error
• func Watch(ctx context.Context, sc outputs.Service_SubClient, timeout time.Duration) error

Functions

func Forward

func Forward(res *outputs.Response) error

Forward processes a single *outputs.Response and forwards the event to the metric counters.

func Watch

func Watch(ctx context.Context, sc outputs.Service_SubClient, timeout time.Duration) error

Watch allows to watch and process a stream of *outputs.Response from a given outputs.Service_SubClient. The timeout parameter specifies the frequency of the watch operation.

It waits until the stream is closed, the context is cancelled or an error occured.