Skip to content

Commit 1d3b212

Browse files
authored
Add comments to CSFLE consumer examples (#1377)
1 parent ca4a207 commit 1d3b212

File tree

3 files changed

+24
-3
lines changed

3 files changed

+24
-3
lines changed

examples/avrov2_consumer_encryption_example/avrov2_consumer_encryption_example.go

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,14 @@ func main() {
8181
os.Exit(1)
8282
}
8383

84-
deser, err := avrov2.NewDeserializer(client, serde.ValueSerde, avrov2.NewDeserializerConfig())
84+
deserConfig := avrov2.NewDeserializerConfig()
85+
// KMS properties can be passed as follows
86+
//deserConfig.RuleConfig = map[string]string{
87+
// "secret.access.key": "xxx",
88+
// "access.key,id": "xxx",
89+
//}
90+
91+
deser, err := avrov2.NewDeserializer(client, serde.ValueSerde, deserConfig)
8592

8693
if err != nil {
8794
fmt.Printf("Failed to create deserializer: %s\n", err)

examples/json_consumer_encryption_example/json_consumer_encryption_example.go

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,14 @@ func main() {
8282
os.Exit(1)
8383
}
8484

85-
deser, err := jsonschema.NewDeserializer(client, serde.ValueSerde, jsonschema.NewDeserializerConfig())
85+
deserConfig := jsonschema.NewDeserializerConfig()
86+
// KMS properties can be passed as follows
87+
//deserConfig.RuleConfig = map[string]string{
88+
// "secret.access.key": "xxx",
89+
// "access.key,id": "xxx",
90+
//}
91+
92+
deser, err := jsonschema.NewDeserializer(client, serde.ValueSerde, deserConfig)
8693

8794
if err != nil {
8895
fmt.Printf("Failed to create deserializer: %s\n", err)

examples/protobuf_consumer_encryption_example/protobuf_consumer_encryption_example.go

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,14 @@ func main() {
8282
os.Exit(1)
8383
}
8484

85-
deser, err := protobuf.NewDeserializer(client, serde.ValueSerde, protobuf.NewDeserializerConfig())
85+
deserConfig := protobuf.NewDeserializerConfig()
86+
// KMS properties can be passed as follows
87+
//deserConfig.RuleConfig = map[string]string{
88+
// "secret.access.key": "xxx",
89+
// "access.key,id": "xxx",
90+
//}
91+
92+
deser, err := protobuf.NewDeserializer(client, serde.ValueSerde, deserConfig)
8693

8794
if err != nil {
8895
fmt.Printf("Failed to create deserializer: %s\n", err)

0 commit comments

Comments
 (0)