metrics

Documentation

Index

• func MeasureConn(conn ssnet.DuplexConn, bytesSent, bytesRceived *int64) ssnet.DuplexConn
• func MeasureReader(reader io.Reader, count *int64) io.Reader
• func MeasureWriter(writer io.Writer, count *int64) io.Writer
• func SPrintMetrics(m ProxyMetrics) string
• type MetricsMap
  • func NewMetricsMap() *MetricsMap
  • func (this *MetricsMap) Add(key string, toAdd ProxyMetrics)
  • func (this *MetricsMap) Get(key string) ProxyMetrics
• type ProxyMetrics
• type TCPMetrics
  • func NewPrometheusTCPMetrics() TCPMetrics

Functions

func MeasureConn

func MeasureConn(conn ssnet.DuplexConn, bytesSent, bytesRceived *int64) ssnet.DuplexConn

func MeasureReader

func MeasureReader(reader io.Reader, count *int64) io.Reader

func MeasureWriter

func MeasureWriter(writer io.Writer, count *int64) io.Writer

func SPrintMetrics

func SPrintMetrics(m ProxyMetrics) string

Types

type MetricsMap

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

func NewMetricsMap

func NewMetricsMap() *MetricsMap

func (*MetricsMap) Add

func (this *MetricsMap) Add(key string, toAdd ProxyMetrics)

func (*MetricsMap) Get

func (this *MetricsMap) Get(key string) ProxyMetrics

type ProxyMetrics

type ProxyMetrics struct {
	ClientProxy int64
	ProxyTarget int64
	TargetProxy int64
	ProxyClient int64
}

type TCPMetrics

type TCPMetrics interface {
	AddTCPConnection()
	RemoveTCPConnection(accessKey, status string, duration time.Duration)
}

func NewPrometheusTCPMetrics

func NewPrometheusTCPMetrics() TCPMetrics