outbound

Documentation

Index

• type Config
• type ExpiringReceiver
  • func (this *ExpiringReceiver) Expired() bool
• type Factory
  • func (this *Factory) Create(space app.Space, rawConfig interface{}, meta *proxy.OutboundHandlerMeta) (proxy.OutboundHandler, error)
  • func (this *Factory) StreamCapability() internet.StreamConnectionType
• type Receiver
  • func NewReceiver(dest v2net.Destination, users ...*protocol.User) *Receiver
  • func (this *Receiver) AddUser(user *protocol.User)
  • func (this *Receiver) HasUser(user *protocol.User) bool
  • func (this *Receiver) PickUser() *protocol.User
• type ReceiverManager
  • func NewReceiverManager(receivers []*Receiver) *ReceiverManager
  • func (this *ReceiverManager) AddDetour(rec *Receiver, availableMin byte)
  • func (this *ReceiverManager) PickReceiver() *Receiver
• type VMessOutboundHandler
  • func (this *VMessOutboundHandler) Dispatch(target v2net.Destination, payload *alloc.Buffer, ray ray.OutboundRay) error

Types

type Config

type Config struct {
	Receivers []*Receiver
}

type ExpiringReceiver

type ExpiringReceiver struct {
	*Receiver
	// contains filtered or unexported fields
}

func (*ExpiringReceiver) Expired

func (this *ExpiringReceiver) Expired() bool

type Factory

type Factory struct{}

func (*Factory) Create

func (this *Factory) Create(space app.Space, rawConfig interface{}, meta *proxy.OutboundHandlerMeta) (proxy.OutboundHandler, error)

func (*Factory) StreamCapability

func (this *Factory) StreamCapability() internet.StreamConnectionType

type Receiver

type Receiver struct {
	sync.RWMutex
	Destination v2net.Destination
	Accounts    []*protocol.User
}

func NewReceiver

func NewReceiver(dest v2net.Destination, users ...*protocol.User) *Receiver

func (*Receiver) AddUser

func (this *Receiver) AddUser(user *protocol.User)

func (*Receiver) HasUser

func (this *Receiver) HasUser(user *protocol.User) bool

func (*Receiver) PickUser

func (this *Receiver) PickUser() *protocol.User

type ReceiverManager

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

func NewReceiverManager

func NewReceiverManager(receivers []*Receiver) *ReceiverManager

func (*ReceiverManager) AddDetour

func (this *ReceiverManager) AddDetour(rec *Receiver, availableMin byte)

func (*ReceiverManager) PickReceiver

func (this *ReceiverManager) PickReceiver() *Receiver

type VMessOutboundHandler

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

func (*VMessOutboundHandler) Dispatch

func (this *VMessOutboundHandler) Dispatch(target v2net.Destination, payload *alloc.Buffer, ray ray.OutboundRay) error