in pkg/integrations/rawtemplate.go [158:178]
func (c *rawYAMLConfig) validate() error {
if len(c.Pipelines) == 0 {
return errors.New("missing pipelines")
}
for _, pipeline := range c.Pipelines {
if pipeline.Receiver != nil {
if _, found := c.Receivers[*pipeline.Receiver]; !found {
return fmt.Errorf("receiver %q not defined", pipeline.Receiver.String())
}
}
for _, processor := range pipeline.Processors {
if _, found := c.Processors[processor]; !found {
return fmt.Errorf("processor %q not defined", processor.String())
}
}
}
return nil
}