node

Documentation

Index

• Variables
• type Node
  • func NewCollector(sampleInterval int64) Node
  • func (n *Node) Get()
  • func (n *Node) Query(node string) ([]byte, error)
  • func (n *Node) SetMetrics(nodeName string, availableBytes float64, capacityBytes float64)
  • func (n *Node) Watch()

Variables

var (
	AdjustedPollingRateGaugeVec *prometheus.GaugeVec
)

Types

type Node

type Node struct {
	AdjustedPollingRate bool

	MaxNodeQueryConcurrency int

	Set             mapset.Set[string]
	KubeletEndpoint *sync.Map // key=nodeName val=kubeletEndpoint
	WaitGroup       *sync.WaitGroup
	// contains filtered or unexported fields
}

func NewCollector

func NewCollector(sampleInterval int64) Node

func (*Node) Get

func (n *Node) Get()

func (*Node) Query

func (n *Node) Query(node string) ([]byte, error)

func (*Node) SetMetrics

func (n *Node) SetMetrics(nodeName string, availableBytes float64, capacityBytes float64)

func (*Node) Watch

func (n *Node) Watch()