controllers

Documentation

Index

• Constants
• Variables
• func TemplateRateLimiter(failureBaseDelay time.Duration, failureMaxDelay time.Duration, frequency int, ...) ratelimiter.RateLimiter
• type IstioReconciler
  • func NewReconciler(mgr manager.Manager) *IstioReconciler
  • func (r *IstioReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *IstioReconciler) SetupWithManager(mgr ctrl.Manager, rateLimiter RateLimiter) error
• type ManifestResolver
  • func (m *ManifestResolver) Get(obj types.BaseCustomObject, _ logr.Logger) (types.InstallationSpec, error)
• type RateLimiter

Constants

const (
	IstioVersion   string = "1.16.1"
	IstioImageBase string = "distroless"
)

Variables

var (
	ConfigFlags types.Flags
	SetFlags    types.Flags
)

var IstioTag = fmt.Sprintf("%s-%s", IstioVersion, IstioImageBase)

Functions

func TemplateRateLimiter

func TemplateRateLimiter(failureBaseDelay time.Duration, failureMaxDelay time.Duration,
	frequency int, burst int,
) ratelimiter.RateLimiter

TemplateRateLimiter implements a rate limiter for a client-go.workqueue. It has both an overall (token bucket) and per-item (exponential) rate limiting.

Types

type IstioReconciler

type IstioReconciler struct {
	declarative.ManifestReconciler // declarative reconciler override
	*rest.Config                   // required to pass rest config to the declarative library
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

IstioReconciler reconciles a Istio object

func NewReconciler

func NewReconciler(mgr manager.Manager) *IstioReconciler

func (*IstioReconciler) Reconcile

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

func (*IstioReconciler) SetupWithManager

func (r *IstioReconciler) SetupWithManager(mgr ctrl.Manager, rateLimiter RateLimiter) error

+kubebuilder:rbac:groups=operator.kyma-project.io,resources=istios,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=operator.kyma-project.io,resources=istios/status,verbs=get;update;patch +kubebuilder:rbac:groups=operator.kyma-project.io,resources=istios/finalizers,verbs=update +kubebuilder:rbac:groups="",resources=namespaces,verbs=get;create;update;patch

type ManifestResolver

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

ManifestResolver represents the chart information for the passed Istio resource.

func (*ManifestResolver) Get

func (m *ManifestResolver) Get(obj types.BaseCustomObject, _ logr.Logger) (types.InstallationSpec, error)

Get returns the chart information to be processed.

type RateLimiter

type RateLimiter struct {
	Burst           int
	Frequency       int
	BaseDelay       time.Duration
	FailureMaxDelay time.Duration
}