k8

type EndpointsReader struct {
	Events chan *EndpointsRequest
}

type EndpointsRequest struct {
	Type            RequestType
	RemoteEndpoints *v1.Endpoints
	LocalEndpoints  *v1.Endpoints
}

type EndpointsWriter struct {
	Events chan *EndpointsRequest
	Client kubernetes.Interface
}

type RequestType int

type ServiceReader struct {
	Events chan *ServiceRequest
}

type ServiceRequest struct {
	Type          RequestType
	RemoteService *v1.Service
	LocalService  *v1.Service
}

type ServiceWriter struct {
	Events chan *ServiceRequest
	Client kubernetes.Interface
}

type Watcher interface {
	Add(interface{})
	Update(interface{}, interface{})
	Delete(interface{})
}