mirror of
https://github.com/v2fly/v2ray-core.git
synced 2024-12-22 18:17:52 -05:00
76 lines
1.7 KiB
Go
76 lines
1.7 KiB
Go
package internal
|
|
|
|
import (
|
|
"github.com/v2ray/v2ray-core/app"
|
|
)
|
|
|
|
type Space struct {
|
|
packetDispatcher PacketDispatcherWithContext
|
|
dnsCache DnsCacheWithContext
|
|
pubsub PubsubWithContext
|
|
inboundHandlerManager InboundHandlerManagerWithContext
|
|
tag string
|
|
}
|
|
|
|
func NewSpace(tag string, packetDispatcher PacketDispatcherWithContext, dnsCache DnsCacheWithContext, pubsub PubsubWithContext, inboundHandlerManager InboundHandlerManagerWithContext) *Space {
|
|
return &Space{
|
|
tag: tag,
|
|
packetDispatcher: packetDispatcher,
|
|
dnsCache: dnsCache,
|
|
pubsub: pubsub,
|
|
inboundHandlerManager: inboundHandlerManager,
|
|
}
|
|
}
|
|
|
|
func (this *Space) HasPacketDispatcher() bool {
|
|
return this.packetDispatcher != nil
|
|
}
|
|
|
|
func (this *Space) PacketDispatcher() app.PacketDispatcher {
|
|
return &contextedPacketDispatcher{
|
|
packetDispatcher: this.packetDispatcher,
|
|
context: &contextImpl{
|
|
callerTag: this.tag,
|
|
},
|
|
}
|
|
}
|
|
|
|
func (this *Space) HasDnsCache() bool {
|
|
return this.dnsCache != nil
|
|
}
|
|
|
|
func (this *Space) DnsCache() app.DnsCache {
|
|
return &contextedDnsCache{
|
|
dnsCache: this.dnsCache,
|
|
context: &contextImpl{
|
|
callerTag: this.tag,
|
|
},
|
|
}
|
|
}
|
|
|
|
func (this *Space) HasPubsub() bool {
|
|
return this.pubsub != nil
|
|
}
|
|
|
|
func (this *Space) Pubsub() app.Pubsub {
|
|
return &contextedPubsub{
|
|
pubsub: this.pubsub,
|
|
context: &contextImpl{
|
|
callerTag: this.tag,
|
|
},
|
|
}
|
|
}
|
|
|
|
func (this *Space) HasInboundHandlerManager() bool {
|
|
return this.inboundHandlerManager != nil
|
|
}
|
|
|
|
func (this *Space) InboundHandlerManager() app.InboundHandlerManager {
|
|
return &inboundHandlerManagerWithContext{
|
|
manager: this.inboundHandlerManager,
|
|
context: &contextImpl{
|
|
callerTag: this.tag,
|
|
},
|
|
}
|
|
}
|