proxy

Nov 12, 2024

Changes in this version

type Options

+ DNSResolver DNSCache

+ Logger *logrus.Logger

Oct 22, 2024

Changes in this version

type Options

+ MaxResponseBodySize int

+ ReadBufferSize int

+ WriteBufferSize int

Sep 24, 2024

Changes in this version

type DNSCache

+ LookupIPAddr func(context.Context, string) (names []net.IPAddr, err error)

+ type DNSCacheOptions struct

+ FetchTimeout time.Duration

+ Logger *logrus.Logger

+ LookupTimeout time.Duration

+ UseCache bool

type MockDNSCache

+ func (m *MockDNSCache) LookupIPAddr(arg0 context.Context, arg1 string) ([]net.IPAddr, error)

type MockDNSCacheMockRecorder

+ func (mr *MockDNSCacheMockRecorder) LookupIPAddr(arg0, arg1 interface{}) *gomock.Call

type Resolver

+ func (r *Resolver) LookupIPAddr(ctx context.Context, addr string) ([]net.IPAddr, error)

Aug 19, 2024

Changes in this version

+ type DNSCache interface

+ Fetch func(ctx context.Context, addr string) ([]net.IP, error)

+ LookupIP func(ctx context.Context, addr string) ([]net.IP, error)

+ Refresh func()

+ Stop func()

+ func NewDNSResolver(freq time.Duration, lookupTimeout time.Duration, resolver *net.Resolver, ...) (DNSCache, error)

+ type MockDNSCache struct

+ func NewMockDNSCache(ctrl *gomock.Controller) *MockDNSCache

+ func (m *MockDNSCache) EXPECT() *MockDNSCacheMockRecorder

+ func (m *MockDNSCache) Fetch(ctx context.Context, addr string) ([]net.IP, error)

+ func (m *MockDNSCache) LookupIP(ctx context.Context, addr string) ([]net.IP, error)

+ func (m *MockDNSCache) Refresh()

+ func (m *MockDNSCache) Stop()

+ type MockDNSCacheMockRecorder struct

+ func (mr *MockDNSCacheMockRecorder) Fetch(ctx, addr interface{}) *gomock.Call

+ func (mr *MockDNSCacheMockRecorder) LookupIP(ctx, addr interface{}) *gomock.Call

+ func (mr *MockDNSCacheMockRecorder) Refresh() *gomock.Call

+ func (mr *MockDNSCacheMockRecorder) Stop() *gomock.Call

type Options

+ DNSConfig config.DNS

+ type Resolver struct

+ func (r *Resolver) Fetch(ctx context.Context, addr string) ([]net.IP, error)

+ func (r *Resolver) LookupIP(ctx context.Context, addr string) ([]net.IP, error)

+ func (r *Resolver) Refresh()

+ func (r *Resolver) Stop()

Sep 8, 2023

Changes in this version

+ func Perform(ctx *fasthttp.RequestCtx, proxyPool Pool) error

+ type FastHTTPWebSocketClient struct

+ ConnStr string

+ Dialer *websocket.Dialer

+ Logger *logrus.Logger

+ func (f *FastHTTPWebSocketClient) GetConn(ctx *fasthttp.RequestCtx) (*FastHTTPWebSocketConn, error)

+ type FastHTTPWebSocketConn struct

+ Conn *websocket.Conn

+ Ctx *fasthttp.RequestCtx

+ Logger *logrus.Logger

+ func (f *FastHTTPWebSocketConn) Close() error

+ func (f *FastHTTPWebSocketConn) ReadMessage() (messageType int, p []byte, err error)

+ func (f *FastHTTPWebSocketConn) SendCloseConnection(closeType int) error

+ func (f *FastHTTPWebSocketConn) SendComplete(messageType int, id string) error

+ func (f *FastHTTPWebSocketConn) SendError(messageType int, msgID string, requestErrors error) error

+ func (f *FastHTTPWebSocketConn) WriteMessage(messageType int, data []byte) error

+ type GqlWSErrorMessage struct

+ ID string

+ Payload graphql.RequestErrors

+ Type string

+ type MockWebSocketClient struct

+ func NewMockWebSocketClient(ctrl *gomock.Controller) *MockWebSocketClient

+ func (m *MockWebSocketClient) EXPECT() *MockWebSocketClientMockRecorder

+ func (m *MockWebSocketClient) GetConn(ctx *fasthttp.RequestCtx) (*FastHTTPWebSocketConn, error)

+ type MockWebSocketClientMockRecorder struct

+ func (mr *MockWebSocketClientMockRecorder) GetConn(ctx interface{}) *gomock.Call

+ type MockWebSocketConn struct

+ func NewMockWebSocketConn(ctrl *gomock.Controller) *MockWebSocketConn

+ func (m *MockWebSocketConn) Close() error

+ func (m *MockWebSocketConn) EXPECT() *MockWebSocketConnMockRecorder

+ func (m *MockWebSocketConn) ReadMessage() (int, []byte, error)

+ func (m *MockWebSocketConn) SendCloseConnection(closeType int) error

+ func (m *MockWebSocketConn) SendComplete(messageType int, id string) error

+ func (m *MockWebSocketConn) SendError(messageType int, msgID string, requestErrors error) error

+ func (m *MockWebSocketConn) WriteMessage(messageType int, data []byte) error

+ type MockWebSocketConnMockRecorder struct

+ func (mr *MockWebSocketConnMockRecorder) Close() *gomock.Call

+ func (mr *MockWebSocketConnMockRecorder) ReadMessage() *gomock.Call

+ func (mr *MockWebSocketConnMockRecorder) SendCloseConnection(closeType interface{}) *gomock.Call

+ func (mr *MockWebSocketConnMockRecorder) SendComplete(messageType, id interface{}) *gomock.Call

+ func (mr *MockWebSocketConnMockRecorder) SendError(messageType, msgID, requestErrors interface{}) *gomock.Call

+ func (mr *MockWebSocketConnMockRecorder) WriteMessage(messageType, data interface{}) *gomock.Call

+ type Options struct

+ ClientPoolCapacity int

+ DialTimeout time.Duration

+ InitialPoolCapacity int

+ InsecureConnection bool

+ MaxConnsPerHost int

+ ReadTimeout time.Duration

+ RootCA string

+ WriteTimeout time.Duration

+ type WSClientOptions struct

+ DialTimeout time.Duration

+ Host string

+ InsecureConnection bool

+ Path string

+ RootCA string

+ Scheme string

+ type WebSocketClient interface

+ GetConn func(ctx *fasthttp.RequestCtx) (*FastHTTPWebSocketConn, error)

+ func NewWSClient(logger *logrus.Logger, options *WSClientOptions) (WebSocketClient, error)

+ type WebSocketConn interface

+ Close func() error

+ ReadMessage func() (messageType int, p []byte, err error)

+ SendCloseConnection func(closeType int) error

+ SendComplete func(messageType int, id string) error

+ SendError func(messageType int, msgID string, requestErrors error) error

+ WriteMessage func(messageType int, data []byte) error

Sep 13, 2022

Changes in this version

+ type MockHTTPClient struct

+ func NewMockHTTPClient(ctrl *gomock.Controller) *MockHTTPClient

+ func (m *MockHTTPClient) Do(req *fasthttp.Request, resp *fasthttp.Response) error

+ func (m *MockHTTPClient) EXPECT() *MockHTTPClientMockRecorder

+ type MockHTTPClientMockRecorder struct

+ func (mr *MockHTTPClientMockRecorder) Do(req, resp interface{}) *gomock.Call

+ type MockPool struct

+ func NewMockPool(ctrl *gomock.Controller) *MockPool

+ func (m *MockPool) Close()

+ func (m *MockPool) EXPECT() *MockPoolMockRecorder

+ func (m *MockPool) Get() (HTTPClient, error)

+ func (m *MockPool) Len() int

+ func (m *MockPool) Put(arg0 HTTPClient) error

+ type MockPoolMockRecorder struct

+ func (mr *MockPoolMockRecorder) Close() *gomock.Call

+ func (mr *MockPoolMockRecorder) Get() *gomock.Call

+ func (mr *MockPoolMockRecorder) Len() *gomock.Call

+ func (mr *MockPoolMockRecorder) Put(arg0 interface{}) *gomock.Call

Jan 25, 2022

Changes in this version

+ type HTTPClient interface

+ Do func(req *fasthttp.Request, resp *fasthttp.Response) error

+ type Pool interface

+ Close func()

+ Get func() (HTTPClient, error)

+ Len func() int

+ Put func(HTTPClient) error

+ func NewChanPool(initialCap, maxCap int, hostAddr string, server *config.Server) (Pool, error)