splithttp

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

type DialerClient interface {
	IsClosed() bool

	// ctx, url, body, uploadOnly
	OpenStream(context.Context, string, io.Reader, bool) (io.ReadCloser, net.Addr, net.Addr, error)

	// ctx, url, body, contentLength
	PostPacket(context.Context, string, io.Reader, int64) error
}

type DownConfig struct {
	Address     string           `protobuf:"bytes,8,opt,name=address,proto3" json:"address,omitempty"`
	Port        uint32           `protobuf:"varint,9,opt,name=port,proto3" json:"port,omitempty"`
	XhttpConfig *SplitHttpConfig `protobuf:"bytes,2,opt,name=xhttp_config,json=xhttpConfig,proto3" json:"xhttp_config,omitempty"`
	// Types that are valid to be assigned to Security:
	//
	//	*DownConfig_Tls
	//	*DownConfig_Reality
	Security isDownConfig_Security `protobuf_oneof:"security"`
	// contains filtered or unexported fields
}

type DownConfig_Reality struct {
	Reality *reality.RealityConfig `protobuf:"bytes,21,opt,name=reality,proto3,oneof"`
}

type DownConfig_Tls struct {
	Tls *tls.TlsConfig `protobuf:"bytes,20,opt,name=tls,proto3,oneof"`
}

type FakePacketConn struct {
	net.Conn
}

type H1Conn struct {
	UnreadedResponsesCount int
	RespBufReader          *bufio.Reader
	net.Conn
}

type Listener struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Packet struct {
	Reader  io.ReadCloser
	Payload []byte
	Seq     uint64
}

type RangeConfig struct {
	From int32 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To   int32 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

type SplitHttpConfig struct {
	Host          string            `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Path          string            `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Mode          string            `protobuf:"bytes,3,opt,name=mode,proto3" json:"mode,omitempty"`
	Headers       map[string]string `` /* 141-byte string literal not displayed */
	XPaddingBytes *RangeConfig      `protobuf:"bytes,5,opt,name=xPaddingBytes,proto3" json:"xPaddingBytes,omitempty"`
	NoGRPCHeader  bool              `protobuf:"varint,6,opt,name=noGRPCHeader,proto3" json:"noGRPCHeader,omitempty"`
	// server only
	NoSSEHeader          bool         `protobuf:"varint,7,opt,name=noSSEHeader,proto3" json:"noSSEHeader,omitempty"`
	ScMaxEachPostBytes   *RangeConfig `protobuf:"bytes,8,opt,name=scMaxEachPostBytes,proto3" json:"scMaxEachPostBytes,omitempty"`
	ScMinPostsIntervalMs *RangeConfig `protobuf:"bytes,9,opt,name=scMinPostsIntervalMs,proto3" json:"scMinPostsIntervalMs,omitempty"`
	// server only
	ScMaxBufferedPosts int64 `protobuf:"varint,10,opt,name=scMaxBufferedPosts,proto3" json:"scMaxBufferedPosts,omitempty"`
	// server only
	ScStreamUpServerSecs *RangeConfig `protobuf:"bytes,11,opt,name=scStreamUpServerSecs,proto3" json:"scStreamUpServerSecs,omitempty"`
	Xmux                 *XmuxConfig  `protobuf:"bytes,12,opt,name=xmux,proto3" json:"xmux,omitempty"`
	DownloadSettings     *DownConfig  `protobuf:"bytes,13,opt,name=downloadSettings,proto3" json:"downloadSettings,omitempty"`
	// contains filtered or unexported fields
}

type WaitReadCloser struct {
	Wait chan struct{}
	io.ReadCloser
}

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

type XmuxClient struct {
	XmuxConn  XmuxConn
	OpenUsage atomic.Int32

	LeftRequests atomic.Int32
	UnreusableAt time.Time
	// contains filtered or unexported fields
}

type XmuxConfig struct {
	MaxConcurrency   *RangeConfig `protobuf:"bytes,1,opt,name=maxConcurrency,proto3" json:"maxConcurrency,omitempty"`
	MaxConnections   *RangeConfig `protobuf:"bytes,2,opt,name=maxConnections,proto3" json:"maxConnections,omitempty"`
	CMaxReuseTimes   *RangeConfig `protobuf:"bytes,3,opt,name=cMaxReuseTimes,proto3" json:"cMaxReuseTimes,omitempty"`
	HMaxRequestTimes *RangeConfig `protobuf:"bytes,4,opt,name=hMaxRequestTimes,proto3" json:"hMaxRequestTimes,omitempty"`
	HMaxReusableSecs *RangeConfig `protobuf:"bytes,5,opt,name=hMaxReusableSecs,proto3" json:"hMaxReusableSecs,omitempty"`
	HKeepAlivePeriod int64        `protobuf:"varint,6,opt,name=hKeepAlivePeriod,proto3" json:"hKeepAlivePeriod,omitempty"`
	// contains filtered or unexported fields
}

type XmuxConn interface {
	IsClosed() bool
}

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