push

package
v0.15.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 11, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
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(checkpointer export.Checkpointer, exporter export.Exporter, opts ...Option) *Controller

New constructs a Controller, an implementation of MeterProvider, using the provided checkpointer, exporter, and options to configure an SDK with periodic collection.

func (*Controller) MeterProvider added in v0.12.0

func (c *Controller) MeterProvider() metric.MeterProvider

MeterProvider returns a MeterProvider 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

func WithPeriod(period time.Duration) Option

WithPeriod sets the Period configuration option of a Config.

func WithResource

func WithResource(r *resource.Resource) Option

WithResource sets the Resource configuration option of a Config.

func WithTimeout

func WithTimeout(timeout time.Duration) Option

WithTimeout sets the Timeout configuration option of a Config.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL