adapter

Documentation

Index

• Variables
• func DialContextWithMetadata(dialer network.Dialer, ctx context.Context, network, addr string, ...) (net.Conn, error)
• type InjectOutbound
• type Metadata
  • func (m *Metadata) GenerateID()
• type MetadataOutbound
• type MinecraftMetadata
  • func (m *MinecraftMetadata) CleanOriginDestination() (clean string)
  • func (m *MinecraftMetadata) FMLMarkup() string
  • func (m *MinecraftMetadata) IsFML() bool
  • func (m *MinecraftMetadata) Valid() bool
• type Outbound
• type OutboundReloadOptions
  • func (o *OutboundReloadOptions) FindListsByTag(tags []string) ([]set.StringSet, error)
  • func (o *OutboundReloadOptions) FindOutboundByName(name string) (Outbound, error)
• type Protocol
• type RouteResourceProvider
• type Router
• type SRVMetadata
• type SRVOutbound
• type Service
• type TLSMetadata

Variables

var ErrInjectionRequired = errors.New("injection required")

Functions

func DialContextWithMetadata

func DialContextWithMetadata(dialer network.Dialer, ctx context.Context, network, addr string, metadata *Metadata) (net.Conn, error)

Types

type InjectOutbound

type InjectOutbound interface {
	InjectConnection(ctx context.Context, conn *bufio.CachedConn, metadata *Metadata) error
}

type Metadata

type Metadata struct {
	ConnectionID        string
	ServiceName         string
	SniffedProtocol     Protocol
	SourceAddress       netip.AddrPort
	DestinationHostname string
	DestinationPort     uint16
	SRV                 *SRVMetadata
	Minecraft           *MinecraftMetadata
	TLS                 *TLSMetadata
	Custom              map[string]any
}

func (*Metadata) GenerateID

func (m *Metadata) GenerateID()

type MetadataOutbound

type MetadataOutbound interface {
	DialContextWithMetadata(ctx context.Context, network string, address string, metadata *Metadata) (net.Conn, error)
}

type MinecraftMetadata

type MinecraftMetadata struct {
	ProtocolVersion      uint
	PlayerName           string
	OriginDestination    string
	RewrittenDestination string

	OriginPort    uint16
	RewrittenPort uint16
	UUID          [16]byte
	NextState     int8
	SniffPosition int
	// contains filtered or unexported fields
}

func (*MinecraftMetadata) CleanOriginDestination

func (m *MinecraftMetadata) CleanOriginDestination() (clean string)

func (*MinecraftMetadata) FMLMarkup

func (m *MinecraftMetadata) FMLMarkup() string

func (*MinecraftMetadata) IsFML

func (m *MinecraftMetadata) IsFML() bool

func (*MinecraftMetadata) Valid

func (m *MinecraftMetadata) Valid() bool

type Outbound

type Outbound interface {
	Name() string
	PostInitialize(router Router, provider RouteResourceProvider) error
	Reload(options OutboundReloadOptions) error
	DialContext(ctx context.Context, network string, address string) (net.Conn, error)
}

type OutboundReloadOptions

type OutboundReloadOptions struct {
	Router Router
	Config *config.Outbound
	Lists  map[string]set.StringSet
}

func (*OutboundReloadOptions) FindListsByTag

func (o *OutboundReloadOptions) FindListsByTag(tags []string) ([]set.StringSet, error)

func (*OutboundReloadOptions) FindOutboundByName

func (o *OutboundReloadOptions) FindOutboundByName(name string) (Outbound, error)

type Protocol

type Protocol = uint8

type RouteResourceProvider

type RouteResourceProvider interface {
	FindOutboundByName(name string) (Outbound, error)
	FindListsByTag(tags []string) ([]set.StringSet, error)
}

type Router

type Router interface {
	RouteResourceProvider
	HandleConnection(conn net.Conn, metadata *Metadata)
}

type SRVMetadata

type SRVMetadata struct {
	ServiceName string
}

type SRVOutbound

type SRVOutbound interface {
	DialContextWithSRV(ctx context.Context, network string, address string, serviceName string) (net.Conn, error)
}

type Service

type Service interface {
	Start(ctx context.Context) error
	Reload(ctx context.Context, newConfig *config.Service) error
	UpdateRouter(router Router)
	io.Closer
}

type TLSMetadata

type TLSMetadata struct {
	SNI string
}