common

Nov 15, 2019

Changes in this version

type ServiceType

+ const SeedService

Sep 12, 2019

Changes in this version

+ type ServiceState int64

+ const StartingState

+ func (s *ServiceState) CompareAndSwap(old, new ServiceState) bool

+ func (s *ServiceState) Load() ServiceState

+ func (s *ServiceState) MarshalJSON() ([]byte, error)

+ func (s *ServiceState) Store(state ServiceState)

Jul 16, 2019

Changes in this version

+ const MultipleOnSameNodeCapability

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

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

+ func IPStrToUint32(ipAddr string) (uint32, error)

+ func NormalizeIP(ip, ipFamily string) string

+ func Profile()

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

+ type BoolPredicate func(b bool) bool

type Getter

+ GetFieldBool func(field string) (bool, error)

+ MatchBool func(field string, predicate BoolPredicate) bool

+ MatchInt64 func(field string, predicate Int64Predicate) bool

+ MatchString func(field string, predicate StringPredicate) bool

+ type Int64Predicate func(i int64) bool

+ type StringPredicate func(s string) bool

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

Oct 9, 2018

Changes in this version

+ func RandString(n int) string

Aug 8, 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

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

+ type RWMutex struct

Apr 12, 2018

Changes in this version

+ const AllPackets

+ const OnlyIPPackets

type Metric

+ IsZero func() bool

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

+ Sub func(m Metric) Metric

Jan 29, 2018

Changes in this version

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

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

+ 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 RawSocket

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

Dec 6, 2017

Changes in this version

+ const BPFCapability

+ const ExtraTCPMetricCapability

+ const RawPacketsCapability

+ var ProbeCapabilities = map[string]ProbeCapability

+ func CheckProbeCapabilities(probeType string, capability ProbeCapability) bool

+ func IsIPv6(str string) bool

+ func NormalizeAddrForURL(addr string) string

+ func NormalizeIPForUrl(ip net.IP) string

+ type ProbeCapability int

Nov 14, 2017

Changes in this version

+ func NormalizeValue(v interface{}) interface

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

type Metric

+ GetFieldInt64 func(field string) (int64, 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 TimedMetric

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

Mar 31, 2017

Changes in this version

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

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

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

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

+ func UnixMillis(t time.Time) int64

+ type Metric interface

+ Add func(m Metric) Metric

+ GetField 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)

+ func (p *PortAllocator) ReleaseAll()

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

+ 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) GetField(field string) (int64, error)

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

Dec 9, 2016

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 NetNSContext struct

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

+ func (n *NetNSContext) Close()

+ func (n *NetNSContext) Quit() error

Nov 8, 2016

Changes in this version

+ type CaptureType struct

+ Allowed []string

+ Default string

Oct 6, 2016

Changes in this version

+ type Iterator struct

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

+ func (it *Iterator) Done() bool

+ func (it *Iterator) Next() bool

Sep 15, 2016

Changes in this version

+ 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 IsCaptureAllowed(nodeType string) bool

Aug 4, 2016

Changes in this version

+ const RunningState

+ const StoppedState

+ const StoppingState

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

+ func MaxInt64(a, b int64) int64

+ func MinInt64(a, b int64) int64

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