source

Documentation

Index

• type IngressSource
  • func NewIngressWatcher(factory informers.SharedInformerFactory, namespace string, ...) IngressSource
  • func (i *IngressSource) Run(stopCh chan struct{}) error
• type ServiceSource
  • func NewServicesWatcher(factory informers.SharedInformerFactory, namespace string, ...) ServiceSource
  • func (s *ServiceSource) Run(stopCh chan struct{}) error

Types

type IngressSource

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

IngressSource handles adding, updating, or removing mDNS record advertisements

func NewIngressWatcher

func NewIngressWatcher(factory informers.SharedInformerFactory, namespace string, notifyChan chan<- resource.Resource) IngressSource

NewIngressWatcher creates an IngressSource

func (*IngressSource) Run

func (i *IngressSource) Run(stopCh chan struct{}) error

Run starts shared informers and waits for the shared informer cache to synchronize.

type ServiceSource

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

ServiceSource handles adding, updating, or removing mDNS record advertisements

func NewServicesWatcher

func NewServicesWatcher(factory informers.SharedInformerFactory, namespace string, notifyChan chan<- resource.Resource, publishInternal *bool) ServiceSource

NewServicesWatcher creates an ServiceSource

func (*ServiceSource) Run

func (s *ServiceSource) Run(stopCh chan struct{}) error

Run starts shared informers and waits for the shared informer cache to synchronize.