Method WriteData

go/fory/union.go:168–196

WriteData serializes union payload (case_id + case_value).

(ctx *WriteContext, value reflect.Value)

// WriteData serializes union payload (case_id + case_value).
func (s *UnionSerializer) WriteData(ctx *WriteContext, value reflect.Value) {
	if ctx.HasError() {
		return
	}
	if err := s.initialize(ctx.TypeResolver()); err != nil {
		ctx.SetError(SerializationErrorf("union serializer init failed: %v", err))
		return
	}

	caseID, caseValue, err := getUnionCaseValue(value)
	if err != nil {
		ctx.SetError(SerializationErrorf("union value access failed: %v", err))
		return
	}
	info, ok := s.caseByID[caseID]
	if !ok {
		ctx.SetError(SerializationErrorf("unknown union case id: %d", caseID))
		return
	}

	ctx.Buffer().WriteVarUint32(uint32(caseID))
	if info.declaredValue {
		writeUnionDeclaredValue(ctx, info, reflect.ValueOf(caseValue))
	} else if info.needsOverride {
		writeUnionOverrideValue(ctx, info, reflect.ValueOf(caseValue))
	} else {
		ctx.WriteValue(reflect.ValueOf(caseValue), RefModeTracking, true)
	}
}

// Read is the entry point for union deserialization.
func (s *UnionSerializer) Read(ctx *ReadContext, refMode RefMode, readType bool, hasGenerics bool, value reflect.Value) {