metricsx

package

v2.32.0+incompatible Latest Latest Go to latest Published: Aug 10, 2021 License: Apache-2.0, BSD-3-Clause, MIT Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/apache/beam

Links

Open Source Insights

Documentation ¶

Index ¶

func FromMonitoringInfos(attempted []*pipepb.MonitoringInfo, committed []*pipepb.MonitoringInfo) *metrics.Results
func Int64Counter(v int64) ([]byte, error)
func Int64Distribution(count, sum, min, max int64) ([]byte, error)
func Int64Latest(t time.Time, v int64) ([]byte, error)
func UrnToString(u Urn) string
func UrnToType(u Urn) string
type Urn

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func FromMonitoringInfos ¶

func FromMonitoringInfos(attempted []*pipepb.MonitoringInfo, committed []*pipepb.MonitoringInfo) *metrics.Results

FromMonitoringInfos extracts metrics from monitored states and groups them into counters, distributions and gauges.

func Int64Counter ¶

func Int64Counter(v int64) ([]byte, error)

Int64Counter returns an encoded payload of the integer counter.

func Int64Distribution ¶

func Int64Distribution(count, sum, min, max int64) ([]byte, error)

Int64Distribution returns an encoded payload of the distribution of an integer value.

func Int64Latest ¶

func Int64Latest(t time.Time, v int64) ([]byte, error)

Int64Latest returns an encoded payload of the latest seen integer value.

func UrnToString ¶

func UrnToString(u Urn) string

UrnToString returns a string representation of the urn.

func UrnToType ¶

func UrnToType(u Urn) string

UrnToType maps the urn to it's encoding type. This function is written to be inlinable by the compiler.

Types ¶

type Urn ¶

type Urn uint32

Urn is an enum type for representing urns of metrics and monitored states.

const (
	UrnUserSumInt64 Urn = iota
	UrnUserSumFloat64
	UrnUserDistInt64
	UrnUserDistFloat64
	UrnUserLatestMsInt64
	UrnUserLatestMsFloat64
	UrnUserTopNInt64
	UrnUserTopNFloat64
	UrnUserBottomNInt64
	UrnUserBottomNFloat64

	UrnElementCount
	UrnSampledByteSize

	UrnStartBundle
	UrnProcessBundle
	UrnFinishBundle
	UrnTransformTotalTime

	UrnProgressRemaining
	UrnProgressCompleted
	UrnDataChannelReadIndex

	UrnTestSentinel // Must remain last.
)

The supported urns of metrics and monitored states.

Source Files ¶

View all Source files

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