Function readNumericValueByTypeID

go/fory/union.go:497–586

(ctx *ReadContext, targetType reflect.Type, typeID TypeId)

}

func readNumericValueByTypeID(ctx *ReadContext, targetType reflect.Type, typeID TypeId) (reflect.Value, bool) {
	buf := ctx.Buffer()
	base := targetType
	isPtr := false
	if base.Kind() == reflect.Ptr {
		isPtr = true
		base = base.Elem()
	}
	var v reflect.Value
	switch base.Kind() {
	case reflect.Int32:
		var value int32
		switch typeID {
		case INT32:
			value = buf.ReadInt32(ctx.Err())
		case VARINT32:
			value = buf.ReadVarint32(ctx.Err())
		default:
			ctx.SetError(DeserializationErrorf("unsupported union int32 type id: %d", typeID))
			return reflect.Value{}, false
		}
		if ctx.HasError() {
			return reflect.Value{}, false
		}
		v = reflect.New(base).Elem()
		v.SetInt(int64(value))
	case reflect.Uint32:
		var value uint32
		switch typeID {
		case UINT32:
			value = buf.ReadUint32(ctx.Err())
		case VAR_UINT32:
			value = buf.ReadVarUint32(ctx.Err())
		default:
			ctx.SetError(DeserializationErrorf("unsupported union uint32 type id: %d", typeID))
			return reflect.Value{}, false
		}
		if ctx.HasError() {
			return reflect.Value{}, false
		}
		v = reflect.New(base).Elem()
		v.SetUint(uint64(value))
	case reflect.Int64:
		var value int64
		switch typeID {
		case INT64:
			value = buf.ReadInt64(ctx.Err())
		case VARINT64:
			value = buf.ReadVarint64(ctx.Err())
		case TAGGED_INT64:
			value = buf.ReadTaggedInt64(ctx.Err())
		default:
			ctx.SetError(DeserializationErrorf("unsupported union int64 type id: %d", typeID))
			return reflect.Value{}, false
		}
		if ctx.HasError() {
			return reflect.Value{}, false
		}