intercept

Documentation

Index

• func GetInterceptAddresses(service *entities.Service, protocols []string, resolver dns.Resolver, ...) error
• func SetDnsInterceptIpRange(cidr string) error
• type AddressTracker
• type InterceptAddrCB
• type InterceptAddress
  • 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
  • func (addr *InterceptAddress) String() 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 GetInterceptAddresses

func GetInterceptAddresses(service *entities.Service, protocols []string, resolver dns.Resolver, addressCB InterceptAddrCB) error

func SetDnsInterceptIpRange

func SetDnsInterceptIpRange(cidr string) error

Types

type AddressTracker

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

type InterceptAddrCB

type InterceptAddrCB interface {
	Apply(*InterceptAddress)
}

type InterceptAddress

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

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

func (*InterceptAddress) String

func (addr *InterceptAddress) String() 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()