Documentation
¶
Index ¶
- type ClusterInfo
- type ClusterResourceExtractorFunc
- type ClusterScopedSnapshot
- type ClusterSnapshot
- type ClusterSnapshotter
- func (c *ClusterSnapshotter) AddResource(resource interface{}) error
- func (c *ClusterSnapshotter) GetResourceChannel() <-chan []collector.CollectedResource
- func (c *ClusterSnapshotter) GetType() string
- func (c *ClusterSnapshotter) IsAvailable(ctx context.Context) bool
- func (c *ClusterSnapshotter) Start(ctx context.Context) error
- func (c *ClusterSnapshotter) Stop() error
- type Namespace
- type NamespaceResourceExtractorFunc
- type NamespacedResourceHandler
- type NamespacedResourceListFunc
- type NodeData
- type ResourceExtractorFunc
- type ResourceHandler
- type ResourceIdentifier
- type ResourceListFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterInfo ¶
type ClusterInfo = gen.ClusterInfo
aliases for proto types to maintain compatibility for now
type ClusterResourceExtractorFunc ¶
type ClusterResourceExtractorFunc func(*gen.ClusterScopedSnapshot) map[string]*gen.ResourceIdentifier
ClusterResourceExtractorFunc extracts a resource map from cluster-scoped snapshot
type ClusterScopedSnapshot ¶
type ClusterScopedSnapshot = gen.ClusterScopedSnapshot
aliases for proto types to maintain compatibility for now
type ClusterSnapshot ¶
type ClusterSnapshot = gen.ClusterSnapshot
aliases for proto types to maintain compatibility for now
type ClusterSnapshotter ¶
type ClusterSnapshotter struct {
// contains filtered or unexported fields
}
ClusterSnapshotter takes periodic snapshots and computes deltas
func NewClusterSnapshotter ¶
func NewClusterSnapshotter( client kubernetes.Interface, kedaClient kedaclient.Interface, dynamicClient dynamic.Interface, interval time.Duration, sender transport.DirectSender, collectorManager *collector.CollectionManager, namespaces []string, excludedPods []collector.ExcludedPod, excludedNodes []string, logger logr.Logger, ) *ClusterSnapshotter
func (*ClusterSnapshotter) AddResource ¶
func (c *ClusterSnapshotter) AddResource(resource interface{}) error
AddResource manually adds a resource - not supported for cluster snapshotter
func (*ClusterSnapshotter) GetResourceChannel ¶
func (c *ClusterSnapshotter) GetResourceChannel() <-chan []collector.CollectedResource
func (*ClusterSnapshotter) GetType ¶
func (c *ClusterSnapshotter) GetType() string
func (*ClusterSnapshotter) IsAvailable ¶
func (c *ClusterSnapshotter) IsAvailable(ctx context.Context) bool
func (*ClusterSnapshotter) Stop ¶
func (c *ClusterSnapshotter) Stop() error
type NamespaceResourceExtractorFunc ¶
type NamespaceResourceExtractorFunc func(*gen.Namespace) map[string]*gen.ResourceIdentifier
NamespaceResourceExtractorFunc extracts a resource map from namespace snapshot
type NamespacedResourceHandler ¶
type NamespacedResourceHandler struct {
Lister NamespacedResourceListFunc
Extractor ResourceExtractorFunc
SnapshotExtractor NamespaceResourceExtractorFunc
}
NamespacedResourceHandler combines a namespaced lister and extractor for a resource type
type NamespacedResourceListFunc ¶
type NamespacedResourceListFunc func(ctx context.Context, namespace string, options metav1.ListOptions) (runtime.Object, error)
NamespacedResourceListFunc defines a function type for listing namespaced resources by UID
type ResourceExtractorFunc ¶
ResourceExtractorFunc defines a function type for extracting first item from a list
type ResourceHandler ¶
type ResourceHandler struct {
Lister ResourceListFunc
Extractor ResourceExtractorFunc
SnapshotExtractor ClusterResourceExtractorFunc
}
ResourceHandler combines a lister and extractor for a resource type
type ResourceIdentifier ¶
type ResourceIdentifier = gen.ResourceIdentifier
aliases for proto types to maintain compatibility for now
type ResourceListFunc ¶
ResourceListFunc defines a function type for listing resources by UID
Source Files