manager

Documentation

Index

• Variables
• func ComputeTolerationsFromNodes(nodes map[string]*Node) []map[string]interface{}
• type ClusterManager
  • func New(ctx *program.Context, nodes map[string]*Node) *ClusterManager
  • func (m *ClusterManager) ManageTaints(node *Node) error
  • func (m *ClusterManager) Nodes() map[string]*Node
  • func (m *ClusterManager) Resources() []pulumi.Resource
  • func (m *ClusterManager) Up(kubeconfig pulumi.AnyOutput, provider *kubernetes.Provider) error
  • func (m *ClusterManager) ValidateNodePatches() error
• type Node

Variables

var AllowedTaintsEffects = []string{"NoSchedule", "NoExecute", "PreferNoSchedule"}

var DefaultTaints = map[string][]string{
	variables.ServerRole: {

		"CriticalAddonsOnly=true:NoExecute",
		"node-role.kubernetes.io/control-plane:NoSchedule",
	},
}

Functions

func ComputeTolerationsFromNodes

func ComputeTolerationsFromNodes(nodes map[string]*Node) []map[string]interface{}

Types

type ClusterManager

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

func New

func New(ctx *program.Context, nodes map[string]*Node) *ClusterManager

func (*ClusterManager) ManageTaints

func (m *ClusterManager) ManageTaints(node *Node) error

func (*ClusterManager) Nodes

func (m *ClusterManager) Nodes() map[string]*Node

func (*ClusterManager) Resources

func (m *ClusterManager) Resources() []pulumi.Resource

func (*ClusterManager) Up

func (m *ClusterManager) Up(kubeconfig pulumi.AnyOutput, provider *kubernetes.Provider) error

func (*ClusterManager) ValidateNodePatches

func (m *ClusterManager) ValidateNodePatches() error

type Node

type Node struct {
	ID     string
	Taints []string
	Labels []string
}

Node is a representation of kubernetes node. Used for keeping node taints and labels updated.