submariner

Documentation

Index

• Constants
• 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

Constants

const NetworkPluginSyncerComponent = "submariner-networkplugin-syncer"

Types

type BrokerReconciler

type BrokerReconciler struct {
	Client client.Client
	Config *rest.Config
}

BrokerReconciler reconciles a Broker object.

func (*BrokerReconciler) Reconcile

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

func (*BrokerReconciler) SetupWithManager

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

type Config

type Config struct {
	// This client is scoped to the operator namespace intended to only be used for resources created and maintained by this
	// controller. Also it's a split client that reads objects from the cache and writes to the apiserver.
	ScopedClient client.Client
	// This client can be used to access any other resource not in the operator namespace.
	GeneralClient                client.Client
	RestConfig                   *rest.Config
	Scheme                       *runtime.Scheme
	DynClient                    dynamic.Interface
	ClusterNetwork               *network.ClusterNetwork
	GetAuthorizedBrokerClientFor func(spec *submopv1a1.SubmarinerSpec, brokerToken, brokerCA string,
		secretGVR schema.GroupVersionResource) (dynamic.Interface, error)
}

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

func (*Reconciler) SetupWithManager

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