schema

Documentation

Index

• type Config
• type Converter
  • func NewConverter(cfg Config, in ...agent.MessageSource) Converter
  • func (c Converter) Output() <-chan broker.Message
• type Encoding
• type ExitSignalApp
• type MessageSource
• type Monitor
• type Persistor

Types

type Config

type Config struct {
	Monitor     Monitor
	Persistor   Persistor
	App         ExitSignalApp
	Username    string
	UserVersion string
	AppID       string
	MacHash     string
	Encoding    Encoding
}

Config provides parameters needed by a Converter.

type Converter

type Converter struct {
	Config
	// contains filtered or unexported fields
}

Converter converts a stream of agent.Message to a stream of broker.Message.

func NewConverter

func NewConverter(cfg Config, in ...agent.MessageSource) Converter

NewConverter returns a converter for the given input streams that uses the given persistor and app.

func (Converter) Output

func (c Converter) Output() <-chan broker.Message

Output returns the converter's output stream.

type Encoding

type Encoding int

Encoding represents the serialization encoding.

const (
	MsgPack Encoding = iota
	JSON
)

These are the available encodings.

type ExitSignalApp

type ExitSignalApp interface {
	AgentVersion() string
	CheckSum() string
	ExitStatus() int
	Signal() string
}

ExitSignalApp is an App that has a signal and exit status.

type MessageSource

type MessageSource interface {
	Output() <-chan agent.Message
}

MessageSource is a source of agent messages.

type Monitor

type Monitor interface {
	GetMetrics() device.Metrics
	Close()
}

Monitor provides system metrics.

type Persistor

type Persistor interface {
	CreateMessage(*broker.Message) error
}

Persistor provides a persistor interface.