routing

package

v0.9.19 Latest Latest Go to latest Published: Mar 26, 2026 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/metraction/pharos

Links

Open Source Insights

Documentation ¶

Index ¶

func NewDebug(label string) flow.MapFunction[any, any]
func NewImageSchedulerFlow(databaseContext *model.DatabaseContext, config *model.Config)
func NewMono(element any) chan any
func NewScanResultCollectorFlow(ctx context.Context, config *model.Config, source streams.Source, ...) streams.Flow
func NewScanResultsInternalFlow(source streams.Source, databaseContext *model.DatabaseContext) streams.Flow
func NewScannerFlow(ctx context.Context, cfg *model.Config, checkRedis bool) streams.Flow
type PrometheusReporter
- func NewPrometheusReporter(ctx *context.Context, config *model.Config) *PrometheusReporter
- func (pr *PrometheusReporter) NewTicker() chan any
- func (pr *PrometheusReporter) RunAsServer() error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewDebug ¶

func NewDebug(label string) flow.MapFunction[any, any]

func NewImageSchedulerFlow ¶

func NewImageSchedulerFlow(databaseContext *model.DatabaseContext, config *model.Config)

func NewMono ¶

func NewMono(element any) chan any

func NewScanResultCollectorFlow ¶

func NewScanResultCollectorFlow(
	ctx context.Context,
	config *model.Config,
	source streams.Source,

	databaseContext *model.DatabaseContext,
	log *zerolog.Logger,
	checkRedis bool) streams.Flow

func NewScanResultsInternalFlow ¶

func NewScanResultsInternalFlow(source streams.Source, databaseContext *model.DatabaseContext) streams.Flow

func NewScannerFlow ¶

func NewScannerFlow(ctx context.Context, cfg *model.Config, checkRedis bool) streams.Flow

Types ¶

type PrometheusReporter ¶

type PrometheusReporter struct {
	Context               *context.Context
	Config                *model.Config
	Logger                *zerolog.Logger
	Secrets               *[]v1.Secret
	PrometheusIntegration *hwintegrations.PrometheusIntegration
}

func NewPrometheusReporter ¶

func NewPrometheusReporter(ctx *context.Context, config *model.Config) *PrometheusReporter

func (*PrometheusReporter) NewTicker ¶

func (pr *PrometheusReporter) NewTicker() chan any

func (*PrometheusReporter) RunAsServer ¶

func (pr *PrometheusReporter) RunAsServer() error

Source Files ¶

View all Source files

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