intercept

Documentation

Index

• func NewInterceptAddress(service *entities.Service, protocol string, resolver dns.Resolver) (*interceptAddress, error)
• func SetDnsInterceptIpRange(cidr string) error
• type InterceptedService
• type Interceptor
• type LUT
  • func NewLUT() LUT
  • func (m LUT) GetByAddress(addr net.Addr) (*InterceptedService, error)
  • func (m LUT) GetByName(serviceName string) []InterceptedService
  • func (m LUT) Put(addr interceptAddress, serviceName string, data interface{}) error
  • func (m LUT) Remove(interceptAddr interceptAddress)
• type Protocol
• type ServiceListener
  • func NewServiceListener(context ziti.Context, interceptor Interceptor, resolver dns.Resolver) *ServiceListener
  • func (self *ServiceListener) HandleServicesChange(eventType config.ServiceEventType, service *edge.Service)
  • func (self *ServiceListener) WaitForShutdown()

Functions

func NewInterceptAddress

func NewInterceptAddress(service *entities.Service, protocol string, resolver dns.Resolver) (*interceptAddress, error)

func SetDnsInterceptIpRange

func SetDnsInterceptIpRange(cidr string) error

Types

type InterceptedService

type InterceptedService struct {
	Name string
	Addr interceptAddress
	Data interface{} // interceptor-specific data attached to this intercept. intent is to provide context needed in Interceptor.StopIntercepting
}

type Interceptor

type Interceptor interface {
	Start(context ziti.Context)
	Stop()
	Intercept(service *entities.Service, resolver dns.Resolver) error
	StopIntercepting(serviceName string, removeRoute bool) error
}

type LUT

type LUT map[interceptAddress]InterceptedService

func NewLUT

func NewLUT() LUT

func (LUT) GetByAddress

func (m LUT) GetByAddress(addr net.Addr) (*InterceptedService, error)

Return the service that is being intercepted at the given address, if any.

func (LUT) GetByName

func (m LUT) GetByName(serviceName string) []InterceptedService

func (LUT) Put

func (m LUT) Put(addr interceptAddress, serviceName string, data interface{}) error

func (LUT) Remove

func (m LUT) Remove(interceptAddr interceptAddress)

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(context ziti.Context, interceptor Interceptor, resolver dns.Resolver) *ServiceListener

func (*ServiceListener) HandleServicesChange

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

func (*ServiceListener) WaitForShutdown

func (self *ServiceListener) WaitForShutdown()