Github-Mirror/seaweedfs
1
0 Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2026-10-13 09:38:36 +02:00
Code Issues Packages Projects Releases Wiki Activity

chore(weed/mq/kafka/schema): remove unused functions (#9088)

Browse Source
This commit is contained in:
Lars Lehtonen authored and GitHub committed 2026-04-15 10:23:12 -07:00
1 parent 2c460e0fc9
commit d292d3640d
2 files changed
-11
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

weed/mq/kafka/schema/avro_decoder.go
-6
View File
@@ -431,12 +431,6 @@ func convertAvroSimpleType(avroType string) (*schema_pb.Type, error) {
}
}
// convertAvroComplexType converts complex Avro types to SeaweedMQ types
func convertAvroComplexType(avroType map[string]interface{}) (*schema_pb.Type, error) {
fieldType, _, err := convertAvroComplexTypeWithRepeated(avroType)
return fieldType, err
}
// convertAvroComplexTypeWithRepeated converts complex Avro types to SeaweedMQ types and returns if it's repeated
func convertAvroComplexTypeWithRepeated(avroType map[string]interface{}) (*schema_pb.Type, bool, error) {
typeStr, ok := avroType["type"].(string)
weed/mq/kafka/schema/manager.go
-5
View File
@@ -641,11 +641,6 @@ func recordValueToMapWithAvroContext(recordValue *schema_pb.RecordValue, preserv
return result
}
// schemaValueToGoValue converts a schema Value back to a Go value
func schemaValueToGoValue(value *schema_pb.Value) interface{} {
return schemaValueToGoValueWithAvroContext(value, false)
}
// schemaValueToGoValueWithAvroContext converts a schema Value back to a Go value
// with optional Avro union format preservation
func schemaValueToGoValueWithAvroContext(value *schema_pb.Value, preserveAvroUnions bool) interface{} {