integrations

package
v0.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 22, 2026 License: GPL-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewHttpTransport

func NewHttpTransport(cfg *model.Config) *http.Transport

func PrometheusResult

func PrometheusResult(o model.OutputWithError) []model.ImageMetric

Types

type CraneIntegration

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

func NewCraneIntegration

func NewCraneIntegration(cfg *model.Config) *CraneIntegration

func (*CraneIntegration) CraneRetrieveLabels

func (ci *CraneIntegration) CraneRetrieveLabels(elem model.ImageMetric) model.Image

func (*CraneIntegration) WhiteListImages

func (ci *CraneIntegration) WhiteListImages() func(elem model.ImageMetric) bool

type Dedup

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

Dedup holds state for filtering duplicate images in-memory.

func NewDedup

func NewDedup() *Dedup

NewDedup constructs a Dedup instance.

func (*Dedup) FilterDublicates

func (d *Dedup) FilterDublicates(item any) bool

FilterDublicates is a predicate for flow.NewFilter to filter out already seen images.

type DevLakeIntegration

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

func NewDevLakeIntegration

func NewDevLakeIntegration(cfg *model.Config) *DevLakeIntegration

func (*DevLakeIntegration) PostDeployment

func (di *DevLakeIntegration) PostDeployment(image model.Image) model.OutputWithError

type MultiRegistryKeychain

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

func (*MultiRegistryKeychain) Resolve

func (kc *MultiRegistryKeychain) Resolve(resource authn.Resource) (authn.Authenticator, error)

type PrometheusIntegration

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

func NewPrometheusIntegration

func NewPrometheusIntegration(cfg *model.Config) *PrometheusIntegration

func (PrometheusIntegration) FetchImageMetrics

func (integration PrometheusIntegration) FetchImageMetrics(_ any) model.OutputWithError

type PrometheusResponse

type PrometheusResponse struct {
	Status string `json:"status"`
	Data   struct {
		ResultType string `json:"resultType"`
		Result     []struct {
			Metric map[string]string `json:"metric"`
			// Value: [ <timestamp>, "<value>" ]
			Value []interface{} `json:"value"`
		} `json:"result"`
	} `json:"data"`
}

PrometheusResponse is a minimal struct for parsing Prometheus API responses

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL