Documentation ¶
Index ¶
- type Cache
- type Reconciler
- func (r *Reconciler) GetCache() *Cache
- func (r *Reconciler) ReconcileService(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *Reconciler) ReconcileServicePort(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *Reconciler) ReconcileSync(_ context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cache ¶
type Cache struct {
// contains filtered or unexported fields
}
func (*Cache) GetCacheBySvcID ¶
func (c *Cache) GetCacheBySvcID(svcID string) (*proxycache.BaseSvc, []proxycache.Backend, []string)
type Reconciler ¶
type Reconciler struct { client.Client Scheme *runtime.Scheme DpMgr *datapath.DpManager LocalNode string SyncChan chan event.GenericEvent Cache // contains filtered or unexported fields }
Reconciler watch Service related resource and implement Service
func (*Reconciler) GetCache ¶
func (r *Reconciler) GetCache() *Cache
func (*Reconciler) ReconcileService ¶
ReconcileService receive Service from work queue
func (*Reconciler) ReconcileServicePort ¶
func (r *Reconciler) ReconcileServicePort(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
ReconcileSvcPort receive servicePort from work queue
func (*Reconciler) ReconcileSync ¶
ReconcileSync receive proxySuncEvent from work queue
func (*Reconciler) SetupWithManager ¶
func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager add service controller and servicePort controller to mgr
Click to show internal directories.
Click to hide internal directories.