net

Documentation

Index

• type NetMetric
• type NetSink
  • func NewSink(log logger.Underlying, registry go_metrics.Registry) (*NetSink, error)
  • func (s *NetSink) Close()
  • func (s *NetSink) HttpInfo() map[string]float64
  • func (s *NetSink) Init(ctx context.Context, format formats.Format, compression kt.Compression, ...) error
  • func (s *NetSink) Send(ctx context.Context, payload *kt.Output)

Types

type NetMetric

type NetMetric struct {
	DeliveryErr go_metrics.Meter
	DeliveryWin go_metrics.Meter
}

type NetSink

type NetSink struct {
	logger.ContextL
	// contains filtered or unexported fields
}

func NewSink

func NewSink(log logger.Underlying, registry go_metrics.Registry) (*NetSink, error)

func (*NetSink) Close

func (s *NetSink) Close()

func (*NetSink) HttpInfo

func (s *NetSink) HttpInfo() map[string]float64

func (*NetSink) Init

func (s *NetSink) Init(ctx context.Context, format formats.Format, compression kt.Compression, fmtr formats.Formatter) error

func (*NetSink) Send

func (s *NetSink) Send(ctx context.Context, payload *kt.Output)