splithttp

package

Go to main page

Versions in this module

v24

v24.12.15

Dec 16, 2024

Changes in this version

type BrowserDialerClient

+ func (c *BrowserDialerClient) IsClosed() bool

type Config

+ Headers map[string]string

+ ScMaxBufferedPosts int64

+ func (c *Config) GetNormalizedScMaxBufferedPosts() int

+ func (x *Config) GetHeaders() map[string]string

+ func (x *Config) GetScMaxBufferedPosts() int64

type DefaultDialerClient

+ func (c *DefaultDialerClient) IsClosed() bool

type DialerClient

+ IsClosed func() bool

+ type RangeConfig struct

+ From int32

+ To int32

+ func (*RangeConfig) Descriptor() ([]byte, []int)

+ func (*RangeConfig) ProtoMessage()

+ func (x *RangeConfig) GetFrom() int32

+ func (x *RangeConfig) GetTo() int32

+ func (x *RangeConfig) ProtoReflect() protoreflect.Message

+ func (x *RangeConfig) Reset()

+ func (x *RangeConfig) String() string

+ type XmuxClient struct

+ LeftRequests atomic.Int32

+ OpenUsage atomic.Int32

+ XmuxConn XmuxConn

+ type XmuxConfig struct

+ CMaxLifetimeMs *RangeConfig

+ CMaxReuseTimes *RangeConfig

+ HKeepAlivePeriod int64

+ HMaxRequestTimes *RangeConfig

+ MaxConcurrency *RangeConfig

+ MaxConnections *RangeConfig

+ func (*XmuxConfig) Descriptor() ([]byte, []int)

+ func (*XmuxConfig) ProtoMessage()

+ func (m *XmuxConfig) GetNormalizedCMaxLifetimeMs() RangeConfig

+ func (m *XmuxConfig) GetNormalizedCMaxRequestTimes() RangeConfig

+ func (m *XmuxConfig) GetNormalizedCMaxReuseTimes() RangeConfig

+ func (m *XmuxConfig) GetNormalizedMaxConcurrency() RangeConfig

+ func (m *XmuxConfig) GetNormalizedMaxConnections() RangeConfig

+ func (x *XmuxConfig) GetCMaxLifetimeMs() *RangeConfig

+ func (x *XmuxConfig) GetCMaxReuseTimes() *RangeConfig

+ func (x *XmuxConfig) GetHKeepAlivePeriod() int64

+ func (x *XmuxConfig) GetHMaxRequestTimes() *RangeConfig

+ func (x *XmuxConfig) GetMaxConcurrency() *RangeConfig

+ func (x *XmuxConfig) GetMaxConnections() *RangeConfig

+ func (x *XmuxConfig) ProtoReflect() protoreflect.Message

+ func (x *XmuxConfig) Reset()

+ func (x *XmuxConfig) String() string

+ type XmuxConn interface

+ IsClosed func() bool

+ type XmuxManager struct

+ func NewXmuxManager(xmuxConfig XmuxConfig, newConnFunc func() XmuxConn) *XmuxManager

+ func (m *XmuxManager) GetXmuxClient(ctx context.Context) *XmuxClient

v24.11.30

Nov 30, 2024

Changes in this version

type BrowserDialerClient

+ func (c *BrowserDialerClient) Open(ctx context.Context, pureURL string) (io.WriteCloser, io.ReadCloser)

type Config

+ KeepAlivePeriod int64

+ func (x *Config) GetKeepAlivePeriod() int64

type DefaultDialerClient

+ func (c *DefaultDialerClient) Open(ctx context.Context, pureURL string) (io.WriteCloser, io.ReadCloser)

type DialerClient

+ Open func(context.Context, string) (io.WriteCloser, io.ReadCloser)

+ type WaitReadCloser struct

+ Wait chan struct{}

+ func (w *WaitReadCloser) Close() error

+ func (w *WaitReadCloser) Read(b []byte) (int, error)

+ func (w *WaitReadCloser) Set(rc io.ReadCloser)

v24.11.21

Nov 25, 2024

Changes in this version

type Config

+ NoGRPCHeader bool

+ func (x *Config) GetNoGRPCHeader() bool

v24.11.11

Nov 11, 2024

Changes in this version

type BrowserDialerClient

+ func (c *BrowserDialerClient) OpenUpload(ctx context.Context, baseURL string) io.WriteCloser

type Config

+ Mode string

+ func (x *Config) GetMode() string

type DefaultDialerClient

+ func (c *DefaultDialerClient) OpenUpload(ctx context.Context, baseURL string) io.WriteCloser

type DialerClient

+ OpenUpload func(context.Context, string) io.WriteCloser

type Packet

+ Reader io.ReadCloser

v24.11.7

Nov 9, 2024

v24.11.6

Nov 9, 2024

Changes in this version

+ var File_transport_internet_splithttp_config_proto protoreflect.FileDescriptor

+ func Dial(ctx context.Context, dest net.Destination, ...) (stat.Connection, error)

+ func ListenSH(ctx context.Context, address net.Address, port net.Port, ...) (internet.Listener, error)

+ func NewMuxManager(config Multiplexing, newResource func() interface{}) *muxManager

+ func NewUploadQueue(maxPackets int) *uploadQueue

+ type BrowserDialerClient struct

+ func (c *BrowserDialerClient) OpenDownload(ctx context.Context, baseURL string) (io.ReadCloser, gonet.Addr, gonet.Addr, error)

+ func (c *BrowserDialerClient) SendUploadRequest(ctx context.Context, url string, payload io.ReadWriteCloser, ...) error

+ type Config struct

+ DownloadSettings *internet.StreamConfig

+ Header map[string]string

+ Host string

+ NoSSEHeader bool

+ Path string

+ ScMaxConcurrentPosts *RandRangeConfig

+ ScMaxEachPostBytes *RandRangeConfig

+ ScMinPostsIntervalMs *RandRangeConfig

+ XPaddingBytes *RandRangeConfig

+ Xmux *Multiplexing

+ func (*Config) Descriptor() ([]byte, []int)

+ func (*Config) ProtoMessage()

+ func (c *Config) GetNormalizedPath() string

+ func (c *Config) GetNormalizedQuery() string

+ func (c *Config) GetNormalizedScMaxConcurrentPosts() RandRangeConfig

+ func (c *Config) GetNormalizedScMaxEachPostBytes() RandRangeConfig

+ func (c *Config) GetNormalizedScMinPostsIntervalMs() RandRangeConfig

+ func (c *Config) GetNormalizedXPaddingBytes() RandRangeConfig

+ func (c *Config) GetRequestHeader() http.Header

+ func (c *Config) WriteResponseHeader(writer http.ResponseWriter)

+ func (x *Config) GetDownloadSettings() *internet.StreamConfig

+ func (x *Config) GetHeader() map[string]string

+ func (x *Config) GetHost() string

+ func (x *Config) GetNoSSEHeader() bool

+ func (x *Config) GetPath() string

+ func (x *Config) GetScMaxConcurrentPosts() *RandRangeConfig

+ func (x *Config) GetScMaxEachPostBytes() *RandRangeConfig

+ func (x *Config) GetScMinPostsIntervalMs() *RandRangeConfig

+ func (x *Config) GetXPaddingBytes() *RandRangeConfig

+ func (x *Config) GetXmux() *Multiplexing

+ func (x *Config) ProtoReflect() protoreflect.Message

+ func (x *Config) Reset()

+ func (x *Config) String() string

+ type DefaultDialerClient struct

+ func (c *DefaultDialerClient) OpenDownload(ctx context.Context, baseURL string) (io.ReadCloser, gonet.Addr, gonet.Addr, error)

+ func (c *DefaultDialerClient) SendUploadRequest(ctx context.Context, url string, payload io.ReadWriteCloser, ...) error

+ type DialerClient interface

+ OpenDownload func(context.Context, string) (io.ReadCloser, net.Addr, net.Addr, error)

+ SendUploadRequest func(context.Context, string, io.ReadWriteCloser, int64) error

+ type H1Conn struct

+ RespBufReader *bufio.Reader

+ UnreadedResponsesCount int

+ func NewH1Conn(conn net.Conn) *H1Conn

+ type LazyReader struct

+ CreateReader func() (io.Reader, error)

+ func (r *LazyReader) Read(b []byte) (int, error)

+ type Listener struct

+ func (ln *Listener) Addr() net.Addr

+ func (ln *Listener) Close() error

+ type Multiplexing struct

+ CMaxLifetimeMs *RandRangeConfig

+ CMaxReuseTimes *RandRangeConfig

+ MaxConcurrency *RandRangeConfig

+ MaxConnections *RandRangeConfig

+ func (*Multiplexing) Descriptor() ([]byte, []int)

+ func (*Multiplexing) ProtoMessage()

+ func (m *Multiplexing) GetNormalizedCMaxLifetimeMs() RandRangeConfig

+ func (m *Multiplexing) GetNormalizedCMaxReuseTimes() RandRangeConfig

+ func (m *Multiplexing) GetNormalizedMaxConcurrency() RandRangeConfig

+ func (m *Multiplexing) GetNormalizedMaxConnections() RandRangeConfig

+ func (x *Multiplexing) GetCMaxLifetimeMs() *RandRangeConfig

+ func (x *Multiplexing) GetCMaxReuseTimes() *RandRangeConfig

+ func (x *Multiplexing) GetMaxConcurrency() *RandRangeConfig

+ func (x *Multiplexing) GetMaxConnections() *RandRangeConfig

+ func (x *Multiplexing) ProtoReflect() protoreflect.Message

+ func (x *Multiplexing) Reset()

+ func (x *Multiplexing) String() string

+ type Packet struct

+ Payload []byte

+ Seq uint64

+ type RandRangeConfig struct

+ From int32

+ To int32

+ func (*RandRangeConfig) Descriptor() ([]byte, []int)

+ func (*RandRangeConfig) ProtoMessage()

+ func (x *RandRangeConfig) GetFrom() int32

+ func (x *RandRangeConfig) GetTo() int32

+ func (x *RandRangeConfig) ProtoReflect() protoreflect.Message

+ func (x *RandRangeConfig) Reset()

+ func (x *RandRangeConfig) String() string

Other modules containing this package

github.com/xmplusdev/xray-core

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL