common

type Fetcher interface {
	// Get returns the list of resources from the cloud after applying the filters.
	Get(ctx context.Context) (types.ResourcesWithLabels, error)
	// ResourceType identifies the resource type the fetcher is returning.
	ResourceType() string
	// FetcherType identifies the Fetcher Type (cloud resource name).
	// Eg, ec2, rds, aks, gce
	FetcherType() string
	// Cloud returns the cloud the fetcher is operating.
	Cloud() string
}

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

type WatcherConfig struct {
	// FetchersFn is a function that returns the fetchers used for this watcher.
	FetchersFn func() []Fetcher
	// Interval is the interval between fetches.
	Interval time.Duration
	// TriggerFetchC can be used to force an instant Poll, instead of waiting for the next poll Interval.
	TriggerFetchC chan struct{}
	// Log is the watcher logger.
	Log logrus.FieldLogger
	// Clock is used to control time.
	Clock clockwork.Clock
	// DiscoveryGroup is the name of the discovery group that the current
	// discovery service is a part of.
	// It is used to filter out discovered resources that belong to another
	// discovery services. When running in high availability mode and the agents
	// have access to the same cloud resources, this field value must be the same
	// for all discovery services. If different agents are used to discover different
	// sets of cloud resources, this field must be different for each set of agents.
	DiscoveryGroup string
	// Origin is used to specify what type of origin watcher's resources are
	Origin string
}