submariner

Documentation

Index

• type BrokerReconciler
  • func (r *BrokerReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
  • func (r *BrokerReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Config
• type Reconciler
  • func NewReconciler(config *Config) *Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error

Types

type BrokerReconciler

type BrokerReconciler struct {
	Client client.Client
	Config *rest.Config
	Log    logr.Logger
	Scheme *runtime.Scheme
}

BrokerReconciler reconciles a Broker object.

func (*BrokerReconciler) Reconcile

func (r *BrokerReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

TODO skitt: these rbac declarations (and others, see submariner_controller.go) need to be separated from methods in order to be taken into account; but they produce ClusterRoles, not the Roles we want +kubebuilder:rbac:groups=submariner.io,resources=brokers,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=submariner.io,resources=brokers/status,verbs=get;update;patch

func (*BrokerReconciler) SetupWithManager

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

nolint:wrapcheck // No need to wrap here.

type Config

type Config struct {
	// This client is a split client that reads objects from the cache and writes to the apiserver
	Client         client.Client
	RestConfig     *rest.Config
	Scheme         *runtime.Scheme
	KubeClient     kubernetes.Interface
	SubmClient     submarinerclientset.Interface
	DynClient      dynamic.Interface
	ClusterNetwork *network.ClusterNetwork
}

type Reconciler

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

Reconciler reconciles a Submariner object.

func NewReconciler

func NewReconciler(config *Config) *Reconciler

NewReconciler returns a new Reconciler.

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

+kubebuilder:rbac:groups=submariner.io,resources=submariners,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=submariner.io,resources=submariners/status,verbs=get;update;patch nolint:gocyclo // Refactoring would yield functions with a lot of params which isn't ideal either.

func (*Reconciler) SetupWithManager

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