sublet

Documentation

Index

• type Config
• type NodeController
  • func NewNodeController(conf NodeControllerConfig) (*NodeController, error)
  • func (s *NodeController) Start(ctx context.Context) error
  • func (s *NodeController) SyncNodeFromSource(ctx context.Context, node *corev1.Node) error
• type NodeControllerConfig
• type PodController
  • func NewPodController(conf PodControllerConfig) (*PodController, error)
  • func (s *PodController) DeletePodFromSource(ctx context.Context, srcPod *corev1.Pod) error
  • func (s *PodController) DeletePodToSource(ctx context.Context, pod *corev1.Pod) (err error)
  • func (s *PodController) Start(ctx context.Context) error
  • func (s *PodController) SyncPodStatusFromSource(ctx context.Context, srcPod *corev1.Pod) error
  • func (s *PodController) SyncPodToSource(ctx context.Context, pod *corev1.Pod) error
• type PodControllerConfig
• type Sublet
  • func NewSublet(conf Config) (*Sublet, error)
  • func (s *Sublet) Start(ctx context.Context) error

Types

type Config

type Config struct {
	SubclusterName  string
	NodeName        string
	Client          kubernetes.Interface
	SourceNodeName  string
	SourceClient    kubernetes.Interface
	SourceNamespace string
	DnsServers      []string
	DnsSearches     []string
}

type NodeController

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

func NewNodeController

func NewNodeController(conf NodeControllerConfig) (*NodeController, error)

func (*NodeController) Start

func (s *NodeController) Start(ctx context.Context) error

func (*NodeController) SyncNodeFromSource

func (s *NodeController) SyncNodeFromSource(ctx context.Context, node *corev1.Node) error

type NodeControllerConfig

type NodeControllerConfig struct {
	NodeName       string
	Client         kubernetes.Interface
	SourceNodeName string
	SourceClient   kubernetes.Interface
}

type PodController

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

func NewPodController

func NewPodController(conf PodControllerConfig) (*PodController, error)

func (*PodController) DeletePodFromSource

func (s *PodController) DeletePodFromSource(ctx context.Context, srcPod *corev1.Pod) error

func (*PodController) DeletePodToSource

func (s *PodController) DeletePodToSource(ctx context.Context, pod *corev1.Pod) (err error)

DeletePodToSource deletes the specified pod out of memory.

func (*PodController) Start

func (s *PodController) Start(ctx context.Context) error

func (*PodController) SyncPodStatusFromSource

func (s *PodController) SyncPodStatusFromSource(ctx context.Context, srcPod *corev1.Pod) error

func (*PodController) SyncPodToSource

func (s *PodController) SyncPodToSource(ctx context.Context, pod *corev1.Pod) error

type PodControllerConfig

type PodControllerConfig struct {
	SubclusterName  string
	NodeName        string
	Client          kubernetes.Interface
	SourceNodeName  string
	SourceClient    kubernetes.Interface
	SourceNamespace string
	DnsServers      []string
	DnsSearches     []string
}

type Sublet

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

func NewSublet

func NewSublet(conf Config) (*Sublet, error)

func (*Sublet) Start

func (s *Sublet) Start(ctx context.Context) error