Help us shape the future of Go! Take the 2026 Go Developer Survey

podaccess

package
v1.6.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 20, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NonUniqueEtcdMemberToPod

func NonUniqueEtcdMemberToPod(intervals monitorapi.Intervals) map[string]NonUniquePodKey

func NonUniquePodToNode

func NonUniquePodToNode(intervals monitorapi.Intervals) map[NonUniquePodKey]string

Types

type LogError

type LogError struct {
	Pod     *corev1.Pod
	Locator monitorapi.Locator
	Error   error
}

type LogHandler

type LogHandler interface {
	HandleLogLine(logLine LogLineContent)
}

type LogLineContent

type LogLineContent struct {
	Instant time.Time
	Pod     *corev1.Pod
	Locator monitorapi.Locator
	Line    string
}

type NonUniquePodKey

type NonUniquePodKey struct {
	Namespace string
	Name      string
}

type OneTimePodStreamer

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

func NewOneTimePodStreamer

func NewOneTimePodStreamer(kubeClient kubernetes.Interface, namespace, podName, containerName string, logHandlers ...LogHandler) *OneTimePodStreamer

func (*OneTimePodStreamer) ReadLog

func (s *OneTimePodStreamer) ReadLog(ctx context.Context) error

type PodKey

type PodKey struct {
	Namespace string
	Name      string
	UID       string
}

type PodStreamer

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

func NewPodStreamer

func NewPodStreamer(kubeClient kubernetes.Interface, namespace, podName, containerName string) *PodStreamer

func (*PodStreamer) Output

func (s *PodStreamer) Output() (chan LogLineContent, chan LogError)

func (*PodStreamer) Run

func (s *PodStreamer) Run(ctx context.Context) error

func (*PodStreamer) Stop

func (s *PodStreamer) Stop(ctx context.Context)

type PodsStreamer

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

func NewPodsStreamer

func NewPodsStreamer(
	kubeClient kubernetes.Interface,
	selector labels.Selector,
	namespaceName string,
	containerName string,
	logHandler LogHandler,

	podInformer coreinformers.PodInformer,
) *PodsStreamer

func (*PodsStreamer) Run

func (c *PodsStreamer) Run(ctx context.Context, finishedCleanup chan struct{})

Run starts the controller and blocks until stopCh is closed.

func (*PodsStreamer) Stop

func (c *PodsStreamer) Stop(ctx context.Context)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL