cleaner

Documentation

Index

• type Cleaner
  • func New(localClient, remoteClient kubernetes.Interface, ...) *Cleaner
  • func (c *Cleaner) Run(stopChan <-chan struct{})

Types

type Cleaner

type Cleaner struct {
	LocalClient    kubernetes.Interface
	RemoteClient   kubernetes.Interface
	EndpointWriter chan *k8.EndpointsRequest
	ServiceWriter  chan *k8.ServiceRequest
}

Cleaner looks for orphaned services/endpoints on the local side and sends requests to delete them. A service/endpoint is considered an orphan if it's no longer existing on the remote side, but somehow still exists on the local side

func New

func New(localClient, remoteClient kubernetes.Interface, endpointWriter chan *k8.EndpointsRequest, serviceWriter chan *k8.ServiceRequest) *Cleaner

func (*Cleaner) Run

func (c *Cleaner) Run(stopChan <-chan struct{})