metrics

type HttpCounters struct {
	// Request is the count of http requests.
	Request uint64

	// StatusOK is the count of http 200 responses.
	StatusOK uint64

	// StatusBadRequest is the count of http 400 responses.
	StatusBadRequest uint64

	// StatusUnauthorized is the count of http 401 responses.
	StatusUnauthorized uint64

	// StatusNotFound is the count of http 404 responses.
	StatusNotFound uint64

	// StatusInternalServerError is the count of http 500 responses.
	StatusInternalServerError uint64

	// StatusServiceUnavailable is the count of http 503 responses.
	StatusServiceUnavailable uint64

	// Written is the number of bytes written.
	Written uint64

	// At is the time the counters were sampled at.
	At time.Time
}

type Logger interface {
	Printf(string, ...interface{})
}

type MsgCounters struct {
	// Rx is the count of messages received.
	Rx uint64

	// Tx is the count of messages transmitted.
	Tx uint64

	// Proc is the count of messages processed.
	Proc uint64

	// Err is the count of errored messages.
	Err uint64

	// At is the time the counters were sampled at.
	At time.Time
}

type Processor interface {
	Process([]byte) error
}

type ProcessorWithContext interface {
	Process(context.Context, []byte) error
}

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

type TimerStats struct {
	ID           string
	Count        int
	Average      int
	Percentile95 int
	Percentile50 int
}