metric

Documentation

Index

• func Register(registerer prometheus.Registerer, toRegister ...prometheus.Collector) error
• type AllowLimiter
• type AllowLimiterInstrumentation
  • func NewAllowLimiterInstrumentation(limiterName string, limit float64, limitUnit string, tr trace.Tracer, ...) (*AllowLimiterInstrumentation, error)
  • func (i *AllowLimiterInstrumentation) Allow(ctx context.Context) (allowed bool)
• type LimiterWrapper
  • func NewLimiterWrapper(limiterName string, limit float64, limitUnit string, m otelmetric.Meter, ...) (*LimiterWrapper, error)
  • func (w *LimiterWrapper) Start(ctx context.Context) (context.Context, func(allowed bool))
• type OtelErrorHandler
  • func (h *OtelErrorHandler) Handle(err error)
• type WaitLimiter
• type WaitLimiterInstrumentation
  • func NewWaitLimiterInstrumentation(limiterName string, limit float64, limitUnit string, tr trace.Tracer, ...) (*WaitLimiterInstrumentation, error)
  • func (i *WaitLimiterInstrumentation) Wait(ctx context.Context) error

Functions

func Register

func Register(registerer prometheus.Registerer, toRegister ...prometheus.Collector) error

Types

type AllowLimiter

type AllowLimiter interface {
	Allow(context.Context) bool
}

type AllowLimiterInstrumentation

type AllowLimiterInstrumentation struct {
	// contains filtered or unexported fields
}

func NewAllowLimiterInstrumentation

func NewAllowLimiterInstrumentation(limiterName string, limit float64, limitUnit string, tr trace.Tracer, m otelmetric.Meter, delegate AllowLimiter) (*AllowLimiterInstrumentation, error)

func (*AllowLimiterInstrumentation) Allow

func (i *AllowLimiterInstrumentation) Allow(ctx context.Context) (allowed bool)

type LimiterWrapper

type LimiterWrapper struct {
	// contains filtered or unexported fields
}

func NewLimiterWrapper

func NewLimiterWrapper(limiterName string, limit float64, limitUnit string, m otelmetric.Meter, tr trace.Tracer) (*LimiterWrapper, error)

func (*LimiterWrapper) Start

func (w *LimiterWrapper) Start(ctx context.Context) (context.Context, func(allowed bool))

type OtelErrorHandler

type OtelErrorHandler slog.Logger

func (*OtelErrorHandler) Handle

func (h *OtelErrorHandler) Handle(err error)

type WaitLimiter

type WaitLimiter interface {
	Wait(context.Context) error
}

type WaitLimiterInstrumentation

type WaitLimiterInstrumentation struct {
	// contains filtered or unexported fields
}

func NewWaitLimiterInstrumentation

func NewWaitLimiterInstrumentation(limiterName string, limit float64, limitUnit string, tr trace.Tracer, m otelmetric.Meter, delegate WaitLimiter) (*WaitLimiterInstrumentation, error)

func (*WaitLimiterInstrumentation) Wait

func (i *WaitLimiterInstrumentation) Wait(ctx context.Context) error