miner

Documentation

Overview

Package miner implements miner controller.

Index

• Variables
• func HasMatchingLabels(matchSelector metav1.LabelSelector, matchLabels map[string]string) bool
• type MinerEnv
  • func GetMinerEnv() MinerEnv
• type Reconciler
  • func (r *Reconciler) PodToMiners(ctx context.Context, o client.Object) []ctrl.Request
  • func (r *Reconciler) Reconcile(ctx context.Context, rq ctrl.Request) (_ ctrl.Result, reterr error)
  • func (r *Reconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options, ...) error

Variables

var ErrPodNotFound = errors.New("cannot find pod with matching ProviderID")

ErrPodNotFound signals that a corev1.Pod could not be found for the given provider id.

Functions

func HasMatchingLabels

func HasMatchingLabels(matchSelector metav1.LabelSelector, matchLabels map[string]string) bool

HasMatchingLabels verifies that the Label Selector matches the given Labels.

Types

type MinerEnv

type MinerEnv struct {
	Image *string `env:"IMAGE"`
}

func GetMinerEnv

func GetMinerEnv() MinerEnv

type Reconciler

type Reconciler struct {
	APIReader client.Reader

	DryRun          bool
	ProviderClient  kubernetes.Interface
	RedisClient     *redis.Client
	ComponentConfig *config.MinerControllerConfiguration

	// WatchFilterValue is the label value used to filter events prior to reconciliation.
	WatchFilterValue string
	// contains filtered or unexported fields
}

Reconciler reconciles a Miner object.

func (*Reconciler) PodToMiners

func (r *Reconciler) PodToMiners(ctx context.Context, o client.Object) []ctrl.Request

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, rq ctrl.Request) (_ ctrl.Result, reterr error)

func (*Reconciler) SetupWithManager

func (r *Reconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options, providerCluster cluster.Cluster) error