statzagg

README

statzagg

aggregate statistics from various other consumers

class diagram

Documentation

Overview

Package statzagg - aggregate statitics posted by other clients

Package statzagg - aggregate statitics posted by other clients

Package statzagg - aggregate statitics posted by other clients

Index

• type EventStats
  • func (h *EventStats) String() string
• type HTTPClientStatz
  • func (h *HTTPClientStatz) ReadHTTPHeader(hdr *http.Header) error
  • func (h *HTTPClientStatz) String() string
• type LogStatzAgg
  • func NewLogStatzAgg(wtr io.Writer) *LogStatzAgg
  • func (l *LogStatzAgg) PostEventStats(ctx context.Context, statz *EventStats)
  • func (l *LogStatzAgg) PostHTTPClientStats(ctx context.Context, statz *HTTPClientStatz)
• type NullStatzAgg
  • func (n *NullStatzAgg) PostEventStats(ctx context.Context, statz *EventStats)
  • func (n *NullStatzAgg) PostHTTPClientStats(ctx context.Context, statz *HTTPClientStatz)
• type StatzAgg

Types

type EventStats

type EventStats struct {
	EventClock time.Time     //Tx Begin
	ID         string        //Client ID
	Name       string        //Name of event
	Err        error         //Error
	Values     []interface{} //Value
}

EventStats - Events stats

func (*EventStats) String

func (h *EventStats) String() string

String - output of user readable

type HTTPClientStatz

type HTTPClientStatz struct {
	httpstat.Result           //HTTP statistic
	BegClock        time.Time //Tx Begin
	EndClock        time.Time //Tx Completed
	ID              string    //Client ID
	URL             string    //URL
	Status          int       //HTTP status code
	Bytes           int64     //HTTP response bytes
	Err             error     //Client error
	CdnHeaders      string    //cdn record for tracing
}

HTTPClientStatz - client stats

func (*HTTPClientStatz) ReadHTTPHeader

func (h *HTTPClientStatz) ReadHTTPHeader(hdr *http.Header) error

ReadHTTPHeader - reads required details from header

func (*HTTPClientStatz) String

func (h *HTTPClientStatz) String() string

String - output of user readable

type LogStatzAgg

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

LogStatzAgg - Write logs of metrics

func NewLogStatzAgg

func NewLogStatzAgg(wtr io.Writer) *LogStatzAgg

NewLogStatzAgg - Create LogStatzAgg

func (*LogStatzAgg) PostEventStats

func (l *LogStatzAgg) PostEventStats(ctx context.Context, statz *EventStats)

PostEventStats - Post Event Tx

func (*LogStatzAgg) PostHTTPClientStats

func (l *LogStatzAgg) PostHTTPClientStats(ctx context.Context, statz *HTTPClientStatz)

PostHTTPClientStats - post stats

type NullStatzAgg

type NullStatzAgg struct {
}

NullStatzAgg - Ignores Statz

func (*NullStatzAgg) PostEventStats

func (n *NullStatzAgg) PostEventStats(ctx context.Context, statz *EventStats)

PostEventStats - Post Event Tx

func (*NullStatzAgg) PostHTTPClientStats

func (n *NullStatzAgg) PostHTTPClientStats(ctx context.Context, statz *HTTPClientStatz)

PostHTTPClientStats - Post Http Tx

type StatzAgg

type StatzAgg interface {
	PostHTTPClientStats(context.Context, *HTTPClientStatz) //PostHTTPClientStats - Post Http Tx
	PostEventStats(context.Context, *EventStats)           //PostEventStats - Post Event Tx
}

StatzAgg - Aggregates Statz