xdispatcher

Oct 1, 2023

Changes in this version

+ var File_app_xdispatcher_config_proto protoreflect.FileDescriptor

+ type Config struct

+ Settings *SessionConfig

+ func (*Config) Descriptor() ([]byte, []int)

+ func (*Config) ProtoMessage()

+ func (x *Config) GetSettings() *SessionConfig

+ func (x *Config) ProtoReflect() protoreflect.Message

+ func (x *Config) Reset()

+ func (x *Config) String() string

+ type DNSThenOthersSniffResult struct

+ func (DNSThenOthersSniffResult) Protocol() string

+ func (f DNSThenOthersSniffResult) Domain() string

+ func (f DNSThenOthersSniffResult) IsProtoSubsetOf(protocolName string) bool

+ type DefaultDispatcher struct

+ Limiter *limiter.Limiter

+ RuleManager *rule.Manager

+ func (*DefaultDispatcher) Close() error

+ func (*DefaultDispatcher) Start() error

+ func (*DefaultDispatcher) Type() interface{}

+ func (d *DefaultDispatcher) Dispatch(ctx context.Context, destination net.Destination) (*transport.Link, error)

+ func (d *DefaultDispatcher) DispatchLink(ctx context.Context, destination net.Destination, outbound *transport.Link) error

+ func (d *DefaultDispatcher) Init(config *Config, om outbound.Manager, router routing.Router, pm policy.Manager, ...) error

+ type SessionConfig struct

+ func (*SessionConfig) Descriptor() ([]byte, []int)

+ func (*SessionConfig) ProtoMessage()

+ func (x *SessionConfig) ProtoReflect() protoreflect.Message

+ func (x *SessionConfig) Reset()

+ func (x *SessionConfig) String() string

+ type SizeStatWriter struct

+ Counter stats.Counter

+ Writer buf.Writer

+ func (w *SizeStatWriter) Close() error

+ func (w *SizeStatWriter) Interrupt()

+ func (w *SizeStatWriter) WriteMultiBuffer(mb buf.MultiBuffer) error

+ type SniffResult interface

+ Domain func() string

+ Protocol func() string

+ func CompositeResult(domainResult SniffResult, protocolResult SniffResult) SniffResult

+ type Sniffer struct

+ func NewSniffer(ctx context.Context) *Sniffer

+ func (s *Sniffer) Sniff(c context.Context, payload []byte, network net.Network) (SniffResult, error)

+ func (s *Sniffer) SniffMetadata(c context.Context) (SniffResult, error)

+ type SnifferIsProtoSubsetOf interface

+ IsProtoSubsetOf func(protocolName string) bool

+ type SnifferResultComposite interface

+ ProtocolForDomainResult func() string