nodes

Documentation

Index

• Constants
• type Deleter
  • func NewDeleter(masterNodes, workerNodes []string, cluster *pb.K8Scluster) *Deleter
  • func (d *Deleter) DeleteNodes() (*pb.K8Scluster, error)
• type K8sList
• type LonghornReplica
• type LonghornVolume
• type Metadata
• type MetadataAnnotations
• type PatchAnnotations
• type Patcher
  • func NewPatcher(cluster *pb.K8Scluster, logger zerolog.Logger) *Patcher
  • func (p *Patcher) PatchAnnotations() error
  • func (p *Patcher) PatchLabels() error
  • func (p *Patcher) PatchProviderID() error
  • func (p *Patcher) PatchTaints() error
• type ReplicaSpec
• type Status
• type VolumeSpec

Constants

const (
	ProviderIdFormat = "claudie://%s"
)

Types

type Deleter

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

func NewDeleter

func NewDeleter(masterNodes, workerNodes []string, cluster *pb.K8Scluster) *Deleter

New returns new Deleter struct, used for node deletion from a k8s cluster masterNodes - master nodes to DELETE workerNodes - worker nodes to DELETE

func (*Deleter) DeleteNodes

func (d *Deleter) DeleteNodes() (*pb.K8Scluster, error)

DeleteNodes deletes nodes specified in d.masterNodes and d.workerNodes return nil if successful, error otherwise

type K8sList

type K8sList[T any] struct {
	Items []T `yaml:"items"`
}

type LonghornReplica

type LonghornReplica struct {
	Metadata Metadata    `yaml:"metadata"`
	Status   Status      `yaml:"status"`
	Spec     ReplicaSpec `yaml:"spec"`
}

type LonghornVolume

type LonghornVolume struct {
	Metadata Metadata   `yaml:"metadata"`
	Spec     VolumeSpec `yaml:"spec"`
}

type Metadata

type Metadata struct {
	Name string `yaml:"name"`
}

type MetadataAnnotations

type MetadataAnnotations struct {
	Annotations map[string]string `json:"annotations"`
}

type PatchAnnotations

type PatchAnnotations struct {
	MetadataAnnotations `json:"metadata"`
}

type Patcher

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

func NewPatcher

func NewPatcher(cluster *pb.K8Scluster, logger zerolog.Logger) *Patcher

func (*Patcher) PatchAnnotations

func (p *Patcher) PatchAnnotations() error

func (*Patcher) PatchLabels

func (p *Patcher) PatchLabels() error

func (*Patcher) PatchProviderID

func (p *Patcher) PatchProviderID() error

func (*Patcher) PatchTaints

func (p *Patcher) PatchTaints() error

type ReplicaSpec

type ReplicaSpec struct {
	VolumeName string `yaml:"volumeName"`
}

type Status

type Status struct {
	OwnerID      string `yaml:"ownerID"`
	CurrentState string `yaml:"currentState"`
	Started      bool   `yaml:"started"`
}

type VolumeSpec

type VolumeSpec struct {
	NumberOfReplicas int `yaml:"numberOfReplicas"`
}