internal

Documentation

Index

• type DnsCacheWithContext
• type PacketDispatcherWithContext
• type PubsubWithContext
• type Space
  • func NewSpace(tag string, packetDispatcher PacketDispatcherWithContext, ...) *Space
  • func (this *Space) DnsCache() app.DnsCache
  • func (this *Space) HasDnsCache() bool
  • func (this *Space) HasPacketDispatcher() bool
  • func (this *Space) HasPubsub() bool
  • func (this *Space) PacketDispatcher() app.PacketDispatcher
  • func (this *Space) Pubsub() app.Pubsub

Types

type DnsCacheWithContext

type DnsCacheWithContext interface {
	Get(context app.Context, domain string) net.IP
	Add(contaxt app.Context, domain string, ip net.IP)
}

type PacketDispatcherWithContext

type PacketDispatcherWithContext interface {
	DispatchToOutbound(context app.Context, packet v2net.Packet) ray.InboundRay
}

type PubsubWithContext

type PubsubWithContext interface {
	Publish(context app.Context, topic string, message app.PubsubMessage)
	Subscribe(context app.Context, topic string, handler app.TopicHandler)
}

type Space

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

func NewSpace

func NewSpace(tag string, packetDispatcher PacketDispatcherWithContext, dnsCache DnsCacheWithContext, pubsub PubsubWithContext) *Space

func (*Space) DnsCache

func (this *Space) DnsCache() app.DnsCache

func (*Space) HasDnsCache

func (this *Space) HasDnsCache() bool

func (*Space) HasPacketDispatcher

func (this *Space) HasPacketDispatcher() bool

func (*Space) HasPubsub

func (this *Space) HasPubsub() bool

func (*Space) PacketDispatcher

func (this *Space) PacketDispatcher() app.PacketDispatcher

func (*Space) Pubsub

func (this *Space) Pubsub() app.Pubsub