Documentation ¶
Index ¶
- func AddLatencyProbe(ch channel.Channel, binding channel.Binding, interval time.Duration, ...)
- func AddLatencyProbeResponder(binding channel.Binding)
- func ProbeLatencyConfigurable(config *ProbeConfig)
- type Handler
- type HandlerF
- type LatencyHandler
- type ProbeConfig
- type Responder
- type RoundTripLatency
- type SendTimeTracker
- type Type
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddLatencyProbe ¶
func ProbeLatencyConfigurable ¶
func ProbeLatencyConfigurable(config *ProbeConfig)
Types ¶
type LatencyHandler ¶
type LatencyHandler struct {
// contains filtered or unexported fields
}
LatencyHandler responds to latency messages with Result messages.
func (*LatencyHandler) ContentType ¶
func (h *LatencyHandler) ContentType() int32
func (*LatencyHandler) HandleReceive ¶
func (h *LatencyHandler) HandleReceive(msg *channel.Message, ch channel.Channel)
type ProbeConfig ¶
type Responder ¶
type Responder struct {
// contains filtered or unexported fields
}
Responder responds to latency messages with LatencyResponse messages.
func (*Responder) ContentType ¶
type RoundTripLatency ¶
type RoundTripLatency struct { channel.BaseSendable channel.BaseSendListener // contains filtered or unexported fields }
func (*RoundTripLatency) Msg ¶
func (self *RoundTripLatency) Msg() *channel.Message
func (*RoundTripLatency) NotifyBeforeWrite ¶
func (self *RoundTripLatency) NotifyBeforeWrite()
func (*RoundTripLatency) SendListener ¶
func (self *RoundTripLatency) SendListener() channel.SendListener
func (*RoundTripLatency) Sequence ¶
func (self *RoundTripLatency) Sequence() int32
func (*RoundTripLatency) SetSequence ¶
func (self *RoundTripLatency) SetSequence(seq int32)
type SendTimeTracker ¶
type SendTimeTracker struct { channel.BaseSendable channel.BaseSendListener Handler HandlerF StartTime time.Time // contains filtered or unexported fields }
func (*SendTimeTracker) NotifyBeforeWrite ¶
func (self *SendTimeTracker) NotifyBeforeWrite()
func (*SendTimeTracker) SendListener ¶
func (self *SendTimeTracker) SendListener() channel.SendListener
func (*SendTimeTracker) Sequence ¶
func (self *SendTimeTracker) Sequence() int32
func (*SendTimeTracker) SetSequence ¶
func (self *SendTimeTracker) SetSequence(seq int32)
Click to show internal directories.
Click to hide internal directories.