Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dispatch

package

Go to main page

Versions in this module

v0

v0.1.2

Apr 3, 2019

Changes in this version

+ const CertfetchPriority

+ const CertsniffPriority

+ const ClassifyPriority

+ const DNSPriority

+ const ExamplePriority

+ const GeoipPriority

+ const NfAccept

+ const NfDrop

+ const ReporterPriority

+ const RevDNSPriority

+ const SniPriority

+ const StatsPriority

+ func GetConntrackTable() map[uint32]*Conntrack

+ func HandleWarehouseCleanup()

+ func HandleWarehousePlayback()

+ func MirrorNfqueueSubscriptions(session *Session) map[string]SubscriptionHolder

+ type Conntrack struct

+ ClientByteRate float32

+ ClientBytes uint64

+ ClientBytesDiff uint64

+ ClientPacketRate float32

+ ClientPackets uint64

+ ClientPacketsDiff uint64

+ ClientSideTuple Tuple

+ ConnMark uint32

+ ConntrackID uint32

+ CreationTime time.Time

+ EventCount uint64

+ Family uint8

+ Guardian sync.RWMutex

+ LastActivityTime time.Time

+ LastUpdateTime time.Time

+ ServerByteRate float32

+ ServerBytes uint64

+ ServerBytesDiff uint64

+ ServerPacketRate float32

+ ServerPackets uint64

+ ServerPacketsDiff uint64

+ ServerSideTuple Tuple

+ Session *Session

+ SessionID uint64

+ TCPState uint8

+ TimeoutSeconds uint32

+ TimestampStart uint64

+ TimestampStop uint64

+ TotalByteRate float32

+ TotalBytes uint64

+ TotalBytesDiff uint64

+ TotalPacketRate float32

+ TotalPackets uint64

+ TotalPacketsDiff uint64

+ func (ct *Conntrack) String() string

type NfqueueMessage

+ ClientToServer bool

+ Family int

+ ICMPv4Layer *layers.ICMPv4

+ IP4Layer *layers.IPv4

+ IP6Layer *layers.IPv6

+ MsgTuple Tuple

+ PacketMark uint32

+ TCPLayer *layers.TCP

+ UDPLayer *layers.UDP

+ type Session struct

+ func (sess *Session) AddByteCount(value uint64) uint64

+ func (sess *Session) AddEventCount(value uint64) uint64

+ func (sess *Session) AddPacketCount(value uint64) uint64

+ func (sess *Session) DeleteAttachment(name string) bool

+ func (sess *Session) GetAttachment(name string) interface{}

+ func (sess *Session) GetByteCount() uint64

+ func (sess *Session) GetClientInterfaceID() uint8

+ func (sess *Session) GetClientInterfaceType() uint8

+ func (sess *Session) GetClientSideTuple() Tuple

+ func (sess *Session) GetConntrackConfirmed() bool

+ func (sess *Session) GetConntrackID() uint32

+ func (sess *Session) GetConntrackPointer() *Conntrack

+ func (sess *Session) GetCreationTime() time.Time

+ func (sess *Session) GetEventCount() uint64

+ func (sess *Session) GetLastActivity() time.Time

+ func (sess *Session) GetPacketCount() uint64

+ func (sess *Session) GetServerInterfaceID() uint8

+ func (sess *Session) GetServerInterfaceType() uint8

+ func (sess *Session) GetServerSideTuple() Tuple

+ func (sess *Session) GetSessionID() uint64

+ func (sess *Session) LockAttachments() map[string]interface{}

+ func (sess *Session) PutAttachment(name string, value interface{})

+ func (sess *Session) SetByteCount(value uint64) uint64

+ func (sess *Session) SetClientInterfaceID(value uint8) uint8

+ func (sess *Session) SetClientInterfaceType(value uint8) uint8

+ func (sess *Session) SetClientSideTuple(tuple Tuple)

+ func (sess *Session) SetConntrackConfirmed(argument bool)

+ func (sess *Session) SetConntrackID(value uint32) uint32

+ func (sess *Session) SetConntrackPointer(pointer *Conntrack)

+ func (sess *Session) SetCreationTime(value time.Time)

+ func (sess *Session) SetEventCount(value uint64) uint64

+ func (sess *Session) SetLastActivity(value time.Time)

+ func (sess *Session) SetPacketCount(value uint64) uint64

+ func (sess *Session) SetServerInterfaceID(value uint8) uint8

+ func (sess *Session) SetServerInterfaceType(value uint8) uint8

+ func (sess *Session) SetServerSideTuple(tuple Tuple)

+ func (sess *Session) SetSessionID(value uint64) uint64

+ func (sess *Session) UnlockAttachments()

v0.1.1

Aug 17, 2018

Changes in this version

+ func AttachNfqueueSubscriptions(session *SessionEntry)

+ func GetSessionAttachment(entry *SessionEntry, name string) interface

+ func InsertConntrackSubscription(owner string, priority int, function ConntrackHandlerFunction)

+ func InsertNetloggerSubscription(owner string, priority int, function NetloggerHandlerFunction)

+ func InsertNfqueueSubscription(owner string, priority int, function NfqueueHandlerFunction)

+ func PutSessionAttachment(entry *SessionEntry, name string, value interface{})

+ func ReleaseSession(session *SessionEntry, owner string)

+ func Shutdown()

+ func Startup()

+ type ConntrackEntry struct

+ C2Sbytes uint64

+ C2Srate float32

+ ClientSideTuple Tuple

+ ConntrackID uint32

+ CreationTime time.Time

+ EventCount uint64

+ LastActivityTime time.Time

+ PurgeFlag bool

+ S2Cbytes uint64

+ S2Crate float32

+ ServerSideTuple Tuple

+ Session *SessionEntry

+ SessionID uint64

+ TotalBytes uint64

+ TotalRate float32

+ func (c ConntrackEntry) String() string

+ type ConntrackHandlerFunction func(int, *ConntrackEntry)

+ type NetloggerHandlerFunction func(*NetloggerMessage)

+ type NetloggerMessage struct

+ DstAddress string

+ DstInterface uint8

+ DstPort uint16

+ IcmpType uint16

+ Mark uint32

+ Prefix string

+ Protocol uint8

+ SrcAddress string

+ SrcInterface uint8

+ SrcPort uint16

+ Version uint8

+ type NfqueueHandlerFunction func(NfqueueMessage, uint32, bool) NfqueueResult

+ type NfqueueMessage struct

+ IP4layer *layers.IPv4

+ IP6layer *layers.IPv6

+ Length int

+ Packet gopacket.Packet

+ Payload []byte

+ Session *SessionEntry

+ TCPlayer *layers.TCP

+ Tuple Tuple

+ UDPlayer *layers.UDP

+ type NfqueueResult struct

+ Owner string

+ PacketMark uint32

+ SessionRelease bool

+ type SessionEntry struct

+ ByteCount uint64

+ ClientSideTuple Tuple

+ ConntrackConfirmed bool

+ CreationTime time.Time

+ EventCount uint64

+ LastActivityTime time.Time

+ PacketCount uint64

+ ServerSideTuple Tuple

+ SessionID uint64

+ type SubscriptionHolder struct

+ ConntrackFunc ConntrackHandlerFunction

+ NetloggerFunc NetloggerHandlerFunction

+ NfqueueFunc NfqueueHandlerFunction

+ Owner string

+ Priority int

+ type Tuple struct

+ ClientAddress net.IP

+ ClientPort uint16

+ Protocol uint8

+ ServerAddress net.IP

+ ServerPort uint16

+ func (t Tuple) Equal(o Tuple) bool

+ func (t Tuple) EqualReverse(o Tuple) bool

+ func (t Tuple) String() string

+ func (t Tuple) StringReverse() string