X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dmaap-mediator-producer%2Finternal%2Fjobtypes%2Fjobtypes.go;h=894c586ec87613402968bcdeeb46b7abf6d04546;hb=f300194deee749427175a05ed4af8bd563447ba0;hp=14d837debbe10196394edbea4669df2430a8b5e9;hpb=cce95ff706e7b7d703b0bf1cfa6ce855cc2d9b68;p=nonrtric.git diff --git a/dmaap-mediator-producer/internal/jobtypes/jobtypes.go b/dmaap-mediator-producer/internal/jobtypes/jobtypes.go index 14d837de..894c586e 100644 --- a/dmaap-mediator-producer/internal/jobtypes/jobtypes.go +++ b/dmaap-mediator-producer/internal/jobtypes/jobtypes.go @@ -27,11 +27,12 @@ import ( ) type Type struct { - Name string + TypeId string Schema string } var typeDir = "configs" +var supportedTypes = make([]string, 0) func GetTypes() ([]*Type, error) { types := make([]*Type, 0, 1) @@ -53,15 +54,21 @@ func GetTypes() ([]*Type, error) { return types, nil } +func GetSupportedTypes() []string { + return supportedTypes +} + func getType(path string) (*Type, error) { fileName := filepath.Base(path) typeName := strings.TrimSuffix(fileName, filepath.Ext(fileName)) if typeSchema, err := os.ReadFile(path); err == nil { - return &Type{ - Name: typeName, + typeInfo := Type{ + TypeId: typeName, Schema: string(typeSchema), - }, nil + } + supportedTypes = append(supportedTypes, typeName) + return &typeInfo, nil } else { return nil, err }