controllers

Documentation

Index

• Variables
• type ClusterStatus
• type ErrKeyNotFound
  • func NewKeyError(msg string) *ErrKeyNotFound
  • func (e *ErrKeyNotFound) Error() string
• type PachydermExportReconciler
  • func (r *PachydermExportReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PachydermExportReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PachydermImportReconciler
  • func (r *PachydermImportReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PachydermImportReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PachydermReconciler
  • func (r *PachydermReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PachydermReconciler) SetupWithManager(mgr ctrl.Manager) error

Variables

var (
	// ErrServiceNotReady returns when a microservice is not ready
	ErrServiceNotReady = errors.New("waiting for core microservice")
	// ErrPasswordNotFound returns when the postgres database password is not found
	ErrPasswordNotFound = errors.New("postgres-password key not found")
	// ErrorPachydermNotFound is returned when the pachyderm object is not found in the restore
	ErrPachydermNotFound = errors.New("pachyderm resource not found")
	// ErrDatabaseNotFound is returned when the database dump is not found in the restore
	ErrDatabaseNotFound = errors.New("database restore not found")
	// ErrPachdPodsRunning is returned when pachd pods are running while in maintenance mode
	ErrPachdPodsRunning = errors.New("pachd pods still running")
)

var (
	ErrPostgresNotReady = goerrors.New("postgres pod not ready")
)

Types

type ClusterStatus

type ClusterStatus struct {
	PachdAddress string `json:"pachd_address,omitempty"`
}

ClusterStatus returns address of the Pachyderm cluster

type ErrKeyNotFound

type ErrKeyNotFound struct {
	Key string
}

ErrKeyNotFound is a custom error

func NewKeyError

func NewKeyError(msg string) *ErrKeyNotFound

NewKeyError returns a custom error

func (*ErrKeyNotFound) Error

func (e *ErrKeyNotFound) Error() string

type PachydermExportReconciler

type PachydermExportReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

PachydermExportReconciler reconciles a PachydermExport object

func (*PachydermExportReconciler) Reconcile

func (r *PachydermExportReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile method runs when an event is triggered for the watched reesources

func (*PachydermExportReconciler) SetupWithManager

func (r *PachydermExportReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type PachydermImportReconciler

type PachydermImportReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

PachydermImportReconciler reconciles a PachydermImport object

func (*PachydermImportReconciler) Reconcile

func (r *PachydermImportReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the PachydermImport object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.12.1/pkg/reconcile

func (*PachydermImportReconciler) SetupWithManager

func (r *PachydermImportReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type PachydermReconciler

type PachydermReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
}

PachydermReconciler reconciles a Pachyderm object

func (*PachydermReconciler) Reconcile

func (r *PachydermReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile function attempts to bring the state of the world to resemble the desired state

func (*PachydermReconciler) SetupWithManager

func (r *PachydermReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.