in pkg/integrations/integrations.go [110:130]
func (c *Config) 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 %s 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
}