code: func NewAdapter(grpcServer *grpc.Server) *Adapter {
  	//TODO grpcServer.RegisterCodec(json.NewCodec(), "application/json")
  	adapter := &Adapter{
  		base:   syncbase.NewRegistry(),
  		server: grpcServer,
  	}
  	msg.RegisterDataMsgServiceServer(grpcServer, &DataMsgServiceServer{adapter})
  
  	return adapter
  }
docs: // NewAdapter creates a new instance of Adapter.