diff --git a/stream/stream.go b/stream/stream.go index 9452317..7abcaf4 100644 --- a/stream/stream.go +++ b/stream/stream.go @@ -1144,11 +1144,11 @@ func (s *Stream) Close() error { } // GetStats returns stream statistics -func (s *Stream) GetStats() map[string]interface{} { +func (s *Stream) GetStats() map[string]any { s.mu.RLock() defer s.mu.RUnlock() - return map[string]interface{}{ + return map[string]any{ "packets_out": atomic.LoadUint64(&s.packetsOut), "packets_in": atomic.LoadUint64(&s.packetsIn), "bytes_out": atomic.LoadUint64(&s.bytesOut), diff --git a/types/reflect_size.go b/types/reflect_size.go index c8bf8e6..bc79389 100644 --- a/types/reflect_size.go +++ b/types/reflect_size.go @@ -6,7 +6,7 @@ import ( ) // CalculateSize uses reflection to calculate the serialized size of a struct -func CalculateSize(v interface{}) uint32 { +func CalculateSize(v any) uint32 { return calculateSizeValue(reflect.ValueOf(v)) } @@ -58,7 +58,7 @@ func calculateStructSize(v reflect.Value) uint32 { for i := 0; i < v.NumField(); i++ { field := v.Field(i) fieldType := t.Field(i) - + // Skip unexported fields if !field.CanInterface() { continue @@ -115,7 +115,7 @@ func calculateArraySize(v reflect.Value) uint32 { if v.Len() == 0 { return 0 } - + elemSize := getElementSize(v.Type().Elem()) return uint32(v.Len()) * elemSize } @@ -173,9 +173,9 @@ type SizeCalculator interface { } // CalculateSizeOptimized uses the Size() method if available, otherwise uses reflection -func CalculateSizeOptimized(v interface{}) uint32 { +func CalculateSizeOptimized(v any) uint32 { if sc, ok := v.(SizeCalculator); ok { return sc.Size() } return CalculateSize(v) -} \ No newline at end of file +}