protobuf3 support for "Any" about protobuf HOT 5 CLOSED

var (
    logger   = logging.GetLogger("checker")
    registry = make(map[string]reflect.Type)
)

func init() {
    registry["HttpCheck"] = reflect.TypeOf(HttpCheck{})
}

func UnmarshalAny(any *Any) (interface{}, error) {
    class := any.TypeUrl
    bytes := any.Value

    instance := reflect.New(registry[class]).Interface()
    err := proto.Unmarshal(bytes, instance.(proto.Message))
    if err != nil {
        return nil, err
    }
    logger.Debug("instance: %v", instance)

    return instance, nil
}

type TestCheckRequest struct {
    MaxHosts  int32      `protobuf:"varint,1,opt,name=max_hosts" json:"max_hosts,omitempty"`
    Deadline  *Timestamp `protobuf:"bytes,2,opt,name=deadline" json:"deadline,omitempty"`
    CheckSpec *Any       `protobuf:"bytes,3,opt,name=check_spec" json:"check_spec,omitempty"`
}

type HttpCheck struct {
    Name     string    `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
    Path     string    `protobuf:"bytes,2,opt,name=path" json:"path,omitempty"`
    Protocol string    `protobuf:"bytes,3,opt,name=protocol" json:"protocol,omitempty"`
    Port     int32     `protobuf:"varint,4,opt,name=port" json:"port,omitempty"`
    Verb     string    `protobuf:"bytes,5,opt,name=verb" json:"verb,omitempty"`
    Target   *Target   `protobuf:"bytes,6,opt,name=target" json:"target,omitempty"`
    Headers  []*Header `protobuf:"bytes,7,rep,name=headers" json:"headers,omitempty"`
    Body     string    `protobuf:"bytes,8,opt,name=body" json:"body,omitempty"`
}