utils

Documentation

Index

• func GetNodeObject(clientset *kubernetes.Clientset, hostnameOverride string) (*apiv1.Node, error)
• func GetPodCidrFromCniSpec(cniConfFilePath string) (net.IPNet, error)
• func GetPodCidrFromNodeSpec(clientset *kubernetes.Clientset, hostnameOverride string) (string, error)
• func InsertPodCidrInCniSpec(cniConfFilePath string, cidr string) error
• type Broadcaster
  • func NewBroadcaster() *Broadcaster
  • func (b *Broadcaster) Add(listener Listener)
  • func (b *Broadcaster) Notify(instance interface{})
• type Listener
• type ListenerFunc
  • func (f ListenerFunc) OnUpdate(instance interface{})

Functions

func GetNodeObject

func GetNodeObject(clientset *kubernetes.Clientset, hostnameOverride string) (*apiv1.Node, error)

func GetPodCidrFromCniSpec

func GetPodCidrFromCniSpec(cniConfFilePath string) (net.IPNet, error)

func GetPodCidrFromNodeSpec

func GetPodCidrFromNodeSpec(clientset *kubernetes.Clientset, hostnameOverride string) (string, error)

func InsertPodCidrInCniSpec

func InsertPodCidrInCniSpec(cniConfFilePath string, cidr string) error

Types

type Broadcaster

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

func NewBroadcaster

func NewBroadcaster() *Broadcaster

func (*Broadcaster) Add

func (b *Broadcaster) Add(listener Listener)

func (*Broadcaster) Notify

func (b *Broadcaster) Notify(instance interface{})

type Listener

type Listener interface {
	OnUpdate(instance interface{})
}

type ListenerFunc

type ListenerFunc func(instance interface{})

func (ListenerFunc) OnUpdate

func (f ListenerFunc) OnUpdate(instance interface{})