fetchers

Documentation

Index

• Constants
• type AKSFetcherConfig
  • func (c *AKSFetcherConfig) CheckAndSetDefaults() error
• type EKSFetcherConfig
  • func (c *EKSFetcherConfig) CheckAndSetDefaults() error
• type Fetcher
  • func NewAKSFetcher(cfg AKSFetcherConfig) (Fetcher, error)
  • func NewEKSFetcher(cfg EKSFetcherConfig) (Fetcher, error)

Constants

const (
	// Azure identifies that a fetcher is watching resources from Azure.
	Azure = "azure"
	// AWS identifies that a fetcher is watching resources from AWS.
	AWS = "aws"
)

Types

type AKSFetcherConfig

type AKSFetcherConfig struct {
	// Client is the Azure AKS client.
	Client azure.AKSClient
	// Regions are the regions where the clusters should be located.
	Regions []string
	// ResourceGroups are the Azure resource groups the clusters must belong to.
	ResourceGroups []string
	// FilterLabels are the filter criteria.
	FilterLabels types.Labels
	// Log is the logger.
	Log logrus.FieldLogger
}

AKSFetcherConfig configures the AKS fetcher.

func (*AKSFetcherConfig) CheckAndSetDefaults

func (c *AKSFetcherConfig) CheckAndSetDefaults() error

CheckAndSetDefaults validates and sets the defaults values.

type EKSFetcherConfig

type EKSFetcherConfig struct {
	// Client is the AWS eKS client.
	Client eksiface.EKSAPI
	// Region is the region where the clusters should be located.
	Region string
	// FilterLabels are the filter criteria.
	FilterLabels types.Labels
	// Log is the logger.
	Log logrus.FieldLogger
}

EKSFetcherConfig configures the EKS fetcher.

func (*EKSFetcherConfig) CheckAndSetDefaults

func (c *EKSFetcherConfig) CheckAndSetDefaults() error

CheckAndSetDefaults validates and sets the defaults values.

type Fetcher

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
	// Cloud returns the cloud the fetcher is operating.
	Cloud() string
}

Fetcher defines the common methods across all fetchers.

func NewAKSFetcher

func NewAKSFetcher(cfg AKSFetcherConfig) (Fetcher, error)

NewAKSFetcher creates a new AKS fetcher configuration.

func NewEKSFetcher

func NewEKSFetcher(cfg EKSFetcherConfig) (Fetcher, error)

NewEKSFetcher creates a new EKS fetcher configuration.