in dev/import-beats/policy_templates.go [81:108]
func updatePolicyTemplate(dsc policyTemplateContent, params updatePolicyTemplateParameters) (policyTemplateContent, error) {
dsc.moduleName = params.moduleName
dsc.moduleTitle = params.moduleTitle
if dsc.inputs == nil {
dsc.inputs = map[string]policyTemplateInput{}
}
for _, dataStream := range params.dataStreams {
for _, stream := range dataStream.manifest.Streams {
inputType := stream.Input
v, ok := dsc.inputs[inputType]
if !ok {
v = policyTemplateInput{
packageType: params.packageType,
inputType: inputType,
vars: params.inputVars[inputType],
}
}
v.dataStreamNames = append(v.dataStreamNames, dataStream.name)
dsc.inputs[inputType] = v
}
}
return dsc, nil
}