consumer

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

type Config struct {
	BrokerURL          string
	Endpoint           string
	Socks5Listen       string // e.g. ":1080"
	PollInterval       time.Duration
	RetryBackoff       time.Duration
	InsecureSkipVerify bool   // Skip TLS certificate verification
	AuthToken          string // Authentication token for broker
	// CoalesceWindow is passed through to pollmux.Connector; <= 0 uses
	// pollmux.DefaultCoalesceWindow.
	CoalesceWindow time.Duration
	// PollMode is "" or "stream" (default) to request stream mode, or
	// "batch" to opt out and force the older discrete poll mode.
	PollMode string
	// PollGrace is passed through to pollmux.Connector; <= 0 uses
	// pollmux.DefaultPollGrace. Raise it when the broker sits behind a
	// reverse proxy/CDN whose own latency can push a stream-mode poll's
	// response headers past the default 10s.
	PollGrace time.Duration
	// UploadStreamPreference is passed through to
	// pollmux.Connector.UploadStreamPreference: "" (default) auto-detects,
	// "stream" forces it, "batch" disables it. See that field's doc.
	UploadStreamPreference string
	// UploadProbeTimeout is passed through to
	// pollmux.Connector.UploadProbeTimeout; <= 0 uses pollmux's default (15s).
	UploadProbeTimeout time.Duration
	// PreferWebSocket is passed through to pollmux.Connector.PreferWebSocket.
	// Takes effect only if the broker also has EnableWebSocket on; otherwise
	// negotiation falls back to PollMode as if this were false.
	PreferWebSocket bool
	// PreferResume is passed through to pollmux.Connector.PreferResume. When
	// the broker also has EnableResume on and the negotiated transport
	// supports it, the Conn returned by Connect resumes the same session
	// across transport failures instead of surfacing them, so the yamux
	// session built on it (and every stream inside) carries on and Serve
	// keeps running. Otherwise it is silently ignored and a transport
	// failure ends Serve exactly as it does today.
	PreferResume bool
}

type NoopResolver struct{}

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