goDB

type AggFlowMap map[Key]*Val

type Attribute interface {
	Name() string
	// Some attributes use more than a single output column.
	ExtraColumns() []string
	// ExtractStrings() extracts a list of records representing the
	// attribute from a given key.
	// You may assume that the length of the returned list is always
	// the length of ExtraColumns() + 1.
	ExtractStrings(key *ExtraKey) []string
	// contains filtered or unexported methods
}

type BlockMetadata struct {
	Timestamp            int64 `json:"timestamp"`
	PcapPacketsReceived  int   `json:"pcap_packets_received"`
	PcapPacketsDropped   int   `json:"pcap_packets_dropped"`
	PcapPacketsIfDropped int   `json:"pcap_packets_if_dropped"`
	PacketsLogged        int   `json:"packets_logged"`

	// As in Summary
	FlowCount uint64 `json:"flowcount"`
	Traffic   uint64 `json:"traffic"`
}

type BytesRecStringParser struct{}

type BytesSentStringParser struct{}

type DBData struct {
	// counters
	Bytes_rcvd []byte
	Bytes_sent []byte
	Pkts_rcvd  []byte
	Pkts_sent  []byte

	// attributes
	Dip   []byte
	Sip   []byte
	Dport []byte
	Proto []byte

	// metadata (important for folder naming)
	Tstamp int64
	Iface  string
}

type DBLog struct {
	Log *syslog.Writer
}

type DBSummary struct {
	Interfaces map[string]InterfaceSummary `json:"interfaces"`
}

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

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

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

type DipAttribute struct{}

type DipStringParser struct{}

type DportAttribute struct{}

type DportStringParser struct{}

type ExtraKey struct {
	Time  int64
	Iface string
	Key
}

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

type GPFiler interface {
	BlocksUsed() (int, error)
	WriteTimedBlock(timestamp int64, data []byte) error
	ReadTimedBlock(timestamp int64) ([]byte, error)
	ReadBlock(block int) ([]byte, error)
	GetBlocks() ([]int64, error)
	GetTimestamps() ([]int64, error)
	Close() error
}

type IfaceStringParser struct{}

type InterfaceSummary struct {
	// Number of flows
	FlowCount uint64 `json:"flowcount"`
	// Total traffic volume in byte
	Traffic uint64 `json:"traffic"`
	Begin   int64  `json:"begin"`
	End     int64  `json:"end"`
}

type InterfaceSummaryUpdate struct {
	// Name of the interface. For example, "eth0".
	Interface string
	// Number of flows
	FlowCount uint64
	// Traffic volume in bytes
	Traffic   uint64
	Timestamp time.Time
}

type Key struct {
	Sip      [16]byte
	Dip      [16]byte
	Dport    [2]byte
	Protocol byte
}

type Metadata struct {
	Blocks []BlockMetadata `json:"blocks"`
}

type NOPStringParser struct{}

type Node interface {
	fmt.Stringer
	// contains filtered or unexported methods
}

type PacketsRecStringParser struct{}

type PacketsSentStringParser struct{}

type ProtoAttribute struct{}

type ProtoStringParser struct{}

type Query struct {
	// list of attributes that will be compared, e.g. "dip" "sip"
	// in a "talk_conv" query
	Attributes  []Attribute
	Conditional Node
	// contains filtered or unexported fields
}

type SipAttribute struct{}

type SipStringParser struct{}

type StringKeyParser interface {
	ParseKey(element string, key *ExtraKey) error
}

type StringValParser interface {
	ParseVal(element string, val *Val) error
}

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

type TimeStringParser struct{}

type Val struct {
	NBytesRcvd uint64
	NBytesSent uint64
	NPktsRcvd  uint64
	NPktsSent  uint64
}