testemit

Documentation

Overview

Copyright 2020 New Relic Corporation. All rights reserved. SPDX-License-Identifier: Apache-2.0

Index

• type EmittedData
• type RecordEmitter
  • func (t *RecordEmitter) Emit(metadata integration.Definition, extraLabels data.Map, ...) error
  • func (t *RecordEmitter) ExpectTimeout(pluginName string, timeout time.Duration) error
  • func (t *RecordEmitter) ReceiveFrom(pluginName string) (EmittedData, error)

Types

type EmittedData

type EmittedData struct {
	DataSet       protocol.PluginDataSetV3
	Metadata      integration.Definition
	ExtraLabels   data.Map
	EntityRewrite []data.EntityRewrite
}

EmittedData stores both PluginDataSetV3 metric and the plugin metadata

type RecordEmitter

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

RecordEmitter implements a test emitter that stores the submitted data as Plugins structs

func (*RecordEmitter) Emit

func (t *RecordEmitter) Emit(metadata integration.Definition, extraLabels data.Map, entityRewrite []data.EntityRewrite, json []byte) error

func (*RecordEmitter) ExpectTimeout

func (t *RecordEmitter) ExpectTimeout(pluginName string, timeout time.Duration) error

ExpectTimeout returns error if no timeout happens when listening for the plugin emissions. It embeds the emitted metric information in the error, if it has received it

func (*RecordEmitter) ReceiveFrom

func (t *RecordEmitter) ReceiveFrom(pluginName string) (EmittedData, error)