@@ -27,6 +27,8 @@ import (
27
27
"github.com/redpanda-data/benthos/v4/public/bloblang"
28
28
"github.com/redpanda-data/benthos/v4/public/service"
29
29
30
+ "github.com/redpanda-data/connect/v4/public/schema"
31
+
30
32
_ "github.com/redpanda-data/connect/v4/public/components/all"
31
33
32
34
_ "embed"
@@ -50,6 +52,9 @@ var templateHTTPRaw string
50
52
//go:embed templates/logger.adoc.tmpl
51
53
var templateLoggerRaw string
52
54
55
+ //go:embed templates/redpanda.adoc.tmpl
56
+ var templateRedpandaRaw string
57
+
53
58
//go:embed templates/tests.adoc.tmpl
54
59
var templateTestsRaw string
55
60
62
67
templatePlugin * template.Template
63
68
templateHTTP * template.Template
64
69
templateLogger * template.Template
70
+ templateRedpanda * template.Template
65
71
templateTests * template.Template
66
72
templateTemplates * template.Template
67
73
)
@@ -72,6 +78,7 @@ func init() {
72
78
templatePlugin = template .Must (template .New ("plugin" ).Parse (templatePluginFieldsRaw + templatePluginRaw ))
73
79
templateHTTP = template .Must (template .New ("http" ).Parse (templatePluginFieldsRaw + templateHTTPRaw ))
74
80
templateLogger = template .Must (template .New ("logger" ).Parse (templatePluginFieldsRaw + templateLoggerRaw ))
81
+ templateRedpanda = template .Must (template .New ("redpanda" ).Parse (templatePluginFieldsRaw + templateRedpandaRaw ))
75
82
templateTests = template .Must (template .New ("tests" ).Parse (templatePluginFieldsRaw + templateTestsRaw ))
76
83
templateTemplates = template .Must (template .New ("templates" ).Parse (templatePluginFieldsRaw + templateTemplatesRaw ))
77
84
}
@@ -88,20 +95,24 @@ func create(t, path string, resBytes []byte) {
88
95
fmt .Printf ("Documentation for '%v' has changed, updating: %v\n " , t , path )
89
96
}
90
97
98
+ func getSchema () * service.ConfigSchema {
99
+ return schema .Standard ("" , "" )
100
+ }
101
+
91
102
func main () {
92
103
docsDir := "./docs/modules/components/pages"
93
104
flag .StringVar (& docsDir , "dir" , docsDir , "The directory to write docs to" )
94
105
flag .Parse ()
95
106
96
- service . GlobalEnvironment ().WalkInputs (viewForDir (path .Join (docsDir , "./inputs" )))
97
- service . GlobalEnvironment ().WalkBuffers (viewForDir (path .Join (docsDir , "./buffers" )))
98
- service . GlobalEnvironment ().WalkCaches (viewForDir (path .Join (docsDir , "./caches" )))
99
- service . GlobalEnvironment ().WalkMetrics (viewForDir (path .Join (docsDir , "./metrics" )))
100
- service . GlobalEnvironment ().WalkOutputs (viewForDir (path .Join (docsDir , "./outputs" )))
101
- service . GlobalEnvironment ().WalkProcessors (viewForDir (path .Join (docsDir , "./processors" )))
102
- service . GlobalEnvironment ().WalkRateLimits (viewForDir (path .Join (docsDir , "./rate_limits" )))
103
- service . GlobalEnvironment ().WalkTracers (viewForDir (path .Join (docsDir , "./tracers" )))
104
- service . GlobalEnvironment ().WalkScanners (viewForDir (path .Join (docsDir , "./scanners" )))
107
+ getSchema (). Environment ().WalkInputs (viewForDir (path .Join (docsDir , "./inputs" )))
108
+ getSchema (). Environment ().WalkBuffers (viewForDir (path .Join (docsDir , "./buffers" )))
109
+ getSchema (). Environment ().WalkCaches (viewForDir (path .Join (docsDir , "./caches" )))
110
+ getSchema (). Environment ().WalkMetrics (viewForDir (path .Join (docsDir , "./metrics" )))
111
+ getSchema (). Environment ().WalkOutputs (viewForDir (path .Join (docsDir , "./outputs" )))
112
+ getSchema (). Environment ().WalkProcessors (viewForDir (path .Join (docsDir , "./processors" )))
113
+ getSchema (). Environment ().WalkRateLimits (viewForDir (path .Join (docsDir , "./rate_limits" )))
114
+ getSchema (). Environment ().WalkTracers (viewForDir (path .Join (docsDir , "./tracers" )))
115
+ getSchema (). Environment ().WalkScanners (viewForDir (path .Join (docsDir , "./scanners" )))
105
116
106
117
// Bloblang stuff
107
118
doBloblangMethods (docsDir )
@@ -116,6 +127,9 @@ func main() {
116
127
// Logger docs
117
128
doLogger (docsDir )
118
129
130
+ // Redpanda docs
131
+ doRedpanda (docsDir )
132
+
119
133
// Template docs
120
134
doTemplates (docsDir )
121
135
}
@@ -284,7 +298,7 @@ func doBloblangMethods(dir string) {
284
298
}
285
299
286
300
func doTestDocs (dir string ) {
287
- data , err := service . GlobalEnvironment (). FullConfigSchema ( "" , "" ).TemplateData ()
301
+ data , err := getSchema ( ).TemplateData ()
288
302
if err != nil {
289
303
panic (fmt .Sprintf ("Failed to prepare tests docs: %v" , err ))
290
304
}
@@ -306,7 +320,7 @@ func doTestDocs(dir string) {
306
320
}
307
321
308
322
func doHTTP (dir string ) {
309
- data , err := service . GlobalEnvironment (). FullConfigSchema ( "" , "" ).TemplateData ("http" )
323
+ data , err := getSchema ( ).TemplateData ("http" )
310
324
if err != nil {
311
325
panic (fmt .Sprintf ("Failed to prepare http docs: %v" , err ))
312
326
}
@@ -320,7 +334,7 @@ func doHTTP(dir string) {
320
334
}
321
335
322
336
func doLogger (dir string ) {
323
- data , err := service . GlobalEnvironment (). FullConfigSchema ( "" , "" ).TemplateData ("logger" )
337
+ data , err := getSchema ( ).TemplateData ("logger" )
324
338
if err != nil {
325
339
panic (fmt .Sprintf ("Failed to prepare logger docs: %v" , err ))
326
340
}
@@ -333,8 +347,22 @@ func doLogger(dir string) {
333
347
create ("logger docs" , filepath .Join (dir , "logger" , "about.adoc" ), buf .Bytes ())
334
348
}
335
349
350
+ func doRedpanda (dir string ) {
351
+ data , err := getSchema ().TemplateData ("redpanda" )
352
+ if err != nil {
353
+ panic (fmt .Sprintf ("Failed to prepare redpanda docs: %v" , err ))
354
+ }
355
+
356
+ var buf bytes.Buffer
357
+ if err := templateRedpanda .Execute (& buf , data ); err != nil {
358
+ panic (fmt .Sprintf ("Failed to generate redpanda docs: %v" , err ))
359
+ }
360
+
361
+ create ("redpanda docs" , filepath .Join (dir , "redpanda" , "about.adoc" ), buf .Bytes ())
362
+ }
363
+
336
364
func doTemplates (dir string ) {
337
- data , err := service . GlobalEnvironment ().TemplateSchema ("" , "" ).TemplateData ()
365
+ data , err := getSchema (). Environment ().TemplateSchema ("" , "" ).TemplateData ()
338
366
if err != nil {
339
367
panic (fmt .Sprintf ("Failed to prepare template docs: %v" , err ))
340
368
}
0 commit comments