Function DeserializeFunction

core/functions/serialization.go:69–118

DeserializeFunction returns the Function that was serialized in the byte slice. Returns an empty Function (invalid ID) if data is nil or empty.

(ctx context.Context, data []byte)

// DeserializeFunction returns the Function that was serialized in the byte slice. Returns an empty Function (invalid
// ID) if data is nil or empty.
func DeserializeFunction(ctx context.Context, data []byte) (Function, error) {
	if len(data) == 0 {
		return Function{}, nil
	}
	reader := utils.NewReader(data)
	version := reader.VariableUint()
	if version > 3 {
		return Function{}, errors.Errorf("version %d of functions is not supported, please upgrade the server", version)
	}

	// Read from the reader
	f := Function{}
	f.ID = id.Function(reader.Id())
	f.ReturnType = id.Type(reader.Id())
	f.ParameterNames = reader.StringSlice()
	f.ParameterTypes = reader.IdTypeSlice()
	f.Variadic = reader.Bool()
	f.IsNonDeterministic = reader.Bool()
	f.Strict = reader.Bool()
	f.Definition = reader.String()
	// Read the operations
	opCount := reader.VariableUint()
	f.Operations = make([]plpgsql.InterpreterOperation, opCount)
	for opIdx := uint64(0); opIdx < opCount; opIdx++ {
		op := plpgsql.InterpreterOperation{}
		op.OpCode = plpgsql.OpCode(reader.Uint16())
		op.PrimaryData = reader.String()
		op.SecondaryData = reader.StringSlice()
		op.Target = reader.String()
		op.Index = int(reader.Int32())
		op.Options = reader.StringMap()
		f.Operations[opIdx] = op
	}
	if version >= 1 {
		f.ExtensionName = reader.String()
		f.ExtensionSymbol = reader.String()
	}
	if version >= 2 {
		f.SQLDefinition = reader.String()
		f.SetOf = reader.Bool()
	}
	if version >= 3 {
		f.ParameterDefaults = reader.StringSlice()
	}
	if !reader.IsEmpty() {
		return Function{}, errors.Errorf("extra data found while deserializing a function")
	}
	// Return the deserialized object
	return f, nil
}