stats

Documentation

Index

• type Reader
• type Record
  • func (z *Record) DecodeMsg(dc *msgp.Reader) (err error)
  • func (z *Record) EncodeMsg(en *msgp.Writer) (err error)
  • func (z *Record) MarshalMsg(b []byte) (o []byte, err error)
  • func (z *Record) Msgsize() (s int)
  • func (z *Record) UnmarshalMsg(bts []byte) (o []byte, err error)
• type Recorder
• type Stats

Types

type Reader

type Reader interface {
	// Last records for specific app with limits
	LastByUID(uid string, limit int) ([]Record, error)
	// Last all records
	Last(limit int) ([]Record, error)
}

Reader from tracking systems. All returned records should be sorted from newest to oldest (by insertion moment)

type Record

type Record struct {
	UID    string    `json:"uid"`              // app UID
	Input  []byte    `json:"input,omitempty"`  // input data (could be empty if failed before read)
	Output []byte    `json:"output,omitempty"` // output data (could be empty if failed before run)
	Err    string    `json:"error,omitempty"`  // optional error
	Code   int       `json:"code"`             // response HTTP code
	Method string    `json:"method"`           // request HTTP method
	Remote string    `json:"remote"`           // request remote address (usually ip:port)
	Origin string    `json:"origin,omitempty"` // request origin header (could be empty)
	URI    string    `json:"uri"`              // raw request URI
	Token  string    `json:"token,omitempty"`  // request Authorization header (could be empty)
	Begin  time.Time `json:"begin"`            // started time
	End    time.Time `json:"end"`              // ended time
}

Tracking record

func (*Record) DecodeMsg

func (z *Record) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*Record) EncodeMsg

func (z *Record) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*Record) MarshalMsg

func (z *Record) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*Record) Msgsize

func (z *Record) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*Record) UnmarshalMsg

func (z *Record) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type Recorder

type Recorder interface {
	// Track single recorder
	Track(record Record)
}

Recorder for apps requests

type Stats

type Stats interface {
	Recorder
	Reader
}