indexer

Documentation

Index

• Constants
• func FormatClaim(claimName string, claimValue string) string
• func FreightApprovedForStagesIndexer(obj client.Object) []string
• func FreightByVerifiedStagesIndexer(obj client.Object) []string
• func FreightByWarehouseIndexer(obj client.Object) []string
• func IndexEventsByInvolvedObjectAPIGroup(ctx context.Context, clstr cluster.Cluster) error
• func IndexFreightByApprovedStages(ctx context.Context, clstr cluster.Cluster) error
• func IndexFreightByVerifiedStages(ctx context.Context, clstr cluster.Cluster) error
• func IndexFreightByWarehouse(ctx context.Context, clstr cluster.Cluster) error
• func IndexPromotionsByStage(ctx context.Context, clstr cluster.Cluster) error
• func IndexPromotionsByStageAndFreight(ctx context.Context, clstr cluster.Cluster) error
• func IndexRunningPromotionsByArgoCDApplications(ctx context.Context, clstr cluster.Cluster, shardName string) error
• func IndexServiceAccountsByOIDCClaims(ctx context.Context, clstr cluster.Cluster) error
• func IndexStagesByAnalysisRun(ctx context.Context, clstr cluster.Cluster, shardName string) error
• func IndexStagesByFreight(ctx context.Context, clstr cluster.Cluster) error
• func IndexStagesByUpstreamStages(ctx context.Context, clstr cluster.Cluster) error
• func IndexStagesByWarehouse(ctx context.Context, clstr cluster.Cluster) error
• func StageAndFreightKey(stage, freight string) string

Constants

const (
	EventsByInvolvedObjectAPIGroupIndexField = "involvedObject.apiGroup"

	FreightByVerifiedStagesIndexField     = "verifiedIn"
	FreightApprovedForStagesIndexField    = "approvedFor"
	FreightByWarehouseIndexField          = "warehouse"
	PromotionsByStageAndFreightIndexField = "stageAndFreight"

	PromotionsByStageIndexField = "stage"

	RunningPromotionsByArgoCDApplicationsIndexField = "applications"

	StagesByAnalysisRunIndexField        = "analysisRun"
	StagesByArgoCDApplicationsIndexField = "applications"
	StagesByFreightIndexField            = "freight"
	StagesByUpstreamStagesIndexField     = "upstreamStages"
	StagesByWarehouseIndexField          = "warehouse"

	ServiceAccountsByOIDCClaimsIndexField = "claims"
)

Functions

func FormatClaim

func FormatClaim(claimName string, claimValue string) string

A helper function to format a claims name and values to be used by the IndexServiceAccountsByOIDCClaims index.

func FreightApprovedForStagesIndexer

func FreightApprovedForStagesIndexer(obj client.Object) []string

FreightApprovedForStagesIndexer is a client.IndexerFunc that indexes Freight by the Stages for which it has been (manually) approved.

func FreightByVerifiedStagesIndexer

func FreightByVerifiedStagesIndexer(obj client.Object) []string

FreightByVerifiedStagesIndexer is a client.IndexerFunc that indexes Freight by the Stages in which it has been verified.

func FreightByWarehouseIndexer

func FreightByWarehouseIndexer(obj client.Object) []string

FreightByWarehouseIndexer is a client.IndexerFunc that indexes Freight by the Warehouse it is associated with.

func IndexEventsByInvolvedObjectAPIGroup

func IndexEventsByInvolvedObjectAPIGroup(ctx context.Context, clstr cluster.Cluster) error

IndexEventsByInvolvedObjectAPIGroup sets up the indexing of Events by the API group of the involved object.

It configures the field indexer of the provided cluster to allow querying Events by the API group of the involved object using the EventsByInvolvedObjectAPIGroupIndexField selector.

func IndexFreightByApprovedStages

func IndexFreightByApprovedStages(ctx context.Context, clstr cluster.Cluster) error

IndexFreightByApprovedStages sets up indexing of Freight by the Stages for which it has been (manually) approved.

It configures the cluster's field indexer to allow querying Freight using the FreightApprovedForStagesIndexField selector.

func IndexFreightByVerifiedStages

func IndexFreightByVerifiedStages(ctx context.Context, clstr cluster.Cluster) error

IndexFreightByVerifiedStages sets up indexing of Freight by the Stages that have verified it.

It configures the cluster's field indexer to allow querying Freight using the FreightByVerifiedStagesIndexField selector.

func IndexFreightByWarehouse

func IndexFreightByWarehouse(ctx context.Context, clstr cluster.Cluster) error

IndexFreightByWarehouse sets up indexing of Freight by the Warehouse they are associated with.

It configures the cluster's field indexer to allow querying Freight using the FreightByWarehouseIndexField selector.

func IndexPromotionsByStage

func IndexPromotionsByStage(ctx context.Context, clstr cluster.Cluster) error

IndexPromotionsByStage sets up the indexing of Promotions by the Stage they reference.

It configures the field indexer of the provided cluster to allow querying Promotions by the Stage they reference using the PromotionsByStageIndexField.

func IndexPromotionsByStageAndFreight

func IndexPromotionsByStageAndFreight(
	ctx context.Context,
	clstr cluster.Cluster,
) error

IndexPromotionsByStageAndFreight sets up indexing of Promotions by the Stage and Freight they reference.

It configures the cluster's field indexer to allow querying Promotions using the PromotionsByStageAndFreightIndexField selector. The value of the index is the concatenation of the Stage and Freight keys, as returned by the StageAndFreightKey function.

func IndexRunningPromotionsByArgoCDApplications

func IndexRunningPromotionsByArgoCDApplications(
	ctx context.Context,
	clstr cluster.Cluster,
	shardName string,
) error

IndexRunningPromotionsByArgoCDApplications sets up the indexing of running Promotions by the Argo CD Applications they are associated with.

It configures the field indexer of the provided cluster to allow querying running Promotions by the Argo CD Applications they are associated with using the RunningPromotionsByArgoCDApplicationsIndexField selector.

When the provided shardName is non-empty, only Promotions labeled with the provided shardName are indexed. When the provided shardName is empty, only Promotions not labeled with a shardName are indexed.

func IndexServiceAccountsByOIDCClaims

func IndexServiceAccountsByOIDCClaims(ctx context.Context, clstr cluster.Cluster) error

IndexServiceAccountsByOIDCClaims sets up indexing of ServiceAccounts by their OIDC claim annotations.

It configures the manager's field indexer to allow querying ServiceAccounts using the ServiceAccountsByOIDCClaimIndexField selector.

func IndexStagesByAnalysisRun

func IndexStagesByAnalysisRun(ctx context.Context, clstr cluster.Cluster, shardName string) error

IndexStagesByAnalysisRun sets up the indexing of Stages by the AnalysisRun they are associated with.

It configures the field indexer of the provided cluster to allow querying Stages by the AnalysisRun they are associated with using the StagesByAnalysisRunIndexField selector.

func IndexStagesByFreight

func IndexStagesByFreight(ctx context.Context, clstr cluster.Cluster) error

IndexStagesByFreight sets up indexing of Stages by the Freight they reference.

It configures the cluster's field indexer to allow querying Stages using the StagesByFreightIndexField selector.

func IndexStagesByUpstreamStages

func IndexStagesByUpstreamStages(ctx context.Context, clstr cluster.Cluster) error

IndexStagesByUpstreamStages sets up indexing of Stages by the upstream Stages they reference.

It configures the cluster's field indexer to allow querying Stages using the StagesByUpstreamStagesIndexField selector.

func IndexStagesByWarehouse

func IndexStagesByWarehouse(ctx context.Context, clstr cluster.Cluster) error

IndexStagesByWarehouse sets up indexing of Stages by the Warehouse they are associated with.

It configures the cluster's field indexer to allow querying Stages using the StagesByWarehouseIndexField selector.

func StageAndFreightKey

func StageAndFreightKey(stage, freight string) string

StageAndFreightKey returns a key that uniquely identifies a Stage and Freight.