Documentation
¶
Index ¶
- func CollectGarbage(ctx context.Context, queries *queries.Queries, ...) error
- func StartGarbageCollector(ctx context.Context, queries *queries.Queries, ...)
- func StartScraper(ctx context.Context, queries *queries.Queries, clientSet *kubernetes.Clientset, ...) error
- func WithTransaction(ctx context.Context, conn *pgx.Conn, f func(tx pgx.Tx) error) error
- type Manager
- type NodeEventHandler
- type NodeScraper
- type PersistObjectHandler
- type PodCache
- type PodCacheK8s
- type PodLister
- type PodNamespaceLister
- type ScrapeFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CollectGarbage ¶
func StartGarbageCollector ¶
func StartScraper ¶
Types ¶
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
func (*Manager) AddTarget ¶
func (m *Manager) AddTarget(id string, scrapeFunc ScrapeFunc, interval time.Duration)
func (*Manager) RemoveTarget ¶
type NodeEventHandler ¶
type NodeEventHandler struct {
// contains filtered or unexported fields
}
func NewNodeEventHandler ¶
func NewNodeEventHandler( manager *Manager, k8sClient k8s.ClientInterface, queries *queries.Queries, interval time.Duration, cache PodCache, ) *NodeEventHandler
func (*NodeEventHandler) OnAdd ¶
func (h *NodeEventHandler) OnAdd(obj interface{}, isInInitialList bool)
func (*NodeEventHandler) OnDelete ¶
func (h *NodeEventHandler) OnDelete(obj interface{})
func (*NodeEventHandler) OnUpdate ¶
func (h *NodeEventHandler) OnUpdate(oldObj, obj interface{})
type NodeScraper ¶
type NodeScraper struct {
// contains filtered or unexported fields
}
func NewNodeScrapper ¶
func NewNodeScrapper(name string, k8sClients k8s.ClientInterface, queries *queries.Queries, cache PodCache) *NodeScraper
type PersistObjectHandler ¶
type PersistObjectHandler struct {
// contains filtered or unexported fields
}
func NewPersistObjectHandler ¶
func NewPersistObjectHandler(queries *queries.Queries, kind string) *PersistObjectHandler
func (*PersistObjectHandler) OnAdd ¶
func (h *PersistObjectHandler) OnAdd(obj interface{}, isInInitialList bool)
func (*PersistObjectHandler) OnDelete ¶
func (h *PersistObjectHandler) OnDelete(obj interface{})
func (*PersistObjectHandler) OnUpdate ¶
func (h *PersistObjectHandler) OnUpdate(oldObj, newObj interface{})
func (*PersistObjectHandler) Upsert ¶
func (h *PersistObjectHandler) Upsert(obj interface{})
type PodCacheK8s ¶
type PodCacheK8s struct {
// contains filtered or unexported fields
}
PodCacheK8s is a wrapper around listerv1.PodLister original client is hard to mock wrapper provides an easier to use interface
func NewPodCacheK8s ¶
func NewPodCacheK8s(lister listerv1.PodLister) *PodCacheK8s
type PodNamespaceLister ¶
type PodNamespaceLister listerv1.PodNamespaceLister
type ScrapeFunc ¶
Source Files
Click to show internal directories.
Click to hide internal directories.