webhook_traffic

Documentation

Index

• func K8sWebhookServiceInputKey(webhookService cloudclient.K8sWebhookServiceInput) string
• func OnEvict(key string, _ CacheValue)
• type CacheValue
• type ConversionWebhookReconciler
  • func NewConversionWebhookReconciler(handler *WebhookServicesHandler) *ConversionWebhookReconciler
  • func (r *ConversionWebhookReconciler) InjectRecorder(recorder record.EventRecorder)
  • func (r *ConversionWebhookReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ConversionWebhookReconciler) SetupWithManager(mgr ctrl.Manager) error
• type EndpointsReconciler
  • func NewEndpointsReconciler(handler *WebhookServicesHandler) *EndpointsReconciler
  • func (r *EndpointsReconciler) InjectRecorder(recorder record.EventRecorder)
  • func (r *EndpointsReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *EndpointsReconciler) SetupWithManager(mgr ctrl.Manager) error
• type KubeFinder
• type MutatingWebhookReconciler
  • func NewMutatingWebhookReconciler(handler *WebhookServicesHandler) *MutatingWebhookReconciler
  • func (r *MutatingWebhookReconciler) InjectRecorder(recorder record.EventRecorder)
  • func (r *MutatingWebhookReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MutatingWebhookReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ServicesReconciler
  • func NewServicesReconciler(handler *WebhookServicesHandler) *ServicesReconciler
  • func (r *ServicesReconciler) InjectRecorder(recorder record.EventRecorder)
  • func (r *ServicesReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ServicesReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ValidatingWebhookReconciler
  • func NewValidatingWebhookReconciler(handler *WebhookServicesHandler) *ValidatingWebhookReconciler
  • func (r *ValidatingWebhookReconciler) InjectRecorder(recorder record.EventRecorder)
  • func (r *ValidatingWebhookReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ValidatingWebhookReconciler) SetupWithManager(mgr ctrl.Manager) error
• type WebhookServicesCache
  • func NewWebhookServicesCache() *WebhookServicesCache
  • func (c *WebhookServicesCache) GenerateValue(webhookServices []cloudclient.K8sWebhookServiceInput) (CacheValue, error)
  • func (c *WebhookServicesCache) Get() (CacheValue, bool)
  • func (c *WebhookServicesCache) Set(value CacheValue) bool
• type WebhookServicesHandler
  • func NewWebhookServicesHandler(client client.Client, otterizeCloud cloudclient.CloudClient, ...) *WebhookServicesHandler
  • func (h *WebhookServicesHandler) HandleAll(ctx context.Context) error
• type WebhookTrafficReconciler
• type WebhookTrafficReconcilerManager
  • func NewWebhookTrafficReconcilerManager(client client.Client, handler *WebhookServicesHandler) *WebhookTrafficReconcilerManager
  • func (r *WebhookTrafficReconcilerManager) InjectRecorder(recorder record.EventRecorder)
  • func (r *WebhookTrafficReconcilerManager) SetupWithManager(mgr ctrl.Manager) error

Functions

func K8sWebhookServiceInputKey

func K8sWebhookServiceInputKey(webhookService cloudclient.K8sWebhookServiceInput) string

func OnEvict

func OnEvict(key string, _ CacheValue)

Types

type CacheValue

type CacheValue []byte

type ConversionWebhookReconciler

type ConversionWebhookReconciler struct {
	client.Client
	injectablerecorder.InjectableRecorder
	// contains filtered or unexported fields
}

func NewConversionWebhookReconciler

func NewConversionWebhookReconciler(handler *WebhookServicesHandler) *ConversionWebhookReconciler

func (*ConversionWebhookReconciler) InjectRecorder

func (r *ConversionWebhookReconciler) InjectRecorder(recorder record.EventRecorder)

func (*ConversionWebhookReconciler) Reconcile

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

func (*ConversionWebhookReconciler) SetupWithManager

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

type EndpointsReconciler

type EndpointsReconciler struct {
	client.Client
	injectablerecorder.InjectableRecorder
	// contains filtered or unexported fields
}

func NewEndpointsReconciler

func NewEndpointsReconciler(handler *WebhookServicesHandler) *EndpointsReconciler

func (*EndpointsReconciler) InjectRecorder

func (r *EndpointsReconciler) InjectRecorder(recorder record.EventRecorder)

func (*EndpointsReconciler) Reconcile

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

func (*EndpointsReconciler) SetupWithManager

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

type KubeFinder

type KubeFinder interface {
	ResolveOtterizeIdentityForService(ctx context.Context, service *corev1.Service, now time.Time) (model.OtterizeServiceIdentity, bool, error)
}

type MutatingWebhookReconciler

type MutatingWebhookReconciler struct {
	client.Client
	injectablerecorder.InjectableRecorder
	// contains filtered or unexported fields
}

func NewMutatingWebhookReconciler

func NewMutatingWebhookReconciler(handler *WebhookServicesHandler) *MutatingWebhookReconciler

func (*MutatingWebhookReconciler) InjectRecorder

func (r *MutatingWebhookReconciler) InjectRecorder(recorder record.EventRecorder)

func (*MutatingWebhookReconciler) Reconcile

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

func (*MutatingWebhookReconciler) SetupWithManager

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

type ServicesReconciler

type ServicesReconciler struct {
	client.Client

	injectablerecorder.InjectableRecorder
	// contains filtered or unexported fields
}

func NewServicesReconciler

func NewServicesReconciler(handler *WebhookServicesHandler) *ServicesReconciler

func (*ServicesReconciler) InjectRecorder

func (r *ServicesReconciler) InjectRecorder(recorder record.EventRecorder)

func (*ServicesReconciler) Reconcile

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

func (*ServicesReconciler) SetupWithManager

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

type ValidatingWebhookReconciler

type ValidatingWebhookReconciler struct {
	client.Client
	injectablerecorder.InjectableRecorder
	// contains filtered or unexported fields
}

func NewValidatingWebhookReconciler

func NewValidatingWebhookReconciler(handler *WebhookServicesHandler) *ValidatingWebhookReconciler

func (*ValidatingWebhookReconciler) InjectRecorder

func (r *ValidatingWebhookReconciler) InjectRecorder(recorder record.EventRecorder)

func (*ValidatingWebhookReconciler) Reconcile

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

func (*ValidatingWebhookReconciler) SetupWithManager

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

type WebhookServicesCache

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

func NewWebhookServicesCache

func NewWebhookServicesCache() *WebhookServicesCache

func (*WebhookServicesCache) GenerateValue

func (c *WebhookServicesCache) GenerateValue(webhookServices []cloudclient.K8sWebhookServiceInput) (CacheValue, error)

func (*WebhookServicesCache) Get

func (c *WebhookServicesCache) Get() (CacheValue, bool)

func (*WebhookServicesCache) Set

func (c *WebhookServicesCache) Set(value CacheValue) bool

type WebhookServicesHandler

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

func NewWebhookServicesHandler

func NewWebhookServicesHandler(client client.Client, otterizeCloud cloudclient.CloudClient, kubeFinder KubeFinder) *WebhookServicesHandler

func (*WebhookServicesHandler) HandleAll

func (h *WebhookServicesHandler) HandleAll(ctx context.Context) error

type WebhookTrafficReconciler

type WebhookTrafficReconciler interface {
	SetupWithManager(mgr ctrl.Manager) error
	InjectRecorder(recorder record.EventRecorder)
	Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
}

type WebhookTrafficReconcilerManager

type WebhookTrafficReconcilerManager struct {
	client.Client
	injectablerecorder.InjectableRecorder
	// contains filtered or unexported fields
}

func NewWebhookTrafficReconcilerManager

func NewWebhookTrafficReconcilerManager(client client.Client, handler *WebhookServicesHandler) *WebhookTrafficReconcilerManager

func (*WebhookTrafficReconcilerManager) InjectRecorder

func (r *WebhookTrafficReconcilerManager) InjectRecorder(recorder record.EventRecorder)

func (*WebhookTrafficReconcilerManager) SetupWithManager

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