log

Documentation

Index

• func DumpLog(ctx context.Context, client kubernetes.Interface, pod *corev1.Pod, ...) (string, error)
• func Print(ctx context.Context, cmd *cobra.Command, client kubernetes.Interface, ...) error
• func PrintUsingSelector(ctx context.Context, cmd *cobra.Command, client kubernetes.Interface, ...) error
• type PodScraper
  • func NewPodScraper(c kubernetes.Interface, namespace string, podName string, ...) *PodScraper
  • func (s *PodScraper) Start(ctx context.Context) *bufio.Reader
• type SelectorScraper
  • func NewSelectorScraper(client kubernetes.Interface, namespace string, defaultContainerName string, ...) *SelectorScraper
  • func (s *SelectorScraper) Start(ctx context.Context) *bufio.Reader

Functions

func DumpLog

func DumpLog(ctx context.Context, client kubernetes.Interface, pod *corev1.Pod, podLogOpts corev1.PodLogOptions) (string, error)

DumpLog extract the full log from a Pod. Recommended when the quantity of log expected is minimum.

func Print

func Print(ctx context.Context, cmd *cobra.Command, client kubernetes.Interface, integration *v1.Integration, tailLines *int64, out io.Writer) error

Print prints integrations logs to the stdout.

func PrintUsingSelector

func PrintUsingSelector(ctx context.Context, cmd *cobra.Command, client kubernetes.Interface, namespace, defaultContainerName, selector string, tailLines *int64, out io.Writer) error

PrintUsingSelector prints pod logs using a selector.

Types

type PodScraper

type PodScraper struct {
	L klog.Logger
	// contains filtered or unexported fields
}

PodScraper scrapes logs of a specific pod.

func NewPodScraper

func NewPodScraper(c kubernetes.Interface, namespace string, podName string, defaultContainerName string, tailLines *int64) *PodScraper

NewPodScraper creates a new pod scraper.

func (*PodScraper) Start

func (s *PodScraper) Start(ctx context.Context) *bufio.Reader

Start returns a reader that streams the pod logs.

type SelectorScraper

type SelectorScraper struct {
	L klog.Logger
	// contains filtered or unexported fields
}

SelectorScraper scrapes all pods with a given selector.

func NewSelectorScraper

func NewSelectorScraper(client kubernetes.Interface, namespace string, defaultContainerName string, labelSelector string, tailLines *int64) *SelectorScraper

NewSelectorScraper creates a new SelectorScraper.

func (*SelectorScraper) Start

func (s *SelectorScraper) Start(ctx context.Context) *bufio.Reader

Start returns a reader that streams the log of all selected pods.