outbound

Documentation

Index

• type Config
• type ExpiringReceiver
  • func (this *ExpiringReceiver) Expired() bool
• type Receiver
  • func NewReceiver(dest v2net.Destination, users ...*proto.User) *Receiver
  • func (this *Receiver) AddUser(user *proto.User)
  • func (this *Receiver) HasUser(user *proto.User) bool
  • func (this *Receiver) PickUser() *proto.User
• type ReceiverManager
  • func NewReceiverManager(receivers []*Receiver) *ReceiverManager
  • func (this *ReceiverManager) AddDetour(rec *Receiver, availableMin byte)
  • func (this *ReceiverManager) PickReceiver() (v2net.Destination, *proto.User)
• type VMessOutboundHandler
  • func (this *VMessOutboundHandler) Dispatch(firstPacket v2net.Packet, 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 Receiver

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

func NewReceiver

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

func (*Receiver) AddUser

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

func (*Receiver) HasUser

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

func (*Receiver) PickUser

func (this *Receiver) PickUser() *proto.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() (v2net.Destination, *proto.User)

type VMessOutboundHandler

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

func (*VMessOutboundHandler) Dispatch

func (this *VMessOutboundHandler) Dispatch(firstPacket v2net.Packet, ray ray.OutboundRay) error