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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.