flows

package
v2.8.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Sep 11, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SizeEthAddr    = 6
	SizeVlan       = 2
	SizeIPv4Addr   = 4
	SizeIPv6Addr   = 16
	SizeICMPID     = 2
	SizePortNumber = 2

	SizeEthFlowID    = 2 * SizeEthAddr    // source + dest mac address
	SizeVlanFlowID   = SizeVlan           // raw vlan id
	SizeIPv4FlowID   = 2 * SizeIPv4Addr   // source + dest ip
	SizeIPv6FlowID   = 2 * SizeIPv6Addr   // source + dest ip
	SizeICMPFlowID   = SizeICMPID         // icmp identifier (if present)
	SizeTCPFlowID    = 2 * SizePortNumber // source + dest port
	SizeUDPFlowID    = 2 * SizePortNumber // source + dest port
	SizeConnectionID = 8                  // 64bit internal connection id

	SizeFlowIDMax int = SizeEthFlowID +
		2*(SizeVlanFlowID+SizeIPv4FlowID+SizeIPv6FlowID) +
		SizeICMPFlowID +
		SizeTCPFlowID +
		SizeUDPFlowID +
		SizeConnectionID
)

Variables

View Source 
var (
	ErrInvalidTimeout = errors.New("timeout must not <= 1s")
	ErrInvalidPeriod  = errors.New("report period must be -1 or >= 1s")
)

Functions

func FlowIDsEqual 

func FlowIDsEqual(f1, f2 *FlowID) bool

Types

type Float 

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

func (*Float) Add 

func (c *Float) Add(f *Flow, delta float64)

func (*Float) Set 

func (c *Float) Set(f *Flow, value float64)

type Flow 

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

type FlowID 

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

func (*FlowID) AddConnectionID 

func (f *FlowID) AddConnectionID(id uint64)

func (*FlowID) AddEth 

func (f *FlowID) AddEth(src, dst net.HardwareAddr)

func (*FlowID) AddICMPv4Request 

func (f *FlowID) AddICMPv4Request(id uint16)

func (*FlowID) AddICMPv4Response 

func (f *FlowID) AddICMPv4Response(id uint16)

func (*FlowID) AddICMPv6Request 

func (f *FlowID) AddICMPv6Request(id uint16)

func (*FlowID) AddICMPv6Response 

func (f *FlowID) AddICMPv6Response(id uint16)

func (*FlowID) AddIPv4 

func (f *FlowID) AddIPv4(src, dst net.IP)

func (*FlowID) AddIPv6 

func (f *FlowID) AddIPv6(src, dst net.IP)

func (*FlowID) AddTCP 

func (f *FlowID) AddTCP(src, dst uint16)

func (*FlowID) AddUDP 

func (f *FlowID) AddUDP(src, dst uint16)

func (*FlowID) AddVLan 

func (f *FlowID) AddVLan(id uint16)

func (*FlowID) ConnectionID 

func (f *FlowID) ConnectionID() []byte

func (*FlowID) Eth 

func (f *FlowID) Eth() []byte

func (FlowID) EthAddr 

func (f FlowID) EthAddr() ([]byte, []byte, bool)

func (*FlowID) Flags 

func (f *FlowID) Flags() FlowIDFlag

func (*FlowID) Get 

func (f *FlowID) Get(i FlowIDFlag) []byte

func (*FlowID) ICMPv4 

func (f *FlowID) ICMPv4() []byte

func (*FlowID) ICMPv6 

func (f *FlowID) ICMPv6() []byte

func (*FlowID) IPv4 

func (f *FlowID) IPv4() []byte

func (*FlowID) IPv4Addr 

func (f *FlowID) IPv4Addr() ([]byte, []byte, bool)

func (*FlowID) IPv6 

func (f *FlowID) IPv6() []byte

func (*FlowID) IPv6Addr 

func (f *FlowID) IPv6Addr() ([]byte, []byte, bool)

func (*FlowID) OutterIPv4 

func (f *FlowID) OutterIPv4() []byte

func (*FlowID) OutterIPv4Addr 

func (f *FlowID) OutterIPv4Addr() ([]byte, []byte, bool)

func (*FlowID) OutterIPv6 

func (f *FlowID) OutterIPv6() []byte

func (*FlowID) OutterIPv6Addr 

func (f *FlowID) OutterIPv6Addr() ([]byte, []byte, bool)

func (*FlowID) OutterVLan 

func (f *FlowID) OutterVLan() []byte

func (*FlowID) Reset 

func (f *FlowID) Reset(buf []byte)

func (*FlowID) Serialize 

func (f *FlowID) Serialize() []byte

func (*FlowID) TCP 

func (f *FlowID) TCP() []byte

func (*FlowID) TCPAddr 

func (f *FlowID) TCPAddr() ([]byte, []byte, bool)

func (*FlowID) UDP 

func (f *FlowID) UDP() []byte

func (*FlowID) UDPAddr 

func (f *FlowID) UDPAddr() ([]byte, []byte, bool)

func (*FlowID) VLan 

func (f *FlowID) VLan() []byte

type FlowIDFlag 

type FlowIDFlag uint16
const (
	EthFlow FlowIDFlag = (1 << iota)
	OutterVlanFlow
	VLanFlow
	OutterIPv4Flow
	IPv4Flow
	OutterIPv6Flow
	IPv6Flow
	ICMPv4Flow
	ICMPv6Flow
	UDPFlow
	TCPFlow
	ConnectionID
)

type Flows 

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

func NewFlows 

func NewFlows(pub Reporter, config *config.Flows) (*Flows, error)

func (*Flows) Get 

func (f *Flows) Get(id *FlowID) *Flow

func (*Flows) Lock 

func (f *Flows) Lock()

func (*Flows) NewFloat 

func (f *Flows) NewFloat(name string) (*Float, error)

func (*Flows) NewInt 

func (f *Flows) NewInt(name string) (*Int, error)

func (*Flows) NewUint 

func (f *Flows) NewUint(name string) (*Uint, error)

func (*Flows) Start 

func (f *Flows) Start()

func (*Flows) Stop 

func (f *Flows) Stop()

func (*Flows) Unlock 

func (f *Flows) Unlock()

type Int 

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

func (*Int) Add 

func (c *Int) Add(f *Flow, delta int64)

func (*Int) Set 

func (c *Int) Set(f *Flow, value int64)

type Reporter 

type Reporter func([]beat.Event)

Reporter callback type, to report flow events to.

type Uint 

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

func (*Uint) Add 

func (c *Uint) Add(f *Flow, delta uint64)

func (*Uint) Set 

func (c *Uint) Set(f *Flow, value uint64)

type Var 

type Var interface{}

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.