chain

package

Go to main page

Versions in this module

v0

v0.0.11

Dec 23, 2024

Changes in this version

+ type HTTPBodyRewriteSettings struct

+ Pattern *regexp.Regexp

+ Replacement []byte

+ Type string

type HTTPNodeSettings

+ RequestHeader map[string]string

+ ResponseHeader map[string]string

+ RewriteResponseBody []HTTPBodyRewriteSettings

+ RewriteURL []HTTPURLRewriteSetting

type NodeOption

+ func MatcherNodeOption(matcher routing.Matcher) NodeOption

+ func PriorityNodeOption(priority int) NodeOption

type NodeOptions

+ Matcher routing.Matcher

+ Priority int

+ type Transporter interface

+ Bind func(ctx context.Context, conn net.Conn, network, address string, ...) (net.Listener, error)

+ Connect func(ctx context.Context, conn net.Conn, network, address string) (net.Conn, error)

+ Copy func() Transporter

+ Dial func(ctx context.Context, addr string) (net.Conn, error)

+ Handshake func(ctx context.Context, conn net.Conn) (net.Conn, error)

+ Multiplex func() bool

+ Options func() *TransportOptions

v0.0.10

Jun 24, 2024

v0.0.9

Jun 24, 2024

v0.0.8

Jun 24, 2024

Changes in this version

type DialOption

+ func NetnsDialOption(netns string) DialOption

type DialOptions

+ Netns string

type RouterOption

+ func NetnsRouterOption(netns string) RouterOption

type RouterOptions

+ Netns string

type TransportOption

+ func NetnsTransportOption(netns string) TransportOption

type TransportOptions

+ Netns string

v0.0.7

Jun 17, 2024

Changes in this version

+ type NodeFilterSettings struct

+ Host string

+ Path string

+ Protocol string

type NodeOption

+ func NodeFilterOption(filter *NodeFilterSettings) NodeOption

type NodeOptions

+ Filter *NodeFilterSettings

v0.0.6

Feb 26, 2024

v0.0.5

Feb 26, 2024

v0.0.4

Feb 26, 2024

v0.0.3

Feb 26, 2024

v0.0.2

Feb 26, 2024

Changes in this version

type HTTPNodeSettings

+ Auther auth.IAuthenticator

+ Rewrite []HTTPURLRewriteSetting

+ type HTTPURLRewriteSetting struct

+ Pattern *regexp.Regexp

+ Replacement string

v0.0.1

Dec 21, 2023

Changes in this version

+ var ErrEmptyRoute = errors.New("empty route")

+ func Resolve(ctx context.Context, network, addr string, r resolver.IResolver, ...) (string, error)

+ type BindOption func(opts *BindOptions)

+ func BacklogBindOption(backlog int) BindOption

+ func LoggerBindOption(logger logger.ILogger) BindOption

+ func MuxBindOption(mux bool) BindOption

+ func UDPConnTTLBindOption(ttl time.Duration) BindOption

+ func UDPDataBufferSizeBindOption(size int) BindOption

+ func UDPDataQueueSizeBindOption(size int) BindOption

+ type BindOptions struct

+ Backlog int

+ Logger logger.ILogger

+ Mux bool

+ UDPConnTTL time.Duration

+ UDPDataBufferSize int

+ UDPDataQueueSize int

+ type DialOption func(opts *DialOptions)

+ func InterfaceDialOption(ifName string) DialOption

+ func LoggerDialOption(logger logger.ILogger) DialOption

+ func SockOptsDialOption(so *SockOpts) DialOption

+ func TimeoutDialOption(d time.Duration) DialOption

+ type DialOptions struct

+ Interface string

+ Logger logger.ILogger

+ SockOpts *SockOpts

+ Timeout time.Duration

+ type HTTPNodeSettings struct

+ Header map[string]string

+ Host string

+ type IChainer interface

+ Route func(ctx context.Context, network, address string, opts ...RouteOption) IRoute

+ type IRoute interface

+ Bind func(ctx context.Context, network, address string, opts ...BindOption) (net.Listener, error)

+ Dial func(ctx context.Context, network, address string, opts ...DialOption) (net.Conn, error)

+ Nodes func() []*Node

+ var DefaultRoute IRoute = &route{}

+ type Node struct

+ Addr string

+ Name string

+ func NewNode(name string, addr string, opts ...NodeOption) *Node

+ func (node *Node) Copy() *Node

+ func (node *Node) Marker() selector.IMarker

+ func (node *Node) Metadata() metadata.IMetaData

+ func (node *Node) Options() *NodeOptions

+ type NodeOption func(*NodeOptions)

+ func AutherNodeOption(auther auth.IAuthenticator) NodeOption

+ func BypassNodeOption(bp bypass.IBypass) NodeOption

+ func HTTPNodeOption(httpSettings *HTTPNodeSettings) NodeOption

+ func HostMapperNodeOption(m hosts.IHostMapper) NodeOption

+ func HostNodeOption(host string) NodeOption

+ func MetadataNodeOption(md metadata.IMetaData) NodeOption

+ func NetworkNodeOption(network string) NodeOption

+ func PathNodeOption(path string) NodeOption

+ func ProtocolNodeOption(protocol string) NodeOption

+ func ResoloverNodeOption(resolver resolver.IResolver) NodeOption

+ func TLSNodeOption(tlsSettings *TLSNodeSettings) NodeOption

+ func TransportNodeOption(tr *Transport) NodeOption

+ type NodeOptions struct

+ Auther auth.IAuthenticator

+ Bypass bypass.IBypass

+ HTTP *HTTPNodeSettings

+ Host string

+ HostMapper hosts.IHostMapper

+ Metadata metadata.IMetaData

+ Network string

+ Path string

+ Protocol string

+ Resolver resolver.IResolver

+ TLS *TLSNodeSettings

+ Transport *Transport

+ type RouteOption func(opts *RouteOptions)

+ func WithHostRouteOption(host string) RouteOption

+ type RouteOptions struct

+ Host string

+ type Router struct

+ func NewRouter(opts ...RouterOption) *Router

+ func (r *Router) Bind(ctx context.Context, network, address string, opts ...BindOption) (ln net.Listener, err error)

+ func (r *Router) Dial(ctx context.Context, network, address string) (conn net.Conn, err error)

+ func (r *Router) Options() *RouterOptions

+ type RouterOption func(*RouterOptions)

+ func ChainRouterOption(chain IChainer) RouterOption

+ func HostMapperRouterOption(m hosts.IHostMapper) RouterOption

+ func InterfaceRouterOption(ifceName string) RouterOption

+ func LoggerRouterOption(logger logger.ILogger) RouterOption

+ func RecordersRouterOption(recorders ...recorder.RecorderObject) RouterOption

+ func ResolverRouterOption(resolver resolver.IResolver) RouterOption

+ func RetriesRouterOption(retries int) RouterOption

+ func SockOptsRouterOption(so *SockOpts) RouterOption

+ func TimeoutRouterOption(timeout time.Duration) RouterOption

+ type RouterOptions struct

+ Chain IChainer

+ HostMapper hosts.IHostMapper

+ IfceName string

+ Logger logger.ILogger

+ Recorders []recorder.RecorderObject

+ Resolver resolver.IResolver

+ Retries int

+ SockOpts *SockOpts

+ Timeout time.Duration

+ type SockOpts struct

+ Mark int

+ type TLSNodeSettings struct

+ Options struct{ ... }

+ Secure bool

+ ServerName string

+ type Transport struct

+ func NewTransport(d dialer.IDialer, c connector.IConnector, opts ...TransportOption) *Transport

+ func (tr *Transport) Bind(ctx context.Context, conn net.Conn, network, address string, ...) (net.Listener, error)

+ func (tr *Transport) Connect(ctx context.Context, conn net.Conn, network, address string) (net.Conn, error)

+ func (tr *Transport) Copy() *Transport

+ func (tr *Transport) Dial(ctx context.Context, addr string) (net.Conn, error)

+ func (tr *Transport) Handshake(ctx context.Context, conn net.Conn) (net.Conn, error)

+ func (tr *Transport) Multiplex() bool

+ func (tr *Transport) Options() *TransportOptions

+ type TransportOption func(*TransportOptions)

+ func AddrTransportOption(addr string) TransportOption

+ func InterfaceTransportOption(ifceName string) TransportOption

+ func RouteTransportOption(route IRoute) TransportOption

+ func SockOptsTransportOption(so *SockOpts) TransportOption

+ func TimeoutTransportOption(timeout time.Duration) TransportOption

+ type TransportOptions struct

+ Addr string

+ IfceName string

+ Route IRoute

+ SockOpts *SockOpts

+ Timeout time.Duration

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