func()

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
}