client

Documentation

Overview

package client implements the normal labels.Applicator functions but maps them onto a grpc server call

Index

• type Client
  • func NewClient(conn *grpc.ClientConn, logger logging.Logger) Client
  • func (c Client) WatchMatches(selector klabels.Selector, labelType labels.Type, _ time.Duration, ...) (chan []labels.Labeled, error)

Types

type Client

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

func NewClient

func NewClient(conn *grpc.ClientConn, logger logging.Logger) Client

func (Client) WatchMatches

func (c Client) WatchMatches(selector klabels.Selector, labelType labels.Type, _ time.Duration, quitCh <-chan struct{}) (chan []labels.Labeled, error)

WatchMatches uses streaming gRPC to subscribe to updates to a label selector and passes each update on the output channel. Returns an error if the initial gRPC call fails. Any further connection breakages will attempt to be re-established in a loop.

aggregationRate is unused because aggregation is handled by the server