cilium

Documentation

Index

• func ChangeDiff(currentSpec, newSpec *cluster.Spec) *types.ChangeDiff
• type Cilium
  • func NewCilium(client Client, helm Helm) *Cilium
  • func (c *Cilium) GenerateManifest(ctx context.Context, clusterSpec *cluster.Spec, providerNamespaces []string) ([]byte, error)
• type Client
• type Helm
• type Templater
  • func NewTemplater(helm Helm) *Templater
  • func (c *Templater) GenerateManifest(ctx context.Context, spec *cluster.Spec) ([]byte, error)
  • func (c *Templater) GenerateNetworkPolicyManifest(spec *cluster.Spec, namespaces []string) ([]byte, error)
  • func (c *Templater) GenerateUpgradeManifest(ctx context.Context, currentSpec, newSpec *cluster.Spec) ([]byte, error)
  • func (c *Templater) GenerateUpgradePreflightManifest(ctx context.Context, spec *cluster.Spec) ([]byte, error)
• type Upgrader
  • func NewUpgrader(client Client, helm Helm) *Upgrader
  • func (u *Upgrader) RunPostControlPlaneUpgradeSetup(ctx context.Context, cluster *types.Cluster) error
  • func (u *Upgrader) Upgrade(ctx context.Context, cluster *types.Cluster, ...) (*types.ChangeDiff, error)

Functions

func ChangeDiff

func ChangeDiff(currentSpec, newSpec *cluster.Spec) *types.ChangeDiff

Types

type Cilium

type Cilium struct {
	*Upgrader
}

func NewCilium

func NewCilium(client Client, helm Helm) *Cilium

func (*Cilium) GenerateManifest

func (c *Cilium) GenerateManifest(ctx context.Context, clusterSpec *cluster.Spec, providerNamespaces []string) ([]byte, error)

type Client

type Client interface {
	ApplyKubeSpecFromBytes(ctx context.Context, cluster *types.Cluster, data []byte) error
	DeleteKubeSpecFromBytes(ctx context.Context, cluster *types.Cluster, data []byte) error
	GetDaemonSet(ctx context.Context, name, namespace, kubeconfig string) (*v1.DaemonSet, error)
	GetDeployment(ctx context.Context, name, namespace, kubeconfig string) (*v1.Deployment, error)
	RolloutRestartDaemonSet(ctx context.Context, name, namespace, kubeconfig string) error
}

type Helm

type Helm interface {
	Template(ctx context.Context, ociURI, version, namespace string, values interface{}, kubeVersion string) ([]byte, error)
}

type Templater

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

func NewTemplater

func NewTemplater(helm Helm) *Templater

func (*Templater) GenerateManifest

func (c *Templater) GenerateManifest(ctx context.Context, spec *cluster.Spec) ([]byte, error)

func (*Templater) GenerateNetworkPolicyManifest

func (c *Templater) GenerateNetworkPolicyManifest(spec *cluster.Spec, namespaces []string) ([]byte, error)

func (*Templater) GenerateUpgradeManifest

func (c *Templater) GenerateUpgradeManifest(ctx context.Context, currentSpec, newSpec *cluster.Spec) ([]byte, error)

func (*Templater) GenerateUpgradePreflightManifest

func (c *Templater) GenerateUpgradePreflightManifest(ctx context.Context, spec *cluster.Spec) ([]byte, error)

type Upgrader

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

func NewUpgrader

func NewUpgrader(client Client, helm Helm) *Upgrader

func (*Upgrader) RunPostControlPlaneUpgradeSetup

func (u *Upgrader) RunPostControlPlaneUpgradeSetup(ctx context.Context, cluster *types.Cluster) error

func (*Upgrader) Upgrade

func (u *Upgrader) Upgrade(ctx context.Context, cluster *types.Cluster, currentSpec, newSpec *cluster.Spec, namespaces []string) (*types.ChangeDiff, error)