sender

Documentation

Index

• type Config
  • func (*Config) Descriptor() ([]byte, []int)
  • func (m *Config) GetSettings() []*PerProxyConfig
  • func (*Config) ProtoMessage()
  • func (m *Config) Reset()
  • func (m *Config) String() string
• type DatagramSenderConfig
  • func (*DatagramSenderConfig) Descriptor() ([]byte, []int)
  • func (m *DatagramSenderConfig) GetVia() *v2ray_core_common_net.IPOrDomain
  • func (*DatagramSenderConfig) ProtoMessage()
  • func (m *DatagramSenderConfig) Reset()
  • func (m *DatagramSenderConfig) String() string
• type PerProxyConfig
  • func (*PerProxyConfig) Descriptor() ([]byte, []int)
  • func (m *PerProxyConfig) GetSettings() []*v2ray_core_common_serial.TypedMessage
  • func (m *PerProxyConfig) GetTag() string
  • func (*PerProxyConfig) ProtoMessage()
  • func (m *PerProxyConfig) Reset()
  • func (m *PerProxyConfig) String() string
• type Sender
• type SenderManager
  • func FromSpace(space app.Space) *SenderManager
  • func New(space app.Space, config *Config) (*SenderManager, error)
• type SenderManagerFactory
  • func (SenderManagerFactory) Create(space app.Space, config interface{}) (app.Application, error)
• type StreamSender
  • func NewStreamSender(config *StreamSenderConfig, space app.Space) *StreamSender
  • func (s *StreamSender) SendTo(destination net.Destination) (internet.Connection, error)
• type StreamSenderConfig
  • func (*StreamSenderConfig) Descriptor() ([]byte, []int)
  • func (m *StreamSenderConfig) GetProxySettings() *v2ray_core_transport_internet.ProxyConfig
  • func (m *StreamSenderConfig) GetStreamSettings() *v2ray_core_transport_internet.StreamConfig
  • func (m *StreamSenderConfig) GetVia() *v2ray_core_common_net.IPOrDomain
  • func (*StreamSenderConfig) ProtoMessage()
  • func (m *StreamSenderConfig) Reset()
  • func (m *StreamSenderConfig) String() string

Types

type Config

type Config struct {
	Settings []*PerProxyConfig `protobuf:"bytes,1,rep,name=settings" json:"settings,omitempty"`
}

func (*Config) Descriptor

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

func (*Config) GetSettings

func (m *Config) GetSettings() []*PerProxyConfig

func (*Config) ProtoMessage

func (*Config) ProtoMessage()

func (*Config) Reset

func (m *Config) Reset()

func (*Config) String

func (m *Config) String() string

type DatagramSenderConfig

type DatagramSenderConfig struct {
	Via *v2ray_core_common_net.IPOrDomain `protobuf:"bytes,1,opt,name=via" json:"via,omitempty"`
}

func (*DatagramSenderConfig) Descriptor

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

func (*DatagramSenderConfig) GetVia

func (m *DatagramSenderConfig) GetVia() *v2ray_core_common_net.IPOrDomain

func (*DatagramSenderConfig) ProtoMessage

func (*DatagramSenderConfig) ProtoMessage()

func (*DatagramSenderConfig) Reset

func (m *DatagramSenderConfig) Reset()

func (*DatagramSenderConfig) String

func (m *DatagramSenderConfig) String() string

type PerProxyConfig

type PerProxyConfig struct {
	Tag      string                                   `protobuf:"bytes,1,opt,name=tag" json:"tag,omitempty"`
	Settings []*v2ray_core_common_serial.TypedMessage `protobuf:"bytes,2,rep,name=settings" json:"settings,omitempty"`
}

func (*PerProxyConfig) Descriptor

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

func (*PerProxyConfig) GetSettings

func (m *PerProxyConfig) GetSettings() []*v2ray_core_common_serial.TypedMessage

func (*PerProxyConfig) GetTag

func (m *PerProxyConfig) GetTag() string

func (*PerProxyConfig) ProtoMessage

func (*PerProxyConfig) ProtoMessage()

func (*PerProxyConfig) Reset

func (m *PerProxyConfig) Reset()

func (*PerProxyConfig) String

func (m *PerProxyConfig) String() string

type Sender

type Sender interface {
	SendTo(net.Destination) (internet.Connection, error)
}

type SenderManager

type SenderManager struct {
}

func FromSpace

func FromSpace(space app.Space) *SenderManager

func New

func New(space app.Space, config *Config) (*SenderManager, error)

type SenderManagerFactory

type SenderManagerFactory struct{}

func (SenderManagerFactory) Create

func (SenderManagerFactory) Create(space app.Space, config interface{}) (app.Application, error)

type StreamSender

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

func NewStreamSender

func NewStreamSender(config *StreamSenderConfig, space app.Space) *StreamSender

func (*StreamSender) SendTo

func (s *StreamSender) SendTo(destination net.Destination) (internet.Connection, error)

type StreamSenderConfig

type StreamSenderConfig struct {
	Via            *v2ray_core_common_net.IPOrDomain           `protobuf:"bytes,1,opt,name=via" json:"via,omitempty"`
	StreamSettings *v2ray_core_transport_internet.StreamConfig `protobuf:"bytes,2,opt,name=stream_settings,json=streamSettings" json:"stream_settings,omitempty"`
	ProxySettings  *v2ray_core_transport_internet.ProxyConfig  `protobuf:"bytes,3,opt,name=proxy_settings,json=proxySettings" json:"proxy_settings,omitempty"`
}

func (*StreamSenderConfig) Descriptor

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

func (*StreamSenderConfig) GetProxySettings

func (m *StreamSenderConfig) GetProxySettings() *v2ray_core_transport_internet.ProxyConfig

func (*StreamSenderConfig) GetStreamSettings

func (m *StreamSenderConfig) GetStreamSettings() *v2ray_core_transport_internet.StreamConfig

func (*StreamSenderConfig) GetVia

func (m *StreamSenderConfig) GetVia() *v2ray_core_common_net.IPOrDomain

func (*StreamSenderConfig) ProtoMessage

func (*StreamSenderConfig) ProtoMessage()

func (*StreamSenderConfig) Reset

func (m *StreamSenderConfig) Reset()

func (*StreamSenderConfig) String

func (m *StreamSenderConfig) String() string