engine

Documentation

Index

• Variables
• func CreateMeterDefinitionV1Beta1Watch(c *marketplacev1beta1client.MarketplaceV1beta1Client) func(string) cache.ListerWatcher
• func CreatePVCListWatch(kubeClient clientset.Interface) func(string) cache.ListerWatcher
• func CreatePodListWatch(kubeClient clientset.Interface) func(string) cache.ListerWatcher
• func CreateServiceListWatch(kubeClient clientset.Interface) func(string) cache.ListerWatcher
• func CreateServiceMonitorListWatch(c *monitoringv1client.MonitoringV1Client) func(string) cache.ListerWatcher
• type Engine
  • func NewEngine(ctx context.Context, namespaces types.Namespaces, scheme *runtime.Scheme, ...) (*Engine, error)
  • func ProvideEngine(log logr.Logger, runnables Runnables) *Engine
  • func (e *Engine) Start(ctx context.Context) error
  • func (e *Engine) Stop()
• type ListWatchers
• type ListerRunnable
  • func (p *ListerRunnable) Start(ctx context.Context) error
  • func (p *ListerRunnable) Stop()
• type MeterDefinitionDictionaryStoreRunnable
  • func ProvideMeterDefinitionDictionaryStoreRunnable(kubeClient clientset.Interface, nses pkgtypes.Namespaces, ...) *MeterDefinitionDictionaryStoreRunnable
• type MeterDefinitionListerRunnable
• type MeterDefinitionStoreListWatchers
  • func ProvideMeterDefinitionStoreListWatchers(kubeClient clientset.Interface, store *stores.MeterDefinitionStore, ...) MeterDefinitionStoreListWatchers
• type MeterDefinitionStoreRunnable
  • func ProvideMeterDefinitionStoreRunnable(nses pkgtypes.Namespaces, log logr.Logger, ns *filter.NamespaceWatcher, ...) *MeterDefinitionStoreRunnable
• type NamespacedCachedListers
  • func ProvideNamespacedCacheListers(ns *filter.NamespaceWatcher, log logr.Logger, listWatchers ListWatchers) *NamespacedCachedListers
  • func (w *NamespacedCachedListers) Start(ctx context.Context) error
• type NamespacedListWatcherFunc
• type PVCListerRunnable
• type PodListerRunnable
• type RunAndStop
• type Runnable
• type Runnables
  • func ProvideRunnables(meterDefinitionStore *MeterDefinitionStoreRunnable, ...) Runnables
• type ServiceListerRunnable
• type ServiceMonitorListerRunnable
• type Stoppable
• type StoreRunnable
  • func (p *StoreRunnable) Start(ctx context.Context) error

Variables

var EngineSet = wire.NewSet(
	ProvideEngine,
	stores.NewMeterDefinitionDictionary,
	stores.NewMeterDefinitionStore,
	ProvideMeterDefinitionStoreListWatchers,
	wire.Struct(new(filter.MeterDefinitionLookupFilterFactory), "*"),
)

var RunnablesSet = wire.NewSet(
	mailbox.ProvideMailbox,
	ProvideRunnables,
	ProvideMeterDefinitionStoreRunnable,
	ProvideMeterDefinitionDictionaryStoreRunnable,
	processors.ProvideMeterDefinitionRemovalWatcher,

	processors.ProvideStatusProcessor,
	processors.ProvidePrometheusProcessor,
	processors.ProvidePrometheusMdefProcessor,
	mailbox.ProvideObjectChannelProducer,
	mailbox.ProvideMeterDefinitionChannelProducer,
	filter.ProvideNamespaceWatcher,
)

Functions

func CreateMeterDefinitionV1Beta1Watch

func CreateMeterDefinitionV1Beta1Watch(c *marketplacev1beta1client.MarketplaceV1beta1Client) func(string) cache.ListerWatcher

func CreatePVCListWatch

func CreatePVCListWatch(kubeClient clientset.Interface) func(string) cache.ListerWatcher

func CreatePodListWatch

func CreatePodListWatch(kubeClient clientset.Interface) func(string) cache.ListerWatcher

func CreateServiceListWatch

func CreateServiceListWatch(kubeClient clientset.Interface) func(string) cache.ListerWatcher

func CreateServiceMonitorListWatch

func CreateServiceMonitorListWatch(c *monitoringv1client.MonitoringV1Client) func(string) cache.ListerWatcher

Types

type Engine

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

func NewEngine

func NewEngine(ctx context.Context, namespaces types.Namespaces, scheme *runtime.Scheme, restConfig *rest.Config, clientOptions managers.ClientOptions, log logr.Logger, prometheusData *metrics.PrometheusData, statusFlushDuration processors.StatusFlushDuration) (*Engine, error)

func ProvideEngine

func ProvideEngine(
	log logr.Logger,
	runnables Runnables,
) *Engine

func (*Engine) Start

func (e *Engine) Start(ctx context.Context) error

func (*Engine) Stop

func (e *Engine) Stop()

type ListWatchers

type ListWatchers map[reflect.Type]NamespacedListWatcherFunc

type ListerRunnable

type ListerRunnable struct {
	Store cache.Store
	// contains filtered or unexported fields
}

func (*ListerRunnable) Start

func (p *ListerRunnable) Start(ctx context.Context) error

func (*ListerRunnable) Stop

func (p *ListerRunnable) Stop()

type MeterDefinitionDictionaryStoreRunnable

type MeterDefinitionDictionaryStoreRunnable struct {
	StoreRunnable
}

func ProvideMeterDefinitionDictionaryStoreRunnable

func ProvideMeterDefinitionDictionaryStoreRunnable(
	kubeClient clientset.Interface,
	nses pkgtypes.Namespaces,
	c *marketplacev1beta1client.MarketplaceV1beta1Client,
	store *stores.MeterDefinitionDictionary,
	log logr.Logger,
) *MeterDefinitionDictionaryStoreRunnable

type MeterDefinitionListerRunnable

type MeterDefinitionListerRunnable struct {
	ListerRunnable
}

type MeterDefinitionStoreListWatchers

type MeterDefinitionStoreListWatchers ListWatchers

func ProvideMeterDefinitionStoreListWatchers

func ProvideMeterDefinitionStoreListWatchers(
	kubeClient clientset.Interface,
	store *stores.MeterDefinitionStore,
	c *monitoringv1client.MonitoringV1Client,
) MeterDefinitionStoreListWatchers

type MeterDefinitionStoreRunnable

type MeterDefinitionStoreRunnable struct {
	StoreRunnable
}

func ProvideMeterDefinitionStoreRunnable

func ProvideMeterDefinitionStoreRunnable(
	nses pkgtypes.Namespaces,
	log logr.Logger,
	ns *filter.NamespaceWatcher,
	listWatchers MeterDefinitionStoreListWatchers,
	store *stores.MeterDefinitionStore,
) *MeterDefinitionStoreRunnable

type NamespacedCachedListers

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

func ProvideNamespacedCacheListers

func ProvideNamespacedCacheListers(
	ns *filter.NamespaceWatcher,
	log logr.Logger,
	listWatchers ListWatchers,
) *NamespacedCachedListers

func (*NamespacedCachedListers) Start

func (w *NamespacedCachedListers) Start(ctx context.Context) error

type NamespacedListWatcherFunc

type NamespacedListWatcherFunc func(ns string) RunAndStop

type PVCListerRunnable

type PVCListerRunnable struct {
	ListerRunnable
}

type PodListerRunnable

type PodListerRunnable struct {
	ListerRunnable
}

type RunAndStop

type RunAndStop interface {
	Runnable
	Stoppable
}

type Runnable

type Runnable interface {
	// Start starts the runnable and does not block.
	Start(context.Context) error
}

type Runnables

type Runnables []Runnable

func ProvideRunnables

func ProvideRunnables(
	meterDefinitionStore *MeterDefinitionStoreRunnable,
	meterDefinitionDictionary *MeterDefinitionDictionaryStoreRunnable,
	mb *mailbox.Mailbox,
	statusProcessor *processors.StatusProcessor,

	prometheusProcessor *processors.PrometheusProcessor,
	prometheusMdefProcessor *processors.PrometheusMdefProcessor,
	removalWatcher *processors.MeterDefinitionRemovalWatcher,
	objectChannelProducer *mailbox.ObjectChannelProducer,
	mdefChannelProducer *mailbox.MeterDefinitionChannelProducer,
	nsWatcher *filter.NamespaceWatcher,
) Runnables

type Recoverable interface {
	RegisterHealthCheck(func([]*health.Config))
	Recover()
}

type ServiceListerRunnable

type ServiceListerRunnable struct {
	ListerRunnable
}

type ServiceMonitorListerRunnable

type ServiceMonitorListerRunnable struct {
	ListerRunnable
}

type Stoppable

type Stoppable interface {
	Stop()
}

type StoreRunnable

type StoreRunnable struct {
	Store      cache.Store
	Reflectors Runnables
	ResyncTime time.Duration
	// contains filtered or unexported fields
}

func (*StoreRunnable) Start

func (p *StoreRunnable) Start(ctx context.Context) error