podaccess

package
v0.0.0-...-478b8a2 Latest Latest
Warning

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

Go to latest
Published: Jul 16, 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