pods

package

v0.2.1 Latest Latest Go to latest Published: Aug 18, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Package pods watches kubelet's local PodsAPI and publishes fail-closed snapshots.

View Source

const DefaultSocket = "unix:///var/lib/kubelet/pods-api/pods-api.sock"

DefaultSocket is the kubelet PodsAPI Unix socket.

This section is empty.

func Dial(socket string) (*grpc.ClientConn, error)

Dial connects to the kubelet PodsAPI Unix socket with plaintext credentials.

type Client interface {
	Watch(context.Context) (Stream, error)
}

Client is the injectable subset of the kubelet PodsAPI client.

type GRPCClient struct{ Client podsv1alpha1.PodsClient }

GRPCClient adapts the generated kubelet client.

func (c GRPCClient) Watch(ctx context.Context) (Stream, error)

Watch starts a kubelet PodsAPI watch.

type Pod struct {
	UID       string
	Namespace string
	Labels    map[string]string
	Address   netip.Addr
	Eligible  bool
}

Pod is the selector and readiness information owned by the watcher.

type Snapshot map[string]Pod

Snapshot is an atomic, complete view keyed by Pod UID.

type Stream interface {
	Recv() (*podsv1alpha1.WatchPodsEvent, error)
}

Stream is the injectable subset of a PodsAPI watch stream.

type Watcher struct {
	Client  Client
	Publish func(Snapshot)
	Delay   time.Duration
}

Watcher reconnects to PodsAPI and publishes complete snapshots.

func (w *Watcher) Run(ctx context.Context) error

Run watches until context cancellation, publishing empty state on every disconnect.