roprometheus

package module

v0.0.0-...-a6ee939 Latest Latest Go to latest Published: Jan 10, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/samber/ro

Links

Open Source Insights

README ¶

Prometheus (Enterprise Edition)

Configuration

The plugin uses a CollectorConfig struct to configure Prometheus metrics collection:

type CollectorConfig struct {
    // Namespace is the namespace of the metrics.
    // Example: "myapp" -> metrics will be prefixed with "myapp_"
    Namespace string
    
    // Subsystem is the subsystem of the metrics.
    // Example: "pipeline" -> metrics will be prefixed with "myapp_pipeline_"
    Subsystem string
    
    // ConstLabels are labels that are applied to all metrics.
    // These labels help identify the source of metrics across different instances.
    ConstLabels prometheus.Labels
    
    // SummaryObjectives defines the quantile objectives for summary metrics.
    // Default values provide good coverage for most use cases.
    SummaryObjectives map[float64]float64
}

Configuration Options

Namespace: Sets the namespace prefix for all metrics. This helps organize metrics by application or service.
Subsystem: Sets the subsystem prefix for all metrics. This provides additional categorization within the namespace.
ConstLabels: Adds constant labels to all metrics. Useful for identifying environment, version, or instance information.
SummaryObjectives: Configures quantile objectives for summary metrics (latency, processing time, etc.).

Default Values

The plugin provides sensible defaults for summary objectives:

var DefaultSummaryObjectives = map[float64]float64{
    0.5:  0.05,  // 50th percentile with 5% error
    0.9:  0.01,  // 90th percentile with 1% error
    0.95: 0.005, // 95th percentile with 0.5% error
    0.99: 0.001, // 99th percentile with 0.1% error
}

Example

import (
    "github.com/samber/ro"
    roprometheus "github.com/samber/ro/ee/plugins/prometheus"
)

var obs, collector = roprometheus.Pipe3(
    roprometheus.CollectorConfig{
        Namespace: "example",
        Subsystem: "",
        ConstLabels: prometheus.Labels{
            "foo": "bar",
        },
    },
    ro.Just(1, 2, 3),
    ro.Map(func(v int64) int64 {
        return v*2
    }),
    ro.Take(2),
)

func main() {
    prometheus.MustRegister(collector)

    obs.Subscribe(
        ...
    )
}

Documentation ¶

Index ¶

Constants
Variables
func IncCounterOnComplete[T any](counter prometheus.Counter) func(ro.Observable[T]) ro.Observable[T]
func IncCounterOnError[T any](counter prometheus.Counter) func(ro.Observable[T]) ro.Observable[T]
func IncCounterOnNext[T any](counter prometheus.Counter) func(ro.Observable[T]) ro.Observable[T]
func IncCounterOnSubscription[T any](counter prometheus.Counter) func(ro.Observable[T]) ro.Observable[T]
func ObserveNextLag[T any](summaryOrHistogram prometheus.Observer) func(ro.Observable[T]) ro.Observable[T]
func Pipe1[A any, B any](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[B], prometheus.Collector)
func Pipe10[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[K], prometheus.Collector)
func Pipe11[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, ...](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[L], prometheus.Collector)
func Pipe12[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, ...](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[M], prometheus.Collector)
func Pipe13[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, ...](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[N], prometheus.Collector)
func Pipe14[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, ...](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[O], prometheus.Collector)
func Pipe15[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, ...](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[P], prometheus.Collector)
func Pipe16[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, ...](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[Q], prometheus.Collector)
func Pipe17[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, ...](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[R], prometheus.Collector)
func Pipe18[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, ...](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[S], prometheus.Collector)
func Pipe19[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, ...](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[T], prometheus.Collector)
func Pipe2[A any, B any, C any](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[C], prometheus.Collector)
func Pipe20[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, ...](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[U], prometheus.Collector)
func Pipe21[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, ...](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[V], prometheus.Collector)
func Pipe22[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, ...](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[W], prometheus.Collector)
func Pipe23[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, ...](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[X], prometheus.Collector)
func Pipe24[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, ...](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[Y], prometheus.Collector)
func Pipe3[A any, B any, C any, D any](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[D], prometheus.Collector)
func Pipe4[A any, B any, C any, D any, E any](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[E], prometheus.Collector)
func Pipe5[A any, B any, C any, D any, E any, F any](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[F], prometheus.Collector)
func Pipe6[A any, B any, C any, D any, E any, F any, G any](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[G], prometheus.Collector)
func Pipe7[A any, B any, C any, D any, E any, F any, G any, H any](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[H], prometheus.Collector)
func Pipe8[A any, B any, C any, D any, E any, F any, G any, H any, I any](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[I], prometheus.Collector)
func Pipe9[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any](collectorConfig CollectorConfig, source ro.Observable[A], ...) (ro.Observable[J], prometheus.Collector)
type CollectorConfig

Constants ¶

View Source

const (
	LabelNamePipePosition = "pipe_position"
)

Variables ¶

View Source

var DefaultSummaryObjectives = map[float64]float64{
	0.5:  0.05,
	0.9:  0.01,
	0.95: 0.005,
	0.99: 0.001,
}

Functions ¶

func IncCounterOnComplete ¶

func IncCounterOnComplete[T any](counter prometheus.Counter) func(ro.Observable[T]) ro.Observable[T]

IncCounterOnComplete is a pipe operator that increments a counter when a new Complete() notification is sent to the destination observer.

It adds a short lock for each Complete() notification: 30ns for the prometheus/client_golang locks.

func IncCounterOnError ¶

func IncCounterOnError[T any](counter prometheus.Counter) func(ro.Observable[T]) ro.Observable[T]

IncCounterOnError is a pipe operator that increments a counter when a new Error() notification is sent to the destination observer.

It adds a short lock for each Error() notification: 30ns for the prometheus/client_golang locks.

func IncCounterOnNext ¶

func IncCounterOnNext[T any](counter prometheus.Counter) func(ro.Observable[T]) ro.Observable[T]

IncCounterOnNext is a pipe operator that increments a counter when a new Next() notification is sent to the destination observer.

It adds a short lock for each Next() notification: 30ns for the prometheus/client_golang locks.

func IncCounterOnSubscription ¶

func IncCounterOnSubscription[T any](counter prometheus.Counter) func(ro.Observable[T]) ro.Observable[T]

IncCounterOnSubscription is a pipe operator that increments a counter when a new subscription is created.

It adds a short lock for each subscription: 30ns for the prometheus/client_golang locks.

func ObserveNextLag ¶

func ObserveNextLag[T any](summaryOrHistogram prometheus.Observer) func(ro.Observable[T]) ro.Observable[T]

ObserveNextLag is a pipe operator that tracks the time it takes for a notification to traverse from the source observable to the destination observer. It mesures the time the source pauses while waiting for the destination to process the notification.

It adds a short lock for each Next() notification:

2x 15ns for the time tracking
30ns for the prometheus/client_golang locks

func Pipe1 ¶

func Pipe1[A any, B any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
) (ro.Observable[B], prometheus.Collector)

Pipe1 is a typesafe 🎉 implementation of Pipe, that takes a source and 1 operator.

func Pipe10 ¶

func Pipe10[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
	operator9 func(ro.Observable[I]) ro.Observable[J],
	operator10 func(ro.Observable[J]) ro.Observable[K],
) (ro.Observable[K], prometheus.Collector)

func Pipe11 ¶

func Pipe11[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, L any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
	operator9 func(ro.Observable[I]) ro.Observable[J],
	operator10 func(ro.Observable[J]) ro.Observable[K],
	operator11 func(ro.Observable[K]) ro.Observable[L],
) (ro.Observable[L], prometheus.Collector)

Pipe11 is a typesafe 🎉 implementation of Pipe, that takes a source and 11 operators.

func Pipe12 ¶

func Pipe12[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, L any, M any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
	operator9 func(ro.Observable[I]) ro.Observable[J],
	operator10 func(ro.Observable[J]) ro.Observable[K],
	operator11 func(ro.Observable[K]) ro.Observable[L],
	operator12 func(ro.Observable[L]) ro.Observable[M],
) (ro.Observable[M], prometheus.Collector)

Pipe12 is a typesafe 🎉 implementation of Pipe, that takes a source and 12 operators.

func Pipe13 ¶

func Pipe13[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, L any, M any, N any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
	operator9 func(ro.Observable[I]) ro.Observable[J],
	operator10 func(ro.Observable[J]) ro.Observable[K],
	operator11 func(ro.Observable[K]) ro.Observable[L],
	operator12 func(ro.Observable[L]) ro.Observable[M],
	operator13 func(ro.Observable[M]) ro.Observable[N],
) (ro.Observable[N], prometheus.Collector)

Pipe13 is a typesafe 🎉 implementation of Pipe, that takes a source and 13 operators.

func Pipe14 ¶

func Pipe14[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, L any, M any, N any, O any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
	operator9 func(ro.Observable[I]) ro.Observable[J],
	operator10 func(ro.Observable[J]) ro.Observable[K],
	operator11 func(ro.Observable[K]) ro.Observable[L],
	operator12 func(ro.Observable[L]) ro.Observable[M],
	operator13 func(ro.Observable[M]) ro.Observable[N],
	operator14 func(ro.Observable[N]) ro.Observable[O],
) (ro.Observable[O], prometheus.Collector)

Pipe14 is a typesafe 🎉 implementation of Pipe, that takes a source and 14 operators.

func Pipe15 ¶

func Pipe15[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, L any, M any, N any, O any, P any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
	operator9 func(ro.Observable[I]) ro.Observable[J],
	operator10 func(ro.Observable[J]) ro.Observable[K],
	operator11 func(ro.Observable[K]) ro.Observable[L],
	operator12 func(ro.Observable[L]) ro.Observable[M],
	operator13 func(ro.Observable[M]) ro.Observable[N],
	operator14 func(ro.Observable[N]) ro.Observable[O],
	operator15 func(ro.Observable[O]) ro.Observable[P],
) (ro.Observable[P], prometheus.Collector)

Pipe15 is a typesafe 🎉 implementation of Pipe, that takes a source and 15 operators.

func Pipe16 ¶

func Pipe16[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, L any, M any, N any, O any, P any, Q any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
	operator9 func(ro.Observable[I]) ro.Observable[J],
	operator10 func(ro.Observable[J]) ro.Observable[K],
	operator11 func(ro.Observable[K]) ro.Observable[L],
	operator12 func(ro.Observable[L]) ro.Observable[M],
	operator13 func(ro.Observable[M]) ro.Observable[N],
	operator14 func(ro.Observable[N]) ro.Observable[O],
	operator15 func(ro.Observable[O]) ro.Observable[P],
	operator16 func(ro.Observable[P]) ro.Observable[Q],
) (ro.Observable[Q], prometheus.Collector)

Pipe16 is a typesafe 🎉 implementation of Pipe, that takes a source and 16 operators.

func Pipe17 ¶

func Pipe17[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, L any, M any, N any, O any, P any, Q any, R any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
	operator9 func(ro.Observable[I]) ro.Observable[J],
	operator10 func(ro.Observable[J]) ro.Observable[K],
	operator11 func(ro.Observable[K]) ro.Observable[L],
	operator12 func(ro.Observable[L]) ro.Observable[M],
	operator13 func(ro.Observable[M]) ro.Observable[N],
	operator14 func(ro.Observable[N]) ro.Observable[O],
	operator15 func(ro.Observable[O]) ro.Observable[P],
	operator16 func(ro.Observable[P]) ro.Observable[Q],
	operator17 func(ro.Observable[Q]) ro.Observable[R],
) (ro.Observable[R], prometheus.Collector)

Pipe17 is a typesafe 🎉 implementation of Pipe, that takes a source and 17 operators.

func Pipe18 ¶

func Pipe18[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, L any, M any, N any, O any, P any, Q any, R any, S any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
	operator9 func(ro.Observable[I]) ro.Observable[J],
	operator10 func(ro.Observable[J]) ro.Observable[K],
	operator11 func(ro.Observable[K]) ro.Observable[L],
	operator12 func(ro.Observable[L]) ro.Observable[M],
	operator13 func(ro.Observable[M]) ro.Observable[N],
	operator14 func(ro.Observable[N]) ro.Observable[O],
	operator15 func(ro.Observable[O]) ro.Observable[P],
	operator16 func(ro.Observable[P]) ro.Observable[Q],
	operator17 func(ro.Observable[Q]) ro.Observable[R],
	operator18 func(ro.Observable[R]) ro.Observable[S],
) (ro.Observable[S], prometheus.Collector)

Pipe18 is a typesafe 🎉 implementation of Pipe, that takes a source and 18 operators.

func Pipe19 ¶

func Pipe19[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, L any, M any, N any, O any, P any, Q any, R any, S any, T any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
	operator9 func(ro.Observable[I]) ro.Observable[J],
	operator10 func(ro.Observable[J]) ro.Observable[K],
	operator11 func(ro.Observable[K]) ro.Observable[L],
	operator12 func(ro.Observable[L]) ro.Observable[M],
	operator13 func(ro.Observable[M]) ro.Observable[N],
	operator14 func(ro.Observable[N]) ro.Observable[O],
	operator15 func(ro.Observable[O]) ro.Observable[P],
	operator16 func(ro.Observable[P]) ro.Observable[Q],
	operator17 func(ro.Observable[Q]) ro.Observable[R],
	operator18 func(ro.Observable[R]) ro.Observable[S],
	operator19 func(ro.Observable[S]) ro.Observable[T],
) (ro.Observable[T], prometheus.Collector)

Pipe19 is a typesafe 🎉 implementation of Pipe, that takes a source and 19 operators.

func Pipe2 ¶

func Pipe2[A any, B any, C any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
) (ro.Observable[C], prometheus.Collector)

Pipe2 is a typesafe 🎉 implementation of Pipe, that takes a source and 2 operators.

func Pipe20 ¶

func Pipe20[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, L any, M any, N any, O any, P any, Q any, R any, S any, T any, U any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
	operator9 func(ro.Observable[I]) ro.Observable[J],
	operator10 func(ro.Observable[J]) ro.Observable[K],
	operator11 func(ro.Observable[K]) ro.Observable[L],
	operator12 func(ro.Observable[L]) ro.Observable[M],
	operator13 func(ro.Observable[M]) ro.Observable[N],
	operator14 func(ro.Observable[N]) ro.Observable[O],
	operator15 func(ro.Observable[O]) ro.Observable[P],
	operator16 func(ro.Observable[P]) ro.Observable[Q],
	operator17 func(ro.Observable[Q]) ro.Observable[R],
	operator18 func(ro.Observable[R]) ro.Observable[S],
	operator19 func(ro.Observable[S]) ro.Observable[T],
	operator20 func(ro.Observable[T]) ro.Observable[U],
) (ro.Observable[U], prometheus.Collector)

Pipe20 is a typesafe 🎉 implementation of Pipe, that takes a source and 20 operators.

func Pipe21 ¶

func Pipe21[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, L any, M any, N any, O any, P any, Q any, R any, S any, T any, U any, V any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
	operator9 func(ro.Observable[I]) ro.Observable[J],
	operator10 func(ro.Observable[J]) ro.Observable[K],
	operator11 func(ro.Observable[K]) ro.Observable[L],
	operator12 func(ro.Observable[L]) ro.Observable[M],
	operator13 func(ro.Observable[M]) ro.Observable[N],
	operator14 func(ro.Observable[N]) ro.Observable[O],
	operator15 func(ro.Observable[O]) ro.Observable[P],
	operator16 func(ro.Observable[P]) ro.Observable[Q],
	operator17 func(ro.Observable[Q]) ro.Observable[R],
	operator18 func(ro.Observable[R]) ro.Observable[S],
	operator19 func(ro.Observable[S]) ro.Observable[T],
	operator20 func(ro.Observable[T]) ro.Observable[U],
	operator21 func(ro.Observable[U]) ro.Observable[V],
) (ro.Observable[V], prometheus.Collector)

Pipe21 is a typesafe 🎉 implementation of Pipe, that takes a source and 21 operators.

func Pipe22 ¶

func Pipe22[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, L any, M any, N any, O any, P any, Q any, R any, S any, T any, U any, V any, W any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
	operator9 func(ro.Observable[I]) ro.Observable[J],
	operator10 func(ro.Observable[J]) ro.Observable[K],
	operator11 func(ro.Observable[K]) ro.Observable[L],
	operator12 func(ro.Observable[L]) ro.Observable[M],
	operator13 func(ro.Observable[M]) ro.Observable[N],
	operator14 func(ro.Observable[N]) ro.Observable[O],
	operator15 func(ro.Observable[O]) ro.Observable[P],
	operator16 func(ro.Observable[P]) ro.Observable[Q],
	operator17 func(ro.Observable[Q]) ro.Observable[R],
	operator18 func(ro.Observable[R]) ro.Observable[S],
	operator19 func(ro.Observable[S]) ro.Observable[T],
	operator20 func(ro.Observable[T]) ro.Observable[U],
	operator21 func(ro.Observable[U]) ro.Observable[V],
	operator22 func(ro.Observable[V]) ro.Observable[W],
) (ro.Observable[W], prometheus.Collector)

Pipe22 is a typesafe 🎉 implementation of Pipe, that takes a source and 22 operators.

func Pipe23 ¶

func Pipe23[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, L any, M any, N any, O any, P any, Q any, R any, S any, T any, U any, V any, W any, X any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
	operator9 func(ro.Observable[I]) ro.Observable[J],
	operator10 func(ro.Observable[J]) ro.Observable[K],
	operator11 func(ro.Observable[K]) ro.Observable[L],
	operator12 func(ro.Observable[L]) ro.Observable[M],
	operator13 func(ro.Observable[M]) ro.Observable[N],
	operator14 func(ro.Observable[N]) ro.Observable[O],
	operator15 func(ro.Observable[O]) ro.Observable[P],
	operator16 func(ro.Observable[P]) ro.Observable[Q],
	operator17 func(ro.Observable[Q]) ro.Observable[R],
	operator18 func(ro.Observable[R]) ro.Observable[S],
	operator19 func(ro.Observable[S]) ro.Observable[T],
	operator20 func(ro.Observable[T]) ro.Observable[U],
	operator21 func(ro.Observable[U]) ro.Observable[V],
	operator22 func(ro.Observable[V]) ro.Observable[W],
	operator23 func(ro.Observable[W]) ro.Observable[X],
) (ro.Observable[X], prometheus.Collector)

Pipe23 is a typesafe 🎉 implementation of Pipe, that takes a source and 23 operators.

func Pipe24 ¶

func Pipe24[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any, K any, L any, M any, N any, O any, P any, Q any, R any, S any, T any, U any, V any, W any, X any, Y any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
	operator9 func(ro.Observable[I]) ro.Observable[J],
	operator10 func(ro.Observable[J]) ro.Observable[K],
	operator11 func(ro.Observable[K]) ro.Observable[L],
	operator12 func(ro.Observable[L]) ro.Observable[M],
	operator13 func(ro.Observable[M]) ro.Observable[N],
	operator14 func(ro.Observable[N]) ro.Observable[O],
	operator15 func(ro.Observable[O]) ro.Observable[P],
	operator16 func(ro.Observable[P]) ro.Observable[Q],
	operator17 func(ro.Observable[Q]) ro.Observable[R],
	operator18 func(ro.Observable[R]) ro.Observable[S],
	operator19 func(ro.Observable[S]) ro.Observable[T],
	operator20 func(ro.Observable[T]) ro.Observable[U],
	operator21 func(ro.Observable[U]) ro.Observable[V],
	operator22 func(ro.Observable[V]) ro.Observable[W],
	operator23 func(ro.Observable[W]) ro.Observable[X],
	operator24 func(ro.Observable[X]) ro.Observable[Y],
) (ro.Observable[Y], prometheus.Collector)

Pipe24 is a typesafe 🎉 implementation of Pipe, that takes a source and 24 operators.

func Pipe3 ¶

func Pipe3[A any, B any, C any, D any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
) (ro.Observable[D], prometheus.Collector)

Pipe3 is a typesafe 🎉 implementation of Pipe, that takes a source and 3 operators.

func Pipe4 ¶

func Pipe4[A any, B any, C any, D any, E any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
) (ro.Observable[E], prometheus.Collector)

Pipe4 is a typesafe 🎉 implementation of Pipe, that takes a source and 4 operators.

func Pipe5 ¶

func Pipe5[A any, B any, C any, D any, E any, F any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
) (ro.Observable[F], prometheus.Collector)

Pipe5 is a typesafe 🎉 implementation of Pipe, that takes a source and 5 operators.

func Pipe6 ¶

func Pipe6[A any, B any, C any, D any, E any, F any, G any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
) (ro.Observable[G], prometheus.Collector)

Pipe6 is a typesafe 🎉 implementation of Pipe, that takes a source and 6 operators.

func Pipe7 ¶

func Pipe7[A any, B any, C any, D any, E any, F any, G any, H any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
) (ro.Observable[H], prometheus.Collector)

Pipe7 is a typesafe 🎉 implementation of Pipe, that takes a source and 7 operators.

func Pipe8 ¶

func Pipe8[A any, B any, C any, D any, E any, F any, G any, H any, I any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
) (ro.Observable[I], prometheus.Collector)

Pipe8 is a typesafe 🎉 implementation of Pipe, that takes a source and 8 operators.

func Pipe9 ¶

func Pipe9[A any, B any, C any, D any, E any, F any, G any, H any, I any, J any](
	collectorConfig CollectorConfig,
	source ro.Observable[A],
	operator1 func(ro.Observable[A]) ro.Observable[B],
	operator2 func(ro.Observable[B]) ro.Observable[C],
	operator3 func(ro.Observable[C]) ro.Observable[D],
	operator4 func(ro.Observable[D]) ro.Observable[E],
	operator5 func(ro.Observable[E]) ro.Observable[F],
	operator6 func(ro.Observable[F]) ro.Observable[G],
	operator7 func(ro.Observable[G]) ro.Observable[H],
	operator8 func(ro.Observable[H]) ro.Observable[I],
	operator9 func(ro.Observable[I]) ro.Observable[J],
) (ro.Observable[J], prometheus.Collector)

Types ¶

type CollectorConfig ¶

type CollectorConfig struct {
	// Namespace is the namespace of the metrics.
	Namespace string
	// Subsystem is the subsystem of the metrics.
	Subsystem string
	// ConstLabels are labels that are applied to all metrics.
	ConstLabels prometheus.Labels

	// Custom options
	SummaryObjectives map[float64]float64
}

Source Files ¶

View all Source files

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