k8sadapter

package

v1.3.0 Latest Latest Go to latest Published: Feb 23, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewAdapter(opt Options) (*Adapter, error)

func (a *Adapter) ListNodes(ctx context.Context) ([]*domain.Node, error)

ListNodes returns all nodes in the Kubernetes cluster

func (a *Adapter) QueryDecisionMakerPods(ctx context.Context, opt *domain.QueryDecisionMakerPodsOptions) ([]*domain.DecisionMakerPod, error)

func (a *Adapter) QueryPods(ctx context.Context, opt *domain.QueryPodsOptions) ([]*domain.Pod, error)

func (a *Adapter) StopPodWatcher()

type Options struct {
	KubeConfigPath string
	InCluster      bool
}