common

May 17, 2019

Changes in this version

+ var ProbeTypes = []string

+ func ParseAddr(address string) (protocol string, target string, err error)

Mar 21, 2019

Changes in this version

+ type MasterElection interface

+ AddEventListener func(listener MasterElectionListener)

+ IsMaster func() bool

+ Start func()

+ StartAndWait func()

+ Stop func()

+ TTL func() time.Duration

+ type MasterElectionListener interface

+ OnStartAsMaster func()

+ OnStartAsSlave func()

+ OnSwitchToMaster func()

+ OnSwitchToSlave func()

+ type MasterElectionService interface

+ NewElection func(key string) MasterElection

+ type Service struct

+ ID string

+ Type ServiceType

Dec 3, 2018

Changes in this version

+ func GetFieldKeys(obj map[string]interface{}) []string

+ func LookupPath(obj interface{}, path string, kind reflect.Kind) (reflect.Value, bool)

+ func SetupTLSLoadCA(certPEM string) (*x509.CertPool, error)

+ type Getter interface

+ GetField func(field string) (interface{}, error)

+ GetFieldInt64 func(field string) (int64, error)

+ GetFieldKeys func() []string

+ GetFieldString func(field string) (string, error)

type Metric

+ GetFieldKeys func() []string

+ type ProcessInfo struct

+ CStime int64

+ CUtime int64

+ Name string

+ Nice int64

+ PGrp int64

+ PPid int64

+ Pid int64

+ Priority int64

+ Process string

+ RSS int64

+ Session int64

+ Start int64

+ State ProcessState

+ Stime int64

+ Threads int64

+ Utime int64

+ Vsize int64

+ func GetProcessInfo(pid int) (*ProcessInfo, error)

+ type ProcessState rune

+ const Dead

+ const Running

+ const Sleeping

+ const Stopped

+ const TracingStop

+ const Waiting

+ const Zombie

Dec 17, 2018

Changes in this version

+ func RandString(n int) string

Sep 14, 2018

Changes in this version

+ func NormalizeIPForURL(ip net.IP) string

+ func StructFieldKeys(i interface{}) []string

type Metric

+ GetFields func() []string

Jun 21, 2018

Changes in this version

+ const AllPackets

+ const OnlyIPPackets

+ func RetryExponential(fnc func() error, try int, baseDelay time.Duration) error

type Metric

+ IsZero func() bool

+ Split func(cut int64) (Metric, Metric)

+ Sub func(m Metric) Metric

+ type RWMutex struct

Jan 29, 2018

Changes in this version

+ const BPFCapability

+ const ExtraTCPMetricCapability

+ const RawPacketsCapability

+ var ErrNotImplemented = errors.New("Not implemented")

+ var ProbeCapabilities = map[string]ProbeCapability

+ func CheckProbeCapabilities(probeType string, capability ProbeCapability) bool

+ func GetFields(obj map[string]interface{}) ([]string, error)

+ func IsIPv6(str string) bool

+ func NormalizeAddrForURL(addr string) string

+ func NormalizeIPForUrl(ip net.IP) string

+ func NormalizeValue(obj interface{}) interface

+ func ProbeTypeForNode(nodeTYpe string, captureType string) (string, error)

+ type Debouncer struct

+ func NewDebouncer(interval time.Duration, callback func()) *Debouncer

+ func (d *Debouncer) Call()

+ func (d *Debouncer) Start()

+ func (d *Debouncer) Stop()

type Metric

+ GetLast func() int64

+ GetStart func() int64

+ SetLast func(last int64)

+ SetStart func(start int64)

+ type ProbeCapability int

type RawSocket

+ func (s *RawSocket) Write(data []byte) (int, error)

type ServiceAddress

+ func (sa ServiceAddress) String() string

Oct 12, 2017

Changes in this version

+ var ErrNotFound = errors.New("No result found")

+ var ErrTimeout = errors.New("Timeout")

+ func IPV4CIDRToRegex(cidr string) (string, error)

+ func RangeToRegex(min, max int) string

type ServiceType

+ const UnknownService

Aug 1, 2017

Changes in this version

+ var ErrCantCompareInterface = errors.New("Can't compare interface")

+ var ErrFieldNotFound = errors.New("Field not found")

+ var ErrFieldWrongType = errors.New("Field has wrong type")

+ var ErrInvalidPortRange = errors.New("Invalid port range")

+ var ErrNoPortLeft = errors.New("No free port left")

+ func DelField(obj map[string]interface{}, k string) interface

+ func GetField(obj map[string]interface{}, k string) (interface{}, error)

+ func JSONDecode(r io.Reader, i interface{}) error

+ func SetField(obj map[string]interface{}, k string, v interface{}) bool

+ func SetupTLSClientConfig(certPEM string, keyPEM string) *tls.Config

+ func SetupTLSLoadCertificate(certPEM string) *x509.CertPool

+ func SetupTLSServerConfig(certPEM string, keyPEM string) *tls.Config

+ func UnixMillis(t time.Time) int64

+ type Metric interface

+ Add func(m Metric) Metric

+ GetFieldInt64 func(field string) (int64, error)

+ type PortAllocator struct

+ MaxPort int

+ MinPort int

+ PortMap map[int]interface{}

+ func NewPortAllocator(min, max int) (*PortAllocator, error)

+ func (p *PortAllocator) Allocate() (int, error)

+ func (p *PortAllocator) Release(i int) error

+ func (p *PortAllocator) ReleaseAll()

+ func (p *PortAllocator) Set(i int, obj interface{}) error

+ type RawSocket struct

+ func NewRawSocket(ifName string) (*RawSocket, error)

+ func NewRawSocketInNs(nsPath string, ifName string) (*RawSocket, error)

+ func (s *RawSocket) Close() error

+ func (s *RawSocket) GetFd() int

+ type ServiceAddress struct

+ Addr string

+ Port int

+ func ServiceAddressFromString(addressPort string) (ServiceAddress, error)

+ type ServiceType string

+ const AgentService

+ const AnalyzerService

+ func (st ServiceType) String() string

+ type SortOrder string

+ const SortAscending

+ const SortDescending

+ type TimeSlice struct

+ Last int64

+ Start int64

+ func NewTimeSlice(s, l int64) *TimeSlice

+ type TimedMetric struct

+ Metric Metric

+ func (tm *TimedMetric) GetFieldInt64(field string) (int64, error)

+ func (tm *TimedMetric) MarshalJSON() ([]byte, error)

Jan 27, 2017

Changes in this version

+ func IPToString(ip net.IP) string

+ func IPv6Supported() bool

+ func ToFloat64(f interface{}) (float64, error)

+ func ToInt64(i interface{}) (int64, error)

+ type CaptureType struct

+ Allowed []string

+ Default string

+ type Iterator struct

+ func NewIterator(values ...int64) (it *Iterator)

+ func (it *Iterator) Done() bool

+ func (it *Iterator) Next() bool

+ type NetNSContext struct

+ func NewNetNsContext(path string) (*NetNSContext, error)

+ func (n *NetNSContext) Close()

+ func (n *NetNSContext) Quit() error

Sep 15, 2016

Changes in this version

+ const RunningState

+ const StoppedState

+ const StoppingState

+ var CantCompareInterface error = errors.New("Can't compare interface")

+ var CaptureTypes = map[string]map[string][]string

+ func CrossTypeCompare(a interface{}, b interface{}) (int, error)

+ func CrossTypeEqual(a interface{}, b interface{}) bool

+ func IsCaptureAllowed(nodeType string) bool

+ func MaxInt64(a, b int64) int64

+ func MinInt64(a, b int64) int64

+ func Retry(fnc func() error, try int, delay time.Duration) error