traffictopology

Documentation

Index

• Constants
• func InitFunc(mgr manager.Manager) (bool, error)
• type EnqueueTP
  • func (e *EnqueueTP) Create(createEvent event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueTP) Delete(deleteEvent event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueTP) Generic(genericEvent event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueTP) Update(updateEvent event.UpdateEvent, q workqueue.RateLimitingInterface)
• type EnqueueTPByBR
  • func (e *EnqueueTPByBR) Create(event.CreateEvent, workqueue.RateLimitingInterface)
  • func (e *EnqueueTPByBR) Delete(event.DeleteEvent, workqueue.RateLimitingInterface)
  • func (e *EnqueueTPByBR) Generic(event.GenericEvent, workqueue.RateLimitingInterface)
  • func (e *EnqueueTPByBR) Update(event.UpdateEvent, workqueue.RateLimitingInterface)
• type TPControllerAdapter
  • func NewTPControllerAdapter(mgr manager.Manager, workloadRegistry workload.Registry) *TPControllerAdapter
  • func (t *TPControllerAdapter) CreateEmployees(ctx context.Context, employer client.Object, ...) ([]rsFrameController.IEmployee, []rsFrameController.IEmployee, error)
  • func (t *TPControllerAdapter) CreateEmployer(ctx context.Context, employer client.Object, ...) ([]rsFrameController.IEmployer, []rsFrameController.IEmployer, error)
  • func (t *TPControllerAdapter) DeleteEmployees(ctx context.Context, employer client.Object, ...) ([]rsFrameController.IEmployee, []rsFrameController.IEmployee, error)
  • func (t *TPControllerAdapter) DeleteEmployer(ctx context.Context, employer client.Object, ...) ([]rsFrameController.IEmployer, []rsFrameController.IEmployer, error)
  • func (t *TPControllerAdapter) EmployeeEventHandler() handler.EventHandler
  • func (t *TPControllerAdapter) EmployeeFed() bool
  • func (t *TPControllerAdapter) EmployeePredicates() predicate.Funcs
  • func (t *TPControllerAdapter) EmployerEventHandler() handler.EventHandler
  • func (t *TPControllerAdapter) EmployerPredicates() predicate.Funcs
  • func (t *TPControllerAdapter) GetControllerName() string
  • func (t *TPControllerAdapter) GetCurrentEmployee(ctx context.Context, employer client.Object) ([]rsFrameController.IEmployee, error)
  • func (t *TPControllerAdapter) GetCurrentEmployer(ctx context.Context, employer client.Object) ([]rsFrameController.IEmployer, error)
  • func (t *TPControllerAdapter) GetExpectedEmployee(ctx context.Context, employer client.Object) ([]rsFrameController.IEmployee, error)
  • func (t *TPControllerAdapter) GetExpectedEmployer(ctx context.Context, employer client.Object) ([]rsFrameController.IEmployer, error)
  • func (t *TPControllerAdapter) GetMaxConcurrent() int
  • func (t *TPControllerAdapter) GetRateLimiter() ratelimiter.RateLimiter
  • func (t *TPControllerAdapter) GetSelectedEmployeeNames(ctx context.Context, employer client.Object) ([]string, error)
  • func (t *TPControllerAdapter) NewEmployee() client.Object
  • func (t *TPControllerAdapter) NewEmployer() client.Object
  • func (t *TPControllerAdapter) RecordStatuses(ctx context.Context, employer client.Object, ...) error
  • func (t *TPControllerAdapter) UpdateEmployees(ctx context.Context, employer client.Object, ...) ([]rsFrameController.IEmployee, []rsFrameController.IEmployee, error)
  • func (t *TPControllerAdapter) UpdateEmployer(ctx context.Context, employer client.Object, ...) ([]rsFrameController.IEmployer, []rsFrameController.IEmployer, error)
• type TPEmployer
  • func (b TPEmployer) EmployerEqual(employer rsFrameController.IEmployer) (bool, error)
  • func (b TPEmployer) GetEmployerId() string
  • func (b TPEmployer) GetEmployerName() string
  • func (b TPEmployer) GetEmployerStatuses() interface{}
• type TREmployerStatues

Constants

const ControllerName = "traffictopology"

Functions

func InitFunc

func InitFunc(mgr manager.Manager) (bool, error)

Types

type EnqueueTP

type EnqueueTP struct {
}

func (*EnqueueTP) Create

func (e *EnqueueTP) Create(createEvent event.CreateEvent, q workqueue.RateLimitingInterface)

func (*EnqueueTP) Delete

func (e *EnqueueTP) Delete(deleteEvent event.DeleteEvent, q workqueue.RateLimitingInterface)

func (*EnqueueTP) Generic

func (e *EnqueueTP) Generic(genericEvent event.GenericEvent, q workqueue.RateLimitingInterface)

func (*EnqueueTP) Update

func (e *EnqueueTP) Update(updateEvent event.UpdateEvent, q workqueue.RateLimitingInterface)

type EnqueueTPByBR

type EnqueueTPByBR struct{}

func (*EnqueueTPByBR) Create

func (e *EnqueueTPByBR) Create(event.CreateEvent, workqueue.RateLimitingInterface)

func (*EnqueueTPByBR) Delete

func (e *EnqueueTPByBR) Delete(event.DeleteEvent, workqueue.RateLimitingInterface)

func (*EnqueueTPByBR) Generic

func (e *EnqueueTPByBR) Generic(event.GenericEvent, workqueue.RateLimitingInterface)

func (*EnqueueTPByBR) Update

func (e *EnqueueTPByBR) Update(event.UpdateEvent, workqueue.RateLimitingInterface)

type TPControllerAdapter

type TPControllerAdapter struct {
	client.Client
	// contains filtered or unexported fields
}

func NewTPControllerAdapter

func NewTPControllerAdapter(mgr manager.Manager, workloadRegistry workload.Registry) *TPControllerAdapter

func (*TPControllerAdapter) CreateEmployees

func (t *TPControllerAdapter) CreateEmployees(ctx context.Context, employer client.Object, toCreates []rsFrameController.IEmployee) ([]rsFrameController.IEmployee, []rsFrameController.IEmployee, error)

func (*TPControllerAdapter) CreateEmployer

func (t *TPControllerAdapter) CreateEmployer(ctx context.Context, employer client.Object, toCreates []rsFrameController.IEmployer) ([]rsFrameController.IEmployer, []rsFrameController.IEmployer, error)

func (*TPControllerAdapter) DeleteEmployees

func (t *TPControllerAdapter) DeleteEmployees(ctx context.Context, employer client.Object, toDeletes []rsFrameController.IEmployee) ([]rsFrameController.IEmployee, []rsFrameController.IEmployee, error)

func (*TPControllerAdapter) DeleteEmployer

func (t *TPControllerAdapter) DeleteEmployer(ctx context.Context, employer client.Object, toDeletes []rsFrameController.IEmployer) ([]rsFrameController.IEmployer, []rsFrameController.IEmployer, error)

func (*TPControllerAdapter) EmployeeEventHandler

func (t *TPControllerAdapter) EmployeeEventHandler() handler.EventHandler

EmployeeEventHandler return nil since we don't need BackendRouting's event trigger reconciling TrafficTopology

func (*TPControllerAdapter) EmployeeFed

func (t *TPControllerAdapter) EmployeeFed() bool

func (*TPControllerAdapter) EmployeePredicates

func (t *TPControllerAdapter) EmployeePredicates() predicate.Funcs

func (*TPControllerAdapter) EmployerEventHandler

func (t *TPControllerAdapter) EmployerEventHandler() handler.EventHandler

func (*TPControllerAdapter) EmployerPredicates

func (t *TPControllerAdapter) EmployerPredicates() predicate.Funcs

func (*TPControllerAdapter) GetControllerName

func (t *TPControllerAdapter) GetControllerName() string

func (*TPControllerAdapter) GetCurrentEmployee

func (t *TPControllerAdapter) GetCurrentEmployee(ctx context.Context, employer client.Object) ([]rsFrameController.IEmployee, error)

func (*TPControllerAdapter) GetCurrentEmployer

func (t *TPControllerAdapter) GetCurrentEmployer(ctx context.Context, employer client.Object) ([]rsFrameController.IEmployer, error)

GetCurrentEmployer returns BackendRouting created already, check those in trafficTopology.status check expected whether created already? no need, we made create/delete idempotent

func (*TPControllerAdapter) GetExpectedEmployee

func (t *TPControllerAdapter) GetExpectedEmployee(ctx context.Context, employer client.Object) ([]rsFrameController.IEmployee, error)

func (*TPControllerAdapter) GetExpectedEmployer

func (t *TPControllerAdapter) GetExpectedEmployer(ctx context.Context, employer client.Object) ([]rsFrameController.IEmployer, error)

func (*TPControllerAdapter) GetMaxConcurrent

func (t *TPControllerAdapter) GetMaxConcurrent() int

GetMaxConcurrent implements controller.ReconcileOptions.

func (*TPControllerAdapter) GetRateLimiter

func (t *TPControllerAdapter) GetRateLimiter() ratelimiter.RateLimiter

GetRateLimiter implements controller.ReconcileOptions.

func (*TPControllerAdapter) GetSelectedEmployeeNames

func (t *TPControllerAdapter) GetSelectedEmployeeNames(ctx context.Context, employer client.Object) ([]string, error)

func (*TPControllerAdapter) NewEmployee

func (t *TPControllerAdapter) NewEmployee() client.Object

func (*TPControllerAdapter) NewEmployer

func (t *TPControllerAdapter) NewEmployer() client.Object

func (*TPControllerAdapter) RecordStatuses

func (t *TPControllerAdapter) RecordStatuses(ctx context.Context, employer client.Object, cudEmployerResults rsFrameController.CUDEmployerResults, cudEmployeeResults rsFrameController.CUDEmployeeResults) error

func (*TPControllerAdapter) UpdateEmployees

func (t *TPControllerAdapter) UpdateEmployees(ctx context.Context, employer client.Object, toUpdates []rsFrameController.IEmployee) ([]rsFrameController.IEmployee, []rsFrameController.IEmployee, error)

func (*TPControllerAdapter) UpdateEmployer

func (t *TPControllerAdapter) UpdateEmployer(ctx context.Context, employer client.Object, toUpdates []rsFrameController.IEmployer) ([]rsFrameController.IEmployer, []rsFrameController.IEmployer, error)

UpdateEmployer won't do update now, since only BackendRouting's name compared TODO what we should do if BackendRouting's spec different

type TPEmployer

type TPEmployer struct {
	BackendRoutingName string
	BackendRouting     v1alpha1.BackendRouting
	Workloads          []v1alpha1.CrossClusterObjectNameReference
}

func (TPEmployer) EmployerEqual

func (b TPEmployer) EmployerEqual(employer rsFrameController.IEmployer) (bool, error)

EmployerEqual only compare name now TODO compare spec, but spec might be changed by BackendRouting controller

func (TPEmployer) GetEmployerId

func (b TPEmployer) GetEmployerId() string

func (TPEmployer) GetEmployerName

func (b TPEmployer) GetEmployerName() string

func (TPEmployer) GetEmployerStatuses

func (b TPEmployer) GetEmployerStatuses() interface{}

type TREmployerStatues

type TREmployerStatues struct {
	BackendRouting v1alpha1.BackendRouting
	Workloads      []v1alpha1.CrossClusterObjectNameReference
}