v2ray-core: github.com/v2ray/v2ray-core/app/dispatcher Index | Files

package dispatcher

import "github.com/v2ray/v2ray-core/app/dispatcher"

Index

Package Files

config.pb.go default.go dispatcher.go errors.generated.go sniffer.go stats.go

Variables

var File_app_dispatcher_config_proto protoreflect.FileDescriptor

type Config Uses

type Config struct {
    Settings *SessionConfig `protobuf:"bytes,1,opt,name=settings,proto3" json:"settings,omitempty"`
    // contains filtered or unexported fields
}

func (*Config) Descriptor Uses

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetSettings Uses

func (x *Config) GetSettings() *SessionConfig

func (*Config) ProtoMessage Uses

func (*Config) ProtoMessage()

func (*Config) ProtoReflect Uses

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

func (*Config) Reset Uses

func (x *Config) Reset()

func (*Config) String Uses

func (x *Config) String() string

type DefaultDispatcher Uses

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

DefaultDispatcher is a default implementation of Dispatcher.

func (*DefaultDispatcher) Close Uses

func (*DefaultDispatcher) Close() error

Close implements common.Closable.

func (*DefaultDispatcher) Dispatch Uses

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

Dispatch implements routing.Dispatcher.

func (*DefaultDispatcher) Init Uses

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

Init initializes DefaultDispatcher.

func (*DefaultDispatcher) Start Uses

func (*DefaultDispatcher) Start() error

Start implements common.Runnable.

func (*DefaultDispatcher) Type Uses

func (*DefaultDispatcher) Type() interface{}

Type implements common.HasType.

type SessionConfig Uses

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

func (*SessionConfig) Descriptor Uses

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

Deprecated: Use SessionConfig.ProtoReflect.Descriptor instead.

func (*SessionConfig) ProtoMessage Uses

func (*SessionConfig) ProtoMessage()

func (*SessionConfig) ProtoReflect Uses

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

func (*SessionConfig) Reset Uses

func (x *SessionConfig) Reset()

func (*SessionConfig) String Uses

func (x *SessionConfig) String() string

type SizeStatWriter Uses

type SizeStatWriter struct {
    Counter stats.Counter
    Writer  buf.Writer
}

func (*SizeStatWriter) Close Uses

func (w *SizeStatWriter) Close() error

func (*SizeStatWriter) Interrupt Uses

func (w *SizeStatWriter) Interrupt()

func (*SizeStatWriter) WriteMultiBuffer Uses

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

type SniffResult Uses

type SniffResult interface {
    Protocol() string
    Domain() string
}

type Sniffer Uses

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

func NewSniffer Uses

func NewSniffer() *Sniffer

func (*Sniffer) Sniff Uses

func (s *Sniffer) Sniff(payload []byte) (SniffResult, error)

Package dispatcher imports 26 packages (graph) and is imported by 10 packages. Updated 2020-12-29. Refresh now. Tools for package owners.