Documentation
¶
Index ¶
Constants ¶
const DefaultPushPeriod = 10 * time.Second
DefaultPushPeriod is the default time interval between pushes.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
// Resource is the OpenTelemetry resource associated with all Meters
// created by the Controller.
Resource *resource.Resource
// Period is the interval between calls to Collect a checkpoint.
Period time.Duration
// Timeout is the duration a collection (i.e. collect, accumulate,
// integrate, and export) can last before it is canceled. Defaults to
// the controller push period.
Timeout time.Duration
}
Config contains configuration for a push Controller.
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller organizes a periodic push of metric data.
func New ¶
func New(selector export.AggregatorSelector, exporter export.Exporter, opts ...Option) *Controller
New constructs a Controller, an implementation of metric.Provider, using the provided exporter and options to configure an SDK with periodic collection.
func (*Controller) Provider ¶
func (c *Controller) Provider() metric.Provider
Provider returns a metric.Provider instance for this controller.
func (*Controller) SetClock ¶
func (c *Controller) SetClock(clock controllerTime.Clock)
SetClock supports setting a mock clock for testing. This must be called before Start().
func (*Controller) Start ¶
func (c *Controller) Start()
Start begins a ticker that periodically collects and exports metrics with the configured interval.
func (*Controller) Stop ¶
func (c *Controller) Stop()
Stop waits for the background goroutine to return and then collects and exports metrics one last time before returning.
type Option ¶
type Option interface {
// Apply sets the Option value of a Config.
Apply(*Config)
}
Option is the interface that applies the value to a configuration option.
func WithPeriod ¶
WithPeriod sets the Period configuration option of a Config.
func WithResource ¶
WithResource sets the Resource configuration option of a Config.
func WithTimeout ¶
WithTimeout sets the Timeout configuration option of a Config.
Source Files