Documentation
¶
Index ¶
- func CircuitMetrics(pollFreq time.Duration, closer <-chan struct{}, f func(string) string) model.Stage
- func Loop3Dialer(host *model.Host, scenario, endpoint string, joiner chan struct{}, ...) model.Stage
- func Loop3Listener(host *model.Host, joiner chan struct{}, bindAddress string, ...) model.Stage
- func LoopDialer(host *model.Host, scenario, endpoint string, joiner chan struct{}, ...) model.Stage
- func LoopListener(host *model.Host, joiner chan struct{}, bindAddress string, ...) model.Stage
- func Mesh(closer <-chan struct{}) model.Stage
- func ModelMetrics(closer <-chan struct{}) model.Stage
- func ModelMetricsWithIdMapper(closer <-chan struct{}, f func(string) string) model.Stage
- type ClientMetrics
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CircuitMetrics ¶
func Loop3Dialer ¶
func Loop3Listener ¶
func LoopDialer ¶
func LoopListener ¶
func ModelMetrics ¶
Types ¶
type ClientMetrics ¶
type ClientMetrics struct {
// contains filtered or unexported fields
}
func NewClientMetrics ¶
func NewClientMetrics(service string, closer <-chan struct{}) *ClientMetrics
func NewClientMetricsWithIdMapper ¶
func NewClientMetricsWithIdMapper(service string, closer <-chan struct{}, f func(string) string) *ClientMetrics
func (*ClientMetrics) HandleMetricsConn ¶
func (metrics *ClientMetrics) HandleMetricsConn(conn net.Conn)
Source Files
Click to show internal directories.
Click to hide internal directories.