k8sclient

type EndpointAddress struct {
	IP string `json:"ip"`
}

type EndpointSubset struct {
	Addresses []EndpointAddress `json:"addresses"`
}

type Endpoints struct {
	Metadata Metadata         `json:"metadata"`
	Subsets  []EndpointSubset `json:"subsets"`
}

type EventType string

type K8sClient interface {
	Namespace() (namespace string)
	GetEndpoints(ctx context.Context, namespace, endpointsName string) (endpoints *Endpoints, err error)
	WatchEndpoints(ctx context.Context, namespace, endpointsName, resourceVersion string, callback WatchEndpointsCallback) (err error)
}

type Metadata struct {
	ResourceVersion string `json:"resourceVersion"`
}

type WatchEndpointsCallback func(eventType EventType, endpoints *Endpoints) (ok bool)