controller

Documentation

Index

• Variables
• type NodesInformer
  • func NewNodesInformer() NodesInformer
• type NodesMap
  • func (n *NodesMap) GetNode(nodeName string) (*usage.NodeInfo, bool)
  • func (n *NodesMap) Load(ctx context.Context, log *logrus.Entry, cluster string, ...) (chan bool, error)
• type Scanner
  • func New(log *logrus.Entry, client *kubernetes.Clientset, uploader firehose.Uploader, ...) Scanner

Variables

var (
	// ErrCacheSync is returned when the cache fails to sync
	ErrCacheSync = errors.New("failed to sync cache")
)

Types

type NodesInformer

type NodesInformer interface {
	Load(ctx context.Context, log *logrus.Entry, cluster string, clientset kubernetes.Interface) (chan bool, error)
	GetNode(nodeName string) (*usage.NodeInfo, bool)
}

func NewNodesInformer

func NewNodesInformer() NodesInformer

type NodesMap

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

func (*NodesMap) GetNode

func (n *NodesMap) GetNode(nodeName string) (*usage.NodeInfo, bool)

func (*NodesMap) Load

func (n *NodesMap) Load(ctx context.Context, log *logrus.Entry, cluster string, clientset kubernetes.Interface) (chan bool, error)

Load loads the NodesMap with the current nodes in the cluster return channel to signal when the map is loaded

type Scanner

type Scanner interface {
	Run(ctx context.Context) error
}

func New

func New(log *logrus.Entry, client *kubernetes.Clientset, uploader firehose.Uploader, informer NodesInformer) Scanner