riemann

Documentation

Index

• type ConfigFunc
  • func WithBatchSize(batchSize int) ConfigFunc
  • func WithClock(clock glock.Clock) ConfigFunc
  • func WithConnectionTimeout(connectionTimeout time.Duration) ConfigFunc
  • func WithDialer(dialer Dialer) ConfigFunc
  • func WithLogger(logger base.Logger) ConfigFunc
  • func WithQueueSize(queueSize int) ConfigFunc
  • func WithReportConfigs(configs ...base.ConfigFunc) ConfigFunc
  • func WithTTL(ttl float32) ConfigFunc
  • func WithTickDuration(tickDuration time.Duration) ConfigFunc
• type Dialer
• type Reporter
  • func NewReporter(addr string, configs ...ConfigFunc) *Reporter
  • func (r *Reporter) Report(name string, value float64, configs ...base.ConfigFunc)
  • func (r *Reporter) Shutdown()

Types

type ConfigFunc

type ConfigFunc func(r *config)

func WithBatchSize

func WithBatchSize(batchSize int) ConfigFunc

func WithClock

func WithClock(clock glock.Clock) ConfigFunc

func WithConnectionTimeout

func WithConnectionTimeout(connectionTimeout time.Duration) ConfigFunc

func WithDialer

func WithDialer(dialer Dialer) ConfigFunc

func WithLogger

func WithLogger(logger base.Logger) ConfigFunc

func WithQueueSize

func WithQueueSize(queueSize int) ConfigFunc

func WithReportConfigs

func WithReportConfigs(configs ...base.ConfigFunc) ConfigFunc

func WithTTL

func WithTTL(ttl float32) ConfigFunc

func WithTickDuration

func WithTickDuration(tickDuration time.Duration) ConfigFunc

type Dialer

type Dialer func() (io.ReadWriteCloser, error)

type Reporter

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

func NewReporter

func NewReporter(addr string, configs ...ConfigFunc) *Reporter

func (*Reporter) Report

func (r *Reporter) Report(name string, value float64, configs ...base.ConfigFunc)

func (*Reporter) Shutdown

func (r *Reporter) Shutdown()