outbound

Documentation

Index

• func CopyEarlyConn(ctx context.Context, conn net.Conn, serverConn net.Conn) error
• func NewConnection(ctx context.Context, this N.Dialer, conn net.Conn, ...) error
• func NewDirectConnection(ctx context.Context, router adapter.Router, this N.Dialer, conn net.Conn, ...) error
• func NewDirectPacketConnection(ctx context.Context, router adapter.Router, this N.Dialer, conn N.PacketConn, ...) error
• func NewPacketConnection(ctx context.Context, this N.Dialer, conn N.PacketConn, ...) error
• func Register[Options any](registry *Registry, outboundType string, constructor ConstructorFunc[Options])
• type Adapter
  • func NewAdapter(protocol string, network []string, tag string, dependencies []string) Adapter
  • func NewAdapterWithDialerOptions(protocol string, network []string, tag string, ...) Adapter
  • func (a *Adapter) Dependencies() []string
  • func (a *Adapter) Network() []string
  • func (a *Adapter) Tag() string
  • func (a *Adapter) Type() string
• type ConstructorFunc
• type Manager
  • func NewManager(logger logger.ContextLogger, registry adapter.OutboundRegistry, ...) *Manager
  • func (m *Manager) Close() error
  • func (m *Manager) Create(ctx context.Context, router adapter.Router, logger log.ContextLogger, ...) error
  • func (m *Manager) Default() adapter.Outbound
  • func (m *Manager) Initialize(defaultOutboundFallback adapter.Outbound)
  • func (m *Manager) Outbound(tag string) (adapter.Outbound, bool)
  • func (m *Manager) Outbounds() []adapter.Outbound
  • func (m *Manager) Remove(tag string) error
  • func (m *Manager) Start(stage adapter.StartStage) error
• type Registry
  • func NewRegistry() *Registry
  • func (r *Registry) CreateOptions(outboundType string) (any, bool)
  • func (r *Registry) CreateOutbound(ctx context.Context, router adapter.Router, logger log.ContextLogger, ...) (adapter.Outbound, error)

Functions

func CopyEarlyConn

func CopyEarlyConn(ctx context.Context, conn net.Conn, serverConn net.Conn) error

func NewConnection

func NewConnection(ctx context.Context, this N.Dialer, conn net.Conn, metadata adapter.InboundContext) error

func NewDirectConnection

func NewDirectConnection(ctx context.Context, router adapter.Router, this N.Dialer, conn net.Conn, metadata adapter.InboundContext, domainStrategy dns.DomainStrategy) error

func NewDirectPacketConnection

func NewDirectPacketConnection(ctx context.Context, router adapter.Router, this N.Dialer, conn N.PacketConn, metadata adapter.InboundContext, domainStrategy dns.DomainStrategy) error

func NewPacketConnection

func NewPacketConnection(ctx context.Context, this N.Dialer, conn N.PacketConn, metadata adapter.InboundContext) error

func Register

func Register[Options any](registry *Registry, outboundType string, constructor ConstructorFunc[Options])

Types

type Adapter

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

func NewAdapter

func NewAdapter(protocol string, network []string, tag string, dependencies []string) Adapter

func NewAdapterWithDialerOptions

func NewAdapterWithDialerOptions(protocol string, network []string, tag string, dialOptions option.DialerOptions) Adapter

func (*Adapter) Dependencies

func (a *Adapter) Dependencies() []string

func (*Adapter) Network

func (a *Adapter) Network() []string

func (*Adapter) Tag

func (a *Adapter) Tag() string

func (*Adapter) Type

func (a *Adapter) Type() string

type ConstructorFunc

type ConstructorFunc[T any] func(ctx context.Context, router adapter.Router, logger log.ContextLogger, tag string, options T) (adapter.Outbound, error)

type Manager

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

func NewManager

func NewManager(logger logger.ContextLogger, registry adapter.OutboundRegistry, defaultTag string) *Manager

func (*Manager) Close

func (m *Manager) Close() error

func (*Manager) Create

func (m *Manager) Create(ctx context.Context, router adapter.Router, logger log.ContextLogger, tag string, inboundType string, options any) error

func (*Manager) Default

func (m *Manager) Default() adapter.Outbound

func (*Manager) Initialize

func (m *Manager) Initialize(defaultOutboundFallback adapter.Outbound)

func (*Manager) Outbound

func (m *Manager) Outbound(tag string) (adapter.Outbound, bool)

func (*Manager) Outbounds

func (m *Manager) Outbounds() []adapter.Outbound

func (*Manager) Remove

func (m *Manager) Remove(tag string) error

func (*Manager) Start

func (m *Manager) Start(stage adapter.StartStage) error

type Registry

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

func NewRegistry

func NewRegistry() *Registry

func (*Registry) CreateOptions

func (r *Registry) CreateOptions(outboundType string) (any, bool)

func (*Registry) CreateOutbound

func (r *Registry) CreateOutbound(ctx context.Context, router adapter.Router, logger log.ContextLogger, tag string, outboundType string, options any) (adapter.Outbound, error)