pipeline

type Msg ¶

type Msg struct {
	Msg     proto.Message
	Meta    outputs.Meta
	Events  []*formatters.EventMsg
	Outputs map[string]struct{}
}

Msg contains the data to be passed from targets or inputs to outputs.

func NewMsg(msg proto.Message, meta outputs.Meta,
	events []*formatters.EventMsg,
	outputs map[string]struct{}) *Msg