1
0

interface{} to any

This commit is contained in:
Sky Johnson 2025-09-05 17:56:00 -05:00
parent 7af6e70d8b
commit d714f293f8
2 changed files with 7 additions and 7 deletions

View File

@ -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),

View File

@ -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)
}
}