controller

Documentation

Index

• Variables
• type BesuGenesisReconciler
  • func (r *BesuGenesisReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *BesuGenesisReconciler) SetupWithManager(mgr ctrl.Manager) error
• type BesuReconciler
  • func (r *BesuReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *BesuReconciler) SetupWithManager(mgr ctrl.Manager) error
• type CRMap
• type InFlight
  • func NewInFlight() *InFlight
  • func (db *InFlight) Delete(key string)
  • func (db *InFlight) Insert(key string) bool
  • func (db *InFlight) IsQueued(key string) bool
  • func (db *InFlight) IsReady(key string) bool
• type PaladinDomainReconciler
  • func (r *PaladinDomainReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PaladinDomainReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PaladinReconciler
  • func (r *PaladinReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PaladinReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PaladinRegistrationReconciler
  • func (r *PaladinRegistrationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PaladinRegistrationReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PaladinRegistryReconciler
  • func (r *PaladinRegistryReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PaladinRegistryReconciler) SetupWithManager(mgr ctrl.Manager) error
• type SmartContractDeploymentReconciler
  • func (r *SmartContractDeploymentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *SmartContractDeploymentReconciler) SetupWithManager(mgr ctrl.Manager) error
• type TransactionInvokeReconciler
  • func (r *TransactionInvokeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *TransactionInvokeReconciler) SetupWithManager(mgr ctrl.Manager) error

Variables

var BesuCRMap = CRMap[corev1alpha1.Besu, *corev1alpha1.Besu, *corev1alpha1.BesuList]{
	NewList:  func() *corev1alpha1.BesuList { return new(corev1alpha1.BesuList) },
	ItemsFor: func(list *corev1alpha1.BesuList) []corev1alpha1.Besu { return list.Items },
	AsObject: func(item *corev1alpha1.Besu) *corev1alpha1.Besu { return item },
}

allows generic functions by giving a mapping between the types and interfaces for the CR

var BesuGenesisCRMap = CRMap[corev1alpha1.BesuGenesis, *corev1alpha1.BesuGenesis, *corev1alpha1.BesuGenesisList]{
	NewList:  func() *corev1alpha1.BesuGenesisList { return new(corev1alpha1.BesuGenesisList) },
	ItemsFor: func(list *corev1alpha1.BesuGenesisList) []corev1alpha1.BesuGenesis { return list.Items },
	AsObject: func(item *corev1alpha1.BesuGenesis) *corev1alpha1.BesuGenesis { return item },
}

allows generic functions by giving a mapping between the types and interfaces for the CR

var PaladinCRMap = CRMap[corev1alpha1.Paladin, *corev1alpha1.Paladin, *corev1alpha1.PaladinList]{
	NewList:  func() *corev1alpha1.PaladinList { return new(corev1alpha1.PaladinList) },
	ItemsFor: func(list *corev1alpha1.PaladinList) []corev1alpha1.Paladin { return list.Items },
	AsObject: func(item *corev1alpha1.Paladin) *corev1alpha1.Paladin { return item },
}

allows generic functions by giving a mapping between the types and interfaces for the CR

var PaladinDomainCRMap = CRMap[corev1alpha1.PaladinDomain, *corev1alpha1.PaladinDomain, *corev1alpha1.PaladinDomainList]{
	NewList:  func() *corev1alpha1.PaladinDomainList { return new(corev1alpha1.PaladinDomainList) },
	ItemsFor: func(list *corev1alpha1.PaladinDomainList) []corev1alpha1.PaladinDomain { return list.Items },
	AsObject: func(item *corev1alpha1.PaladinDomain) *corev1alpha1.PaladinDomain { return item },
}

allows generic functions by giving a mapping between the types and interfaces for the CR

var PaladinRegistrationCRMap = CRMap[corev1alpha1.PaladinRegistration, *corev1alpha1.PaladinRegistration, *corev1alpha1.PaladinRegistrationList]{
	NewList: func() *corev1alpha1.PaladinRegistrationList { return new(corev1alpha1.PaladinRegistrationList) },
	ItemsFor: func(list *corev1alpha1.PaladinRegistrationList) []corev1alpha1.PaladinRegistration {
		return list.Items
	},
	AsObject: func(item *corev1alpha1.PaladinRegistration) *corev1alpha1.PaladinRegistration { return item },
}

allows generic functions by giving a mapping between the types and interfaces for the CR

var PaladinRegistryCRMap = CRMap[corev1alpha1.PaladinRegistry, *corev1alpha1.PaladinRegistry, *corev1alpha1.PaladinRegistryList]{
	NewList:  func() *corev1alpha1.PaladinRegistryList { return new(corev1alpha1.PaladinRegistryList) },
	ItemsFor: func(list *corev1alpha1.PaladinRegistryList) []corev1alpha1.PaladinRegistry { return list.Items },
	AsObject: func(item *corev1alpha1.PaladinRegistry) *corev1alpha1.PaladinRegistry { return item },
}

allows generic functions by giving a mapping between the types and interfaces for the CR

var SmartContractDeploymentCRMap = CRMap[corev1alpha1.SmartContractDeployment, *corev1alpha1.SmartContractDeployment, *corev1alpha1.SmartContractDeploymentList]{
	NewList: func() *corev1alpha1.SmartContractDeploymentList { return new(corev1alpha1.SmartContractDeploymentList) },
	ItemsFor: func(list *corev1alpha1.SmartContractDeploymentList) []corev1alpha1.SmartContractDeployment {
		return list.Items
	},
	AsObject: func(item *corev1alpha1.SmartContractDeployment) *corev1alpha1.SmartContractDeployment { return item },
}

allows generic functions by giving a mapping between the types and interfaces for the CR

var TransactionInvokeCRMap = CRMap[corev1alpha1.TransactionInvoke, *corev1alpha1.TransactionInvoke, *corev1alpha1.TransactionInvokeList]{
	NewList: func() *corev1alpha1.TransactionInvokeList { return new(corev1alpha1.TransactionInvokeList) },
	ItemsFor: func(list *corev1alpha1.TransactionInvokeList) []corev1alpha1.TransactionInvoke {
		return list.Items
	},
	AsObject: func(item *corev1alpha1.TransactionInvoke) *corev1alpha1.TransactionInvoke { return item },
}

allows generic functions by giving a mapping between the types and interfaces for the CR

Types

type BesuGenesisReconciler

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

BesuGenesisReconciler reconciles a BesuGenesis object

func (*BesuGenesisReconciler) Reconcile

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

Reconcile implements the logic when a BesuGenesis resource is created, updated, or deleted

func (*BesuGenesisReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type BesuReconciler

type BesuReconciler struct {
	client.Client

	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

BesuReconciler reconciles a Besu object

func (*BesuReconciler) Reconcile

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

Reconcile implements the logic when a Besu resource is created, updated, or deleted

func (*BesuReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type CRMap

type CRMap[CR any, PCR client.Object, CRL client.ObjectList] struct {
	NewList  func() CRL
	ItemsFor func(list CRL) []CR
	AsObject func(item *CR) PCR
}

This mapping object for each CR type between the CR, pointer to the CR, and list of items for the CR, lets us build generic functions.

type InFlight

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

InFlight is a struct used to manage in flight requests for a unique identifier.

func NewInFlight

func NewInFlight() *InFlight

NewInFlight instanciates a InFlight structures.

func (*InFlight) Delete

func (db *InFlight) Delete(key string)

Delete removes the entry from the inFlight entries map. It doesn't return anything, and will do nothing if the specified key doesn't exist.

func (*InFlight) Insert

func (db *InFlight) Insert(key string) bool

Insert inserts the entry to the current list of inflight, request key is a unique identifier. Returns false when the key already exists.

func (*InFlight) IsQueued

func (db *InFlight) IsQueued(key string) bool

func (*InFlight) IsReady

func (db *InFlight) IsReady(key string) bool

type PaladinDomainReconciler

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

PaladinDomainReconciler reconciles a PaladinDomain object

func (*PaladinDomainReconciler) Reconcile

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

func (*PaladinDomainReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type PaladinReconciler

type PaladinReconciler struct {
	client.Client

	Scheme  *runtime.Scheme
	Changes *InFlight
	// contains filtered or unexported fields
}

PaladinReconciler reconciles a Paladin object

func (*PaladinReconciler) Reconcile

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

Reconcile implements the logic when a Paladin resource is created, updated, or deleted

func (*PaladinReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type PaladinRegistrationReconciler

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

PaladinRegistrationReconciler reconciles a PaladinRegistration object

func (*PaladinRegistrationReconciler) Reconcile

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

func (*PaladinRegistrationReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type PaladinRegistryReconciler

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

PaladinRegistryReconciler reconciles a PaladinRegistry object

func (*PaladinRegistryReconciler) Reconcile

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

func (*PaladinRegistryReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type SmartContractDeploymentReconciler

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

SmartContractDeploymentReconciler reconciles a SmartContractDeployment object

func (*SmartContractDeploymentReconciler) Reconcile

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

func (*SmartContractDeploymentReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type TransactionInvokeReconciler

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

TransactionInvokeReconciler reconciles a TransactionInvoke object

func (*TransactionInvokeReconciler) Reconcile

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

func (*TransactionInvokeReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.