allocation

Documentation

Index

• Variables
• func GetRegisteredAllocatorNames() []string
• func MakeNCollectors(n int, startingIndex int) map[string]*Collector
• func MakeNNewTargets(n int, numCollectors int, startingIndex int) map[string]*target.Item
• func MakeNNewTargetsWithEmptyCollectors(n int, startingIndex int) map[string]*target.Item
• func RecordTargetsKept(targets map[string]*target.Item)
• func Register(name string, provider AllocatorProvider) error
• type AllocationOption
  • func WithFilter(filter Filter) AllocationOption
• type Allocator
  • func New(name string, log logr.Logger, opts ...AllocationOption) (Allocator, error)
• type AllocatorProvider
• type Collector
  • func NewCollector(name, node string) *Collector
  • func (c Collector) Hash() string
  • func (c Collector) String() string
• type Filter

Variables

var (

	// TargetsPerCollector records how many targets have been assigned to each collector.
	// It is currently the responsibility of the strategy to track this information.
	TargetsPerCollector = promauto.NewGaugeVec(prometheus.GaugeOpts{
		Name: "opentelemetry_allocator_targets_per_collector",
		Help: "The number of targets for each collector.",
	}, []string{"collector_name", "strategy"})
	CollectorsAllocatable = promauto.NewGaugeVec(prometheus.GaugeOpts{
		Name: "opentelemetry_allocator_collectors_allocatable",
		Help: "Number of collectors the allocator is able to allocate to.",
	}, []string{"strategy"})
	TimeToAssign = promauto.NewHistogramVec(prometheus.HistogramOpts{
		Name: "opentelemetry_allocator_time_to_allocate",
		Help: "The time it takes to allocate",
	}, []string{"method", "strategy"})

	TargetsUnassigned = promauto.NewGauge(prometheus.GaugeOpts{
		Name: "opentelemetry_allocator_targets_unassigned",
		Help: "Number of targets that could not be assigned due to missing node label.",
	})
)

Functions

func GetRegisteredAllocatorNames

func GetRegisteredAllocatorNames() []string

func MakeNCollectors

func MakeNCollectors(n int, startingIndex int) map[string]*Collector

func MakeNNewTargets

func MakeNNewTargets(n int, numCollectors int, startingIndex int) map[string]*target.Item

func MakeNNewTargetsWithEmptyCollectors

func MakeNNewTargetsWithEmptyCollectors(n int, startingIndex int) map[string]*target.Item

func RecordTargetsKept

func RecordTargetsKept(targets map[string]*target.Item)

func Register

func Register(name string, provider AllocatorProvider) error

Types

type AllocationOption

type AllocationOption func(Allocator)

func WithFilter

func WithFilter(filter Filter) AllocationOption

type Allocator

type Allocator interface {
	SetCollectors(collectors map[string]*Collector)
	SetTargets(targets map[string]*target.Item)
	TargetItems() map[string]*target.Item
	Collectors() map[string]*Collector
	GetTargetsForCollectorAndJob(collector string, job string) []*target.Item
	SetFilter(filter Filter)
}

func New

func New(name string, log logr.Logger, opts ...AllocationOption) (Allocator, error)

type AllocatorProvider

type AllocatorProvider func(log logr.Logger, opts ...AllocationOption) Allocator

type Collector

type Collector struct {
	Name       string
	NodeName   string
	NumTargets int
}

Collector Creates a struct that holds Collector information. This struct will be parsed into endpoint with Collector and jobs info. This struct can be extended with information like annotations and labels in the future.

func NewCollector

func NewCollector(name, node string) *Collector

func (Collector) Hash

func (c Collector) Hash() string

func (Collector) String

func (c Collector) String() string

type Filter

type Filter interface {
	Apply(map[string]*target.Item) map[string]*target.Item
}