controller

Documentation

Index

• Constants
• type ConsumerReconciler
  • func (r *ConsumerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ConsumerReconciler) SetupWithManager(mgr ctrl.Manager) error
• type CustomerResourceIndexer
• type HTTPFilterPolicyReconciler
  • func NewHTTPFilterPolicyReconciler(output component.Output, manager component.ResourceManager) *HTTPFilterPolicyReconciler
  • func (r *HTTPFilterPolicyReconciler) NeedReconcile(ctx context.Context, meta component.ResourceMeta) bool
  • func (r *HTTPFilterPolicyReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *HTTPFilterPolicyReconciler) SetupWithManager(mgr ctrl.Manager) error
• type HTTPRouteIndexer
  • func (v *HTTPRouteIndexer) CustomerResource() client.Object
  • func (v *HTTPRouteIndexer) FindAffectedObjects(ctx context.Context, obj component.ResourceMeta) []reconcile.Request
  • func (v *HTTPRouteIndexer) Predicate() predicate.Predicate
  • func (v *HTTPRouteIndexer) UpdateIndex(idx map[string][]*mosniov1.HTTPFilterPolicy)
• type IstioGatewayIndexer
  • func (v *IstioGatewayIndexer) CustomerResource() client.Object
  • func (v *IstioGatewayIndexer) FindAffectedObjects(ctx context.Context, obj component.ResourceMeta) []reconcile.Request
  • func (v *IstioGatewayIndexer) Predicate() predicate.Predicate
  • func (v *IstioGatewayIndexer) UpdateIndex(idx map[string][]*mosniov1.HTTPFilterPolicy)
• type K8sGatewayIndexer
  • func (v *K8sGatewayIndexer) CustomerResource() client.Object
  • func (v *K8sGatewayIndexer) FindAffectedObjects(ctx context.Context, obj component.ResourceMeta) []reconcile.Request
  • func (v *K8sGatewayIndexer) Predicate() predicate.Predicate
  • func (v *K8sGatewayIndexer) UpdateIndex(idx map[string][]*mosniov1.HTTPFilterPolicy)
• type ServiceRegistryReconciler
  • func (r *ServiceRegistryReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ServiceRegistryReconciler) SetupWithManager(mgr ctrl.Manager) error
• type VirtualServiceIndexer
  • func (v *VirtualServiceIndexer) CustomerResource() client.Object
  • func (v *VirtualServiceIndexer) FindAffectedObjects(ctx context.Context, obj component.ResourceMeta) []reconcile.Request
  • func (v *VirtualServiceIndexer) Predicate() predicate.Predicate
  • func (v *VirtualServiceIndexer) UpdateIndex(idx map[string][]*mosniov1.HTTPFilterPolicy)

Constants

const (
	ConsumerEnvoyFilterName = "htnn-consumer"
)

Types

type ConsumerReconciler

type ConsumerReconciler struct {
	component.ResourceManager
	Output component.Output
}

ConsumerReconciler reconciles a Consumer object

func (*ConsumerReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.16.3/pkg/reconcile

func (*ConsumerReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type CustomerResourceIndexer

type CustomerResourceIndexer interface {
	CustomerResource() client.Object
	FindAffectedObjects(ctx context.Context, obj component.ResourceMeta) []reconcile.Request
	Predicate() predicate.Predicate
}

CustomerResourceIndexer indexes the additional customer resource according to the reconciled customer resource

type HTTPFilterPolicyReconciler

type HTTPFilterPolicyReconciler struct {
	component.ResourceManager
	// contains filtered or unexported fields
}

HTTPFilterPolicyReconciler reconciles a HTTPFilterPolicy object

func NewHTTPFilterPolicyReconciler

func NewHTTPFilterPolicyReconciler(output component.Output, manager component.ResourceManager) *HTTPFilterPolicyReconciler

func (*HTTPFilterPolicyReconciler) NeedReconcile

func (r *HTTPFilterPolicyReconciler) NeedReconcile(ctx context.Context, meta component.ResourceMeta) bool

func (*HTTPFilterPolicyReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.16.3/pkg/reconcile

func (*HTTPFilterPolicyReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type HTTPRouteIndexer

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

func (*HTTPRouteIndexer) CustomerResource

func (v *HTTPRouteIndexer) CustomerResource() client.Object

func (*HTTPRouteIndexer) FindAffectedObjects

func (v *HTTPRouteIndexer) FindAffectedObjects(ctx context.Context, obj component.ResourceMeta) []reconcile.Request

func (*HTTPRouteIndexer) Predicate

func (v *HTTPRouteIndexer) Predicate() predicate.Predicate

func (*HTTPRouteIndexer) UpdateIndex

func (v *HTTPRouteIndexer) UpdateIndex(idx map[string][]*mosniov1.HTTPFilterPolicy)

type IstioGatewayIndexer

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

func (*IstioGatewayIndexer) CustomerResource

func (v *IstioGatewayIndexer) CustomerResource() client.Object

func (*IstioGatewayIndexer) FindAffectedObjects

func (v *IstioGatewayIndexer) FindAffectedObjects(ctx context.Context, obj component.ResourceMeta) []reconcile.Request

func (*IstioGatewayIndexer) Predicate

func (v *IstioGatewayIndexer) Predicate() predicate.Predicate

func (*IstioGatewayIndexer) UpdateIndex

func (v *IstioGatewayIndexer) UpdateIndex(idx map[string][]*mosniov1.HTTPFilterPolicy)

type K8sGatewayIndexer

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

func (*K8sGatewayIndexer) CustomerResource

func (v *K8sGatewayIndexer) CustomerResource() client.Object

func (*K8sGatewayIndexer) FindAffectedObjects

func (v *K8sGatewayIndexer) FindAffectedObjects(ctx context.Context, obj component.ResourceMeta) []reconcile.Request

func (*K8sGatewayIndexer) Predicate

func (v *K8sGatewayIndexer) Predicate() predicate.Predicate

func (*K8sGatewayIndexer) UpdateIndex

func (v *K8sGatewayIndexer) UpdateIndex(idx map[string][]*mosniov1.HTTPFilterPolicy)

type ServiceRegistryReconciler

type ServiceRegistryReconciler struct {
	component.ResourceManager
}

ServiceRegistryReconciler reconciles a ServiceRegistry object

func (*ServiceRegistryReconciler) Reconcile

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

func (*ServiceRegistryReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type VirtualServiceIndexer

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

func (*VirtualServiceIndexer) CustomerResource

func (v *VirtualServiceIndexer) CustomerResource() client.Object

func (*VirtualServiceIndexer) FindAffectedObjects

func (v *VirtualServiceIndexer) FindAffectedObjects(ctx context.Context, obj component.ResourceMeta) []reconcile.Request

func (*VirtualServiceIndexer) Predicate

func (v *VirtualServiceIndexer) Predicate() predicate.Predicate

func (*VirtualServiceIndexer) UpdateIndex

func (v *VirtualServiceIndexer) UpdateIndex(idx map[string][]*mosniov1.HTTPFilterPolicy)