watcheragent

Documentation

Index

• Constants
• func NewGRPCManager(ctx context.Context, logger logr.Logger, dialOptions ...grpc.DialOption) *gRPCManager
• type Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error
• type WatcherManager
  • func NewManager(ctx context.Context, logger logr.Logger, client dynamic.Interface, ...) *WatcherManager
  • func (m *WatcherManager) ListWatches(key types.NamespacedName) map[...]*watcher.Watcher

Constants

const ClusterNameLabel = "cloud.nephio.org/cluster"

Functions

func NewGRPCManager

func NewGRPCManager(ctx context.Context, logger logr.Logger,
	dialOptions ...grpc.DialOption) *gRPCManager

Types

type Reconciler

type Reconciler struct {
	client.Client
	Scheme *runtime.Scheme

	GRPCManager    *gRPCManager
	WatcherManager *WatcherManager
	WatchEvents    chan event.GenericEvent

	Log logr.Logger
}

Reconciler reconciles a WatcherAgent object

func (*Reconciler) Reconcile

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

func (*Reconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type WatcherManager

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

WatcherManager manages different watchers based on the received WatchRequests There is one-to-one mapping between watchers and WatchRequests.

func NewManager

func NewManager(ctx context.Context, logger logr.Logger, client dynamic.Interface,
	restMapper meta.RESTMapper, clock clock.Clock) *WatcherManager

func (*WatcherManager) ListWatches

func (m *WatcherManager) ListWatches(key types.NamespacedName) map[v1alpha1.
	WatchRequest]*watcher.Watcher

ListWatches returns currently active watchers mapped to corresponding watchReq