Documentation
¶
Index ¶
- func NonUniqueEtcdMemberToPod(intervals monitorapi.Intervals) map[string]NonUniquePodKey
- func NonUniquePodToNode(intervals monitorapi.Intervals) map[NonUniquePodKey]string
- type LogError
- type LogHandler
- type LogLineContent
- type NonUniquePodKey
- type OneTimePodStreamer
- type PodKey
- type PodStreamer
- type PodsStreamer
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 LogHandler ¶
type LogHandler interface {
HandleLogLine(logLine LogLineContent)
}
type LogLineContent ¶
type NonUniquePodKey ¶
type OneTimePodStreamer ¶
type OneTimePodStreamer struct {
// contains filtered or unexported fields
}
func NewOneTimePodStreamer ¶
func NewOneTimePodStreamer(kubeClient kubernetes.Interface, namespace, podName, containerName string, logHandlers ...LogHandler) *OneTimePodStreamer
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) 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)
Click to show internal directories.
Click to hide internal directories.