transport

package
v0.2.2 Latest Latest
Warning

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

Go to latest
Published: Jan 2, 2026 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const ZMQ_MSG_V4_FLAG_COMPRESSED = 4
View Source
const ZMQ_MSG_V4_FLAG_TLV = 2
View Source
const ZMQ_MSG_VERSION_4 = 4 // ntop message version for zmq_msg_hdr_v3 in ntop_defines.h

* For more info on this you'll want to read: * include/ntop_typedefs.h, include/ntop_defines.h & src/ZMQCollectorInterface.cpp from * https://github.com/ntop/ntopng

View Source
const ZMQ_TOPIC = "flow" // ntopng only really cares about the first character!

Variables

This section is empty.

Functions

func RegisterZmq added in v0.1.0

func RegisterZmq(zmqListen string, msgType MsgFormat, sourceId int, compress bool)

func SetLogger added in v0.1.0

func SetLogger(l *logrus.Logger)

Types

type MsgFormat added in v0.1.0

type MsgFormat int
const (
	PBUF MsgFormat = iota
	JSON
	TLV
)

type ZmqDriver added in v0.1.0

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

func (*ZmqDriver) Close added in v0.1.0

func (d *ZmqDriver) Close() error

func (*ZmqDriver) Init added in v0.1.0

func (d *ZmqDriver) Init() error

func (*ZmqDriver) Prepare added in v0.1.0

func (d *ZmqDriver) Prepare() error

func (*ZmqDriver) Send added in v0.1.0

func (d *ZmqDriver) Send(key, data []byte) error

Jump to

Keyboard shortcuts

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