chainnodeset

Documentation

Index

• Constants
• func AddOrUpdateNodeStatus(nodeSet *v1.ChainNodeSet, status v1.ChainNodeSetNodeStatus)
• func AddOrUpdateUpgrade(upgrades []appsv1.Upgrade, upgrade appsv1.Upgrade) []appsv1.Upgrade
• func AddressWithPortFromFullAddress(fullAddress string) string
• func ContainsGlobalIngress(ingresses []v1.GlobalIngressConfig, ingressName string, ...) bool
• func ContainsGroup(groups []v1.NodeGroupSpec, groupName string) bool
• func DeleteNodeStatus(nodeSet *v1.ChainNodeSet, name string)
• func RemoveIdFromFullAddresses(fullAddresses []string) []string
• func WithChainNodeSetLabels(nodeSet *v1.ChainNodeSet, additional ...map[string]string) map[string]string
• type GenerationChangedPredicate
  • func (p GenerationChangedPredicate) Create(e event.CreateEvent) bool
  • func (p GenerationChangedPredicate) Delete(e event.DeleteEvent) bool
  • func (p GenerationChangedPredicate) Update(e event.UpdateEvent) bool
• type Reconciler
  • func New(mgr ctrl.Manager, clientSet *kubernetes.Clientset, ...) (*Reconciler, error)
  • func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Constants

const (
	ChainNodeWaitTimeout = 3 * time.Minute
	ChainNodeKind        = "ChainNode"
)

Functions

func AddOrUpdateNodeStatus

func AddOrUpdateNodeStatus(nodeSet *v1.ChainNodeSet, status v1.ChainNodeSetNodeStatus)

func AddOrUpdateUpgrade

func AddOrUpdateUpgrade(upgrades []appsv1.Upgrade, upgrade appsv1.Upgrade) []appsv1.Upgrade

func AddressWithPortFromFullAddress

func AddressWithPortFromFullAddress(fullAddress string) string

func ContainsGlobalIngress

func ContainsGlobalIngress(ingresses []v1.GlobalIngressConfig, ingressName string, ignoreServicesOnly bool) bool

func ContainsGroup

func ContainsGroup(groups []v1.NodeGroupSpec, groupName string) bool

func DeleteNodeStatus

func DeleteNodeStatus(nodeSet *v1.ChainNodeSet, name string)

func RemoveIdFromFullAddresses

func RemoveIdFromFullAddresses(fullAddresses []string) []string

func WithChainNodeSetLabels

func WithChainNodeSetLabels(nodeSet *v1.ChainNodeSet, additional ...map[string]string) map[string]string

Types

type GenerationChangedPredicate

type GenerationChangedPredicate struct {
	predicate.Funcs
}

func (GenerationChangedPredicate) Create

func (p GenerationChangedPredicate) Create(e event.CreateEvent) bool

Create implements default CreateEvent filter

func (GenerationChangedPredicate) Delete

func (p GenerationChangedPredicate) Delete(e event.DeleteEvent) bool

Delete implements default DeleteEvent filter

func (GenerationChangedPredicate) Update

func (p GenerationChangedPredicate) Update(e event.UpdateEvent) bool

Update implements default UpdateEvent filter for validating generation change

type Reconciler

type Reconciler struct {
	client.Client
	ClientSet  *kubernetes.Clientset
	RestConfig *rest.Config
	Scheme     *runtime.Scheme
	// contains filtered or unexported fields
}

Reconciler reconciles a ChainNode object

func New

func New(mgr ctrl.Manager, clientSet *kubernetes.Clientset, opts *controllers.ControllerRunOptions) (*Reconciler, error)

func (*Reconciler) Reconcile

func (r *Reconciler) 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.