core

Documentation

Index

• Variables
• func CreateRegisterScheme() *runtime.Scheme
• func GenKubeSchedulerConfiguration(targetPath string, kubeConfigPath string, poolSize int) error
• func LoadAndCleanObj(objPath string) (obj *unstructured.Unstructured, err error)
• func NewShootCopierFromConfig(copyCfg api.CopierConfig) (copier api.ShootCopier, err error)
• func RegisterToScheme(scheme *runtime.Scheme) *runtime.Scheme
• func ValidateGVRs(groupResources []*restmapper.APIGroupResources, ...) error
• type GardenerShootCopier
  • func (g *GardenerShootCopier) DownloadObjects(ctx context.Context, baseObjDir string, gvrList []schema.GroupVersionResource) error
  • func (g *GardenerShootCopier) GetClient() dynamic.Interface
  • func (g *GardenerShootCopier) GetConfig() api.CopierConfig
  • func (g *GardenerShootCopier) GetSeedCoordinate() api.ShootCoords
  • func (g *GardenerShootCopier) GetShootCoordinate() api.ShootCoords
  • func (g *GardenerShootCopier) UploadObjects(ctx context.Context, baseObjDir string) (err error)
• type KindUploader
  • func (u *KindUploader) UploadAsync(ctx context.Context, taskGroup pond.TaskGroup, obj *unstructured.Unstructured)
• type KubeSchedulerTmplParams

Variables

var (
	SupportedScheme      = CreateRegisterScheme()
	APIResourcesFilename = "api-resources.yaml"
)

Functions

func CreateRegisterScheme

func CreateRegisterScheme() *runtime.Scheme

func GenKubeSchedulerConfiguration

func GenKubeSchedulerConfiguration(targetPath string, kubeConfigPath string, poolSize int) error

func LoadAndCleanObj

func LoadAndCleanObj(objPath string) (obj *unstructured.Unstructured, err error)

func NewShootCopierFromConfig

func NewShootCopierFromConfig(copyCfg api.CopierConfig) (copier api.ShootCopier, err error)

func RegisterToScheme

func RegisterToScheme(scheme *runtime.Scheme) *runtime.Scheme

func ValidateGVRs

func ValidateGVRs(groupResources []*restmapper.APIGroupResources, gvrs []schema.GroupVersionResource) error

Types

type GardenerShootCopier

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

func (*GardenerShootCopier) DownloadObjects

func (g *GardenerShootCopier) DownloadObjects(ctx context.Context, baseObjDir string, gvrList []schema.GroupVersionResource) error

func (*GardenerShootCopier) GetClient

func (g *GardenerShootCopier) GetClient() dynamic.Interface

func (*GardenerShootCopier) GetConfig

func (g *GardenerShootCopier) GetConfig() api.CopierConfig

func (*GardenerShootCopier) GetSeedCoordinate

func (g *GardenerShootCopier) GetSeedCoordinate() api.ShootCoords

func (*GardenerShootCopier) GetShootCoordinate

func (g *GardenerShootCopier) GetShootCoordinate() api.ShootCoords

func (*GardenerShootCopier) UploadObjects

func (g *GardenerShootCopier) UploadObjects(ctx context.Context, baseObjDir string) (err error)

type KindUploader

type KindUploader struct {
	GVK            schema.GroupVersionKind
	GVR            schema.GroupVersionResource
	ResourceFacade dynamic.NamespaceableResourceInterface
	Counter        *atomic.Uint32
}

func (*KindUploader) UploadAsync

func (u *KindUploader) UploadAsync(ctx context.Context, taskGroup pond.TaskGroup, obj *unstructured.Unstructured)

type KubeSchedulerTmplParams

type KubeSchedulerTmplParams struct {
	KubeConfigPath string
	QPS            float32
	Burst          int
}