reconcilers

Documentation

Overview

Package reconcilers contains the reconcilers for the various types of entities in minder.

Index

• Constants
• Variables
• func NewProfileInitMessage(provider string, projectID uuid.UUID) (*message.Message, error)
• func NewRepoReconcilerMessage(provider string, repoID int32, projectID uuid.UUID) (*message.Message, error)
• type ProfileInitEvent
• type Reconciler
  • func NewReconciler(store db.Store, evt *events.Eventer, authCfg *serverconfig.AuthConfig, ...) (*Reconciler, error)
  • func (e *Reconciler) Register(r events.Registrar)
• type ReconcilerOption
  • func WithProviderMetrics(mt providertelemetry.ProviderMetrics) ReconcilerOption
• type RepoReconcilerEvent

Constants

const (
	// InternalReconcilerEventTopic is the topic for internal reconciler events
	InternalReconcilerEventTopic = "internal.repo.reconciler.event"
	// InternalProfileInitEventTopic is the topic for internal init events
	InternalProfileInitEventTopic = "internal.profile.init.event"
)

Variables

var (
	// ArtifactTypeContainerRetentionPeriod represents the retention period for container artifacts
	ArtifactTypeContainerRetentionPeriod = time.Now().AddDate(0, -6, 0)
)

Functions

func NewProfileInitMessage

func NewProfileInitMessage(provider string, projectID uuid.UUID) (*message.Message, error)

NewProfileInitMessage creates a new repos init event

func NewRepoReconcilerMessage

func NewRepoReconcilerMessage(provider string, repoID int32, projectID uuid.UUID) (*message.Message, error)

NewRepoReconcilerMessage creates a new repos init event

Types

type ProfileInitEvent

type ProfileInitEvent struct {
	// Project is the project that the event is relevant to
	Project uuid.UUID `json:"project"`
}

ProfileInitEvent is an event that is sent to the reconciler topic when a new profile is created. It is used to initialize the profile by iterating over all registered entities for the relevant project and sending a profile evaluation event for each one.

type Reconciler

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

Reconciler is a helper that reconciles entities

func NewReconciler

func NewReconciler(
	store db.Store,
	evt *events.Eventer,
	authCfg *serverconfig.AuthConfig,
	opts ...ReconcilerOption,
) (*Reconciler, error)

NewReconciler creates a new reconciler object

func (*Reconciler) Register

func (e *Reconciler) Register(r events.Registrar)

Register implements the Consumer interface.

type ReconcilerOption

type ReconcilerOption func(*Reconciler)

ReconcilerOption is a function that modifies a reconciler

func WithProviderMetrics

func WithProviderMetrics(mt providertelemetry.ProviderMetrics) ReconcilerOption

WithProviderMetrics sets the provider metrics for the reconciler

type RepoReconcilerEvent

type RepoReconcilerEvent struct {
	// Project is the project that the event is relevant to
	Project uuid.UUID `json:"project"`
	// Repository is the repository to be reconciled
	Repository int32 `json:"repository" validate:"gte=0"`
}

RepoReconcilerEvent is an event that is sent to the reconciler topic