log

Documentation

Index

• func Print(ctx context.Context, client kubernetes.Interface, integration *v1.Integration, ...) 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 Print

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

Print prints integrations logs to the stdout

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) *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) *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