latency

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

type MonitorConfig struct {
	// ClientPinger measure the round trip time for client half of the connection.
	ClientPinger Pinger
	// ServerPinger measure the round trip time for server half of the connection.
	ServerPinger Pinger
	// Reporter periodically emits statistics to consumers.
	Reporter Reporter
	// Clock used to measure time.
	Clock clockwork.Clock
	// InitialPingInterval an optional duration to use for the first PingInterval.
	InitialPingInterval time.Duration
	// PingInterval is the frequency at which both legs of the connection are pinged for
	// latency calculations.
	PingInterval time.Duration
	// InitialReportInterval an optional duration to use for the first ReportInterval.
	InitialReportInterval time.Duration
	// ReportInterval is the frequency at which the latency information is reported.
	ReportInterval time.Duration
}

type Pinger interface {
	Ping(ctx context.Context) error
}

type Reporter interface {
	Report(ctx context.Context, statistics Statistics) error
}

type ReporterFunc func(ctx context.Context, stats Statistics) error

type SSHClient interface {
	SendRequest(ctx context.Context, name string, wantReply bool, payload []byte) (bool, []byte, error)
}

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

type Statistics struct {
	// Client measures the round trip time between the client and the Proxy.
	Client int64
	// Server measures the round trip time the Proxy and the target host.
	Server int64
}

type WebSocket interface {
	WriteControl(messageType int, data []byte, deadline time.Time) error
	PongHandler() func(appData string) error
	SetPongHandler(h func(appData string) error)
}

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