Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pod_provider

package

Go to main page

Versions in this module

v0

v0.3.4

Nov 12, 2024

Changes in this version

type RuntimeInfoStore

+ func (r *RuntimeInfoStore) CheckContainerStatusNeedSync(bizStatusData model.BizStatusData) bool

v0.3.3

Nov 4, 2024

v0.3.2

Oct 28, 2024

v0.3.1

Oct 22, 2024

Changes in this version

type RuntimeInfoStore

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

type VPodProvider

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

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

v0.3.0

Oct 17, 2024

Changes in this version

type RuntimeInfoStore

+ func (r *RuntimeInfoStore) ClearContainerStatus(containerKey string)

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

v0.2.2

Sep 24, 2024

Changes in this version

type VPodProvider

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

v0.2.1

Sep 19, 2024

v0.2.0

Sep 11, 2024

Changes in this version

+ type RuntimeInfoStore struct

+ func NewRuntimeInfoStore() *RuntimeInfoStore

+ func (r *RuntimeInfoStore) DeleteContainer(containerKey string)

+ func (r *RuntimeInfoStore) DeletePod(podKey string)

+ 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) GetRelatedPodKeysByContainerName(containerName string) []string

+ func (r *RuntimeInfoStore) PutContainerInfo(containerInfo model.ContainerStatusData)

+ func (r *RuntimeInfoStore) PutPod(pod *corev1.Pod)

+ func (r *RuntimeInfoStore) SyncContainerInfo(containerInfos []model.ContainerStatusData)

+ type VPodProvider struct

+ Namespace string

+ 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) NotifyPods(_ context.Context, cb func(*corev1.Pod))

+ func (b *VPodProvider) Run(ctx context.Context)

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

+ func (b *VPodProvider) SyncSingleContainerInfo(ctx context.Context, info model.ContainerStatusData)

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