mdt

Documentation

Index

• func New(logger *zap.Logger, conn *grpc.ClientConn, sensors []*config.Sensor, ...) telemetry.NMI
• func Version() string
• type Dialout
  • func NewDialout(ctx context.Context, cfg config.Config, outChan telemetry.ExtDSChan) *Dialout
  • func (m *Dialout) MdtDialout(stream dialout.GRPCMdtDialout_MdtDialoutServer) error
  • func (m *Dialout) Start() error
  • func (m *Dialout) Update()
• type MDT
  • func (m *MDT) Start(ctx context.Context) error

Functions

func New

func New(logger *zap.Logger, conn *grpc.ClientConn, sensors []*config.Sensor, outChan telemetry.ExtDSChan) telemetry.NMI

New returns new instance of NMI.

func Version

func Version() string

Version returns version

Types

type Dialout

type Dialout struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Dialout represents MDT dial-out.

func NewDialout

func NewDialout(ctx context.Context, cfg config.Config, outChan telemetry.ExtDSChan) *Dialout

NewDialout returns a new instance of MDT dial-out.

func (*Dialout) MdtDialout

func (m *Dialout) MdtDialout(stream dialout.GRPCMdtDialout_MdtDialoutServer) error

MdtDialout gets stream metrics and fan-out to workers.

func (*Dialout) Start

func (m *Dialout) Start() error

Start creates workers and starts gRPC server.

func (*Dialout) Update

func (m *Dialout) Update()

Update updates path to output once the configuration changed.

type MDT

type MDT struct {
	// contains filtered or unexported fields
}

MDT represents Model-Driven Telemetry.

func (*MDT) Start

func (m *MDT) Start(ctx context.Context) error

Start gets stream metrics and fan-out to workers.