ns_watcher

Documentation

Index

• Constants
• type NSEvent
• type NSWatcher
  • func New(log logrus.FieldLogger, k8sHandle kubernetes.Interface) (*NSWatcher, error)
  • func NewDumb() *NSWatcher
  • func (w *NSWatcher) Errors() chan error
  • func (w *NSWatcher) NSEvents() chan *common.NSEvent
  • func (w *NSWatcher) Run(ctx context.Context)
  • func (w *NSWatcher) Stop()
• type NSWatcherInterface
• type NSWatcherOptions

Constants

const (
	NSWatcherK8sKind int = iota
)

Types

type NSEvent

type NSEvent = common.NSEvent

type NSWatcher

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

func New

func New(
	log logrus.FieldLogger,
	k8sHandle kubernetes.Interface,
) (*NSWatcher, error)

func NewDumb

func NewDumb() *NSWatcher

func (*NSWatcher) Errors

func (w *NSWatcher) Errors() chan error

func (*NSWatcher) NSEvents

func (w *NSWatcher) NSEvents() chan *common.NSEvent

func (*NSWatcher) Run

func (w *NSWatcher) Run(ctx context.Context)

func (*NSWatcher) Stop

func (w *NSWatcher) Stop()

type NSWatcherInterface

type NSWatcherInterface interface {
	Run(context.Context)
	Stop()

	NSEvents() chan *common.NSEvent
	Errors() chan error
}

type NSWatcherOptions

type NSWatcherOptions struct {
	Log logrus.FieldLogger
}