labels

type Applicator interface {
	// Assign a label to the object identified by the Type and ID
	SetLabel(labelType Type, id, name, value string) error

	// Assign a group of labels in a batched operation
	SetLabels(labelType Type, id string, labels map[string]string) error

	// Remove a label from the identified object
	RemoveLabel(labelType Type, id, name string) error

	// Remove all labels from the identified object
	RemoveAllLabels(labelType Type, id string) error

	// Lists all labels on all objects associated with this type.
	// mostly useful for secondary caching. Do not use directly
	// if you just want to answer a simple query - use GetMatches
	// instead.
	ListLabels(labelType Type) ([]Labeled, error)

	// Get all Labels assigned to the given object
	GetLabels(labelType Type, id string) (Labeled, error)

	// Return all objects of the given type that match the given selector.
	GetMatches(selector labels.Selector, labelType Type) ([]Labeled, error)

	// Return all objects of the given type that match the given selector
	// out of a cache that is refreshed at a rate according to
	// aggregationRate
	GetCachedMatches(selector labels.Selector, labelType Type, aggregationRate time.Duration) ([]Labeled, error)

	// Watch a label selector of a given type and see updates to that set
	// of Labeled over time. If an error occurs, the Applicator implementation
	// is responsible for handling it and recovering gracefully.
	//
	// The watch may be terminated by the underlying implementation without signaling on
	// the quit channel - this will be indicated by the closing of the result channel. For
	// this reason, callers should **always** verify that the channel is closed by checking
	// the "ok" boolean or using `range`.
	WatchMatches(
		selector labels.Selector,
		labelType Type,
		aggregationRate time.Duration,
		quitCh <-chan struct{},
	) (chan []Labeled, error)

	// WatchMatchDiff does a diff on top of the results form the WatchMatches and
	// returns a LabeledChanges structure which contain changes
	WatchMatchDiff(
		selector labels.Selector,
		labelType Type,
		aggregationRate time.Duration,
		quitCh <-chan struct{},
	) <-chan *LabeledChanges
}

type ApplicatorWithoutWatches interface {
	SetLabel(labelType Type, id, name, value string) error
	SetLabels(labelType Type, id string, labels map[string]string) error
	SetLabelsTxn(ctx context.Context, labelType Type, id string, labels map[string]string) error
	RemoveLabel(labelType Type, id, name string) error
	RemoveLabelTxn(ctx context.Context, labelType Type, id, name string) error
	RemoveAllLabels(labelType Type, id string) error
	RemoveLabelsTxn(ctx context.Context, labelType Type, id string, keysToRemove []string) error
	RemoveAllLabelsTxn(ctx context.Context, labelType Type, id string) error
	ListLabels(labelType Type) ([]Labeled, error)
	GetLabels(labelType Type, id string) (Labeled, error)
	GetMatches(selector klabels.Selector, labelType Type) ([]Labeled, error)
	GetCachedMatches(selector klabels.Selector, labelType Type, aggregationRate time.Duration) ([]Labeled, error)
	GetLabelsWithIndex(labelType Type, id string) (Labeled, uint64, error)
}

type Batcher struct {
	// contains filtered or unexported fields
}

type CASError struct {
	Key string
}

type ConsulApplicator struct {
	// contains filtered or unexported fields
}

type LabelFetcher interface {
	GetLabelsWithIndex(labelType Type, id string) (Labeled, uint64, error)
}

type Labeled struct {
	LabelType Type       `json:"type"`
	ID        string     `json:"id"`
	Labels    labels.Set `json:"labels"`
}

type LabeledChanges struct {
	Created []Labeled
	Updated []Labeled
	Deleted []Labeled
}

type LabeledWithIndex struct {
	Labeled
	Index uint64 `json:"index"`
}

type MetricsRegistry interface {
	Register(metricName string, metric interface{}) error
}

type SetLabelRequest struct {
	Value string `json:"value"`
}

type SetLabelsRequest struct {
	Values map[string]string `json:"values"`
}

type Type string

type TypeBatcher struct {
	// contains filtered or unexported fields
}