telemetry

package
v0.0.0-...-cdf0fd8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 18, 2022 License: CC0-1.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ModuleName = "telemetry"
)

Variables

This section is empty.

Functions

func RunAdditionalOperations

func RunAdditionalOperations(cfg types.Config) error

RunAdditionalOperations runs the module additional operations

Types

type Config

type Config struct {
	Port uint `yaml:"port"`
}

Config represents the configuration for the telemetry module

func NewConfig

func NewConfig(port uint) *Config

NewConfig allows to build a new Config instance

func ParseConfig

func ParseConfig(bytes []byte) (*Config, error)

ParseConfig allows to parse a byte array as a Config instance

type Module

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

Module represents the telemetry module

func NewModule

func NewModule(
	cfg types.Config,
	messagesParser messages.MessageAddressesParser,
	flowClient client.Proxy,
	encodingConfig *params.EncodingConfig, db *db.Db,
) *Module

NewModule returns a new Module implementation

func (*Module) Name

func (m *Module) Name() string

Name implements modules.Module

func (*Module) RunAdditionalOperations

func (m *Module) RunAdditionalOperations() error

RunAdditionalOperations implements modules.AdditionalOperationsModule

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL