fix(fxgcppubsub): Fixed race conditions on avro binary codec cache (#20)

ekkinox · web-flow · commit 6cf94fc822d3 · 2024-07-09T09:28:59.000+02:00
* fix(fxgcppubsub): Fixed race conditions on avro binary codec

* fix(fxgcppubsub): Fixed race conditions on avro binary codec
diff --git a/fxgcppubsub/codec/avro.go b/fxgcppubsub/codec/avro.go
@@ -23,7 +23,7 @@ type AvroBinaryCodec struct {
 func NewAvroBinaryCodec(schemaDefinition string) (*AvroBinaryCodec, error) {
 	api := avro.Config{}.Freeze()
 
-	schema, err := avro.Parse(schemaDefinition)
+	schema, err := avro.ParseBytesWithCache([]byte(schemaDefinition), "", &avro.SchemaCache{})
 	if err != nil {
 		return nil, fmt.Errorf("cannot parse avro schema: %w", err)
 	}

Original file line number	Diff line number	Diff line change
`@@ -23,7 +23,7 @@ type AvroBinaryCodec struct {`
`23`	`23`	`func NewAvroBinaryCodec(schemaDefinition string) (*AvroBinaryCodec, error) {`
`24`	`24`	`api := avro.Config{}.Freeze()`
`25`	`25`
`26`		`- schema, err := avro.Parse(schemaDefinition)`
	`26`	`+ schema, err := avro.ParseBytesWithCache([]byte(schemaDefinition), "", &avro.SchemaCache{})`
`27`	`27`	`if err != nil {`
`28`	`28`	`return nil, fmt.Errorf("cannot parse avro schema: %w", err)`
`29`	`29`	`}`