intercept

Documentation

Index

• func SetDnsInterceptIpRange(cidr string) error
• type AddressTracker
• type InterceptAddress
  • func GetInterceptAddresses(service *entities.Service, protocol string, resolver dns.Resolver) ([]*InterceptAddress, error)
  • func (addr *InterceptAddress) Contains(ip net.IP, port uint16) bool
  • func (addr *InterceptAddress) HighPort() uint16
  • func (addr *InterceptAddress) IpNet() *net.IPNet
  • func (addr *InterceptAddress) LowPort() uint16
  • func (addr *InterceptAddress) Proto() string
• type Interceptor
• type Protocol
• type ServiceListener
  • func NewServiceListener(interceptor Interceptor, resolver dns.Resolver) *ServiceListener
  • func (self *ServiceListener) HandleProviderReady(provider tunnel.FabricProvider)
  • func (self *ServiceListener) HandleServicesChange(eventType ziti.ServiceEventType, service *edge.Service)
  • func (self *ServiceListener) WaitForShutdown()

Functions

func SetDnsInterceptIpRange

func SetDnsInterceptIpRange(cidr string) error

Types

type AddressTracker

type AddressTracker interface {
	AddAddress(addr string)
	RemoveAddress(addr string) bool
}

type InterceptAddress

type InterceptAddress struct {
	TproxySpec []string
	AcceptSpec []string
	// contains filtered or unexported fields
}

func GetInterceptAddresses

func GetInterceptAddresses(service *entities.Service, protocol string, resolver dns.Resolver) ([]*InterceptAddress, error)

func (*InterceptAddress) Contains

func (addr *InterceptAddress) Contains(ip net.IP, port uint16) bool

func (*InterceptAddress) HighPort

func (addr *InterceptAddress) HighPort() uint16

func (*InterceptAddress) IpNet

func (addr *InterceptAddress) IpNet() *net.IPNet

func (*InterceptAddress) LowPort

func (addr *InterceptAddress) LowPort() uint16

func (*InterceptAddress) Proto

func (addr *InterceptAddress) Proto() string

type Interceptor

type Interceptor interface {
	Start(provider tunnel.FabricProvider)
	Stop()
	Intercept(service *entities.Service, resolver dns.Resolver, tracker AddressTracker) error
	StopIntercepting(serviceName string, tracker AddressTracker) error
}

type Protocol

type Protocol int

const (
	TCP Protocol = 2
	UDP Protocol = 17
)

type ServiceListener

type ServiceListener struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewServiceListener

func NewServiceListener(interceptor Interceptor, resolver dns.Resolver) *ServiceListener

func (*ServiceListener) HandleProviderReady

func (self *ServiceListener) HandleProviderReady(provider tunnel.FabricProvider)

func (*ServiceListener) HandleServicesChange

func (self *ServiceListener) HandleServicesChange(eventType ziti.ServiceEventType, service *edge.Service)

func (*ServiceListener) WaitForShutdown

func (self *ServiceListener) WaitForShutdown()