collectors

type Catalog map[string]CollectorFactory

type CollectionMode int

type Collector interface {
	Detect(context.Context, chan<- []*TagInfo) (CollectionMode, error)
}

type CollectorFactory func() Collector

type CollectorPriority int

type Fetcher interface {
	Fetch(context.Context, string) ([]string, []string, []string, error)
}

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

type Puller interface {
	Fetcher
	Pull(context.Context) error
}

type Streamer interface {
	Fetcher
	Stream() error
	Stop() error
}

type TagCardinality int

type TagInfo struct {
	Source               string    // source collector's name
	Entity               string    // entity name ready for lookup
	HighCardTags         []string  // high cardinality tags that can create a lot of different timeseries (typically one per container, user request, etc.)
	OrchestratorCardTags []string  // orchestrator cardinality tags that have as many combination as pods/tasks
	LowCardTags          []string  // low cardinality tags safe for every pipeline
	StandardTags         []string  // the discovered standard tags (env, version, service) for the entity
	DeleteEntity         bool      // true if the entity is to be deleted from the store
	CacheMiss            bool      // true if the TagInfo is generated by a tag miss
	ExpiryDate           time.Time // keep in cache until expiryDate
}

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