kubelogs

package
v0.0.0-...-1b8e598 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 5, 2020 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrInformerNeverSynced = errors.New("informer cache never completed syncing")

Functions

This section is empty.

Types

type Manager

type Manager struct {
	kubernetes.Interface
	// contains filtered or unexported fields
}

func NewManager

func NewManager(l logger.Interface, cs kubernetes.Interface, lookback, resync time.Duration, debug bool) *Manager

func (*Manager) ContainerCount

func (m *Manager) ContainerCount() (int, int)

func (*Manager) Logs

func (m *Manager) Logs() <-chan logger.LogLine

func (*Manager) NamespaceCount

func (m *Manager) NamespaceCount() int

func (*Manager) Run

func (m *Manager) Run(ctx context.Context) error

func (*Manager) Unwatch

func (m *Manager) Unwatch(namespace string)

func (*Manager) WaitForCacheSync

func (m *Manager) WaitForCacheSync(stopCh <-chan struct{}) error

func (*Manager) Watch

func (m *Manager) Watch(namespace string)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL