beam: github.com/apache/beam/sdks/go/pkg/beam/core/runtime/metricsx Index | Files

package metricsx

import "github.com/apache/beam/sdks/go/pkg/beam/core/runtime/metricsx"

Index

Package Files

metricsx.go urns.go

func FromMonitoringInfos Uses

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 Uses

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

Int64Counter returns an encoded payload of the integer counter.

func Int64Distribution Uses

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

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

func Int64Latest Uses

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

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

func UrnToString Uses

func UrnToString(u Urn) string

UrnToString returns a string representation of the urn.

func UrnToType Uses

func UrnToType(u Urn) string

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

type Urn Uses

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.

Package metricsx imports 8 packages (graph) and is imported by 2 packages. Updated 2021-01-20. Refresh now. Tools for package owners.