watcher

type Event struct {
	EventType string         // "ADDED", "MODIFIED", "DELETED"
	Resource  types.Resource // The resource that changed
	Timestamp time.Time      // When the event occurred
}

type InstanceWatcher interface {
	WatchInstances(namespace, serviceId, labelSelector, fieldSelector string) (<-chan client.InstanceWatchEvent, error)
}

type InstanceWatcherAdapter struct {
	InstanceWatcher
}

type ResourceToWatch interface {
	// Watch starts watching the resource and returns a channel of events
	Watch(ctx context.Context, namespace, labelSelector, fieldSelector string) (<-chan WatchEvent, error)
}

type ResourceWatcher struct {
	// Configuration
	Namespace         string
	AllNamespaces     bool
	LabelSelector     string
	FieldSelector     string
	ResourceName      string
	ShowHeaders       bool
	RefreshInterval   time.Duration
	InitialBufferTime time.Duration
	WatchTimeout      time.Duration
	// contains filtered or unexported fields
}

type ServiceWatcher interface {
	WatchServices(namespace, labelSelector, fieldSelector string) (<-chan client.WatchEvent, context.CancelFunc, error)
}

type ServiceWatcherAdapter struct {
	ServiceWatcher
}

type WatchEvent struct {
	Resource  types.Resource
	EventType string // "ADDED", "MODIFIED", "DELETED"
	Error     error
}