ciliumeventobserver

Documentation

Overview

Package ciliumeventobserver contains the Retina CiliumEventObserver plugin. It uses unix socket to get events from cilium and decode them to flow objects.

Copyright (c) Microsoft Corporation. Licensed under the MIT license.

Index

• Variables
• func New(cfg *kcfg.Config) registry.Plugin
• type DefaultDialer
  • func (d *DefaultDialer) Dial(network, address string) (net.Conn, error)

Variables

var (
	ErrNotImplemented = errors.New("Error, not implemented")
	ErrEmptyData      = errors.New("empty data")
)

Functions

func New

func New(cfg *kcfg.Config) registry.Plugin

Types

type DefaultDialer

type DefaultDialer struct{}

func (*DefaultDialer) Dial

func (d *DefaultDialer) Dial(network, address string) (net.Conn, error)

Wrapper on net.Dial to mock in tests