provider

Documentation

Overview

Package provider contains methods implementing virtual-kubelet provider

Index

• type InitConfig
• type LiqoProvider
  • func NewLiqoProvider(ctx context.Context, cfg *InitConfig, eb record.EventBroadcaster) (*LiqoProvider, error)
  • func (p *LiqoProvider) PodHandler() workload.PodHandler
  • func (p *LiqoProvider) Resync() error

Types

type InitConfig

type InitConfig struct {
	LocalConfig   *rest.Config
	RemoteConfig  *rest.Config
	LocalCluster  liqov1beta1.ClusterID
	RemoteCluster liqov1beta1.ClusterID
	Namespace     string
	LiqoNamespace string

	NodeName             string
	NodeIP               string
	DisableIPReflection  bool
	LocalPodCIDR         string
	InformerResyncPeriod time.Duration

	ReflectorsConfigs map[resources.ResourceReflected]offloadingv1beta1.ReflectorConfig

	EnableAPIServerSupport          bool
	EnableStorage                   bool
	VirtualStorageClassName         string
	RemoteRealStorageClassName      string
	EnableIngress                   bool
	RemoteRealIngressClassName      string
	EnableLoadBalancer              bool
	RemoteRealLoadBalancerClassName string
	EnableMetrics                   bool

	HomeAPIServerHost string
	HomeAPIServerPort string

	OffloadingPatch *offloadingv1beta1.OffloadingPatch

	NetConfiguration *networkingv1beta1.Configuration // only available if network module is enabled
}

InitConfig is the config passed to initialize the LiqoPodProvider.

type LiqoProvider

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

LiqoProvider implements the virtual-kubelet provider interface and stores pods in memory.

func NewLiqoProvider

func NewLiqoProvider(ctx context.Context, cfg *InitConfig, eb record.EventBroadcaster) (*LiqoProvider, error)

NewLiqoProvider creates a new NewLiqoProvider instance.

func (*LiqoProvider) PodHandler

func (p *LiqoProvider) PodHandler() workload.PodHandler

PodHandler returns an handler to interact with the pods offloaded to the remote cluster.

func (*LiqoProvider) Resync

func (p *LiqoProvider) Resync() error

Resync force the resync of all informers contained in the reflection manager.