metrics_collection_traffic

Documentation

Index

• func OnEvict(key string, _ CacheValue)
• type CacheValue
• type EndpointsReconciler
  • func NewEndpointsReconciler(metricsCollectionTrafficHandler *MetricsCollectionTrafficHandler) *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 MetricsCollectionTrafficCache
  • func NewMetricsCollectionTrafficCache() *MetricsCollectionTrafficCache
  • func (c *MetricsCollectionTrafficCache) GenerateValue(pods []cloudclient.K8sResourceEligibleForMetricsCollectionInput) (CacheValue, error)
  • func (c *MetricsCollectionTrafficCache) Get(namespace string, reason cloudclient.EligibleForMetricsCollectionReason) (CacheValue, bool)
  • func (c *MetricsCollectionTrafficCache) Set(namespace string, reason cloudclient.EligibleForMetricsCollectionReason, ...) bool
• type MetricsCollectionTrafficHandler
  • func NewMetricsCollectionTrafficHandler(client client.Client, serviceIdResolver *serviceidresolver.Resolver, ...) *MetricsCollectionTrafficHandler
  • func (r *MetricsCollectionTrafficHandler) HandleAllPodsInNamespace(ctx context.Context, req ctrl.Request) error
  • func (r *MetricsCollectionTrafficHandler) HandleAllServicesInNamespace(ctx context.Context, req ctrl.Request) error
• type PodReconciler
  • func NewPodReconciler(metricsCollectionTrafficHandler *MetricsCollectionTrafficHandler) *PodReconciler
  • func (r *PodReconciler) InjectRecorder(recorder record.EventRecorder)
  • func (r *PodReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PodReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ServiceReconciler
  • func NewServiceReconciler(metricsCollectionTrafficHandler *MetricsCollectionTrafficHandler) *ServiceReconciler
  • func (r *ServiceReconciler) InjectRecorder(recorder record.EventRecorder)
  • func (r *ServiceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ServiceReconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func OnEvict

func OnEvict(key string, _ CacheValue)

Types

type CacheValue

type CacheValue []byte

type EndpointsReconciler

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

func NewEndpointsReconciler

func NewEndpointsReconciler(metricsCollectionTrafficHandler *MetricsCollectionTrafficHandler) *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 MetricsCollectionTrafficCache

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

func NewMetricsCollectionTrafficCache

func NewMetricsCollectionTrafficCache() *MetricsCollectionTrafficCache

func (*MetricsCollectionTrafficCache) GenerateValue

func (c *MetricsCollectionTrafficCache) GenerateValue(pods []cloudclient.K8sResourceEligibleForMetricsCollectionInput) (CacheValue, error)

func (*MetricsCollectionTrafficCache) Get

func (c *MetricsCollectionTrafficCache) Get(namespace string, reason cloudclient.EligibleForMetricsCollectionReason) (CacheValue, bool)

func (*MetricsCollectionTrafficCache) Set

func (c *MetricsCollectionTrafficCache) Set(namespace string, reason cloudclient.EligibleForMetricsCollectionReason, value CacheValue) bool

type MetricsCollectionTrafficHandler

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

func NewMetricsCollectionTrafficHandler

func NewMetricsCollectionTrafficHandler(client client.Client, serviceIdResolver *serviceidresolver.Resolver, otterizeCloud cloudclient.CloudClient) *MetricsCollectionTrafficHandler

func (*MetricsCollectionTrafficHandler) HandleAllPodsInNamespace

func (r *MetricsCollectionTrafficHandler) HandleAllPodsInNamespace(ctx context.Context, req ctrl.Request) error

func (*MetricsCollectionTrafficHandler) HandleAllServicesInNamespace

func (r *MetricsCollectionTrafficHandler) HandleAllServicesInNamespace(ctx context.Context, req ctrl.Request) error

type PodReconciler

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

func NewPodReconciler

func NewPodReconciler(metricsCollectionTrafficHandler *MetricsCollectionTrafficHandler) *PodReconciler

func (*PodReconciler) InjectRecorder

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

func (*PodReconciler) Reconcile

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

func (*PodReconciler) SetupWithManager

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

type ServiceReconciler

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

func NewServiceReconciler

func NewServiceReconciler(metricsCollectionTrafficHandler *MetricsCollectionTrafficHandler) *ServiceReconciler

func (*ServiceReconciler) InjectRecorder

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

func (*ServiceReconciler) Reconcile

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

func (*ServiceReconciler) SetupWithManager

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