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

provider

package

Go to main page

Versions in this module

v0

v0.3.7

Jan 14, 2025

v0.3.6

Jan 9, 2025

Changes in this version

type VNode

+ TakeOvered bool

+ WhenLeaderAcquiredByMe chan struct{}

+ WhenLeaderAcquiredByOthers chan struct{}

+ func (vNode *VNode) Exit() <-chan struct{}

+ func (vNode *VNode) LeaderAcquiredByMe()

+ func (vNode *VNode) LeaderAcquiredByOthers()

+ func (vNode *VNode) NewLease(holderIdentity string) *coordinationv1.Lease

+ func (vNode *VNode) Remove(vnCtx context.Context) (err error)

+ func (vNode *VNode) SetLease(lease *coordinationv1.Lease)

+ func (vNode *VNode) ToDone()

v0.3.5

Dec 3, 2024

Changes in this version

+ type Liveness struct

+ LatestHeartBeatTime time.Time

+ func (liveness *Liveness) Close()

+ func (liveness *Liveness) IsDead() bool

+ func (liveness *Liveness) IsReachable() bool

+ func (liveness *Liveness) UpdateHeartBeatTime()

+ type VNode struct

+ Liveness Liveness

+ func NewVNode(config *model.BuildVNodeConfig, tunnel tunnel.Tunnel) (kn *VNode, err error)

+ func (vNode *VNode) AddKnowPod(pod *corev1.Pod)

+ func (vNode *VNode) CheckAndUpdatePodStatus(ctx context.Context, key string, pod *corev1.Pod)

+ func (vNode *VNode) DeleteKnownPod(key string)

+ func (vNode *VNode) DeletePodsFromKubernetesForget(ctx context.Context, key string)

+ func (vNode *VNode) Done() <-chan struct{}

+ func (vNode *VNode) Err() error

+ func (vNode *VNode) ExitWhenLeaderChanged() <-chan struct{}

+ func (vNode *VNode) GetKnownPod(key string) (any, bool)

+ func (vNode *VNode) GetLease() *coordinationv1.Lease

+ func (vNode *VNode) GetNodeName() string

+ func (vNode *VNode) IsLeader(clientId string) bool

+ func (vNode *VNode) IsReady() (bool, error)

+ func (vNode *VNode) Run(ctx context.Context, initData model.NodeInfo)

+ func (vNode *VNode) Shutdown()

+ func (vNode *VNode) StartLeaderElection(ctx context.Context, clientID string)

+ func (vNode *VNode) SyncAllContainerInfo(ctx context.Context, infos []model.BizStatusData)

+ func (vNode *VNode) SyncNodeStatus(data model.NodeStatusData)

+ func (vNode *VNode) SyncOneContainerInfo(ctx context.Context, bizStatusData model.BizStatusData)

+ func (vNode *VNode) SyncPodsFromKubernetesEnqueue(ctx context.Context, key string)

+ func (vNode *VNode) WaitReady(ctx context.Context, timeout time.Duration) error

+ type VNodeProvider struct

+ func NewVNodeProvider(config *model.BuildVNodeConfig) *VNodeProvider

+ func (v *VNodeProvider) Notify(data model.NodeStatusData)

+ func (v *VNodeProvider) NotifyNodeStatus(_ context.Context, cb func(*corev1.Node))

+ func (v *VNodeProvider) Ping(_ context.Context) error

+ type VNodeStore struct

+ func NewVNodeStore() *VNodeStore

+ func (r *VNodeStore) AddVNode(nodeName string, vnode *VNode) error

+ func (r *VNodeStore) AllNodeNum() int

+ func (r *VNodeStore) DeleteVNode(nodeName string)

+ func (r *VNodeStore) GetDeadVNodes() []*VNode

+ func (r *VNodeStore) GetLeaseOccupiedVNodes(clientID string) []*VNode

+ func (r *VNodeStore) GetLeaseOutdatedVNodeNames(clientID string) []string

+ func (r *VNodeStore) GetUnReachableVNodes() []*VNode

+ func (r *VNodeStore) GetVNode(nodeName string) *VNode

+ func (r *VNodeStore) GetVNodeByNodeName(nodeName string) *VNode

+ func (r *VNodeStore) GetVNodes() []*VNode

+ func (r *VNodeStore) NodeShutdown(nodeName string)

+ func (r *VNodeStore) RunningNodeNum() int

+ func (r *VNodeStore) UpdateNodeStateOnProviderArrived(nodeName string, state model.NodeState)

+ type VPodProvider struct

+ Namespace string

+ func NewVPodProvider(namespace, localIP, nodeName string, client client.Client, ...) *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, pod *corev1.Pod, bizStatus model.BizStatusData) (*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) SyncAllBizStatusToKube(ctx context.Context, bizStatusDatas []model.BizStatusData)

+ func (b *VPodProvider) SyncBizStatusToKube(ctx context.Context, bizStatusData model.BizStatusData)

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

+ type VPodStore struct

+ func NewVPodStore() *VPodStore

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

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

+ func (r *VPodStore) GetPodByKey(podKey string) *corev1.Pod

+ func (r *VPodStore) GetPods() []*corev1.Pod

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