model

type Discovery interface {
	Register(ctx context.Context, hostname string, updCb func(Node) error, meta map[string]string) error
	Deregister(ctx context.Context) error
	GetNodes(ctx context.Context) ([]Node, error)
}

type KVPair[V any] struct {
	Key      string
	Value    V
	Modified time.Time
}

type KeyNotFoundError struct {
	Key string
}

type KvTooOldError struct {
	Key         string
	InsertingTs time.Time
	InRepoTs    time.Time
}

type MergeFunc[V any] func(a, b KVPair[V]) KVPair[V]

type Merger[V any] interface {
	Merge(a, b KVPair[V]) KVPair[V]
}

type MetricsProvider interface {
	Metrics() []prometheus.Collector
}

type Node struct {
	ID          string
	Hostname    string
	ServiceName string
	State       string
	Meta        map[string]string
}