Versions in this module Expand all Collapse all v0 v0.1.0 Oct 19, 2020 Changes in this version + func GetDefaultOutput(sensors []*config.Sensor) string + func GetGNMISubscriptions(sensors []*config.Sensor) []*gpb.Subscription + func GetKey(buf *bytes.Buffer, path []*gpb.PathElem) (string, map[string]string) + func GetPathOutput(sensors []*config.Sensor) map[string]string + func GetValue(tv *gpb.TypedValue) (interface{}, error) + func MergeLabels(keyLabels, prefixLabels map[string]string, prefix string) map[string]string + type DataStore map[string]interface + type DeviceFilterOpt func(config.Device) bool + type DeviceFilterOpts struct + type ExtDSChan chan ExtDataStore + type ExtDataStore struct + DS DataStore + Output string + type NMI interface + Start func(context.Context) error + type NMIFactory func(*zap.Logger, *grpc.ClientConn, []*config.Sensor, ExtDSChan) NMI + type Registrar struct + func NewRegistrar(lg *zap.Logger) *Registrar + func (tr *Registrar) GetNMIFactory(name string) (NMIFactory, bool) + func (tr *Registrar) Register(name, version string, tf NMIFactory) + type Telemetry struct + func New(ctx context.Context, cfg config.Config, tr *Registrar, outChan ExtDSChan) *Telemetry + func (t *Telemetry) AddFilterOpt(index string, filterOpt DeviceFilterOpt) + func (t *Telemetry) DelFilterOpt(index string) + func (t *Telemetry) GetDevices() []config.Device + func (t *Telemetry) Start() + func (t *Telemetry) Update()
Go to main page