client

type Client interface {
	// contains filtered or unexported methods
}

type LeveledLogger struct {
	Logger *logrus.Logger
}

type Opt func(*client) error

type Response interface {
	StatusCode() int
}

type ReverseListenerV2Config struct {
	// AcceptBacklog is used to limit how many streams may be
	// waiting an accept.
	AcceptBacklog int `json:"yamux_accept_backlog"`

	// EnableKeepalive is used to do a period keep alive
	// messages using a ping.
	EnableKeepAlive bool `json:"yamux_enable_keep_alive"`

	// KeepAliveInterval is how often to perform the keep alive
	KeepAliveInterval time.Duration `json:"yamux_keep_alive_interval"`

	// ConnectionWriteTimeout is meant to be a "safety valve" timeout after
	// we which will suspect a problem with the underlying connection and
	// close it. This is only applied to writes, where's there's generally
	// an expectation that things will move along quickly.
	ConnectionWriteTimeout time.Duration `json:"yamux_connection_write_timeout"`

	// MaxStreamWindowSize is used to control the maximum
	// window size that we allow for a stream.
	MaxStreamWindowSize uint32 `json:"yamux_max_stream_window_size"`

	// StreamOpenTimeout is the maximum amount of time that a stream will
	// be allowed to remain in pending state while waiting for an ack from the peer.
	// Once the timeout is reached the session will be gracefully closed.
	// A zero value disables the StreamOpenTimeout allowing unbounded
	// blocking on OpenStream calls.
	StreamOpenTimeout time.Duration `json:"yamux_stream_open_timeout"`

	// StreamCloseTimeout is the maximum time that a stream will allowed to
	// be in a half-closed state when `Close` is called before forcibly
	// closing the connection. Forcibly closed connections will empty the
	// receive buffer, drop any future packets received for that stream,
	// and send a RST to the remote side.
	StreamCloseTimeout time.Duration `json:"yamux_stream_close_timeout"`
}

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