pktmon

Documentation

Index

• Constants
• Variables
• func New(_ *kcfg.Config) api.Plugin
• type GRPCClient
• type Plugin
  • func (p *Plugin) Compile(_ context.Context) error
  • func (p *Plugin) Generate(_ context.Context) error
  • func (p *Plugin) GetFlow(ctx context.Context) error
  • func (p *Plugin) Init() error
  • func (p *Plugin) Name() string
  • func (p *Plugin) RunPktMonServer(ctx context.Context) error
  • func (p *Plugin) SetupChannel(ch chan *v1.Event) error
  • func (p *Plugin) SetupStream() error
  • func (p *Plugin) Start(ctx context.Context) error
  • func (p *Plugin) StartStream(ctx context.Context) error
  • func (p *Plugin) Stop() error

Constants

const (
	Name = "pktmon"
)

Variables

var (
	ErrNilEnricher    = errors.New("enricher is nil")
	ErrUnexpectedExit = errors.New("unexpected exit")
	ErrNilGrpcClient  = errors.New("grpc client is nil")
)

Functions

func New

func New(_ *kcfg.Config) api.Plugin

Types

type GRPCClient

type GRPCClient struct {
	observerv1.ObserverClient
}

type Plugin

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

func (*Plugin) Compile

func (p *Plugin) Compile(_ context.Context) error

func (*Plugin) Generate

func (p *Plugin) Generate(_ context.Context) error

func (*Plugin) GetFlow

func (p *Plugin) GetFlow(ctx context.Context) error

func (*Plugin) Init

func (p *Plugin) Init() error

func (*Plugin) Name

func (p *Plugin) Name() string

func (*Plugin) RunPktMonServer

func (p *Plugin) RunPktMonServer(ctx context.Context) error

func (*Plugin) SetupChannel

func (p *Plugin) SetupChannel(ch chan *v1.Event) error

func (*Plugin) SetupStream

func (p *Plugin) SetupStream() error

func (*Plugin) Start

func (p *Plugin) Start(ctx context.Context) error

func (*Plugin) StartStream

func (p *Plugin) StartStream(ctx context.Context) error

func (*Plugin) Stop

func (p *Plugin) Stop() error