node_observer

Documentation

Index

• type Config
  • func NewConfigFromFile(fname string) (*Config, error)
• type Controller
  • func NewController(ctx context.Context, client kubernetes.Interface, cfg *Config) (*Controller, error)
  • func (c *Controller) Start() error
  • func (c *Controller) Stop(err error)
• type NodeInformer
  • func NewNodeInformer(ctx context.Context, client kubernetes.Interface, nodeLabels map[string]string, ...) *NodeInformer
  • func (n *NodeInformer) SendRequest()
  • func (n *NodeInformer) Start() error
  • func (n *NodeInformer) Stop(_ error)
• type TopologyConfigmap

Types

type Config

type Config struct {
	TopologyGeneratorURL string            `yaml:"topology_generator_url"`
	TopologyConfigmap    TopologyConfigmap `yaml:"topology_configmap"`
	NodeLabels           map[string]string `yaml:"node_labels"`
	Provider             string            `yaml:"provider"`
	Engine               string            `yaml:"engine"`
}

func NewConfigFromFile

func NewConfigFromFile(fname string) (*Config, error)

type Controller

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

func NewController

func NewController(ctx context.Context, client kubernetes.Interface, cfg *Config) (*Controller, error)

func (*Controller) Start

func (c *Controller) Start() error

func (*Controller) Stop

func (c *Controller) Stop(err error)

type NodeInformer

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

func NewNodeInformer

func NewNodeInformer(ctx context.Context, client kubernetes.Interface, nodeLabels map[string]string, reqFunc httpreq.RequestFunc) *NodeInformer

func (*NodeInformer) SendRequest

func (n *NodeInformer) SendRequest()

func (*NodeInformer) Start

func (n *NodeInformer) Start() error

func (*NodeInformer) Stop

func (n *NodeInformer) Stop(_ error)

type TopologyConfigmap

type TopologyConfigmap struct {
	Name      string `yaml:"name"`
	Namespace string `yaml:"namespace"`
	Filename  string `yaml:"filename"`
}