beats

module

Go to main page

Versions in this module

v1

v1.3.1

Sep 14, 2016

v1.3.0

Aug 30, 2016

v1.2.3

May 18, 2016

v1.2.2

Apr 26, 2016

v1.2.1

Apr 7, 2016

v1.2.0

Mar 30, 2016

v1.1.2

Mar 8, 2016

v1.1.1

Feb 11, 2016

v1.1.0

Feb 2, 2016

v1.0.0

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()

v1.0.0-rc2

Nov 17, 2015

v1.0.0-rc1

Nov 5, 2015

v1.0.0-beta4

Oct 22, 2015

v1.0.0-beta3

Sep 4, 2015

v1.0.0-beta2

Jul 13, 2015

v0

v0.5.0

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

v0.4.3

Jan 27, 2015

Changes in this version

+ const BODY_CHUNKED_WAIT_FINAL_CRLF

v0.4.2

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

v0.4.1

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

v0.4.0

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

v0.3.3

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)

v0.3.2

Aug 7, 2014

Changes in this version

type MysqlMessage

+ IgnoreMessage bool

v0.3.1

Jul 16, 2014

v0.3.0

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

v0.2.2

Jun 18, 2014

v0.2.1

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

v0.2.0

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

v0.1.1

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

v0.1.0

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

Incompatible versions in this module

v6.0.0-rc1+incompatible

Sep 25, 2017

v6.0.0-beta2+incompatible

Aug 28, 2017

v6.0.0-beta1+incompatible

Aug 2, 2017

v6.0.0-alpha2+incompatible

May 31, 2017

v6.0.0-alpha1+incompatible

May 5, 2017

v5.6.2+incompatible

Sep 18, 2017

v5.6.1+incompatible

Sep 11, 2017

v5.6.0+incompatible

Sep 6, 2017

v5.5.3+incompatible

Sep 6, 2017

v5.5.2+incompatible

Aug 8, 2017

v5.5.1+incompatible

Jul 18, 2017

v5.5.0+incompatible

Jul 6, 2017

v5.4.3+incompatible

Jun 21, 2017

v5.4.2+incompatible

Jun 14, 2017

v5.4.1+incompatible

May 29, 2017

v5.4.0+incompatible

Apr 28, 2017

v5.3.3+incompatible

May 4, 2017

v5.3.2+incompatible

Apr 24, 2017

v5.3.1+incompatible

Apr 12, 2017

v5.3.0+incompatible

Mar 22, 2017

v5.2.2+incompatible

Feb 24, 2017

v5.2.1+incompatible

Feb 9, 2017

v5.2.0+incompatible

Jan 24, 2017

v5.1.2+incompatible

Jan 10, 2017

v5.1.1+incompatible

Dec 6, 2016

v5.0.0-alpha5+incompatible

Aug 3, 2016

v5.0.0-alpha4+incompatible

Jun 30, 2016

v5.0.0-alpha3+incompatible

May 31, 2016

v5.0.0-alpha2+incompatible

May 2, 2016

v5.0.0-alpha1+incompatible

Apr 5, 2016

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL