controller

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 26, 2024 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ConsumerEnvoyFilterName = "htnn-consumer"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ConsumerReconciler 

type ConsumerReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

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
	RegisterIndexer(ctx context.Context, mgr ctrl.Manager) error
	FindAffectedObjects(ctx context.Context, obj client.Object) []reconcile.Request
	Predicate() predicate.Predicate
}

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

type HTTPFilterPolicyReconciler 

type HTTPFilterPolicyReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

HTTPFilterPolicyReconciler reconciles a HTTPFilterPolicy object

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 client.Object) []reconcile.Request

func (*HTTPRouteIndexer) Index 

func (v *HTTPRouteIndexer) Index(rawObj client.Object) []string

func (*HTTPRouteIndexer) IndexName 

func (v *HTTPRouteIndexer) IndexName() string

func (*HTTPRouteIndexer) Predicate 

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

func (*HTTPRouteIndexer) RegisterIndexer 

func (v *HTTPRouteIndexer) RegisterIndexer(ctx context.Context, mgr ctrl.Manager) error

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 client.Object) []reconcile.Request

func (*IstioGatewayIndexer) Predicate 

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

func (*IstioGatewayIndexer) RegisterIndexer 

func (v *IstioGatewayIndexer) RegisterIndexer(ctx context.Context, mgr ctrl.Manager) error

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 client.Object) []reconcile.Request

func (*K8sGatewayIndexer) Predicate 

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

func (*K8sGatewayIndexer) RegisterIndexer 

func (v *K8sGatewayIndexer) RegisterIndexer(ctx context.Context, mgr ctrl.Manager) error

func (*K8sGatewayIndexer) UpdateIndex 

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

type ServiceRegistryReconciler 

type ServiceRegistryReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

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 client.Object) []reconcile.Request

func (*VirtualServiceIndexer) Index 

func (v *VirtualServiceIndexer) Index(rawObj client.Object) []string

func (*VirtualServiceIndexer) IndexName 

func (v *VirtualServiceIndexer) IndexName() string

func (*VirtualServiceIndexer) Predicate 

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

func (*VirtualServiceIndexer) RegisterIndexer 

func (v *VirtualServiceIndexer) RegisterIndexer(ctx context.Context, mgr ctrl.Manager) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.