outbound

Documentation

Index

• func Register[Options any](registry *Registry, outboundType string, constructor ConstructorFunc[Options])
• type Adapter
  • func NewAdapter(outboundType string, outboundTag string, network []string, ...) Adapter
  • func NewAdapterWithDialerOptions(outboundType string, outboundTag string, network []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 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(outboundType string, outboundTag string, network []string, dependencies []string) Adapter

func NewAdapterWithDialerOptions

func NewAdapterWithDialerOptions(outboundType string, outboundTag string, network []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, endpoint adapter.EndpointManager, 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)