Documentation
¶
Index ¶
Constants ¶
View Source
const ( Count = "nats.count" ContentLength = "nats.content_length" Latency = "nats.duration" Subject = attribute.Key("subject") IsError = attribute.Key("error") )
View Source
const (
TracerName = "nats"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Chain ¶
type Chain func(h subscriber.MsgHandler) subscriber.MsgHandler
type Metrics ¶
type Metrics struct {
// contains filtered or unexported fields
}
func CreateMeasures ¶
func CreateMeasures() *Metrics
type Middleware ¶
type Middleware struct {
// contains filtered or unexported fields
}
func NewMiddleware ¶
func NewMiddleware(c ...Chain) *Middleware
func (*Middleware) Then ¶
func (m *Middleware) Then(next subscriber.MsgHandler) subscriber.MsgHandler
type Recovery ¶
type Recovery struct{}
func NewRecovery ¶
func NewRecovery() *Recovery
func (*Recovery) Call ¶
func (t *Recovery) Call(next subscriber.MsgHandler) subscriber.MsgHandler
type SubMetrics ¶
type SubMetrics struct {
*Metrics
}
SubMetrics implement Middleware interface
func NewMetrics ¶
func NewMetrics(m *Metrics) *SubMetrics
func (*SubMetrics) Call ¶
func (t *SubMetrics) Call(next subscriber.MsgHandler) subscriber.MsgHandler
type Tracer ¶
type Tracer struct{}
Tracer for subscribers implementing Middleware
func (*Tracer) Call ¶
func (t *Tracer) Call(next subscriber.MsgHandler) subscriber.MsgHandler
Source Files
Click to show internal directories.
Click to hide internal directories.