source

Jan 24, 2019

Changes in this version

type Listener

+ func (l *Listener) StoredSources() []core.Source

type Store

+ Do func(func(core.Source))

+ Len func() int

Jan 10, 2019

Changes in this version

type Config

+ MetricsExporter MetricsExporter

type Interface

+ func (i *Interface) SetMetricsExporter(exp MetricsExporter)

+ type MetricsExporter interface

+ SendDataFlow func(labels map[string]string, data *DataFlow)

Dec 22, 2018

Changes in this version

+ type Config struct

+ MetricsBroker MetricsBroker

+ Provider Provider

+ Store Store

type Conn

+ OnClose func()

+ OnRead func(df *DataFlow)

+ OnWrite func(df *DataFlow)

+ func (c *Conn) Read(p []byte) (int, error)

+ func (c *Conn) Write(p []byte) (int, error)

+ type DataFlow struct

+ Avg float64

+ EndedAt time.Time

+ N int

+ StartedAt time.Time

+ Type string

+ func (f *DataFlow) Start()

+ func (f *DataFlow) Stop(n int)

type Interface

+ func (i *Interface) SendMetrics(labels map[string]string, data *DataFlow)

+ func (i *Interface) SetMetricsBroker(br MetricsBroker)

type MergedProvider

+ ControlInterface func(ifi *Interface)

+ type MetricsBroker interface

+ SendDataFlow func(labels map[string]string, data *DataFlow)

Dec 13, 2018

Changes in this version

+ var PollInterval = time.Second * 3

+ var PollTimeout = time.Second * 5

+ func Diff(old, cur []core.Source) (add []core.Source, remove []core.Source)

+ func WithValue(parent core.Source, key interface{}, value interface{}) core.Source

+ type Confidence int

+ const High

+ const Low

+ type DialHook func(ref, network, address string, err error)

+ type Hooker struct

+ func (h *Hooker) Add(err *hookErr)

+ func (h *Hooker) HandleDialErr(ref, network, address string, err error)

+ func (h *Hooker) HookErr(id string) error

type Interface

+ OnDialErr DialHook

+ func (i *Interface) Name() string

+ func (i *Interface) Value(key interface{}) interface{}

+ type Listener struct

+ func NewListener(s Store) *Listener

+ func (l *Listener) Poll(ctx context.Context) error

+ func (l *Listener) Run(ctx context.Context) error

+ type Local struct

+ func (l *Local) Check(ctx context.Context, ifi *Interface, level Confidence) error

+ func (l *Local) Provide(ctx context.Context, level Confidence) ([]*Interface, error)

+ type MergedProvider struct

+ OnDialErr DialHook

+ func (p *MergedProvider) Check(ctx context.Context, src core.Source, level Confidence) error

+ func (p *MergedProvider) Provide(ctx context.Context) ([]core.Source, error)

+ type Provider interface

+ Check func(context.Context, core.Source, Confidence) error

+ Provide func(context.Context) ([]core.Source, error)

+ type Store interface

+ Del func(...core.Source)

+ GetActive func() []core.Source

+ Put func(...core.Source)

Nov 23, 2018

Changes in this version

type Interface

+ func (i *Interface) Close() error

+ func (i *Interface) Follow(c net.Conn) error

+ func (i *Interface) Len() int

Nov 8, 2018

Changes in this version

+ type Conn struct

+ Add func(val int) int

+ Ref string

+ func (c *Conn) Close() error

+ type Interface struct

+ ErrHook func(ref, network, address string, err error)

+ N int

+ func (i *Interface) Add(val int) int

+ func (i *Interface) DialContext(ctx context.Context, network, address string) (net.Conn, error)

+ func (i *Interface) ID() string

+ func (i *Interface) Metrics() map[string]interface{}

+ func (i *Interface) String() string