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

package dispatcher

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

Index

Package Files

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

type Config Uses

type Config struct {
    Settings             *SessionConfig `protobuf:"bytes,1,opt,name=settings,proto3" json:"settings,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

func (*Config) Descriptor Uses

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

func (*Config) GetSettings Uses

func (m *Config) GetSettings() *SessionConfig

func (*Config) ProtoMessage Uses

func (*Config) ProtoMessage()

func (*Config) Reset Uses

func (m *Config) Reset()

func (*Config) String Uses

func (m *Config) String() string

func (*Config) XXX_DiscardUnknown Uses

func (m *Config) XXX_DiscardUnknown()

func (*Config) XXX_Marshal Uses

func (m *Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Config) XXX_Merge Uses

func (m *Config) XXX_Merge(src proto.Message)

func (*Config) XXX_Size Uses

func (m *Config) XXX_Size() int

func (*Config) XXX_Unmarshal Uses

func (m *Config) XXX_Unmarshal(b []byte) error

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 {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*SessionConfig) Descriptor Uses

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

func (*SessionConfig) ProtoMessage Uses

func (*SessionConfig) ProtoMessage()

func (*SessionConfig) Reset Uses

func (m *SessionConfig) Reset()

func (*SessionConfig) String Uses

func (m *SessionConfig) String() string

func (*SessionConfig) XXX_DiscardUnknown Uses

func (m *SessionConfig) XXX_DiscardUnknown()

func (*SessionConfig) XXX_Marshal Uses

func (m *SessionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SessionConfig) XXX_Merge Uses

func (m *SessionConfig) XXX_Merge(src proto.Message)

func (*SessionConfig) XXX_Size Uses

func (m *SessionConfig) XXX_Size() int

func (*SessionConfig) XXX_Unmarshal Uses

func (m *SessionConfig) XXX_Unmarshal(b []byte) error

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 23 packages (graph) and is imported by 40 packages. Updated 2019-03-31. Refresh now. Tools for package owners.