log

Documentation

Index

• func Print(ctx context.Context, client kubernetes.Interface, namespace string, ...) error
• func PrintUsingSelector(ctx context.Context, 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 Print

func Print(ctx context.Context, client kubernetes.Interface, namespace string, name string, out io.Writer) error

Print prints test logs to the given writer.

func PrintUsingSelector

func PrintUsingSelector(ctx context.Context, client kubernetes.Interface, namespace, defaultContainerName, selector string, out io.Writer) error

PrintUsingSelector prints pod logs using a selector.

Types

type PodScraper

type PodScraper struct {
	L log.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 log.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.