beats-1

Nov 24, 2015

Changes in this version

+ var Name = "packetbeat"

+ type CmdLineArgs struct

+ Dumpfile *string

+ File *string

+ Loop *int

+ OneAtAtime *bool

+ PrintDevices *bool

+ TopSpeed *bool

+ WaitShutdown *int

type Packetbeat

+ CmdLineArgs CmdLineArgs

+ PbConfig config.Config

+ Sniff *sniffer.SnifferSetup

+ func (pb *Packetbeat) Cleanup(b *beat.Beat) error

+ func (pb *Packetbeat) CliFlags(b *beat.Beat)

+ func (pb *Packetbeat) Config(b *beat.Beat) error

+ func (pb *Packetbeat) Run(b *beat.Beat) error

+ func (pb *Packetbeat) Setup(b *beat.Beat) error

+ func (pb *Packetbeat) Stop()

Mar 31, 2015

Changes in this version

+ var EnabledFilterPlugins map[filters.Filter]filters.FilterPlugin = map[filters.Filter]filters.FilterPlugin

+ var EnabledInputPlugins map[inputs.Input]inputs.InputPlugin = map[inputs.Input]inputs.InputPlugin

+ var EnabledProtocolPlugins map[protos.Protocol]protos.ProtocolPlugin = map[protos.Protocol]protos.ProtocolPlugin

+ func LoadConfiguredFilters(config map[string]interface{}) ([]filters.FilterPlugin, error)

+ type FilterRunner struct

+ FiltersQueue chan common.MapStr

+ func NewFilterRunner(results chan common.MapStr, order []filters.FilterPlugin) *FilterRunner

+ func (runner *FilterRunner) Run() error

Jan 27, 2015

Changes in this version

+ const BODY_CHUNKED_WAIT_FINAL_CRLF

Dec 8, 2014

Changes in this version

type Event

+ Real_ip string

type Http

+ Headers_whitelist map[string]bool

+ Real_ip_header string

+ Send_all_headers bool

+ Send_headers bool

+ Split_cookie bool

type HttpMessage

+ Body string

+ Headers map[string]string

+ Real_ip string

+ StatusPhrase string

+ TransferEncoding string

type HttpTransaction

+ Real_ip string

Nov 25, 2014

Changes in this version

+ const MaxIpPortTupleRawSize

+ const MaxTcpTupleRawSize

+ const TcpDirectionOriginal

+ const TcpDirectionReverse

+ func TcpSeqBeforeEq(seq1 uint32, seq2 uint32) bool

+ type AfpacketHandle struct

+ TPacket *afpacket.TPacket

+ func NewAfpacketHandle(device string, snaplen int, block_size int, num_blocks int, ...) (*AfpacketHandle, error)

+ func (h *AfpacketHandle) Close()

+ func (h *AfpacketHandle) ReadPacketData() (data []byte, ci gopacket.CaptureInfo, err error)

+ func (h *AfpacketHandle) SetBPFFilter(expr string) (_ error)

+ type DecoderStruct struct

+ Parser *gopacket.DecodingLayerParser

+ func CreateDecoder(datalink layers.LinkType) (*DecoderStruct, error)

+ func (decoder *DecoderStruct) DecodePacketData(data []byte, ci *gopacket.CaptureInfo)

type Event

+ Tags string

+ type HashableIpPortTuple [MaxIpPortTupleRawSize]byte

+ type HashableTcpTuple [MaxTcpTupleRawSize]byte

+ type Http struct

+ Publisher *PublisherType

+ Send_request bool

+ Send_response bool

+ var HttpMod Http

+ func (http *Http) Init(test_mode bool) error

+ func (http *Http) InitDefaults()

+ func (http *Http) Parse(pkt *Packet, tcp *TcpStream, dir uint8)

+ func (http *Http) PublishTransaction(t *HttpTransaction) error

+ func (http *Http) ReceivedFin(tcp *TcpStream, dir uint8)

type HttpMessage

+ TcpTuple TcpTuple

type IpPortTuple

+ func NewIpPortTuple(ip_length int, src_ip net.IP, src_port uint16, dst_ip net.IP, dst_port uint16) IpPortTuple

+ func (t *IpPortTuple) ComputeHashebles()

+ func (t *IpPortTuple) String() string

type MysqlMessage

+ TcpTuple TcpTuple

+ type PacketbeatStruct struct

+ Decoder *DecoderStruct

+ Sniffer *SnifferSetup

+ var Packetbeat PacketbeatStruct

+ type PfringHandle struct

+ func NewPfringHandle(device string, snaplen int, promisc bool) (*PfringHandle, error)

+ func (h *PfringHandle) Close()

+ func (h *PfringHandle) Enable() (_ error)

+ func (h *PfringHandle) ReadPacketData() (data []byte, ci gopacket.CaptureInfo, err error)

+ func (h *PfringHandle) SetBPFFilter(expr string) (_ error)

type PgsqlMessage

+ TcpTuple TcpTuple

type RedisMessage

+ TcpTuple TcpTuple

type RedisOutputType

+ Conn redis.Conn

+ FlushInterval time.Duration

+ func (out *RedisOutputType) RedisConnect(db int) (redis.Conn, error)

+ type SnifferSetup struct

+ DataSource gopacket.PacketDataSource

+ func CreateSniffer(config *tomlInterfaces, file *string) (*SnifferSetup, error)

+ func (sniffer *SnifferSetup) Close()

+ func (sniffer *SnifferSetup) Datalink() layers.LinkType

+ func (sniffer *SnifferSetup) Reopen() error

type TcpTuple

+ func TcpTupleFromIpPort(t *IpPortTuple, tcp_id uint32) TcpTuple

+ func (t *TcpTuple) ComputeHashebles()

type ThriftMessage

+ TcpTuple TcpTuple

Nov 10, 2014

Changes in this version

+ const ThriftFieldState

+ const ThriftMsgTypeCall

+ const ThriftMsgTypeException

+ const ThriftMsgTypeOneway

+ const ThriftMsgTypeReply

+ const ThriftProtocol

+ const ThriftStartState

+ const ThriftTBinary

+ const ThriftTCompact

+ const ThriftTFramed

+ const ThriftTSocket

+ const ThriftTypeBool

+ const ThriftTypeByte

+ const ThriftTypeDouble

+ const ThriftTypeI16

+ const ThriftTypeI32

+ const ThriftTypeI64

+ const ThriftTypeList

+ const ThriftTypeMap

+ const ThriftTypeMask

+ const ThriftTypeSet

+ const ThriftTypeStop

+ const ThriftTypeString

+ const ThriftTypeStruct

+ const ThriftTypeUtf16

+ const ThriftTypeUtf8

+ const ThriftTypeVoid

+ const ThriftVersion1

+ const ThriftVersionMask

+ func BuildMethodsMap(thrift_files map[string]parser.Thrift) map[string]*ThriftIdlMethod

+ func ReadFiles(files []string) (map[string]parser.Thrift, error)

type Event

+ Thrift bson.M

+ type RedisDataType uint16

+ const RedisChannelType

+ const RedisListType

type RedisOutputType

+ DataType RedisDataType

+ type Thrift struct

+ CaptureReply bool

+ CollectionMaxSize int

+ DropAfterNStructFields int

+ Idl *ThriftIdl

+ ObfuscateStrings bool

+ ProtocolType byte

+ PublishQueue chan *ThriftTransaction

+ Publisher *PublisherType

+ Send_request bool

+ Send_response bool

+ StringMaxSize int

+ TransportType byte

+ var ThriftMod Thrift

+ func (thrift *Thrift) Init(test_mode bool) error

+ func (thrift *Thrift) InitDefaults()

+ func (thrift *Thrift) Parse(pkt *Packet, tcp *TcpStream, dir uint8)

+ func (thrift *Thrift) ReceivedFin(tcp *TcpStream, dir uint8)

+ type ThriftField struct

+ Id uint16

+ Type byte

+ Value string

+ type ThriftFieldReader func(data []byte) (value string, ok bool, complete bool, off int)

+ type ThriftIdl struct

+ MethodsByName map[string]*ThriftIdlMethod

+ func NewThriftIdl(idl_files []string) (*ThriftIdl, error)

+ func (thriftidl *ThriftIdl) FindMethod(name string) *ThriftIdlMethod

+ type ThriftIdlMethod struct

+ Exceptions []*string

+ Method *parser.Method

+ Params []*string

+ Service *parser.Service

+ type ThriftMessage struct

+ CmdlineTuple *CmdlineTuple

+ Direction uint8

+ Exceptions string

+ FrameSize uint32

+ HasException bool

+ IsRequest bool

+ Method string

+ Params string

+ ReturnValue string

+ SeqId uint32

+ Service string

+ Stream_id uint32

+ Ts time.Time

+ Tuple *IpPortTuple

+ Type uint32

+ Version uint32

+ func (m *ThriftMessage) String() string

+ type ThriftStream struct

+ func (stream *ThriftStream) PrepareForNewMessage(flush bool)

+ type ThriftTransaction struct

+ Dst Endpoint

+ JsTs time.Time

+ Reply *ThriftMessage

+ Request *ThriftMessage

+ ResponseTime int32

+ Src Endpoint

+ Ts int64

+ Type string

Sep 18, 2014

Changes in this version

+ const FileOutputName

+ const RotatorMaxFiles

+ func Bytes_Htohl(b []byte) uint32

+ func GapInPgsqlStream(tcp *TcpStream, dir uint8)

+ func PgsqlMessageHasEnoughData(msg *PgsqlMessage) bool

+ type FileOutputType struct

+ var FileOutput FileOutputType

+ func (out *FileOutputType) Init(config tomlMothership) error

+ func (out *FileOutputType) PublishEvent(event *Event) error

+ func (out *FileOutputType) PublishIPs(name string, localAddrs []string) error

+ func (out *FileOutputType) UpdateLocalTopologyMap()

+ type FileRotator struct

+ KeepFiles int

+ Name string

+ Path string

+ RotateEveryBytes uint64

+ func (rotator *FileRotator) CheckIfConfigSane() error

+ func (rotator *FileRotator) CreateDirectory() error

+ func (rotator *FileRotator) FileExists(file_no int) bool

+ func (rotator *FileRotator) FilePath(file_no int) string

+ func (rotator *FileRotator) Rotate() error

+ func (rotator *FileRotator) WriteLine(line []byte) error

type HttpMessage

+ XForwardedFor string

type PgsqlMessage

+ Incomplete bool

type TcpStream

+ func (stream *TcpStream) GapInStream(original_dir uint8)

Aug 7, 2014

Changes in this version

type MysqlMessage

+ IgnoreMessage bool

Jul 13, 2014

Changes in this version

+ const ElasticsearchOutputName

+ const RedisOutputName

+ const TCP_MAX_DATA_IN_STREAM

+ type ElasticsearchOutputType struct

+ Index string

+ TopologyExpire int

+ TopologyMap map[string]string

+ var ElasticsearchOutput ElasticsearchOutputType

+ func (out *ElasticsearchOutputType) EnableTTL() error

+ func (out *ElasticsearchOutputType) GetNameByIP(ip string) string

+ func (out *ElasticsearchOutputType) Init(config tomlMothership) error

+ func (out *ElasticsearchOutputType) PublishEvent(event *Event) error

+ func (out *ElasticsearchOutputType) PublishIPs(name string, localAddrs []string) error

+ func (out *ElasticsearchOutputType) UpdateLocalTopologyMap()

+ type OutputInterface interface

+ GetNameByIP func(ip string) string

+ PublishEvent func(event *Event) error

+ PublishIPs func(name string, localAddrs []string) error

+ type PublishedTopology struct

+ IPs string

+ Name string

type PublisherType

+ Output []OutputInterface

+ TopologyOutput OutputInterface

+ type RedisOutputType struct

+ Client *redis.Client

+ Db int

+ DbTopology int

+ Hostname string

+ Index string

+ Password string

+ ReconnectInterval time.Duration

+ Timeout time.Duration

+ TopologyExpire time.Duration

+ TopologyMap map[string]string

+ var RedisOutput RedisOutputType

+ func (out *RedisOutputType) Close()

+ func (out *RedisOutputType) Connect() error

+ func (out *RedisOutputType) GetNameByIP(ip string) string

+ func (out *RedisOutputType) Init(config tomlMothership) error

+ func (out *RedisOutputType) PublishEvent(event *Event) error

+ func (out *RedisOutputType) PublishIPs(name string, localAddrs []string) error

+ func (out *RedisOutputType) Reconnect()

+ func (out *RedisOutputType) SendMessagesGoroutine()

+ func (out *RedisOutputType) UpdateLocalTopologyMap(client *redis.Client)

+ type RedisQueueMsg struct

Jun 10, 2014

Changes in this version

+ const ERROR_STATUS

+ const OK_STATUS

+ func LocalIpAddrs() ([]net.IP, error)

+ func LocalIpAddrsAsStrings(include_loopbacks bool) ([]string, error)

type Event

+ Agent string

type HttpMessage

+ FirstLine string

type PublisherType

+ Index string

May 21, 2014

Changes in this version

+ const CancelRequest

+ const PgsqlGetDataState

+ const PgsqlProtocol

+ const PgsqlStartState

+ const SSLRequest

+ const StartupMessage

+ const Version

+ var RedisCommands = map[string]struct

+ func ParsePgsql(pkt *Packet, tcp *TcpStream, dir uint8)

+ func TcpSeqBefore(seq1 uint32, seq2 uint32) bool

+ type Endpoint struct

+ Cmdline string

+ Ip string

+ Name string

+ Port uint16

+ Proc string

type Event

+ Pgsql bson.M

+ type PgsqlMessage struct

+ CmdlineTuple *CmdlineTuple

+ Direction uint8

+ ErrorCode string

+ ErrorInfo string

+ ErrorSeverity string

+ Fields []string

+ FieldsFormat []byte

+ IsError bool

+ IsOK bool

+ IsRequest bool

+ NumberOfFields int

+ NumberOfRows int

+ Query string

+ Rows [][]string

+ Size uint64

+ Stream_id uint32

+ Ts time.Time

+ Tuple *IpPortTuple

+ type PgsqlStream struct

+ func (stream *PgsqlStream) PrepareForNewMessage()

+ type PgsqlTransaction struct

+ Dst Endpoint

+ JsTs time.Time

+ Pgsql bson.M

+ Request_raw string

+ ResponseTime int32

+ Response_raw string

+ Src Endpoint

+ Ts int64

+ Type string

+ func (trans *PgsqlTransaction) Expire()

+ type Priority int

+ const LOG_ALERT

+ const LOG_CRIT

+ const LOG_DEBUG

+ const LOG_EMERG

+ const LOG_ERR

+ const LOG_INFO

+ const LOG_NOTICE

+ const LOG_WARNING

type PublisherType

+ func (publisher *PublisherType) PublishEvent(ts time.Time, src *Endpoint, dst *Endpoint, event *Event) error

+ func (publisher *PublisherType) PublishPgsqlTransaction(t *PgsqlTransaction) error

type TcpTuple

+ func (t TcpTuple) String() string

May 9, 2014

Changes in this version

+ func IS_DEBUG(selector string) bool

+ func PrintPublishEvent(event *Event)

+ func RECOVER(msg string)

type MysqlMessage

+ PacketLength uint32

Apr 23, 2014

Changes in this version

+ const AGENT_USE_TLS

+ const BODY

+ const BODY_CHUNKED

+ const BODY_CHUNKED_START

+ const FLINE

+ const HEADERS

+ const HTTP_FLAGS_DIR_INITIAL

+ const HTTP_FLAGS_IS_REQUEST

+ const HTTP_VERSION

+ const HttpProtocol

+ const MAX_PAYLOAD_SIZE

+ const MSG_TYPE_HELLO

+ const MSG_TYPE_HELLO_RESP

+ const MSG_TYPE_HTTP

+ const MSG_TYPE_HTTP_TRANSACTION

+ const MSG_TYPE_MYSQL

+ const MSG_TYPE_MYSQL_TRANSACTION

+ const MSG_TYPE_NOP

+ const MSG_TYPE_REDIS

+ const MSG_TYPE_REDIS_TRANSACTION

+ const MSG_TYPE_REPORT

+ const MYSQL_CMD_QUERY

+ const MYSQL_FLAGS_DIR_INITIAL

+ const MYSQL_FLAGS_IS_REQUEST

+ const MYSQL_FLAGS_IS_TRUNCATED

+ const MYSQL_VERSION

+ const MysqlProtocol

+ const MysqlStateEatFields

+ const MysqlStateEatMessage

+ const MysqlStateEatRows

+ const MysqlStateStart

+ const REDIS_FLAGS_DIR_INITIAL

+ const REDIS_FLAGS_IS_REQUEST

+ const REDIS_VERSION

+ const RedisProtocol

+ const START

+ const TCP_FLAG_ACK

+ const TCP_FLAG_FIN

+ const TCP_FLAG_PSH

+ const TCP_FLAG_RST

+ const TCP_FLAG_SYN

+ const TCP_FLAG_URG

+ const TCP_STREAM_EXPIRY

+ const TCP_STREAM_HASH_SIZE

+ const TransactionTimeout

+ const TransactionsHashSize

+ const UnknownProtocol

+ const VERSION

+ func Bytes_Ipv4_Ntoa(bytes []byte) string

+ func Bytes_Ntohl(b []byte) uint32

+ func Bytes_Ntohll(b []byte) uint64

+ func Bytes_Ntohs(b []byte) uint16

+ func CRIT(format string, v ...interface{})

+ func DEBUG(selector string, format string, v ...interface{})

+ func DropPrivileges() error

+ func ERR(format string, v ...interface{})

+ func FindPidsByCmdline(prefix string, processes []string) ([]int, error)

+ func FindPidsByCmdlineGrep(prefix string, process string) ([]int, error)

+ func FindSocketsOfPid(prefix string, pid int) (inodes []int64, err error)

+ func Find_CommandLine_By_Port(port_pid_map PortPidMap, port uint16) (cmdline []byte, err error)

+ func Find_Sockets_Of_Process(pid int) (inodes []int, err error)

+ func FollowTcp(tcphdr []byte, pkt *Packet)

+ func GetId() uint32

+ func HttpReceivedFin(tcp *TcpStream, dir uint8)

+ func INFO(format string, v ...interface{})

+ func Ipv4_Ntoa(ip uint32) string

+ func IsLoopback(ip_str string) (bool, error)

+ func LocalAddrs() ([]string, error)

+ func LogInit(level syslog.Priority, prefix string, toSyslog bool, debugSelectors []string)

+ func MsgError(format string, v ...interface{}) error

+ func ParseHttp(pkt *Packet, tcp *TcpStream, dir uint8)

+ func ParseMysql(pkt *Packet, tcp *TcpStream, dir uint8)

+ func ParseRedis(pkt *Packet, tcp *TcpStream, dir uint8)

+ func PrintNewSockets(sockChan chan NewSocketCreated)

+ func PrintTcpMap()

+ func ReadSocketLink(path string) (int, error)

+ func TcpInit() error

+ func WARN(format string, v ...interface{})

+ func WTF(format string, v ...interface{})

+ func WatchForSockets(prefix string, pid int, sockChan chan NewSocketCreated)

+ type CmdlineTuple struct

+ Dst []byte

+ Src []byte

+ type DbEndpoint struct

+ Cmdline string

+ Ip string

+ Name string

+ Port uint16

+ Proc string

+ type Directory interface

+ Readdirnames func(n int) (names []string, err error)

+ type Event struct

+ Dst_ip string

+ Dst_port uint16

+ Dst_proc string

+ Dst_server string

+ Http bson.M

+ Mysql bson.M

+ Redis bson.M

+ RequestRaw string

+ ResponseRaw string

+ ResponseTime int32

+ Src_country string

+ Src_ip string

+ Src_port uint16

+ Src_proc string

+ Src_server string

+ Status string

+ Timestamp time.Time

+ Type string

+ type GenericError struct

+ func (err GenericError) Error() string

+ type HelloMessage struct

+ Authstr []byte

+ Flags uint16

+ Name []byte

+ Version uint16

+ type HelloRespMessage struct

+ Flags uint16

+ Msg []byte

+ Response_code uint8

+ type HttpMessage struct

+ CmdlineTuple *CmdlineTuple

+ ContentLength int

+ ContentType string

+ Direction uint8

+ Host string

+ IsRequest bool

+ Method string

+ Raw []byte

+ ReasonPhrase string

+ RequestUri string

+ StatusCode uint16

+ Stream_id uint32

+ Ts time.Time

+ Tuple *IpPortTuple

+ type HttpStream struct

+ func (stream *HttpStream) PrepareForNewMessage()

+ type HttpTransaction struct

+ Dst DbEndpoint

+ Http bson.M

+ JsTs time.Time

+ Request_raw string

+ ResponseTime int32

+ Response_raw string

+ Src DbEndpoint

+ Ts int64

+ Type string

+ func (trans *HttpTransaction) Expire()

+ type InodePidMap map[int]int

+ func Generate_InodePidMap() (inode_pid_map InodePidMap, err error)

+ type IpPortTuple struct

+ Dst_ip uint32

+ Dst_port uint16

+ Src_ip uint32

+ Src_port uint16

+ type Logger struct

+ type MsgHeader struct

+ Ts MsgTime

+ Typ uint16

+ type MsgTime struct

+ Nsec int32

+ Sec int64

+ func NewMsgTime(ts time.Time) MsgTime

+ func (msgtime *MsgTime) Time() time.Time

+ type MysqlMessage struct

+ AffectedRows int

+ CmdlineTuple *CmdlineTuple

+ Direction uint8

+ ErrorCode int

+ ErrorInfo string

+ FieldLength uint32

+ Fields []string

+ InsertId int

+ IsError bool

+ IsOK bool

+ IsRequest bool

+ IsTruncated bool

+ Number int

+ NumberOfFields int

+ NumberOfRows int

+ Query string

+ Raw []byte

+ Rows [][]string

+ Seq uint8

+ Size uint64

+ Stream_id uint32

+ Tables string

+ Ts time.Time

+ Tuple *IpPortTuple

+ Typ uint8

+ type MysqlStream struct

+ func (stream *MysqlStream) PrepareForNewMessage()

+ type MysqlTransaction struct

+ Dst DbEndpoint

+ JsTs time.Time

+ Mysql bson.M

+ Request_raw string

+ ResponseTime int32

+ Response_raw string

+ Src DbEndpoint

+ Ts int64

+ Type string

+ func (trans *MysqlTransaction) Expire()

+ type NewSocketCreated struct

+ Inode int

+ Pid int

+ type Packet struct

+ type ParserStream interface

+ AddData func([]byte)

+ Message func() interface{}

+ Parse func() (bool, bool)

+ Reset func()

+ type PortCmdlineMap map[uint16]string

+ type PortPidMap map[uint16]int

+ func Generate_PortPidMap() (port_pid_map PortPidMap, err error)

+ type PortProcMapping struct

+ Pid int

+ Port uint16

+ Proc *Process

+ type Process struct

+ Grepper string

+ Name string

+ Pids []int

+ RefreshPidsTimer <-chan time.Time

+ func NewProcess(proc *ProcessesWatcher, name string, grepper string, ...) (*Process, error)

+ func (p *Process) RefreshPids()

+ type ProcessesWatcher struct

+ LastMapUpdate time.Time

+ LocalAddrs []net.IP

+ MaxReadFreq time.Duration

+ PortProcMap map[uint16]PortProcMapping

+ Processes []*Process

+ ReadFromProc bool

+ RefreshPidsFreq time.Duration

+ TestSignals chan bool

+ func (proc *ProcessesWatcher) FindProc(port uint16) string

+ func (proc *ProcessesWatcher) FindProcessesTuple(tuple *IpPortTuple) (proc_tuple *CmdlineTuple)

+ func (proc *ProcessesWatcher) Init(config *tomlProcs) error

+ func (proc *ProcessesWatcher) IsLocalIp(ip uint32) bool

+ func (proc *ProcessesWatcher) UpdateMap()

+ func (proc *ProcessesWatcher) UpdateMappingEntry(port uint16, pid int, p *Process)

+ type PublishMessage struct

+ CmdlineTuple *CmdlineTuple

+ Data []byte

+ Flags uint16

+ Raw []byte

+ Stream_id uint32

+ Tuple *IpPortTuple

+ Version uint16

+ type PublishTransaction struct

+ Data []byte

+ type PublisherType struct

+ RefreshTopologyTimer <-chan time.Time

+ TopologyMap map[string]string

+ var Publisher PublisherType

+ func (publisher *PublisherType) GetServerName(ip string) string

+ func (publisher *PublisherType) Init() error

+ func (publisher *PublisherType) PublishHttpTransaction(t *HttpTransaction) error

+ func (publisher *PublisherType) PublishMysqlTransaction(t *MysqlTransaction) error

+ func (publisher *PublisherType) PublishRedisTransaction(t *RedisTransaction) error

+ func (publisher *PublisherType) PublishTopology(params ...string) error

+ func (publisher *PublisherType) UpdateTopology()

+ func (publisher *PublisherType) UpdateTopologyPeriodically()

+ type RedisMessage struct

+ Bulks []string

+ CmdlineTuple *CmdlineTuple

+ Direction uint8

+ IsRequest bool

+ Message string

+ NumberOfBulks int64

+ Stream_id uint32

+ Ts time.Time

+ Tuple *IpPortTuple

+ type RedisStream struct

+ func (stream *RedisStream) PrepareForNewMessage()

+ type RedisTransaction struct

+ Dst DbEndpoint

+ JsTs time.Time

+ Redis bson.M

+ Request_raw string

+ ResponseTime int32

+ Response_raw string

+ Src DbEndpoint

+ Ts int64

+ Type string

+ func (trans *RedisTransaction) Expire()

+ type ReportMessage struct

+ Msg []byte

+ type SocketInfo struct

+ Dst_ip uint32

+ Dst_port uint16

+ Inode int64

+ Src_ip uint32

+ Src_port uint16

+ Uid uint16

+ func Parse_Proc_Net_Tcp(input io.Reader) ([]*SocketInfo, error)

+ type SocketsType struct

+ NewSockChan chan NewSocketCreated

+ Processes []string

+ ReadFromCsvFile bool

+ ReadFromProc bool

+ SleepTime time.Duration

+ var Sockets SocketsType

+ func (sockets *SocketsType) BuildPortsMap()

+ func (sockets *SocketsType) Find_Cmdlines(tuple *IpPortTuple) (cmdline_tuple *CmdlineTuple)

+ func (sockets *SocketsType) ReadFromCsv(csv_file string)

+ func (sockets *SocketsType) SetupProcessMonitoring()

+ type TcpStream struct

+ func (stream *TcpStream) AddPacket(pkt *Packet, flags uint8, original_dir uint8)

+ func (stream *TcpStream) Expire()

+ type TcpTuple struct

+ Dst_ip uint32

+ Dst_port uint16

+ Src_ip uint32

+ Src_port uint16

+ type Topology struct

+ Ip string

+ Name string