kind

Documentation

Index

• Variables
• func ClusterExists(ctx context.Context, client ssh.Client, name string) (bool, error)
• func GetClusterContainerNames(ctx context.Context, client ssh.Client, clusterName string) ([]string, error)
• func GetClusters(ctx context.Context, client ssh.Client) ([]string, error)
• func NewPlatform() platform.Platform
• type ConfigParams
• type Platform
  • func (s *Platform) ActiveChanged(ctx context.Context, platformActive bool) error
  • func (s *Platform) ChangeClusterInstDNS(ctx context.Context, clusterInst *edgeproto.ClusterInst, oldFqdn string, ...) error
  • func (s *Platform) CreateClusterInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, ...) error
  • func (s *Platform) CreateKINDCluster(ctx context.Context, clusterInst *edgeproto.ClusterInst) error
  • func (s *Platform) DeleteClusterInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, ...) error
  • func (s *Platform) DeleteKINDCluster(ctx context.Context, clusterInst *edgeproto.ClusterInst) error
  • func (s *Platform) GetDockerNetworkName(ctx context.Context, names *k8smgmt.KubeNames) (string, error)
  • func (s *Platform) GetFeatures() *edgeproto.PlatformFeatures
  • func (s *Platform) GetInitHAConditionalCompatibilityVersion(ctx context.Context) string
  • func (s *Platform) GetMasterIp(ctx context.Context, names *k8smgmt.KubeNames) (string, error)
  • func (s *Platform) InitCommon(ctx context.Context, platformConfig *platform.PlatformConfig, ...) error
  • func (s *Platform) InitHAConditional(ctx context.Context, updateCallback edgeproto.CacheUpdateCallback) error
  • func (s *Platform) NameSanitize(name string) string
  • func (s *Platform) UpdateClusterInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, ...) error

Variables

var ConfigTemplate = `` /* 240-byte string literal not displayed */

var DefaultNodeImage = "kindest/node:v1.26.6@sha256:6e2d8b28a5b601defe327b98bd1c2d1930b49e5d8c512e1895099e4504007adb"

See https://hub.docker.com/r/kindest/node/tags for all available versions Use env var KIND_IMAGE to override default below. NOTE: image digest is required, otherwise the image pulled will be for the latest version of KIND Below is for KIND v0.20.0

Functions

func ClusterExists

func ClusterExists(ctx context.Context, client ssh.Client, name string) (bool, error)

func GetClusterContainerNames

func GetClusterContainerNames(ctx context.Context, client ssh.Client, clusterName string) ([]string, error)

func GetClusters

func GetClusters(ctx context.Context, client ssh.Client) ([]string, error)

func NewPlatform

func NewPlatform() platform.Platform

Types

type ConfigParams

type ConfigParams struct {
	Image      string
	NumMasters []struct{}
	NumNodes   []struct{}
}

type Platform

type Platform struct {
	xind.Xind
}

func (*Platform) ActiveChanged

func (s *Platform) ActiveChanged(ctx context.Context, platformActive bool) error

func (*Platform) ChangeClusterInstDNS

func (s *Platform) ChangeClusterInstDNS(ctx context.Context, clusterInst *edgeproto.ClusterInst, oldFqdn string, updateCallback edgeproto.CacheUpdateCallback) error

func (*Platform) CreateClusterInst

func (s *Platform) CreateClusterInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, updateCallback edgeproto.CacheUpdateCallback, timeout time.Duration) error

func (*Platform) CreateKINDCluster

func (s *Platform) CreateKINDCluster(ctx context.Context, clusterInst *edgeproto.ClusterInst) error

func (*Platform) DeleteClusterInst

func (s *Platform) DeleteClusterInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, updateCallback edgeproto.CacheUpdateCallback) error

func (*Platform) DeleteKINDCluster

func (s *Platform) DeleteKINDCluster(ctx context.Context, clusterInst *edgeproto.ClusterInst) error

func (*Platform) GetDockerNetworkName

func (s *Platform) GetDockerNetworkName(ctx context.Context, names *k8smgmt.KubeNames) (string, error)

func (*Platform) GetFeatures

func (s *Platform) GetFeatures() *edgeproto.PlatformFeatures

func (*Platform) GetInitHAConditionalCompatibilityVersion

func (s *Platform) GetInitHAConditionalCompatibilityVersion(ctx context.Context) string

func (*Platform) GetMasterIp

func (s *Platform) GetMasterIp(ctx context.Context, names *k8smgmt.KubeNames) (string, error)

func (*Platform) InitCommon

func (s *Platform) InitCommon(ctx context.Context, platformConfig *platform.PlatformConfig, caches *platform.Caches, haMgr *redundancy.HighAvailabilityManager, updateCallback edgeproto.CacheUpdateCallback) error

func (*Platform) InitHAConditional

func (s *Platform) InitHAConditional(ctx context.Context, updateCallback edgeproto.CacheUpdateCallback) error

func (*Platform) NameSanitize

func (s *Platform) NameSanitize(name string) string

func (*Platform) UpdateClusterInst

func (s *Platform) UpdateClusterInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, updateCallback edgeproto.CacheUpdateCallback) error