Versions in this module Expand all Collapse all v1 v1.3.1 Sep 14, 2016 Changes in this version + const CLIENT_ERROR_STATUS + const ERROR_STATUS + const MaxIpPortTupleRawSize + const MaxTcpTupleRawSize + const OK_STATUS + const SERVER_ERROR_STATUS + const TsLayout + func Bytes_Htohl(b []byte) uint32 + func Bytes_Ntohl(b []byte) uint32 + func Bytes_Ntohll(b []byte) uint64 + func Bytes_Ntohs(b []byte) uint16 + func DumpInCSVFormat(fields []string, rows [][]string) string + func Ipv4_Ntoa(ip uint32) string + func IsLoopback(ip_str string) (bool, error) + func LoadGeoIPData(config Geoip) *libgeo.GeoIP + func LocalIpAddrs() ([]net.IP, error) + func LocalIpAddrsAsStrings(include_loopbacks bool) ([]string, error) + func ReadString(s []byte) (string, error) + type Cache struct + func NewCache(d time.Duration, initialSize int) *Cache + func NewCacheWithRemovalListener(d time.Duration, initialSize int, l RemovalListener) *Cache + func (c *Cache) CleanUp() int + func (c *Cache) Delete(k Key) Value + func (c *Cache) Entries() map[Key]Value + func (c *Cache) Get(k Key) Value + func (c *Cache) Put(k Key, v Value) Value + func (c *Cache) PutIfAbsent(k Key, v Value) Value + func (c *Cache) PutIfAbsentWithTimeout(k Key, v Value, timeout time.Duration) Value + func (c *Cache) PutWithTimeout(k Key, v Value, timeout time.Duration) Value + func (c *Cache) Replace(k Key, v Value) Value + func (c *Cache) ReplaceWithTimeout(k Key, v Value, timeout time.Duration) Value + func (c *Cache) Size() int + func (c *Cache) StartJanitor(interval time.Duration) + func (c *Cache) StopJanitor() + type CmdlineTuple struct + Dst []byte + Src []byte + type Endpoint struct + Cmdline string + Ip string + Name string + Port uint16 + Proc string + type Eventer interface + Event func(event MapStr) error + type Geoip struct + Paths *[]string + type HashableIpPortTuple [MaxIpPortTupleRawSize]byte + type HashableTcpTuple [MaxTcpTupleRawSize]byte + type IpPortTuple struct + Dst_ip net.IP + Dst_port uint16 + Ip_length int + Src_ip net.IP + Src_port uint16 + 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) Hashable() HashableIpPortTuple + func (t *IpPortTuple) RevHashable() HashableIpPortTuple + func (t *IpPortTuple) String() string + type Key interface + type MapStr map[string]interface + func (m MapStr) EnsureCountField() error + func (m MapStr) EnsureTimestampField(now func() time.Time) error + func (m MapStr) String() string + func (m MapStr) Update(d MapStr) + func (ms *MapStr) UnmarshalYAML(unmarshal func(interface{}) error) error + func MapStrUnion(dict1 MapStr, dict2 MapStr) MapStr + type NetString []byte + func (n NetString) MarshalText() ([]byte, error) + type RemovalListener func(k Key, v Value) + type TcpTuple struct + Dst_ip net.IP + Dst_port uint16 + Ip_length int + Src_ip net.IP + Src_port uint16 + Stream_id uint32 + func TcpTupleFromIpPort(t *IpPortTuple, tcp_id uint32) TcpTuple + func (t *TcpTuple) ComputeHashebles() + func (t *TcpTuple) Hashable() HashableTcpTuple + func (t TcpTuple) IpPort() *IpPortTuple + func (t TcpTuple) String() string + type Time time.Time + func MustParseTime(timespec string) Time + func ParseTime(timespec string) (Time, error) + func (t *Time) UnmarshalJSON(data []byte) (err error) + func (t Time) MarshalJSON() ([]byte, error) + type Value interface
Go to main page