logs

Documentation

Index

• func NewLogstream(namespace string, pod string, container string, podLabels map[string]string, ...) *logstream
• type LogController
  • func NewLogController(informerFactory informers.SharedInformerFactory, ...) *LogController
  • func (c *LogController) Run(stopCh chan struct{}) error
  • func (c *LogController) Watch() chan struct{}

Functions

func NewLogstream

func NewLogstream(namespace string, pod string, container string, podLabels map[string]string, logstore logstores.Logstore, clientset kubernetes.Interface, logCh chan utils.LogEntry, timeout time.Duration) *logstream

Types

type LogController

type LogController struct {
	// contains filtered or unexported fields
}

func NewLogController

func NewLogController(informerFactory informers.SharedInformerFactory, clientset kubernetes.Interface, config *config.Config, logstore logstores.Logstore) *LogController

Instantiates a controller for watching and handling logs

func (*LogController) Run

func (c *LogController) Run(stopCh chan struct{}) error

func (*LogController) Watch

func (c *LogController) Watch() chan struct{}

Watch creates the informerFactory and initializes the log watcher