controllers

Documentation

Index

• Constants
• func ImageIDToRBDID(imageID string) string
• func SnapshotIDToRBDID(snapshotID string) string
• type ImageReconciler
  • func NewImageReconciler(log logr.Logger, conn *rados.Conn, registry image.Source, ...) (*ImageReconciler, error)
  • func (r *ImageReconciler) Start(ctx context.Context) error
• type ImageReconcilerOptions
• type SnapshotReconciler
  • func NewSnapshotReconciler(log logr.Logger, conn *rados.Conn, registry image.Source, ...) (*SnapshotReconciler, error)
  • func (r *SnapshotReconciler) Start(ctx context.Context) error
• type SnapshotReconcilerOptions

Constants

const (
	ImageRBDIDPrefix    = "img_"
	SnapshotRBDIDPrefix = "snap_"

	ImageSnapshotVersion = "v1"
)

const (
	LimitMetadataPrefix = "conf_"
	WWNKey              = "wwn"
)

const (
	ImageFinalizer = "image"
)

const (
	SnapshotFinalizer = "snapshot"
)

Functions

func ImageIDToRBDID

func ImageIDToRBDID(imageID string) string

func SnapshotIDToRBDID

func SnapshotIDToRBDID(snapshotID string) string

Types

type ImageReconciler

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

func NewImageReconciler

func NewImageReconciler(
	log logr.Logger,
	conn *rados.Conn,
	registry image.Source,
	images store.Store[*api.Image],
	snapshots store.Store[*api.Snapshot],
	imageEvents event.Source[*api.Image],
	snapshotEvents event.Source[*api.Snapshot],
	keyEncryption encryption.Encryptor,
	opts ImageReconcilerOptions,
) (*ImageReconciler, error)

func (*ImageReconciler) Start

func (r *ImageReconciler) Start(ctx context.Context) error

type ImageReconcilerOptions

type ImageReconcilerOptions struct {
	Monitors string
	Client   string
	Pool     string
}

type SnapshotReconciler

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

func NewSnapshotReconciler

func NewSnapshotReconciler(
	log logr.Logger,
	conn *rados.Conn,
	registry image.Source,
	store store.Store[*api.Snapshot],
	events event.Source[*api.Snapshot],
	opts SnapshotReconcilerOptions,
) (*SnapshotReconciler, error)

func (*SnapshotReconciler) Start

func (r *SnapshotReconciler) Start(ctx context.Context) error

type SnapshotReconcilerOptions

type SnapshotReconcilerOptions struct {
	Pool                string
	PopulatorBufferSize int64
}