pod_provider

Documentation

Index

• type RuntimeInfoStore
  • func NewRuntimeInfoStore() *RuntimeInfoStore
  • func (r *RuntimeInfoStore) ClearContainerStatus(containerKey string)
  • func (r *RuntimeInfoStore) DeletePod(podKey string, t tunnel.Tunnel)
  • func (r *RuntimeInfoStore) GetContainer(containerKey string) *corev1.Container
  • func (r *RuntimeInfoStore) GetLatestContainerInfoByContainerKey(containerKey string) *model.ContainerStatusData
  • func (r *RuntimeInfoStore) GetLatestContainerInfos() []*model.ContainerStatusData
  • func (r *RuntimeInfoStore) GetPodByKey(podKey string) *corev1.Pod
  • func (r *RuntimeInfoStore) GetPods() []*corev1.Pod
  • func (r *RuntimeInfoStore) GetRelatedPodKeysByContainerKey(containerKey string) []string
  • func (r *RuntimeInfoStore) PutContainerStatus(containerInfo model.ContainerStatusData) (updated bool)
  • func (r *RuntimeInfoStore) PutPod(pod *corev1.Pod, t tunnel.Tunnel)
• type VPodProvider
  • func NewVPodProvider(namespace, localIP, nodeID string, client client.Client, t tunnel.Tunnel) *VPodProvider
  • func (b *VPodProvider) CreatePod(ctx context.Context, pod *corev1.Pod) error
  • func (b *VPodProvider) DeletePod(ctx context.Context, pod *corev1.Pod) error
  • func (b *VPodProvider) GetPod(_ context.Context, namespace, name string) (*corev1.Pod, error)
  • func (b *VPodProvider) GetPodStatus(ctx context.Context, namespace, name string) (*corev1.PodStatus, error)
  • func (b *VPodProvider) GetPods(_ context.Context) ([]*corev1.Pod, error)
  • func (b *VPodProvider) InitContainerInfo(info model.ContainerStatusData)
  • func (b *VPodProvider) NotifyPods(_ context.Context, cb func(*corev1.Pod))
  • func (b *VPodProvider) SyncAllContainerInfo(ctx context.Context, containerInfos []model.ContainerStatusData)
  • func (b *VPodProvider) SyncOneContainerInfo(ctx context.Context, containerInfo model.ContainerStatusData)
  • func (b *VPodProvider) UpdatePod(ctx context.Context, pod *corev1.Pod) error

Types

type RuntimeInfoStore

type RuntimeInfoStore struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

RuntimeInfoStore provide the in memory runtime information.

func NewRuntimeInfoStore

func NewRuntimeInfoStore() *RuntimeInfoStore

func (*RuntimeInfoStore) ClearContainerStatus

func (r *RuntimeInfoStore) ClearContainerStatus(containerKey string)

func (*RuntimeInfoStore) DeletePod

func (r *RuntimeInfoStore) DeletePod(podKey string, t tunnel.Tunnel)

func (*RuntimeInfoStore) GetContainer

func (r *RuntimeInfoStore) GetContainer(containerKey string) *corev1.Container

func (*RuntimeInfoStore) GetLatestContainerInfoByContainerKey

func (r *RuntimeInfoStore) GetLatestContainerInfoByContainerKey(containerKey string) *model.ContainerStatusData

func (*RuntimeInfoStore) GetLatestContainerInfos

func (r *RuntimeInfoStore) GetLatestContainerInfos() []*model.ContainerStatusData

func (*RuntimeInfoStore) GetPodByKey

func (r *RuntimeInfoStore) GetPodByKey(podKey string) *corev1.Pod

func (*RuntimeInfoStore) GetPods

func (r *RuntimeInfoStore) GetPods() []*corev1.Pod

func (*RuntimeInfoStore) GetRelatedPodKeysByContainerKey

func (r *RuntimeInfoStore) GetRelatedPodKeysByContainerKey(containerKey string) []string

func (*RuntimeInfoStore) PutContainerStatus

func (r *RuntimeInfoStore) PutContainerStatus(containerInfo model.ContainerStatusData) (updated bool)

func (*RuntimeInfoStore) PutPod

func (r *RuntimeInfoStore) PutPod(pod *corev1.Pod, t tunnel.Tunnel)

type VPodProvider

type VPodProvider struct {
	Namespace string
	// contains filtered or unexported fields
}

func NewVPodProvider

func NewVPodProvider(namespace, localIP, nodeID string, client client.Client, t tunnel.Tunnel) *VPodProvider

func (*VPodProvider) CreatePod

func (b *VPodProvider) CreatePod(ctx context.Context, pod *corev1.Pod) error

func (*VPodProvider) DeletePod

func (b *VPodProvider) DeletePod(ctx context.Context, pod *corev1.Pod) error

func (*VPodProvider) GetPod

func (b *VPodProvider) GetPod(_ context.Context, namespace, name string) (*corev1.Pod, error)

GetPod this method is simply used to return the observed defaultPod by local

so the outer control loop can call CreatePod / UpdatePod / DeletePod accordingly
just return the defaultPod from the local store

func (*VPodProvider) GetPodStatus

func (b *VPodProvider) GetPodStatus(ctx context.Context, namespace, name string) (*corev1.PodStatus, error)

GetPodStatus this will be called repeatedly by virtual kubelet framework to get the defaultPod status we should query the actual runtime info and translate them in to V1PodStatus accordingly

func (*VPodProvider) GetPods

func (b *VPodProvider) GetPods(_ context.Context) ([]*corev1.Pod, error)

func (*VPodProvider) InitContainerInfo

func (b *VPodProvider) InitContainerInfo(info model.ContainerStatusData)

func (*VPodProvider) NotifyPods

func (b *VPodProvider) NotifyPods(_ context.Context, cb func(*corev1.Pod))

func (*VPodProvider) SyncAllContainerInfo

func (b *VPodProvider) SyncAllContainerInfo(ctx context.Context, containerInfos []model.ContainerStatusData)

func (*VPodProvider) SyncOneContainerInfo

func (b *VPodProvider) SyncOneContainerInfo(ctx context.Context, containerInfo model.ContainerStatusData)

func (*VPodProvider) UpdatePod

func (b *VPodProvider) UpdatePod(ctx context.Context, pod *corev1.Pod) error